上一遍博客中介绍了rabbitmq交换器的类型、队列和交换器的动态声明、交换器动态绑定到队列及使用队列发送和接收消息。在实际的工做中队列和交换器都是从后台管理中申请,程序中直接使用就能够了,今天介绍一下使用spring-boot链接rabbit中已存在的队列和交换器发送和接收消息。
1、管理后台中建立队列和交换器并将交换器绑定到队列
1.建立队列
登陆rabbitmq 管理后台选择Queues标签,点击Add a new queue,输入要建立的队列名称而后点击Add queue 按钮
队列建立成功
2.建立交换器
选择Exchanges标签,点击Add a new exchange,输入交换器名称而后点击Add exchange 按钮
交换器建立成功
3.绑定交换器到队列
点击要绑定队列的交换器名字,跳转到交换器详细信息页,显示该交换器为绑定任何的队列或交换器
输入要绑定的队列名称和路由键(由于建立的是direc交换),点击绑定按钮
绑定成功以下图
2、建立spring-boot应用链接rabbit收发消息
1.引入maven依赖git
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.59</version> </dependency>
2.配置链接信息github
spring: application: name: rabbit-example2 rabbitmq: host: 192.168.98.23 port: 5672 username: root password: root server: port: 8081
3.建立消息生产者web
@Component public class RabbitProducer { @Autowired AmqpTemplate amqpTemplate; public void sendMessage(Object object) { try { Message message= MessageBuilder.withBody(JSON.toJSONString(object).getBytes("UTF-8")) .setContentType(MessageProperties.CONTENT_TYPE_JSON) .setContentEncoding("UTF-8") .setMessageId(UUID.randomUUID().toString()).build(); // 指定exchange name 为x.test0831,路由键为 rk.test amqpTemplate.send("x.test0831","rk.test",message); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } } }
4.建立rest接口发送消息spring
@RestController @RequestMapping(value = "/messages") public class MessageController { @Autowired RabbitProducer rabbitProducer; @PostMapping(value = "/send") public Map<String,Object> sendMessage(@RequestBody Map<String,Object> paramMap) { rabbitProducer.sendMessage(paramMap); Map<String,Object> resultMap=new HashMap<>(); resultMap.put("status","success"); return resultMap; } }
5.使用postman测试消息发送
6.查看队列中是否有收到消息
4.建立消息消费者
@Component
@RabbitListener(queues = “q.test0831”) // 监听队列q.test0831
public class RabbitConsumer {json
@RabbitHandler public void receiveMessage(Object object) { Message message=(Message)object; byte bytes[]=null; if (message != null) { bytes=message.getBody(); } try { String msg=new String(bytes,"UTF-8"); System.out.println("receive message is ------------------------"+msg); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } }
}
启动应用,输出日志
源码地址
https://github.com/tangyajun/spring-boot-rabbitmq-example2app