2016-09-29 43 views
0

我正在使用RabbitMQ和MongoDB。当RabbitMQ从Queue触发一条消息时,我需要用java编写一个服务函数来将数据存储在MongoDB中。如何在java中编写代答服务函数

架构会像

enter image description here

待办事项的RabbitMQ必须从队列中传递一个XML文件来接送服务的能力吗?请帮忙。我对所有这些技术都很陌生。

回答

1

您的PickupService将不得不上传至RMQ的相关主题以接收队列中的消息。消息以异步方式推送给订阅者。 RMQ无法发送文件,但可以在您的示例中以纯文本形式发送文件内容 - xml。

正如你所说的那样,如果你对Swing应用程序很熟悉,那么消息广播就类似于Swing中的动作侦听器。您不能将多个actionListener s注册到按钮单击事件,并且单击按钮时将通知所有监听器。

同样是在这里,你可以有多个用户(的ActionListeners)到主题(按钮),他们会得到的消息(点击按钮事件)时,生产者将其发送到队列(用户点击按钮)