spring rabbit 中如何正确发送回复消息？

Question

我有一个 spring 兔子监听器

@Override
public void onMessage(Message message, Channel channel) {
     //do something

      channel.basicPublish("",queue name, null, SerializationUtils.serialize(r));

}

rabbit 怎么理解这个回复是针对我的特定消息的？万一我有几千条消息。 link 请求和响应需要做什么？有没有办法不序列化地传递到通道 POJO？谢谢

Answer 1

你应该注意 replyTo 和 correlation。

但我会说没有理由手动执行此操作，因为 MessageListenerAdapter 会处理此问题。

您只需要提供一个具有请求-回复功能的 POJO：

class Delegate {
    @SuppressWarnings("unused")
    public String handleMessage(String input) {
        called.set(true);
        return "processed" + input;
    }
}

adapter.setDelegate(new Delegate());

spring rabbit 中如何正确发送回复消息？

How to send reply message in spring rabbit correctly?

java

spring

rabbitmq