java - JAVA中的生产者消费者模式

Question

Here the pattern of consumer-producer

Producer 创建一个新消息，consumer 通过 Broker 监听它们。

到目前为止，生产者 创建并发送消息，而消费者 等待消息。当新消息出现时，consumer 将其打印到屏幕上。

我希望 Producer 被告知 Consumer 已收到消息并将其出列。

我想知道有什么方法可以从Consumer通知/反馈Producer吗？或者我应该通过 Broker 通知 Consumer 吗？怎么做到的？

Answer 1

JMS 标准支持一个回复队列(JMSReplyTo)，使得原始消费者可以在特定队列上向原始生产者返回回复消息。

如图所示；

http://www.enterpriseintegrationpatterns.com/patterns/messaging/RequestReplyJmsExample.html

如果您还使用 JMSCorrelationID，则可以将消息链接在一起，以便您知道回复与 ID 为 xxxxx 的特定请求相关。

当然，这意味着消费者将成为回复消息的生产者。

提供的链接也有代码来显示一个工作示例(虽然我自己没有尝试过)