SpringBoot+RabbitMQ方式收发消息的实现示例

RabbitTemplate实现了标准AmqpTemplate接口，功能大致可以分为发送消息和接受消息。我们这里是在生产者中来用，主要就是使用它的发送消息功能：send和convertAndSend方法。convertAndSend方法是可以传入POJO对象作为参数，底层是有一个MessageConverter帮我们自动将数据转换成byte类型或String或序列化类型。convertAndSend方法就要简单太多，这里我放了一个User对象拿来测试用，直接指定队列然后放入这个对象即可。这段代码就代表onMessage方法会处理erduo队列中的消息。同时这里我们使用Channel做一个消息确认的操作，这里的DeliveryTag代表的是这个消息在队列中的序号，这个信息存放在MessageProperties中。不管怎么说，数据我们是拿到了，也就是代表我们的消费是没有问题的，同时也都进行了消息确认操作，从数据上看，整个消息可以分为两部分：body和MessageProperties。