message-queue

0熱度

1回答

我有一個按計劃每天運行的備份過程（生產），並且定期使用生成的備份來刷新較低的環境。我正在構建一個自動化解決方案，將.bak文件下載到較低的環境（不同的服務器）。我不願意在備份中使用MIRROR TO選項，因爲如果鏡像中的內容失敗，它可能會影響正常的備份操作。我在這裏想要使用服務代理，並在備份過程結束時異步觸發從prod到較低環境的文件副本。我在瞭解服務代理，消息類型，服務，隊列和合同方面付出了很多

0熱度

1回答

如何使用kafka輪詢遠程目錄中的新文件

我在遠程位置有一個文件夾，而其他一些進程一直在將文件放入其中。我正在編寫一個應用程序來下載每個新文件並對其進行處理。現在我正在下載rsync的文件，該文件已在上個小時創建並處理。但我需要一個解決方案，我想將新文件的名稱放到隊列中，然後我的使用者將從隊列中取出名稱，下載文件和進程。在此解決方案中，我可以運行多個只會在卡夫卡隊列上輪詢的生產者。

1熱度

1回答

與動態客戶端集成

我有一個建築設計問題。我們公司最近爲案例管理帶來了COTS（基於.NET的產品）。該產品具有一個複雜的集成模塊，可在每個用戶操作中將完整的案例信息XML提供給MQ。每個XML元素都有一個Add，Edit & Delete標誌來知道哪些元素髮生了變化。我們必須編寫一個應用程序，它們按順序處理這些事件，並在發生更改時有條件地發送給多個外部夥伴。與每個外部合作伙伴的接口在他們所需的數據，表示（XML，

0熱度

1回答

泊塢窗羣 - 負載均衡到最近的節點第一

我試圖以優化的方式多克爾 - 羣負載均衡，這將通過下面的優先級同一臺機器第一請求路由到服務相同DC 其他地方。鑑於以下設置：數據中心，我服務器的I Nginx的：80 服務器-II Nginx的：80 工人數據中心-II 服務器的I Nginx的：80 工人在情況和數據中心，我::服務器-II ::工人將發行通過端口80 API請求，期望的行爲是：檢查是否有任何任務（容器）映射到

0熱度

1回答

Pentaho JMS消費者 - 對單個消費者的多個生產者

我有2個JMS隊列，我的應用程序可以根據收到請求的節點將消息發佈到任何一個隊列。 Pentaho應該積極地看待這兩個隊列，並且應該能夠在消息到達隊列中的任何一個時立即進行處理。目前，我已經實現了一項工作來主動偵聽一個隊列並處理該消息併發布相同的響應。如何配置pentaho以同時主動偵聽兩個隊列，並在任何隊列發佈消息時執行相同的操作？編輯我不知道Pentaho提供此類內部服務通信的任何此類直接

2熱度

2回答

AWS SQS標準隊列或FIFO隊列何時不能重複消息？

我們計劃使用AWS SQS服務對從Web服務創建的事件進行排隊，然後使用多個工作人員來處理這些事件。一個事件只能處理一次。根據AWS SQS文檔，AWS SQS標準隊列可以「偶爾」產生重複消息，但吞吐量無限。 AWS SQS FIFO隊列不會產生重複消息，但吞吐量限制爲每秒300個API調用（batchSize = 10，相當於每秒3000條消息）。我們目前的高峯時間流量僅爲每秒80條消息。所以，

0熱度

1回答

NATS IO內部架構

目前我正在將TIBCO RV遷移到NATS IO以進行項目。我很想知道內部架構如何使NATS IO成爲性能卓越的中間環節，因爲他們在其網站http://nats.io/about/中聲稱。我無法在網上找到解釋nats內部的資源。任何人都可以請幫助我嗎？

0熱度

1回答

MessageDrivenBean不處理消息[Wildfly]

我試圖開發一個「Message Driven Bean」來處理所有本地的ActiveMQ消息，但這是我第一次嘗試做這樣的事情。我發現的大部分材料都解釋瞭如何使用JBOSS服務器編寫MDB，在這種情況下，存在一個包含一些隊列信息的xml文件，但在所有蜻蜓教程中都沒有提及任何類型的配置。我有以下情形：一個簡單的Java項目類似消息生產者一個ActiveMQ的實例上運行的本地 EJB項目部署到W

1熱度

1回答

D中的隊列類型？

許多語言都有隊列類型（http://docs.oracle.com/javase/7/docs/api/java/util/Queue.html）;我甚至找不到實現隊列類型的庫（先進先出數據結構）。缺少排隊令我感到驚訝。 D有排隊的方式嗎？我希望會是類似這樣的語法： //To create Queue!string queue = new Queue!string; //To add q

0熱度

1回答

Apache Camel消息格式

我剛剛開始使用使用Apache Camel 2.15.3的應用程序。我是駱駝的新手，我試圖瞭解郵件是如何發送的，以及它在路由組件之間的外觀。應用程序中的路由使用spring extension xml進行設置。以下是一條路線的樣子。 <route id="register"> <from uri="{{in.queue}}"/> <enrich uri="direct:g