message-queue

1熱度

2回答

我已經閱讀了很多關於微服務架構，但有一兩件事，我不知道如何實現，並希望你能幫助我這個... 可以說我有一個網絡的API - 接收OrderMicroservice負責處理的訂單的端點。訂單放置時必須更新庫存，以便OrderMS將訂單發佈給訂戶（例如Nats使用的訂單/訂單）和InventoryMS將更新庫存，因爲它訂閱了當前的事件/消息....我想要放寬耦合架構，並使用對給定信息感興趣的模塊/ M

1熱度

2回答

ZeroMQ + ReactPHP：多個生產者（推）和多個消費者（拉）

我使用reactphp/zmq。如何在多個拉動員工中擁有多個推動員工，這可能嗎？一個只能有多重拉動和單推，如自述的例子： $push->connect() $pull->bind() 或單拉和多推： $push->bind() $pull->connect() 當我嘗試設置都爲connect的拉不接收消息。否則，試圖與bind它拋出啓動多個進程： ZMQSocketExcepti

0熱度

1回答

使用JMS訂購消息工作過程的最佳做法是什麼

我有一項任務：我想並行化消息接收過程。任務很薄弱：特殊標記的消息必須按特殊順序處理 - 按照我的服務接收的順序。我試圖用JMS解決任務。消息放置在隊列中，並且多個MessageDriveBeans正在處理這些消息。我有一個「經典要求」：我想確保消息按照傳入隊列的順序進行處理。我使用WildFly 8.2（HornetQ - JMS提供程序）。我知道這是「沒有JMS模式要求」。我該如何組織這個過

0熱度

1回答

排隊的消息+ API端點

我們已經開發出模塊化的Web應用程序具有非常強大的API，現在我們需要排隊延遲的工具|費時的工作。我們正在考慮RabbitMQ或AWS SQS。但是，這兩個只是存儲消息，你必須手動從他們那裏收到消息，或者我誤解了它？我們想通過我們的API到信道的所有消息，因此當消息被髮布到隊列中應該是POST-ED（一些延遲之後），以我們的接口。所以我的問題：是否有排隊的支持HTTP POST（帶的oaut

1熱度

1回答

沒有消費者，但是當我發佈ack的東西時會立即返回爲什麼？（golang/rabbitmq）

以下是我使用的發佈商代碼。它在消息從隊列中取出之前需要ack。假設從消費者那裏得到Ack或nack（在代碼的底部）。如果你只是自己運行下面的發佈代碼（而不是同時運行一個消費者代碼），它假設只是掛起，等待ack或nack，但它沒有，它打印出一個確認就好像一個消費者發送了它。所以我很困惑，如果我有任何代碼的一部分是錯誤的。爲我所用代碼的RabbitMQ的官方教程中的基本代碼：https://www.

1熱度

1回答

無法通過CLI

我試圖使用CLI創建一個FIFO創建一個FIFO SQS，但我得到一個錯誤 aws sqs create-queue --queue-name my-queue.fifo --attributes FifoQueue=true --region us-east-1 An error occurred (InvalidAttributeName) when calling the CreateQ

1熱度

1回答

最大系統間兼容性 - 純RabbitMQ或NServiceBus，MassTransit？

請問您是否可以建議 - 如果我需要最大的系統間/語言兼容性，而主服務器將在.NET上實現，我可以使用NServiceBus或MassTransit，還是使用純RabbitMQ代替？ NServiceBus或MassTransit將提供相當不錯的抽象級別，但不同解決方案和環境之間的通信的容易性至關重要。我現在想更多地使用純RabbitMQ，但如果我把它看成是錯誤的，那麼指出一些優點和缺點會非常困難。

1熱度

1回答

如果rabbitmq不能用作鎖定服務，那麼可以做什麼？

的兩個主要問題是：沒有彈性的網絡分區沒有彈性的網絡故障這篇文章說，爲什麼它可以作爲一個鎖定服務：https://www.rabbitmq.com/blog/2014/02/19/distributed-semaphores-with-rabbitmq/ 本文將深入解釋爲什麼由於上面列出的問題而無法使用它：https://aphyr.com/posts/315-jepsen-rabbitmq

0熱度

1回答

是否有可能在同一事務中出隊和排隊

我有一條消息想要在出隊後立即出隊，我想將另一個消息排隊到另一個隊列。我想在同一筆交易中完成所有這些工作。這可能與rabbitmq或任何其他排隊服務？

0熱度

1回答

Spring與ActiveMQ的集成：當隊列中沒有更多待處理消息時獲取通知

我正在使用ActiveMQ與Spring集成。當我的隊列爲空時（沒有更多待處理的消息），我有要求做一些處理。我已經實現了這樣的事情， package my.com.spring.integration; public class MyListenerContainer extends DefaultMessageListenerContainer { @Override prot