2016-09-29 24 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)到主題(按鈕),他們會得到的消息(點擊按鈕事件)時,生產者將其發送到隊列(用戶點擊按鈕)