---

一、使用步骤

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 {@RabbitHandlerpublic void receiveData(String json) {receive(json);}@RabbitHandlerpublic void receiveData(byte[] messageByte) throws Exception {receive(new String(messageByte, "UTF-8"));}
}

---