activeMQ类别和流程

Point-to-Point (点对点)消息模式开发流程 :
        1、生产者(producer)开发流程: 

         1.1 创建Connection: 根据url,user和password创建一个jms Connection。 

         1.2 创建Session: 在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。 

         1.3 创建Destination对象: 需指定其对应的主题(subject)名称,producer和consumer将根据subject来发送/接收对应的消息。 

         1.4 创建MessageProducer: 根据Destination创建MessageProducer对象,同时设置其持久模式。 

         1.5 发送消息到队列(Queue): 封装TextMessage消息,使用MessageProducer的send方法将消息发送出去。 

       2、消费者(consumer)开发流程: 

         2.1 实现MessageListener接口: 消费者类必须实现MessageListener接口,然后在onMessage()方法中监听消息的到达并处理。 

         2.2 创建Connection: 根据url,user和password创建一个jms Connection,如果是durable模式,还需要给connection设置一个clientId。 

         2.3 创建Session和Destination: 与ProducerTool.java中的流程类似,不再赘述。 

         2.4 创建replyProducer【可选】:可以用来将消息处理结果发送给producer。 

         2.5 创建MessageConsumer:  根据Destination创建MessageConsumer对象。 

         2.6 消费message:  在onMessage()方法中接收producer发送过来的消息进行处理,并可以通过replyProducer反馈信息给producer 


Publisher/Subscriber(发布/订阅者)消息模式开发流程 

       1、订阅者(Subscriber)开发流程(TopicListener.java): 

         1.1 实现MessageListener接口: 在onMessage()方法中监听发布者发出的消息队列,并做相应处理。 

         1.2 创建Connection: 根据url,user和password创建一个jms Connection。 

         1.3 创建Session: 在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。 

         1.4 创建Topic:  创建2个Topic, topictest.messages用于接收发布者发出的消息,topictest.control 用于向发布者发送消息,实现双方的交互。 

         1.5 创建consumer和producer对象:根据topictest.messages创建consumer,根据topictest.control创建 producer。 

         1.6 接收处理消息:在onMessage()方法中,对收到的消息进行处理,可直接简单在本地显示消息,或者根 据消息内容不同处理对应的业务逻辑(比如:数据库更新、文件操作等等),并且可以使用producer对象将处理结果返回给发布者。 

       2、发布者(Publisher)开发流程(TopicPublisher.java):

         2.1 实现MessageListener接口:在onMessage()方法中接收订阅者的反馈消息。 

         2.2 创建Connection: 根据url,user和password创建一个jms Connection。 

         2.3 创建Session: 在connection的基础上创建一个session,同时设置是否支持事务和ACKNOWLEDGE标识。 

         2.4 创建Topic:创建2个Topic,topictest.messages用于向订阅者发布消息,topictest.control用于接 收订阅者反馈消息。这2个topic与订阅者开发流程中topic是一一对应的。 

         2.5 创建consumer和producer对象: 根据topictest.messages创建publisher; 根据topictest.control 创建consumer,同时监听订阅者反馈的消息。

         2.6 给所有订阅者发送消息,并接收反馈消息:  示例代码中,一共重复10轮操作。 每轮先向所有订阅者 发送2000个消息; 然后堵塞线程,开始等待; 最后通过onMessage()方法,接收到订阅者反馈的“REPORT”类信息后,才print反馈信息并解除线程堵塞,进入下一轮。 


Queue(点对点)方式和Topic(发布/订阅)方式 的运行结果最明显的区别是:在Queue(点对点)方式中先运行生产者,再运行消费者,消费者还能接受到消息;

而Topic(发布/订阅)方式就不同了,先运行发布者,再运行订阅者,订阅者收到的消息

可能没有或者是不完全的。

原文地址:https://www.cnblogs.com/tk55/p/8715028.html