[Java知识库]多个rabbitmq配置

?项目中可能会遇到与不同服务之前进行数据通讯，所以可能会对接多个mq，这时就需要配置多套mq信息。以下是springboot项目配置方式：

1.首先引入依赖

<dependency>
? ?<groupId>com.mytaxi.spring.multirabbit</groupId>
? ?<artifactId>spring-multirabbit-lib</artifactId>
? ?<version>2.2.0</version>
</dependency>

2.配置文件中配置如下信息

spring:
? ? multirabbitmq:
? ? ? ? connections:
? ? ? ? ? ? twomq:
? ? ? ? ? ? ? ? host: xx.xx.xxx.xx
? ? ? ? ? ? ? ? port: xxxx #MQ端口
? ? ? ? ? ? ? ? username: xxxx? #MQ用户名
? ? ? ? ? ? ? ? password: xxxx? #MQ密码
? ? ? ? ? ? ? ? publisher-confirms: true #开启消息发送成功监听
? ? ? ? ? ? ? ? publisher-returns: true #开启消息发送失败监听
? ? ? ? ? ? ? ? listener:
? ? ? ? ? ? ? ? ? ? simple:
? ? ? ? ? ? ? ? ? ? ? ? acknowledge-mode: manual #手动提交事务

3.配置监听

@Component
public class MmsGiftMessageListenerService {
    /*
    * 监听消息队列
    *
    * */
    @RabbitListener(containerFactory = "twomq", queues = "xxxxxx")
    @RabbitHandler
    public void getSSQMessageListener(Message message, Channel channel) throws IOException {
        try{
            
            }
        }catch (Exception e){
            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        }
    }
}