ActiveMQ的两种消息形式。

「爱情、让人受尽委屈。」 2022-05-28 04:00 257阅读 0赞

# 一、消息的传递类型 #

*  **点对点：**即一个生产者和一个消费者一一对应

PTP的过程好比是两个人打电话，这两个人独享这一条通信链路。一方发送消息，另外一方接收 消息 。在实际应用中因为有多个用户对使用 PTP 的链路，它的通信场景如下图所示：

![31caa4f7-2944-4613-8540-6f1c51aaff4c.jpg][]

*  **发布/订阅：**即一个生产者产生消息并进行发送后，可以由多个消费者进行接收。

发布订阅模式类似听广播，一个播音员广播，可以有很多听众同时收听。这种关系如下图所示：

![285ae295-09ab-4dce-a8bc-18d368235983.jpg][]

# 二、消息的正文格式 #

JMS定义了五种不同的消息正文格式，以及调用的消息类型，允许你发送并接收以一些不同形式的数据，提供现有消息格式的一些级别的兼容性。

*  StreamMessage    Java原始值的数据流  
    
 *  MapMessage        一套名称-值对  
    
 *  TextMessage        一个字符串对象  
    
 *  ObjectMessage    一个序列化的 Java对象

*  BytesMessage     一个字节的数据流

\-----------------------------------------------------------------------------------------------------------------------------

# 一、创建Maven测试项目 #

![5d462056-ab64-4b65-aa84-f8b2ace6015e.png][]

![807b25d1-b7d5-4f3c-b385-92889c9dc598.png][]

# 二、pom.xml #

<table> 
 <tbody> 
  <tr> 
   <td align="left"> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;<span style="color:rgb(63,127,127);">dependencies</span>&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,95,191);">&lt;!--&nbsp;消息队列&nbsp;--&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;<span style="color:rgb(63,127,127);">dependency</span>&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;<span style="color:rgb(63,127,127);">groupId</span>&gt;</span>org.apache.activemq 
     <span style="color:rgb(0,128,128);">&lt;/<span style="color:rgb(63,127,127);">groupId</span>&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;<span style="color:rgb(63,127,127);">artifactId</span>&gt;activemq</span>-all 
     <span style="color:rgb(0,128,128);">&lt;/<span style="color:rgb(63,127,127);">artifactId</span>&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;<span style="color:rgb(63,127,127);">version</span>&gt;</span>5.11.3 
     <span style="color:rgb(0,128,128);">&lt;/<span style="color:rgb(63,127,127);">version</span>&gt;</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(0,128,128);">&lt;/<span style="color:rgb(63,127,127);">dependency</span>&gt;<br></span> 
    </div>&nbsp; &nbsp;&nbsp;<span style="color:rgb(0,128,128);">&lt;/<span style="color:rgb(63,127,127);">dependencies</span>&gt;</span></td> 
  </tr> 
 </tbody> 
</table>

# 三、生产者（消息发送者） #

第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

第二步：使用ConnectionFactory对象创建一个Connection对象。

第三步：开启连接，调用Connection对象的start方法。

第四步：使用Connection对象创建一个Session对象。

第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。

第六步：使用Session对象创建一个Producer对象。

第七步：创建一个Message对象，创建一个TextMessage对象。

第八步：使用Producer对象发送消息。

第九步：关闭资源。

# 四、消费者（消息接收者） #

消费者：接收消息。

第一步：创建一个ConnectionFactory对象。

第二步：从ConnectionFactory对象中获得一个Connection对象。

第三步：开启连接。调用Connection对象的start方法。

第四步：使用Connection对象创建一个Session对象。

第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。

第六步：使用Session对象创建一个Consumer对象。

第七步：接收消息。

第八步：打印消息。

第九步：关闭资源

测试1：先运行生产者，在运行消费者消费消息

测试2：先测试消费者等待消息到来，再运行生产者生产消息

注意：消费者运行后会一直等待键盘输入

