RabbitMQ工具类实现配置文件动态创建队列和绑定

# rabbitmq 根据配置文件动态创建队列和绑定 ### 配置示例 ```yml spring: rabbitmq: # ip host: 192.168.200.31 # 端口 port: 5672 # 用户名 username: medway # 密码 password: medway medway: platform: rabbitmq: # 组件信息 rabbit-infos: # 路由主键 - routing-key: web.socket.test # 队列信息 queue: # 队列名称 name: web.queue.test # 交换机信息 exchange: # 交换机名称 name: web.exchange.test # 交换机类型 默认 广播模式 type: FANOUT ``` ```java public enum ExchangeTypeEnum { DIRECT("1", "直连模式"), FANOUT("2", "广播模式"), TOPIC("3", "通配符模式"), HEADERS("4", "参数模式"); private String code; private String name; } ``` #### 代码示例 ```java // 发送消息 @SpringBootTest @Slf4j public class RabbitmqTest { @Autowired private RabbitTemplate rabbitTemplate; @Autowired private RabbitProperties rabbitProperties; @Test public void sendMessageTest() { RabbitInfo rabbitInfo = rabbitProperties.getRabbitInfos().get(0); String message = rabbitInfo.getQueue().getName() + " ---> 发送消息"; // convertAndSend 三个参数分别是 交换机名称、路由主键、消息内容 rabbitTemplate.convertAndSend(rabbitInfo.getExchange().getName(), rabbitInfo.getRoutingKey(), message); log.info("sendMessageTest 发送消息的内容 {} " + message); } } // 接收消息 @SpringBootTest @Component @Slf4j public class RabbitMessageTest { private static final String QUEUE_NAME = "web.queue.test"; @Test // queues 队列名称， 多线程监听消息： containerFactory = "batchQueueRabbitListenerContainerFactory" @RabbitListener(queues = QUEUE_NAME, containerFactory = "batchQueueRabbitListenerContainerFactory") public void receiveMessageTest(String message) { log.info("receiveMessageTest 接收消息的内容 {} " + message); } } ```