当前位置：首页 > article >正文

RabbitMQ生产消息【交换机、路由键】与消费消息的简单使用

article 2025/1/6 18:50:46

文章目录

一、使用步骤
- 1.新建交换机
- 2.新建队列
- 3.队列绑定交换机和路由键
二、代码
- 1.生产端
- 2.消费端

一、使用步骤

1.新建交换机

点击Exchanges
新增交换机名称为msg.e1，type为direct
在这里插入图片描述

2.新建队列

点击Queues
新增队列，名称为q.test1
在这里插入图片描述

3.队列绑定交换机和路由键

点击新建的队列q.test1，绑定交换机和路由键
在这里插入图片描述
绑定效果如下图：

二、代码

1.生产端

private RabbitTemplate rabbitTemplate;
// 参数1：交换机；参数2：路由键；参数3：数据
rabbitTemplate.convertAndSend("msg.e1", "msg.test1" ,"要发送到队列的数据");

2.消费端

@Component
@RabbitListener(queues = "q.test1")
public class EBSEPolicyConsumer {

	@RabbitHandler
	public void receiveData(String json) {
		receive(json);
	}

	@RabbitHandler
	public void receiveData(byte[] messageByte) throws Exception {
		receive(new String(messageByte, "UTF-8"));
	}
}