java spring boot amqp两个行为不同的侦听器

Question

我是spring amqp的新手，我想创建两个行为不同的听众。问题是，我在编译时不知道队列名称，因此无法使用此解决方案。

我想做的事情是：从“sidechannel”队列中读取（然后删除）第一条消息，它应该是这样的{“queues”：[“queue1”，“queue2”]}。

现在从queue1和queue2读取（然后删除）第一条消息。之后，转至步骤1，阅读侧频道的第一条消息

正如您在下面的代码中所看到的，我试图创建两个具有不同侦听器的SimpleMessageListenerContainer，但它并没有像我想象的那样工作。

我的代码：

@SpringBootApplication
public class Main implements CommandLineRunner {

final static String queueName = "sidechannel";

@Autowired
AnnotationConfigApplicationContext context;

@Autowired
RabbitTemplate rabbitTemplate;

@Bean
Queue queue() {
    return new Queue(queueName, false);
}

@Bean
TopicExchange exchange() {
    return new TopicExchange("spring-boot-exchange");
}

@Bean
Binding binding(Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with(queueName);
}

@Bean
public ConnectionFactory rabbitConnectionFactory() {
    CachingConnectionFactory connectionFactory =
            new CachingConnectionFactory("localhost");
    connectionFactory.setUsername("guest");
    connectionFactory.setPassword("guest");
    return connectionFactory;
}

@Bean
public SimpleMessageListenerContainer messageListenerContainer() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(rabbitConnectionFactory());
    container.setQueueNames(queueName);
    container.setMessageListener(sidechannelListener());
    return container;
}

@Bean
public SimpleMessageListenerContainer messageListenerContainer2() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(rabbitConnectionFactory());
    container.setQueueNames("queue1","queue2");
    container.setMessageListener(queueListener());
    return container;
}



@Bean
public MessageListener sidechannelListener() {
    return message -> {
        String msg = new String(message.getBody());
        System.out.println(msg);
        try {
            Map<String, Object> map = html" target="_blank">jsonToMap(msg);
            for (String name : (ArrayList<String>) map.get("queues")) {
                System.out.println("Waiting for " + name + " message");
                rabbitTemplate.receive(name);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    };
}

@Bean
public MessageListener queueListener() {
    return message -> {
        String msg = new String(message.getBody());
        System.out.println("Received message: ");
        System.out.println(msg);
    };
}


public static void main(String[] args) throws InterruptedException {
    SpringApplication.run(Main.class, args);
}

@Override
public void run(String... args) throws Exception {
    rabbitTemplate.setReceiveTimeout(-1);

    while(true) {
        System.out.println("Waiting for side channel message");
        rabbitTemplate.receive(queueName);
    }
//        context.close();
}
}

首先，由于某种原因，侧通道队列中的消息在处理后不会删除。其次，当我期待这样的输出时：

Waiting for side channel message
{"queues":["queue1","queue2"]}
Waiting for queue1 message
Received message:
"message from queue1"
Waiting for queue2 message
"message from queue2"
Waiting for side channel message

即使我在这些不同的队列上收到消息，也不会发生任何事情（因为RabbitTemplate.setReceiveTimeout（-1）；），但不知何故，它会对我收到的每条消息做出反应...

此外，我不明白的是，如果我首先向sid0008 nel发送消息，然后向queue1发送消息，它会像这样：

Waiting for side channel message
{"queues":["queue1","queue2"]}
Waiting for queue1 message
Received message:
"message from queue1"

现在，如果我向queue1发送另一条（第二条）消息，它会打印出消息，然后等待queue2消息。

所以需要两条消息才能继续循环。。。我不知道我做错了什么。

Answer 1

你似乎在混合各种范式；您有消息驱动的侦听器容器，并且还使用轮询（template.receive（））。通常，queue1、queue2的容器已经处理了来自这些队列的消息，并且

            System.out.println("Waiting for " + name + " message");
            rabbitTemplate.receive(name);

如果超时为