<table> 
 <tbody> 
  <tr> 
   <td align="left"> 
    <div> 
     <span style="color:rgb(127,0,85);">package&nbsp;name.yaohuan.activemq;</span> 
    </div> 
    <div> 
     <span style="color:rgb(127,0,85);">public&nbsp;class&nbsp;QueueTest&nbsp;{ </span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Test</span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;testProducer()&nbsp; 
     <span style="color:rgb(127,0,85);">throws</span>&nbsp;Exception&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第一步：创建ConnectionFactory对象，需要指定服务端ip</span>及端口号。 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//brokerURL服务器的ip</span>及端口号 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; ConnectionFactory&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>&nbsp;=&nbsp; 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;ActiveMQConnectionFactory( 
     <span style="color:rgb(42,0,255);">"tcp://192.168.100.53:61616"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第二步：使用ConnectionFactory对象创建一个Connection对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Connection&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>.createConnection(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第三步：开启连接，调用Connection对象的start方法。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.start(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第四步：使用Connection对象创建一个Session对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//第一个参数：是否开启事务。true：开启事务，第二个参数忽略。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Session&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.createSession( 
     <span style="color:rgb(127,0,85);">false</span>,&nbsp;Session. 
     <span style="color:rgb(0,0,192);">AUTO_ACKNOWLEDGE</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//参数：队列的名称。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Queue&nbsp; 
     <span style="color:rgb(106,62,62);">queue</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createQueue( 
     <span style="color:rgb(42,0,255);">"test-queue"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第六步：使用Session对象创建一个Producer对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; MessageProducer&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createProducer( 
     <span style="color:rgb(106,62,62);">queue</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第七步：创建一个Message对象，创建一个TextMessage对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">/*TextMessage message&nbsp;=&nbsp;new ActiveMQTextMessage();</span> 
    </div> 
    <div> 
     <span style="color:rgb(63,127,95);">&nbsp; &nbsp; &nbsp; &nbsp; message.setText("hello activeMq,this is my first test.");*/</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; TextMessage&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createTextMessage( 
     <span style="color:rgb(42,0,255);">"hello activeMq,this is my first test."</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第八步：使用Producer对象发送消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>.send( 
     <span style="color:rgb(106,62,62);">textMessage</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第九步：关闭资源。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Test</span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;testConsumer()&nbsp; 
     <span style="color:rgb(127,0,85);">throws</span>&nbsp;Exception&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第一步：创建一个ConnectionFactory对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; ConnectionFactory&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>&nbsp;=&nbsp; 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;ActiveMQConnectionFactory( 
     <span style="color:rgb(42,0,255);">"tcp://192.168.100.53:61616"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第二步：从ConnectionFactory对象中获得一个Connection对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Connection&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>.createConnection(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第三步：开启连接。调用Connection对象的start方法。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.start(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第四步：使用Connection对象创建一个Session对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Session&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.createSession( 
     <span style="color:rgb(127,0,85);">false</span>,&nbsp;Session. 
     <span style="color:rgb(0,0,192);">AUTO_ACKNOWLEDGE</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Queue&nbsp; 
     <span style="color:rgb(106,62,62);">queue</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createQueue( 
     <span style="color:rgb(42,0,255);">"test-queue"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第六步：使用Session对象创建一个Consumer对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; MessageConsumer&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createConsumer( 
     <span style="color:rgb(106,62,62);">queue</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第七步：接收消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>.setMessageListener( 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;MessageListener()&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Override</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;onMessage(Message&nbsp; 
     <span style="color:rgb(106,62,62);">message</span>)&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">try</span>&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; TextMessage&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>&nbsp;=&nbsp;(TextMessage)&nbsp; 
     <span style="color:rgb(106,62,62);">message</span>; 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//取消息的内容</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; String&nbsp; 
     <span style="color:rgb(106,62,62);">text</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>.getText(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第八步：打印消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System. 
     <span style="color:rgb(0,0,192);">out</span>.println( 
     <span style="color:rgb(106,62,62);">text</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;}&nbsp; 
     <span style="color:rgb(127,0,85);">catch</span>&nbsp;(JMSException&nbsp; 
     <span style="color:rgb(106,62,62);">e</span>)&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">e</span>.printStackTrace(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;}); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//等待键盘输入</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;System. 
     <span style="color:rgb(0,0,192);">in</span>.read(); 
     <span style="color:rgb(63,127,95);">//这句话会让消费者一直在线</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第九步：关闭资源</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp;} 
    </div>}</td> 
  </tr> 
 </tbody> 
</table>

**注意：**

消息发布后，点击查看消息时，在activemq中默认会报告错误，如下

![a219ec1d-3325-45b7-a3f3-46f6ffbe5a82.png][]

**原因：**

此版本的activemq不支持运行在jdk1.8上，可以切换成jdk1.7

ActiveMQ的5.15版本可以支持jdk1.8

**解决方案：**

配置内置的jetty服务使用jdk1.7启动

在activemq的 bin路径下找到  env 文件

修改其中的配置，将

\#JAVA\_HOME=""

改为

JAVA\_HOME="/usr/local/jdk1.7.0\_76/"

重启activemq

./ activemq restart

\------------------------------------------------------------------------------------------------------------

# 一、生产者（消息发送者） #

第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

第二步：使用ConnectionFactory对象创建一个Connection对象。

第三步：开启连接，调用Connection对象的start方法。

第四步：使用Connection对象创建一个Session对象。

第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Topic对象。

第六步：使用 Session 对象创建一个 Producer 对象。

第七步：创建一个Message对象，创建一个TextMessage对象。

第八步：使用Producer对象发送消息。

第九步：关闭资源。

# 二、消费者（消息接收者） #

消费者：接收消息。

第一步：创建一个ConnectionFactory对象。

第二步：从ConnectionFactory对象中获得一个Connection对象。

第三步：开启连接。调用Connection对象的start方法。

第四步：使用Connection对象创建一个Session对象。

第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且topic的名称一致。

第六步：使用 Session 对象创建一个 Consumer 对象。

第七步：接收消息。

第八步：打印消息。

第九步：关闭资源

<table> 
 <tbody> 
  <tr> 
   <td align="left"><br> 
    <div> 
     <span style="color:rgb(127,0,85);">package&nbsp;name.yaohuan.activemq;</span> 
    </div> 
    <div> 
     <span style="color:rgb(127,0,85);">public&nbsp;class&nbsp;TopicTest&nbsp;{ </span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Test</span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;testProducer()&nbsp; 
     <span style="color:rgb(127,0,85);">throws</span>&nbsp;Exception&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第一步：创建ConnectionFactory对象，需要指定服务端ip</span>及端口号。 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;brokerURL服务器的ip</span>及端口号 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; ConnectionFactory&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>&nbsp;=&nbsp; 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;ActiveMQConnectionFactory( 
     <span style="color:rgb(42,0,255);">"tcp://192.168.100.53:61616"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第二步：使用ConnectionFactory对象创建一个Connection对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Connection&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>.createConnection(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第三步：开启连接，调用Connection对象的start方法。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.start(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第四步：使用Connection对象创建一个Session对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第一个参数：是否开启事务。true：开启事务，第二个参数忽略。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Session&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.createSession( 
     <span style="color:rgb(127,0,85);">false</span>,&nbsp;Session. 
     <span style="color:rgb(0,0,192);">AUTO_ACKNOWLEDGE</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个topic对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;参数：话题的名称。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;Topic&nbsp; 
     <span style="color:rgb(106,62,62);">topic</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createTopic( 
     <span style="color:rgb(42,0,255);">"test-topic"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第六步：使用Session对象创建一个Producer对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; MessageProducer&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createProducer( 
     <span style="color:rgb(106,62,62);">topic</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第七步：创建一个Message对象，创建一个TextMessage对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">/*</span> 
    </div> 
    <div> 
     <span style="color:rgb(63,127,95);">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*&nbsp;TextMessage message&nbsp;=&nbsp;new ActiveMQTextMessage(); message.setText(</span> 
    </div> 
    <div> 
     <span style="color:rgb(63,127,95);">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*&nbsp;"hello activeMq,this is my first test.");</span> 
    </div> 
    <div> 
     <span style="color:rgb(63,127,95);">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*/</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; TextMessage&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createTextMessage( 
     <span style="color:rgb(42,0,255);">"hello activeMq,this is my&nbsp;topic&nbsp;test"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第八步：使用Producer对象发送消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>.send( 
     <span style="color:rgb(106,62,62);">textMessage</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第九步：关闭资源。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">producer</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Test</span> 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;testConsumer()&nbsp; 
     <span style="color:rgb(127,0,85);">throws</span>&nbsp;Exception&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第一步：创建一个ConnectionFactory对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; ConnectionFactory&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>&nbsp;=&nbsp; 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;ActiveMQConnectionFactory( 
     <span style="color:rgb(42,0,255);">"tcp://192.168.100.53:61616"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第二步：从ConnectionFactory对象中获得一个Connection对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Connection&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connectionFactory</span>.createConnection(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第三步：开启连接。调用Connection对象的start方法。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.start(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第四步：使用Connection对象创建一个Session对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; Session&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.createSession( 
     <span style="color:rgb(127,0,85);">false</span>,&nbsp;Session. 
     <span style="color:rgb(0,0,192);">AUTO_ACKNOWLEDGE</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;Topic&nbsp; 
     <span style="color:rgb(106,62,62);">topic</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createTopic( 
     <span style="color:rgb(42,0,255);">"test-topic"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第六步：使用Session对象创建一个Consumer对象。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; MessageConsumer&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.createConsumer( 
     <span style="color:rgb(106,62,62);">topic</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第七步：接收消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>.setMessageListener( 
     <span style="color:rgb(127,0,85);">new</span>&nbsp;MessageListener()&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(100,100,100);">@Override</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">public</span>&nbsp; 
     <span style="color:rgb(127,0,85);">void</span>&nbsp;onMessage(Message&nbsp; 
     <span style="color:rgb(106,62,62);">message</span>)&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(127,0,85);">try</span>&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; TextMessage&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>&nbsp;=&nbsp;(TextMessage)&nbsp; 
     <span style="color:rgb(106,62,62);">message</span>; 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;取消息的内容</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;String&nbsp; 
     <span style="color:rgb(106,62,62);">text</span>&nbsp;=&nbsp; 
     <span style="color:rgb(106,62,62);">textMessage</span>.getText(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第八步：打印消息。</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; System. 
     <span style="color:rgb(0,0,192);">out</span>.println( 
     <span style="color:rgb(106,62,62);">text</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;}&nbsp; 
     <span style="color:rgb(127,0,85);">catch</span>&nbsp;(JMSException&nbsp; 
     <span style="color:rgb(106,62,62);">e</span>)&nbsp;{  
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">e</span>.printStackTrace(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;} 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;}); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; System. 
     <span style="color:rgb(0,0,192);">out</span>.println( 
     <span style="color:rgb(42,0,255);">"topic的消费端03。。。。。"</span>); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;等待键盘输入</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp; System. 
     <span style="color:rgb(0,0,192);">in</span>.read(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(63,127,95);">//&nbsp;第九步：关闭资源</span> 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">consumer</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">session</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
     <span style="color:rgb(106,62,62);">connection</span>.close(); 
    </div> 
    <div>
      &nbsp; &nbsp;&nbsp;} 
    </div>}</td> 
  </tr> 
 </tbody> 
</table>

[31caa4f7-2944-4613-8540-6f1c51aaff4c.jpg]: https://note.wiz.cn/api/document/files/unzip/f460d1e2-bbf1-4d05-b6d7-9604677d9702/5da81eb7-b982-446c-a28f-f1b1d405fa7b.4397/index_files/31caa4f7-2944-4613-8540-6f1c51aaff4c.jpg
[285ae295-09ab-4dce-a8bc-18d368235983.jpg]: https://note.wiz.cn/api/document/files/unzip/f460d1e2-bbf1-4d05-b6d7-9604677d9702/5da81eb7-b982-446c-a28f-f1b1d405fa7b.4397/index_files/285ae295-09ab-4dce-a8bc-18d368235983.jpg
[5d462056-ab64-4b65-aa84-f8b2ace6015e.png]: https://note.wiz.cn/api/document/files/unzip/f460d1e2-bbf1-4d05-b6d7-9604677d9702/1e4fa0ce-a166-4219-ab12-3c0a4cc1dd01.4398/index_files/5d462056-ab64-4b65-aa84-f8b2ace6015e.png
[807b25d1-b7d5-4f3c-b385-92889c9dc598.png]: https://note.wiz.cn/api/document/files/unzip/f460d1e2-bbf1-4d05-b6d7-9604677d9702/1e4fa0ce-a166-4219-ab12-3c0a4cc1dd01.4398/index_files/807b25d1-b7d5-4f3c-b385-92889c9dc598.png
[a219ec1d-3325-45b7-a3f3-46f6ffbe5a82.png]: https://note.wiz.cn/api/document/files/unzip/f460d1e2-bbf1-4d05-b6d7-9604677d9702/1e4fa0ce-a166-4219-ab12-3c0a4cc1dd01.4398/index_files/a219ec1d-3325-45b7-a3f3-46f6ffbe5a82.png