扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
本篇文章给大家分享的是有关如何进行SpringBoot+RabbitMQ方式收发消息，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
“专业、务实、高效、创新、把客户的事当成自己的事”是我们每一个人一直以来坚持追求的企业文化。 创新互联是您可以信赖的网站建设服务商、专业的互联网服务提供商! 专注于成都做网站、网站设计、软件开发、设计服务业务。我们始终坚持以客户需求为导向，结合用户体验与视觉传达，提供有针对性的项目解决方案，提供专业性的建议，创新互联建站将不断地超越自我，追逐市场，引领市场！
本篇会和SpringBoot做整合，采用自动配置的方式进行开发，我们只需要声明RabbitMQ地址就可以了，关于各种创建连接关闭连接的事都由Spring帮我们了~
交给Spring帮我们管理连接可以让我们专注于业务逻辑，就像声明式事务一样易用，方便又高效。
祝有好收获，先赞后看，快乐无限。
1. ?环境配置
第一节我们先来搞一下环境的配置，上一篇中我们已经引入了自动配置的包，我们既然使用了自动配置的方式，那RabbitMQ的连接信息我们直接放在配置文件中就行了，就像我们需要用到JDBC连接的时候去配置一下DataSource一样。
如图所示，我们只需要指明一下连接的IP+端口号和用户名密码就行了，这里我用的是默认的用户名与密码，不写的话默认也都是guest，端口号也是默认5672。
主要我们需要看一下手动确认消息的配置，需要配置成manual才是手动确认，日后还会有其他的配置项，眼下我们配置这一个就可以了。
接下来我们要配置一个Queue，上一篇中我们往一个名叫erduo的队列中发送消息，当时是我们手动定义的此队列，这里我们也需要手动配置，声明一个Bean就可以了。
@Configuration public class RabbitmqConfig { @Bean public Queue erduo() { // 其三个参数：durable exclusive autoDelete // 一般只设置一下持久化即可 return new Queue("erduo",true); } }就这么简单声明一下就可以了，当然了RabbitMQ毕竟是一个独立的组件，如果你在RabbitMQ中通过其他方式已经创建过一个名叫erduo的队列了，你这里也可以不声明，这里起到的一个效果就是如果你没有这个队列，会按照你声明的方式帮你创建这个队列。
配置完环境之后，我们就可以以SpringBoot的方式来编写生产者和消费者了。
2. ?生产者与RabbitTemplate
和上一篇的节奏一样，我们先来编写生产者，不过这次我要引入一个新的工具：RabbitTemplate。
听它的这个名字就知道，又是一个拿来即用的工具类，Spring家族这点就很舒服，什么东西都给你封装一遍，让你用起来更方便更顺手。
RabbitTemplate实现了标准AmqpTemplate接口，功能大致可以分为发送消息和接受消息。
我们这里是在生产者中来用，主要就是使用它的发送消息功能：send和convertAndSend方法。
// 发送消息到默认的Exchange，使用默认的routing key void send(Message message) throws AmqpException; // 使用指定的routing key发送消息到默认的exchange void send(String routingKey, Message message) throws AmqpException; // 使用指定的routing key发送消息到指定的exchange void send(String exchange, String routingKey, Message message) throws AmqpException;
send方法是发送byte数组的数据的模式，这里代表消息内容的对象是Message对象，它的构造方法就是传入byte数组数据，所以我们需要把我们的数据转成byte数组然后构造成一个Message对象再进行发送。
// Object类型，可以传入POJO void convertAndSend(Object message) throws AmqpException; void convertAndSend(String routingKey, Object message) throws AmqpException; void convertAndSend(String exchange, String routingKey, Object message) throws AmqpException;
convertAndSend方法是可以传入POJO对象作为参数，底层是有一个MessageConverter帮我们自动将数据转换成byte类型或String或序列化类型。
所以这里支持的传入对象也只有三种：byte类型，String类型和实现了Serializable接口的POJO。
介绍完了，我们可以看一下代码：
@Slf4j @Component("rabbitProduce") public class RabbitProduce { @Autowired private RabbitTemplate rabbitTemplate; public void send() { String message = "Hello 我是作者和耳朵，欢迎关注我。" + LocalDateTime.now().toString(); System.out.println("Message content : " + message); // 指定消息类型 MessageProperties props = MessagePropertiesBuilder.newInstance() .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN).build(); rabbitTemplate.send(Producer.QUEUE_NAME,new Message(message.getBytes(StandardCharsets.UTF_8),props)); System.out.println("消息发送完毕。"); } public void convertAndSend() { User user = new User(); System.out.println("Message content : " + user); rabbitTemplate.convertAndSend(Producer.QUEUE_NAME,user); System.out.println("消息发送完毕。"); } }这里我特意写明了两个例子，一个用来测试send，另一个用来测试convertAndSend。
send方法里我们看下来和之前的代码是几乎一样的，定义一个消息，然后直接send，但是这个构造消息的构造方法可能比我们想的要多一个参数，我们原来说的只要把数据转成二进制数组放进去即可，现在看来还要多放一个参数了。
MessageProperties，是的我们需要多放一个MessageProperties对象，从他的名字我们也可以看出它的功能就是附带一些参数，但是某些参数是少不了的，不带不行。
比如我的代码这里就是设置了一下消息的类型，消息的类型有很多种可以是二进制类型，文本类型，或者序列化类型，JSON类型，我这里设置的就是文本类型，指定类型是必须的，也可以为我们拿到消息之后要将消息转换成什么样的对象提供一个参考。
convertAndSend方法就要简单太多，这里我放了一个User对象拿来测试用，直接指定队列然后放入这个对象即可。
Tips：User必须实现Serializable接口，不然的话调用此方法的时候会抛出IllegalArgumentException异常。
代码完成之后我们就可以调用了，这里我写一个测试类进行调用：
@SpringBootTest public class RabbitProduceTest { @Autowired private RabbitProduce rabbitProduce; @Test public void sendSimpleMessage() { rabbitProduce.send(); rabbitProduce.convertAndSend(); } }效果如下图~
同时在控制台使用命令rabbitmqctl.bat list_queues查看队列-erduo现在的情况：
如此一来，我们的生产者测试就算完成了，现在消息队列里两条消息了，而且消息类型肯定不一样，一个是我们设置的文本类型，一个是自动设置的序列化类型。
3. ?消费者与RabbitListener
既然队列里面已经有消息了，接下来我们就要看我们该如何通过新的方式拿到消息并消费与确认了。
消费者这里我们要用到@RabbitListener来帮我们拿到指定队列消息，它的用法很简单也很复杂，我们可以先来说简单的方式，直接放到方法上，指定监听的队列就行了。
@Slf4j @Component("rabbitConsumer") public class RabbitConsumer { @RabbitListener(queues = Producer.QUEUE_NAME) public void onMessage(Message message, Channel channel) throws Exception { System.out.println("Message content : " + message); channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); System.out.println("消息已确认"); } }这段代码就代表onMessage方法会处理erduo(Producer.QUEUE_NAME是常量字符串"erduo")队列中的消息。
我们可以看到这个方法里面有两个参数，Message和Channel，如果用不到Channel可以不写此参数，但是Message消息一定是要的，它代表了消息本身。
我们可以想想，我们的程序从RabbitMQ之中拉回一条条消息之后，要以怎么样的方式展示给我们呢？
没错，就是封装为一个个Message对象，这里面放入了一条消息的所有信息，数据结构是什么样一会我一run你就能看到了。
同时这里我们使用Channel做一个消息确认的操作，这里的DeliveryTag代表的是这个消息在队列中的序号，这个信息存放在MessageProperties中。
4. ?SpringBoot 启动！
编写完生产者和消费者，同时已经运行过生产者往消息队列里面放了两条信息，接下来我们可以直接启动消息，查看消费情况：
在我红色框线标记的地方可以看到，因为我们有了消费者所以项目启动后先和RabbitMQ建立了一个连接进行监听队列。
随后就开始消费我们队列中的两条消息：
第一条信息是contentType=text/plain类型，所以直接就在控制台上打印出了具体内容。
第二条信息是contentType=application/x-java-serialized-object，在打印的时候只打印了一个内存地址+字节大小。
不管怎么说，数据我们是拿到了，也就是代表我们的消费是没有问题的，同时也都进行了消息确认操作，从数据上看，整个消息可以分为两部分：body和MessageProperties。
我们可以单独使用一个注解拿到这个body的内容 - @Payload
@RabbitListener(queues = Producer.QUEUE_NAME) public void onMessage(@Payload String body, Channel channel) throws Exception { System.out.println("Message content : " + body); }也可以单独使用一个注解拿到MessageProperties的headers属性，headers属性在截图里也可以看到，只不过是个空的 - @Headers。