开发消息驱动bean 2

消息发送完后，编写消息的接收者：
消息的接收者可以采用java类的形式接收
这里采用消息驱动Bean(Message Driven Bean)接收消息
消息驱动Bean(MDB)是设计用来专门处理基于消息请求的组件。它和无状态Session Bean一样也使用

了实例池技术，容器可以使用一定数量的bean实例并发处理成千上万个JMS消息。正因为MDB具有处理

大量并发消息的能力，所以非常适合应用在一些消息网关产品。如果一个业务执行的时间很长，而执

行结果无需实时向用户反馈时，也很适合使用MDB。如订单成功后给客户发送一封电子邮件或发送一

条短信等。

 

一个MDB通常要实现MessageListener接口，该接口定义了onMessage()方法。Bean通过它来处理收到

的JMS消息。
package javax.jms;
public interface MessageListence{
  public void onMessage(Message message);
}

 

当容器检测到bean守候的目标地址有消息到达时，容器调用onMessage()方法，将消息作为参数传入

MDB。MDB在onMessage()中决定如何处理该消息，可以使用注解指定MDB监听哪一个目标地址

(Destination)。当MDB部署时，容器将读取其中的配置信息

@MessageDriven指定消息驱动bean监听的目标地址的类型和目标地址的JNDI名称，还可以指定接收到

消息时，消息的确认模式是什么

 

新建类 MessageDrivenBean(com.jboss.message包)

 

@ActivationConfigProperty(propertyName="acknowledgeMode",
  propertyValue="Auto-acknowledge")
消息驱动bean会从Queue中去寻找queue/ejb3testQueue所绑定的目的地址
确认模式，自动确认；

如果是容器管理事务，这里设置没有意义

处理接收的消息：
由于客户端是发送的TextMessage文本类型消息
这里把消息强制转换为文本类型
然后把消息打印到控制台

注意：这里的queue/ejb3testQueue是刚才ejb3testQueue-service.xml配置文件中配置的
此时消息驱动bean已开发完，从HelloWorld项目拷贝ant
修改ant的项目名称，执行部署，把消息驱动bean发布到jboss

 

如果可以成功部署，就会把消息打印到控制台中
容器根据消息驱动bean的配置，将获得的消息传入onMessage()方法，方法中又调用了控制台，就输

出了刚才的信息

JMS的发送方和接收方，可以不同时在线，只要接收方登录到系统，就可以接收到消息
而且接收方和发送方，代码之间没有关联，很好的解耦
有关Queue类型的发送就完成了

------------------------------------------------------------------

------------------------------------------------------------------

下面来配置Topic类型的：

修改ejb3testQueue-service.xml文件内容：
增加<mbean>标签

<mbean code="org.jboss.mq.server.jmx.Topic"
  name="jboss.mq.destination:service=Queue,name=ejb3testTopic"> 

       <attribute name="JNDIName">topic/ejb3testTopic</attribute> 

       <depends optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends> 

    </mbean> 

 

即可完成对Topic消息的配置
配置好之后，再次发布到jboss中

 

此时建立Topic消息的发送类
在com.jboss.app包中新建类TopicSender带main()
Topic消息的发布和Queue类似，将Queue代码粘贴过来修改：
1.修改连接工厂TopicConnectionFactory
2.修改连接TopicConnection
3.修改会话为TopicSession
4.修改JNDI

public class TopicSender {

 public static void main(String[] args) {
  try {
   InitialContext ctx = new InitialContext();
   TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup("TopicConnectionFactory");
   TopicConnection conn = factory.createTopicConnection();
   TopicSession session = conn.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);;
   Destination destination = (Destination)ctx.lookup("topic/ejb3testTopic");
   MessageProducer producer = session.createProducer(destination);
   TextMessage msg = session.createTextMessage("您好，这是我第一个消息驱动Bean，我是Topic");
   producer.send(msg);
   session.close();
   conn.close();
   System.out.println("发送完毕");
  } catch (Exception e) {
   e.printStackTrace();
  }
  
 }

}

运行Topic消息发送

 

编写接收消息驱动bean
由于Topic类型消息可以被多个用户接收，所以编写两个消息驱动bean进行测试
观察两个消息驱动bean 是否都能够接收到消息
创建ReceiveBean类，实现MessageListener 用来接收Topic类型消息，代码与Queue类型类似
需要修改注解中的消息类型和监听的目标地址

@MessageDriven(activationConfig={
  @ActivationConfigProperty(propertyName="destinationType"
   ,propertyValue="javax.jms.Topic"),
  @ActivationConfigProperty(propertyName="destination"
   ,propertyValue="topic/ejb3testTopic")
})

public class ReceiveBean implements MessageListener {

 @Override
 public void onMessage(Message message) {
  TextMessage tm = (TextMessage)message;
  try {
   System.out.println(this.getClass()+tm.getText());
  } catch (JMSException e) {
   e.printStackTrace();
  }
 }

}

 

即可完成对Topic消息接收
再创建ReceiveOtherBean类，与ReceiveBean类处理代码一样

为了区分是哪个消息bean输出的Topic消息
在控制台输出稍作修改：
System.out.println(this.getClass()+tm.getText());

 

之后对他们发布
在控制台没有看到输出的Topic消息
原因是，当消息发布时，当时没有Topic类型的消息驱动bean监听Topic
它是无法得到消息的

 

现在再次执行发送Topic消息，此时才会看到控制台上输出的消息

对于发布/订阅的传递模型，多个接收方都会得到这个消息

Queue类型的消息，只允许一个接收方接收