概述
生产者
生产者其实无需配置交换机、队列，只要知道rabbitMQ中的交换机名称、交换机类型、发送routeKey就可以发送消息了。
但是通常我们会声明一下交换机。
代码实现如下：
/**
* 声明交换机
*/
@PostConstruct
public void init() {
Exchange exchange = new TopicExchange(orderExchangeName, true, false);
amqpAdmin.declareExchange(exchange);
}
/**
* 向mq发送消息
* @param recordMsg消息类型
*/
public void sendRecordToMq(RecordMsg recordMsg) {
try {
amqpTemplate.convertAndSend(orderExchangeName, orderRoutingKey, JSONObject.toJSONString(recordMsg));
} catch (Exception e) {
log.error("record callBack mq send error", e);
}
}
消费者
消费者对于需要交换机参与的接收模式，消费者需要先把消息队列、路由key、交换机绑定（如果rabbitMq中交换机、消息队列不存在还要先创建交换机和队列），根据队列名称接收消息。如果生产者把消息根据routingKey发送到了消费者绑定的对应队列中，消费者即可接收到消息。
总结
实际上，交换机、队列、路由Key的绑定关系都是通过客户端对rabbitMQ进行操作，是要在rabbitMQ这个中间件建立收发关系（可以把rabbitMq看成快递公司），只要rabbitMQ已经存在收发关系（即使收到创建、绑定也一样），我们只要简单的指定发送到哪、从哪接收就可以收发消息了。
问题总结
1、如果交换机中没有声明队列，那么生产者发送到交换机的消息会被rabbitMq主动丢弃，不会造成消息堆积。
2、通常情况下，队列、路由key、交换机的绑定关系都是由消费者做的，生产者只需要简单的发送消息即可。
参考
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/99948.html
