EJB注释－2（EJB学习笔记之消息驱动）

消息驱动Bean

消息驱动Bean(MDB)是设计用来专门处理基于消息请求的组件。一个MDB类必须实现MessageListener 接口。当容器检测到bean守候的队列一条消息时，就调用onMessage()方法，将消息作为参数传入。MDB在OnMessage()中决定如何处理该消息。你可以用注释来配置MDB 监听哪一条队列。

消息驱动Bean的服务器





@MessageDriven(activationConfig
=
...
{



@ActivationConfigProperty(propertyName
=
"
destinationType
"
,propertyValue
=
"
javax.jms.Queue
"
),



@ActivationConfigProperty(propertyName
=
"
destination
"
,propertyValue
=
"
queue/test
"
)



}

)







public

class
MessageBean
implements
MessageListener
...
{





public

void
onMessage(Message msg)
...
{





try

...
{



TextMessage tmsg
=
(TextMessage) msg;



//
do your action here





}

catch
(Exception e)
...
{



e.printStackTrace();



}



}



}

通过@MessageDriven 注释指明这是一个消息驱动Bean，并使用@ActivationConfigProperty注释配置消息的

各种属性，其中destinationType 属性指定消息的类型，消息有两种类型topics 和queues，下面是这两种消息

类型的介绍：

Topics 可以有多个客户端。用topic 发布允许一对多，或多对多通讯通道。消息的产生者被叫做publisher, 消

息接受者叫做subscriber。destinationType 属性对应值：javax.jms.Topic.

Queue 仅仅允许一个消息传送给一个客户。一个发送者将消息放入消息队列，接受者从队列中抽取并得到消息，消息就会在队列中消失。第一个接受者抽取并得到消息后，其他人就不能再得到它。destinationType属性对应值：javax.jms.Queue

destination属性用作指定消息路径，消息驱动Bean在发布时，如果路径不存在，容器会自动创建该路径，当容

器关闭时该路径会自动被删除。

消息驱动Bean的客户端



QueueConnection cnn
=

null
;



QueueSender sender
=

null
;



QueueSession sess
=

null
;



Queue queue
=

null
;





try

...
{



Properties props
=

new
Properties();



props.setProperty(
"
java.naming.factory.initial
"
,
"
org.jnp.interfaces.NamingContextFactory
"
);



props.setProperty(
"
java.naming.provider.url
"
,
"
localhost:1099
"
);



props.setProperty(
"
java.naming.factory.url.pkgs
"
,
"
org.jboss.naming
"
);



InitialContext ctx
=

new
InitialContext(props);



QueueConnectionFactory factory
=
(QueueConnectionFactory) ctx.lookup(
"
ConnectionFactory
"
);



cnn
=
factory.createQueueConnection();



sess
=
cnn.createQueueSession(
false
, QueueSession.AUTO_ACKNOWLEDGE);



queue
=
(Queue) ctx.lookup(
"
queue/test
"
);





}

catch
(Exception e)
...
{



out.println(e.getMessage());



}



TextMessage msg
=
sess.createTextMessage(
"
消息驱动Bean
测试"
);



sender
=
sess.createSender(queue);



sender.send(msg);



sess.close ();

具体步骤

(1) 得到一个JNDI初始化上下文(Context)；

(2) 根据上下文来查找一个连接工厂TopicConnectFactory/ QueueConnectionFactory (有两种连接工厂，根据是

topic/queue来使用相应的类型)；

(3) 从连接工厂得到一个连接(Connect 有两种[TopicConnection/ QueueConnection]);

(4) 通过连接来建立一个会话(Session);

(5) 查找目的地(Topic/ Queue);

(6) 根据会话以及目的地来建立消息制造者(TopicPublisher/QueueSender)和消费者(TopicSubscriber/QueueReceiver).

参考:EJB3.0实例教程


(作者：黎活明)