rabbitmq笔记

我不是女神ヾ 2022-01-30 12:39 305阅读 0赞

url: [http://localhost:15672][http_localhost_15672]

用户名:guest

密码:guest

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70][]

virtual hosts 管理

virtual hosts相当于mysql的db

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70 1][]

一般以/开头

我们得对用户进行授权

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70 2][]

一、简单队列

1 简单队列

1.1模型

![20190519165442627.png][]

P:消息的生产者

红色的队列

C：消息的消费者

3个对象：生产者  队列rabbitmq  消费者

1.2获取MQ链接

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.util; &nbsp; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; &nbsp; import java.io.IOException; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.util &nbsp;* @ClassName: ConnectionUtils &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/15 20:46 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class ConnectionUtils { &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; * 获取mq的连接 工具类 &nbsp;&nbsp;&nbsp;&nbsp; * @Date&nbsp; 2019/5/15&nbsp; 20:49 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [] &nbsp;&nbsp;&nbsp;&nbsp; * @return com.rabbitmq.client.Connection &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static Connection getConnection() throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //定义一个连接工厂 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ConnectionFactory factory = new ConnectionFactory(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //设置服务地址 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.setHost("127.0.0.1"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //设置端口 AMQP 5672 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.setPort(5672); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //设置/vhost_zq &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.setVirtualHost("/vhost_zq"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //设置用户名 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.setUsername("guest"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //设置密码 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; factory.setPassword("guest"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return factory.newConnection(); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

1.3 简单队列生产者代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.simple; &nbsp; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; &nbsp; import com.rabbitmq.client.AMQP; &nbsp; import com.rabbitmq.client.Channel; &nbsp; import com.rabbitmq.client.Connection; &nbsp; &nbsp; import java.io.IOException; &nbsp; import java.util.Map; &nbsp; import java.util.concurrent.TimeoutException; &nbsp; &nbsp; /** &nbsp; &nbsp;* @Package: com.cmbc.rabbitmq.simple &nbsp; &nbsp;* @ClassName: Producer &nbsp; &nbsp;* @Description: &nbsp; &nbsp;* @author:&nbsp; &nbsp; &nbsp;* @since: 2019/5/15 20:52 &nbsp; &nbsp;* @version: 1.0 &nbsp; &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp; &nbsp;*/ &nbsp; public class Producer { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "simple_queue"; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //获取一个连接 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //从连接中获取一个通道 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello simple!!!"; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //发布消息 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send " + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

1.4 简单队列消费者代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.simple; &nbsp; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; &nbsp; import com.rabbitmq.client.Channel; &nbsp; import com.rabbitmq.client.Connection; &nbsp; import com.rabbitmq.client.QueueingConsumer; &nbsp; &nbsp; import java.io.IOException; &nbsp; import java.util.concurrent.TimeoutException; &nbsp; &nbsp; /** &nbsp; &nbsp;* @Package: com.cmbc.rabbitmq.simple &nbsp; &nbsp;* @ClassName: Consumer &nbsp; &nbsp;* @Description: 消费者消费消息 &nbsp; &nbsp;* @author:&nbsp; &nbsp; &nbsp;* @since: 2019/5/15 21:05 &nbsp; &nbsp;* @version: 1.0 &nbsp; &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp; &nbsp;*/ &nbsp; public class Consumer { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "simple_queue"; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //获取一个连接 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //从连接中获取一个通道 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //定义队列的消费者 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QueueingConsumer consumer = new QueueingConsumer(channel); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //监听队列 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, true, consumer); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //接收消息 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (true) { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QueueingConsumer.Delivery delivery = consumer.nextDelivery(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; byte[] body = delivery.getBody(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("rev msg" + msg); &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

1.5消费者新的api

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.simple; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.simple &nbsp;* @ClassName: Consumer &nbsp;* @Description: 消费者消费消息 &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/15 21:05 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "simple_queue"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //获取一个连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //从连接中获取一个通道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //定义消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //获取到到达的消息 &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("new api rev msg:" + msg); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, true, consumer); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description 消费者老的api &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/16&nbsp; 10:36 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void oldApi() throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //获取一个连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //从连接中获取一个通道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //定义队列的消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QueueingConsumer consumer = new QueueingConsumer(channel); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, true, consumer); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //接收消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (true) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QueueingConsumer.Delivery delivery = consumer.nextDelivery(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; byte[] body = delivery.getBody(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("rev msg" + msg); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

1.6简单队列的不足

耦合性高，生产者一一对应消费者（如果我想要有多个消费者消费队列中的消息，这时候就不行了），队列名字变更，这时候得同时变更。

2 Work queue 工作队列

2.1模型

![2019051916550820.png][]

为什么会出现工作队列？

Simple队列是一一对应的，而我们实际开发，生产者发送消息是毫不费力的。而消费者一般是要跟业务相结合的，消费者接收到消息之后就需要处理。可能需要花费时间。这时候队列就会积压很多消息。那么一个消费者不够用，我们就通过多个消费者来解决这个问题。

2.2 生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workqueue; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import sun.nio.cs.ext.MacGreek; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 10:58 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; *&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |--consumer1 &nbsp;&nbsp;&nbsp;&nbsp; * producer--queue--| &nbsp;&nbsp;&nbsp;&nbsp; *&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |--consumer2 &nbsp;&nbsp;&nbsp;&nbsp; * &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/16&nbsp; 10:59 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; 50; i++) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello " + i; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send msg:"+ msg); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(i * 20); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

2.3 消费者1

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workqueue; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 11:04 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer1 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(2000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

2.4 消费者2

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workqueue; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 11:04 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer2 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

2.5现象

消费者1和消费者2处理的消息是一样的。是均分的。

消费者1都是偶数

消费者2都是奇数

这种方式叫做轮询分发（round-robin）

结果就是不论谁忙或者谁清闲，都不会去多给任务。任务消息总是你一个我一个这样均分的。

3.公平分发 fair dipatch

3.1生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workfair; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 10:58 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; *&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |--consumer1 &nbsp;&nbsp;&nbsp;&nbsp; * producer--queue--| &nbsp;&nbsp;&nbsp;&nbsp; *&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; |--consumer2 &nbsp;&nbsp;&nbsp;&nbsp; * &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/16&nbsp; 10:59 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; 50; i++) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello " + i; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send msg:" + msg); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(i * 5); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

