0

我有两个在同一个应用程序中实现 Runnable 的 java 类，比如说 A 类和 B 类。

这两个类共享一个 BlockingQueue 来传递一些数据。A类通过BlockingQueue向B类发送数据。然后 B 类获取数据并进行处理。我想要做的是，当由于处理这些数据而在 B 类中发生某些情况时，它会向 A 类发送一条消息，然后 A 类打印这些消息。

所以我正在查看使用 Apache ActiveMQ 的 Spring 消息传递，但似乎必须启动代理才能使用“activemq start”命令进行通信。如果没有启动此代理，是否有可能做到这一点？

这样做的最佳选择是什么？我想使用 Spring 框架来做到这一点，所以可以在 Spring 中使用某种方法来完成吗？或者使用spring的唯一可能性是通过apache activemq？

4

2 回答 2

1

看看Spring Integration；组件使用Messages 进行通信。

您可以使用完全在内存中的配置或通过一些代理（例如 ActiveMQ）提供持久性。

组件本身并不关心这一点；他们只是发送/接收消息。

于 2016-02-08T16:50:31.777 回答
0

在 spring 中创建队列并将其注入两个 Runnables

于 2016-02-08T16:53:04.260 回答