springboot整合rabbitmq和websocket搭建集群多台服务器只有一台的rabbitmq监听有效是为什么急急急！！！！！！！！！！！！！

显示全部楼层 · 2021-1-27 06:49:21

多台服务器连接同一个rabbitmq每台服务器使用SimpleMessageListenerContainer创建了相同队列的监听但只有第一台启动的服务器监听有效其他都是无法监听的是什么情况
@Bean
publicSimpleMessageListenerContainermessageContainer(HandleServicehandleService)throwsAmqpException,IOException{
String[]queues=mqMsgQueues();
System.out.println("=====================初始化创建rabbitMq监听器,监听队列："+queues);
SimpleMessageListenerContainercontainer=newSimpleMessageListenerContainer(connectionFactory);
//存放消息队列
container.setQueueNames(queues);
//设置最多的并发消费者。
container.setMaxConcurrentConsumers(maxConcurrentConsumers);
//设置多个并发消费者一起消费，并支持运行时动态修改。
container.setConcurrentConsumers(concurrentConsumers);
//消费者的个数
container.setPrefetchCount(prefetchCount);
//设置确认模式为自动确认
container.setAcknowledgeMode(AcknowledgeMode.MANUAL);//设置确认模式手工确认
//设置消费者的consumerTag_tag
//container.setConsumerTagStrategy(queue->"chat_queue_"+(++count));
////设置消费者的Arguments
//Mapargs=newHashMap();
//args.put("chat_flag","聊天室监听");
//args.put("fun","推送消息");
//container.setConsumerArguments(args);
container.setMessageListener(handleService);
returncontainer;
}
分 -->

千问 · 2021-1-27 06:49:21

你exchange和queue是如何创建的，是不是创建的时候有问题，建议使用注解创建。还有集群的配置是否有问题，能否互通

springboot整合rabbitmq和websocket搭建集群多台服务器只有一台的rabbitmq监听有效是为什么 急急急！！！！！！！！！！！！！

springboot整合rabbitmq和websocket搭建集群多台服务器只有一台的rabbitmq监听有效是为什么急急急！！！！！！！！！！！！！