3.2消费者1

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workfair; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 11:04 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer1 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(2000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;//手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

3.3消费者2

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.workfair; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.workqueue &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 11:04 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer2 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "work_queue"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;//每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

3.4现象

消费者2处理的消息比消费者1多，大概比例为2:1，能者多劳。

4.消息应答Message acknowledgment与消息持久化

4.1消息应答

boolean autoAck = false;//自动应答为false

channel.basicConsume(QUEUE\_NAME, autoAck, consumer);

boolean autoAck = true;（自动确认模式，一旦rabbitmq将消息分发给消费者就会从内存中删除）

这种情况下，如果杀死正在执行的消费者，那么就会丢失正在处理的消息。

boolean autoAck = false;（手动确认模式），如果有一个消费者1挂掉了，那么生产者将会把发送给消费者1的消息发送给其他消费者，即超时没有获取到应答的情况这样做。Rabbitmq支持消息应答，消费者发送一个消息应答告诉rabbitmq这个消息我已经处理完成你可以删除了，然后rabbitmq就会删除内存中的消息。

消息应答默认是打开的。即为默认是false，默认是手动应答。（消息应答是默认打开的。我们通过显示的设置autoAsk=true关闭这种机制。）

如果rabbitmq挂了，我们的消息仍然会丢失！！！

4.2消息持久化

//3.声明队列

boolean durable = false;

boolean exclusive = false;

boolean autoDelete = false;

Map<String, Object> argments = null;

//4.声明一个队列

channel.queueDeclare(QUEUE\_NAME, durable, exclusive, autoDelete, argments);

我们将程序中的boolean durable = false;改成true是不可以的。尽管代码不报错，但是已经声明的队列的持久化方式是不允许更改的。因为已经定义了QUEUE\_NAME，这个queue是不持久化的，rabbitmq不允许重新定义（不同参数的）一个已存在的队列。

解决方法：将该queue删除，然后再重新定义声明。

5 订阅模式Publish/Subscribe

5.1模型

![20190519165534441.png][]

1.  一个生产者，多个消费者
2.  每个消费者都有自己的一个队列
3.  生产者没有将消息直接发送给队列，而是发送到交换机里面exchange
4.  每个队列都要绑定到交换机上面
5.  生产者发送的消息经过交换机，然后到达队列，实现一个消息被多个消费者消费。

5.2生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.PublishSubscribe; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.PublishSubscribe &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 15:24 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_fanout"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明交换机&nbsp;&nbsp; fanout是分发的意思 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.exchangeDeclare(EXCHANGE_NAME, "fanout"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.发送一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello Publish/Subscribe"; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish(EXCHANGE_NAME, "", null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("exchange send:" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

消息哪里去了啊？丢失了！！！因为交换机没有存储的能力，在rabbitmq里面只有队列有存储的能力。因为这个时候还没有队列绑定到这个交换机，所以数据丢失了。

让交换机绑定队列

5.3    消费者1

<table> 
 <tbody> 
 <tr> 
 <td> 6.&nbsp; package com.cmbc.rabbitmq.PublishSubscribe; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.PublishSubscribe &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 15:34 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer1 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "fanout_queue_email"; &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_fanout"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.将队列绑定到交换机上 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ""); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(2000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

5.4 消费者2

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.PublishSubscribe; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.PublishSubscribe &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/16 15:34 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer2 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "fanout_queue_sms"; &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_fanout"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取链接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.将队列绑定到交换机上 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, ""); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(2000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

结果

6.交换机exchange （转发器）

一方面是接收生产者的消息，另一方面是向队列推送消息。

匿名转发：“”

Fanout;不处理路由器

Direct（处理路由器）

7路由模式

7.1模型

![20190519165712277.png][]

7.2 生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.routing; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.routing &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 10:55 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_direct"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明交换机 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.exchangeDeclare(EXCHANGE_NAME, "direct"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.准备发送的消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello direct"; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.发布队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String routingkey = "info"; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;channel.basicPublish(EXCHANGE_NAME, routingkey, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send "+msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

7.3 消费者1

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.routing; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.routing &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 11:01 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer1 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_direct"; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_direct_1"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.队列绑定交换机 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME,EXCHANGE_NAME,"error"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

7.4 消费者2

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.routing; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.routing &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 11:01 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer2 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_direct"; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_direct_2"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.队列绑定交换机 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "error"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "info"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "warn"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;System.out.println("[2] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

8.[Topics][] exchange

将路由和某个模式匹配

\#匹配一个或者多个

\*匹配一个

8.1模型

商品：发布、删除、修改、查询

![20190519165737827.png][]

8.2 生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.topic; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.topic &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 11:33 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_topic"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明交换机 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.exchangeDeclare(EXCHANGE_NAME, "topic"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg="商品..."; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish(EXCHANGE_NAME,"good.add",null,msg.getBytes()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //channel.basicPublish(EXCHANGE_NAME,"good.delete",null,msg.getBytes()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send "+msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

8.3消费者1

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.topic; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.routing &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 11:01 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer1 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_topic"; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_topic_1"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.队列绑定交换机 只是绑定good.add &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "good.add"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[1] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

8.4 消费者2

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.topic; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.routing &nbsp;* @ClassName: Consumer1 &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/18 11:01 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer2 { &nbsp; &nbsp;&nbsp;&nbsp; private static final String EXCHANGE_NAME = "exchange_topic"; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_topic_2"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.队列绑定交换机 绑定good.# &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "good.#"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.每个消费者发送确认消息之前，生产者只发送一个消息给你，且不发送下一个消息，每次只处理一个消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //限制同一个消费者不得超过一条消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int perfetchCount = 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicQos(perfetchCount); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //7.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] work queue rev msg：" + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("[2] done"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //手动应答 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicAck(envelope.getDeliveryTag(), false); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //6.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = false;//自动应答为false &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

9.rabbitmq 消息确认机制（事务+confirm）

在rabbitmq中国我们可以通过持久化数据来解决rabbitmq服务器的数据丢失的问题。

问题：

生产者将消息送出去之后，消息到底有没有到达rabbitmq服务器，默认的情况是不知道的。

两种方式：

1.  AMQP实现了事务机制
2.  Confirm模式

9.1事务机制

txSelect txCommit txRollback

txSelect：用户将当前的channel设置成为transaction模式；

txCommit：用于提交事务

txRollback：回滚事务

9.1.1生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.transaction; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.transaction &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 8:35 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_transaction"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; * rabbitmq 消息确认机制（事务） &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/19&nbsp; 8:42 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello transaction msg"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.txSelect(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //故意制造异常 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int i = 1 / 0; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.txCommit(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send msg：‘" + msg + " ’commit"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (Exception e) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.txRollback(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("send msg rollback"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

9.1.2 消费者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.transaction; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.*; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.transaction &nbsp;* @ClassName: Consumer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 8:43 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_transaction"; &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.定义一个消费者 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DefaultConsumer consumer = new DefaultConsumer(channel) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //一旦有消息就会触发这个方法 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = new String(body); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;System.out.println("transaction work queue rev msg：‘" + msg+"’"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.消费者开始监听队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoAck = true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicConsume(QUEUE_NAME, autoAck, consumer); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

9.1.3 缺点

这种模式还是很耗时的，采用这种方式，降低了rabbitmq的吞吐量。

9.2 confirm模式

9.2.1生产者端confirm模式的实现原理

生产者将信道设置成confirm模式，一旦信道进入confirm模式，所有在该信道上面发布的消息都会被指派给一个唯一的id（从1开始），一旦消息被投递到所有的匹配的队列中以后，broker就会发送一个确认给生产者（包括消息的唯一id），这就使得生产者知道消息已经正确到达目的队列了，如果消息和队列是可持久的，那么确认消息会将消息写入磁盘后发出，broker回传给生产者的确认消息中deliver-tag域包含了确认消息的序列号，此外broker也可以设置basic.ack的multiple域，表示这个序列号之前的所有消息得到了处理。

Confirm模式的最大的好处是在于他是异步的，也就是发送了一条消息以后没有得到反馈之前，也可以发送另一条消息。

开启confirm模式

Channel.confirmSelect();

9.2.2编程模式

9.2.2.1普通：发一条调用waitForConfirms()，相当于串行

生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.confirm.simple; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.confirm &nbsp;* @ClassName: Producer &nbsp;* @Description: 1.&nbsp;&nbsp;&nbsp; 普通：发一条调用waitForConfirms()，相当于串行 &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 9:12 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_confirm1"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; * 1.&nbsp;&nbsp;&nbsp; 普通：发一条调用waitForConfirms()，相当于串行 &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/19&nbsp; 9:21 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //生产者调用confirmSelect() 将channel设置为confirm模式 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //注意：如果之前已经将队列设置为txSelect则不能再设置为confirmSelect模式了 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.confirmSelect(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello confirm msg"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (!channel.waitForConfirms()) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("msg send failed"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("msg send ok"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

9.2.2.2批量的：发一批调用waitForConfirms()

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.confirm.batch; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.confirm &nbsp;* @ClassName: Producer &nbsp;* @Description: 2.&nbsp;&nbsp;&nbsp; 批量的：发一批调用waitForConfirms() &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 9:12 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_confirm2"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; * 2.&nbsp;&nbsp;&nbsp; 批量的：发一批调用waitForConfirms() &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/19&nbsp; 9:21 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //生产者调用confirmSelect() 将channel设置为confirm模式 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //注意：如果之前已经将队列设置为txSelect则不能再设置为confirmSelect模式了 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.confirmSelect(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.批量发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello confirm batch msg"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; 10; i++) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, (msg + i).getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //确认批量发送的结果 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (!channel.waitForConfirms()) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("msg batch send failed"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("msg batch send ok"); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //5.关闭资源 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.close(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; connection.close(); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

9.2.2.3异步confirm模式：提供一个回调方法

Channel对象提供的confirmLisenter（）回调方法只包含deliverTag（当前channel发出的消息序列号码），我们需要自己为每一个channel维护一个unconfirm的消息序列集合，每publish一条数据，集合元素加一，每回调一次handleAck方法，unconfirm集合删掉相应的一条（multiple=false）或者多条（multiple=true）记录，从程序的运行效率来看，这个unconform集合最好采用有序集合sortedset存储结构。

生产者

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq.confirm.asynchronous; &nbsp; import com.cmbc.rabbitmq.util.ConnectionUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.ConfirmListener; import com.rabbitmq.client.Connection; &nbsp; import java.io.IOException; import java.util.*; import java.util.concurrent.TimeoutException; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq.confirm &nbsp;* @ClassName: Producer &nbsp;* @Description: 3.&nbsp;&nbsp;&nbsp; 异步confirm模式：提供一个回调方法 &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 9:12 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; private static final String QUEUE_NAME = "queue_confirm3"; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description &nbsp;&nbsp;&nbsp;&nbsp; * 3.&nbsp;&nbsp;&nbsp; 异步confirm模式：提供一个回调方法 &nbsp;&nbsp;&nbsp;&nbsp; * @Date 2019/5/19&nbsp; 9:21 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [args] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //1.获取连接 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = ConnectionUtils.getConnection(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //2.获取channel 频道 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Channel channel = connection.createChannel(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //3.声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean durable = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean exclusive = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean autoDelete = false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map&lt;String, Object&gt; argments = null; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //声明一个队列 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.queueDeclare(QUEUE_NAME, durable, exclusive, autoDelete, argments); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //生产者调用confirmSelect() 将channel设置为confirm模式 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //注意：如果之前已经将队列设置为txSelect则不能再设置为confirmSelect模式了 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.confirmSelect(); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //未确认的消息标识 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; SortedSet&lt;Long&gt; confirmSet = Collections.synchronizedSortedSet(new TreeSet&lt;Long&gt;()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //通道添加监听 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.addConfirmListener(new ConfirmListener() { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //消息发送成功的 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleAck(long deliverTag, boolean multiple) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (multiple) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("---handleAck---multiple"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; confirmSet.headSet(deliverTag + 1).clear(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("---handleAck---multiple false"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; confirmSet.remove(deliverTag); &nbsp; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //消息发送不成功的 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public void handleNack(long deliverTag, boolean multiple) throws IOException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (multiple) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("---handleNack---multiple"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //TODO &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("---handleNack---multiple false"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //TODO &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }); &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //4.发送消息 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello confirm asynchronous msg"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (true) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; long seqNo = channel.getNextPublishSeqNo(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; channel.basicPublish("", QUEUE_NAME, null, msg.getBytes()); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; confirmSet.add(seqNo); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

10．Spring集成rabbitmq

10.1生产者配置文件

<table> 
 <tbody> 
 <tr> 
 <td> &lt;?xml version="1.0" encoding="UTF-8"?&gt; &lt;beans xmlns="http://www.springframework.org/schema/beans" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:aop="http://www.springframework.org/schema/aop" xmlns:rabbit="http://www.springframework.org/schema/rabbit" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd"&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--1.定义rabbitmq的连接工厂--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:connection-factory &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; id="connectionFactory" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; host="127.0.0.1" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; port="5672" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; username="guest" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; password="guest" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; virtual-host="/vhost_zq"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--2.定义rabbitmq模板，指定连接工厂以及定义exchange--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:template id="rabbitTemplate" connection-factory="connectionFactory" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; exchange="fanoutExchange"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--mq的管理：包括队列交换器的声明等--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:admin connection-factory="connectionFactory"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--定义队列，自动声明--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:queue name="Queue" auto-declare="true" durable="true"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--定义交换器，自动声明--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:fanout-exchange name="fanoutExchange" auto-declare="true"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;rabbit:bindings&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;rabbit:binding queue="Queue"&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/rabbit:binding&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/rabbit:bindings&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;/rabbit:fanout-exchange&gt; &lt;/beans&gt; &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

10.2 消费者配置文件

<table> 
 <tbody> 
 <tr> 
 <td> &lt;?xml version="1.0" encoding="UTF-8"?&gt; &lt;beans xmlns="http://www.springframework.org/schema/beans" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xmlns:aop="http://www.springframework.org/schema/aop" xmlns:rabbit="http://www.springframework.org/schema/rabbit" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd"&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--1.定义rabbitmq的连接工厂--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:connection-factory &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; id="connectionFactory" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; host="127.0.0.1" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; port="5672" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; username="guest" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; password="guest" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; virtual-host="/vhost_zq"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--定义队列，自动声明--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:queue name="Queue" auto-declare="true" durable="true"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--队列监听--&gt; &nbsp;&nbsp;&nbsp; &lt;rabbit:listener-container connection-factory="connectionFactory"&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;rabbit:listener ref="Consumer" method="listen" queue-names="Queue"/&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;/rabbit:listener-container&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--定义消费者--&gt; &nbsp;&nbsp;&nbsp; &lt;bean id="Consumer" class="com.cmbc.rabbitmq.Consumer"/&gt; &lt;/beans&gt; &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

10.3需要引入的jar

<table> 
 <tbody> 
 <tr> 
 <td> &lt;?xml version="1.0" encoding="UTF-8"?&gt; &nbsp; &lt;project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"&gt; &nbsp;&nbsp;&nbsp; &lt;modelVersion&gt;4.0.0&lt;/modelVersion&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;groupId&gt;com.cmbc.spring.mq&lt;/groupId&gt; &nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-rabbitmq&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp; &lt;version&gt;1.0-SNAPSHOT&lt;/version&gt; &nbsp;&nbsp;&nbsp; &lt;packaging&gt;war&lt;/packaging&gt; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; &lt;properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;app-name&gt;spring-rabbitmq&lt;/app-name&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;project.build.sourceEncoding&gt;UTF-8&lt;/project.build.sourceEncoding&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.compiler.source&gt;1.8&lt;/maven.compiler.source&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.compiler.target&gt;1.8&lt;/maven.compiler.target&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;spring.version&gt;4.2.0.RELEASE&lt;/spring.version&gt; &nbsp;&nbsp;&nbsp; &lt;/properties&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;dependencies&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--测试 start--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;junit&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;junit&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;4.11&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;scope&gt;test&lt;/scope&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--测试 end--&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--spring start--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-context&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-core&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-beans&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-context-support&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-aop&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-aspects&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-expression&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-jdbc&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-orm&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-tx&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-web&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-webmvc&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;${spring.version}&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!-- spring end--&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.springframework.amqp&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;spring-rabbit&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;2.0.1.RELEASE&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--日志 start--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;commons-logging&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;commons-logging&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.2&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--配置logback日志框架所需要的jar start--&gt; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.slf4j&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;slf4j-api&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.7.5&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.slf4j&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;log4j-over-slf4j&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.7.5&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;ch.qos.logback&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;logback-classic&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.1.2&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;ch.qos.logback&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;logback-core&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.1.2&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.logback-extensions&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;logback-ext-spring&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;0.1.1&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.codehaus.janino&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;janino&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;3.0.7&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--配置logback日志框架所需要的jar end--&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--配置cglib动态代理 start--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;cglib&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;cglib&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;2.2.2&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;cglib&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;cglib-nodep&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;2.2.2&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--配置cglib动态代理 end--&gt; &nbsp; &nbsp; &nbsp;&nbsp;&nbsp; &lt;/dependencies&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;finalName&gt;spring-rabbitmq&lt;/finalName&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;resources&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;resource&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;directory&gt;src/main/resources&lt;/directory&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--&lt;includes&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;include&gt;**/*.properties&lt;/include&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;include&gt;**/*.xml&lt;/include&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/includes&gt;--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filtering&gt;true&lt;/filtering&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/resource&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/resources&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugins&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-deploy-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;inherited&gt;false&lt;/inherited&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--设置编译的java版本 很重要 start--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.apache.maven.plugins&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-compiler-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;source&gt;1.8&lt;/source&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;target&gt;1.8&lt;/target&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!--设置编译的java版本 很重要 end--&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-jar-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;archive&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;manifest&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;addDefaultImplementationEntries&gt;true&lt;/addDefaultImplementationEntries&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;addDefaultSpecificationEntries&gt;true&lt;/addDefaultSpecificationEntries&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/manifest&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/archive&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-antrun-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;executions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;execution&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;phase&gt;compile&lt;/phase&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;goals&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;goal&gt;run&lt;/goal&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/goals&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/execution&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/executions&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependencies&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.apache.ant&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;ant&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;1.8.4&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/dependencies&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-surefire-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;includes&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;include&gt;**/*Tests.java&lt;/include&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/includes&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;argLine&gt;-Xmx256m&lt;/argLine&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;groupId&gt;org.apache.maven.plugins&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;artifactId&gt;maven-surefire-plugin&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;version&gt;2.12.4&lt;/version&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;forkMode&gt;once&lt;/forkMode&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;argLine&gt;-Dfile.encoding=UTF-8&lt;/argLine&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/configuration&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugin&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/plugins&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;/build&gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!--配置根据dev test prod等参数给不同环境的应用打包 start--&gt; &nbsp;&nbsp;&nbsp; &lt;profiles&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;profile&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;id&gt;dev&lt;/id&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activeByDefault&gt;true&lt;/activeByDefault&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.app-name&gt;${app-name}&lt;/maven.app-name&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.config-home&gt;${project.build.directory}/../conf&lt;/maven.config-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-home&gt;${project.build.directory}/../log&lt;/maven.log-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-level&gt;DEBUG&lt;/maven.log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.sql-log-level&gt;DEBUG&lt;/maven.sql-log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.console-log-enable&gt;true&lt;/maven.console-log-enable&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filter&gt;src/main/resources/filter/dev.properties&lt;/filter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/profile&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;profile&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;id&gt;test&lt;/id&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.app-name&gt;${app-name}&lt;/maven.app-name&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&lt;maven.config-home&gt;/tmp/test/conf&lt;/maven.config-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-home&gt;/usr/local/tomcat/logs&lt;/maven.log-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-level&gt;INFO&lt;/maven.log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.sql-log-level&gt;INFO&lt;/maven.sql-log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.console-log-enable&gt;false&lt;/maven.console-log-enable&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activeByDefault&gt;false&lt;/activeByDefault&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&lt;filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filter&gt;src/main/resources/filter/test.properties&lt;/filter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/profile&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;profile&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;id&gt;prod&lt;/id&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.app-name&gt;${app-name}&lt;/maven.app-name&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.config-home&gt;/tmp/conf&lt;/maven.config-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-home&gt;/usr/local/tomcat7/logs&lt;/maven.log-home&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.log-level&gt;INFO&lt;/maven.log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.sql-log-level&gt;INFO&lt;/maven.sql-log-level&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;maven.console-log-enable&gt;false&lt;/maven.console-log-enable&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/properties&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;activeByDefault&gt;false&lt;/activeByDefault&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/activation&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;filter&gt;src/main/resources/filter/prod.properties&lt;/filter&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/filters&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/build&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/profile&gt; &nbsp;&nbsp;&nbsp; &lt;/profiles&gt; &nbsp;&nbsp;&nbsp; &lt;!--配置根据dev test prod等参数给不同环境的应用打包 end--&gt; &nbsp; &lt;/project&gt; &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

10.4生产者代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq; &nbsp; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq &nbsp;* @ClassName: Producer &nbsp;* @Description: &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 11:20 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ @Controller public class Producer { &nbsp; &nbsp;&nbsp;&nbsp; @Autowired &nbsp;&nbsp;&nbsp; RabbitTemplate rabbitTemplate; &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description 生产者发送消息 &nbsp;&nbsp;&nbsp;&nbsp; * @Date&nbsp; 2019/5/19&nbsp; 11:31 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [] &nbsp;&nbsp;&nbsp;&nbsp; * @return java.lang.String &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; @RequestMapping("/produceMsg") &nbsp;&nbsp;&nbsp; public String produceMsg() { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String msg = "hello ！！！"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; rabbitTemplate.convertAndSend(msg); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("生产者 send msg " + msg); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return "success"; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

10.5消费者代码

<table> 
 <tbody> 
 <tr> 
 <td> package com.cmbc.rabbitmq; &nbsp; /** &nbsp;* @Package: com.cmbc.rabbitmq &nbsp;* @ClassName: Consumer &nbsp;* @Description: 消费者监听 &nbsp;* @author:&nbsp; &nbsp;* @since: 2019/5/19 11:06 &nbsp;* @version: 1.0 &nbsp;* @Copyright: 2019 . All rights reserved. &nbsp;*/ public class Consumer { &nbsp; &nbsp;&nbsp;&nbsp; /*** &nbsp;&nbsp;&nbsp;&nbsp; * @Author&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; * @Description 消费者具体执行业务的方法 &nbsp;&nbsp;&nbsp;&nbsp; * @Date&nbsp; 2019/5/19&nbsp; 11:20 &nbsp;&nbsp;&nbsp;&nbsp; * @Param [msg] &nbsp;&nbsp;&nbsp;&nbsp; * @return void &nbsp;&nbsp;&nbsp;&nbsp; **/ &nbsp;&nbsp;&nbsp; public void listen(String msg) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("消费者受到消息：" + msg); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

[http_localhost_15672]: http://localhost:15672/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70]: /images/20220130/60986ae0047c44cab2fe510e3eac010a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70 1]: /images/20220130/1df9ea93aefe479db6f4cd5cf9d0f0d5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIwNDUwNDU_size_16_color_FFFFFF_t_70 2]: /images/20220130/9ec69d693b8d49b5bde70f5789da5c73.png
[20190519165442627.png]: /images/20220130/c37596a7a8fc4d51ac0785321166882e.png
[2019051916550820.png]: /images/20220130/0e7f48d723844397a885f4d627f4bd34.png
[20190519165534441.png]: /images/20220130/7c70c4a738f249f3812d65566cf0e22b.png
[20190519165712277.png]: /images/20220130/06eedfc7fec34dc782971964dfd284f5.png
[Topics]: https://www.rabbitmq.com/tutorials/tutorial-five-python.html
[20190519165737827.png]: /images/20220130/631b8e73f5514c27a2097e69e5a1d33c.png