message-queue

0熱度

1回答

生產者不同的線程擁有自己的SynchronizedBlockingQueue。每個生產者都將消息放入自己的隊列中。消費者不同的主題將從無論是從隊列中的任何一個獲得消息，並啓動過程。現在爲了溝通生產者和消費者，我們需要經紀人。這可能是瓶頸。消費者是否有其他方式從任何生產者那裏獲得一條消息並開始流程。

0熱度

1回答

以編程方式配置Apache ActiveMQ

我使用Apache ActiveMQ對大量消息進行排隊，然後在一天結束時將它們出列。不過，我對ActiveMQ的運作方式感到困惑。在我的PC上，我沒有安裝ActiveMQ作爲服務，也沒有在某處安裝服務器。我剛纔包括「ActiveMQ的 - 全5.14.5.jar」作爲我的項目Maven的依賴，我使用下面的代碼至今： public static void main(String[] args) th

0熱度

1回答

Laravel - 架構 - MySQL的 - 臨時表「已存在」

我使用Laravel 5.4的web應用程序，爲的RabbitMQ消息隊列層和Laravel隊列工作。我有兩個相關的問題：臨時表我在構造函數如下表創建代碼： Schema::create('tmp_products', function (Blueprint $table) { $table->temporary(); $table->integer('id');

3熱度

1回答

Express中Laravel隊列作業的等效數據是什麼？

Laravel提供名爲Queues的功能，您可以使用服務（beanstalkd，Amazon SQS，Rabbit MQ）將長時間運行的任務委託給後臺工作人員。一個簡單的例子就是通過排隊的作業發送電子郵件，而不是從控制器發送。所述排隊作業能夠識別任務是否完成，或者如果失敗，則重試一定次數。什麼是Express（NodeJS）相當於此功能（如果它甚至存在）？我試圖通過直接尋找服務上的資源（如Rab

0熱度

1回答

Masstransit。處理程序不確認消息

我有出版商： static void Main() { var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc

0熱度

2回答

NATS發佈者可以將單個消息發送到多個隊列嗎？

我正在構建一個系統，兩個不同的實體需要處理來自同一個源的消息（以不同的方式 - 例如，一個會記錄所有消息，而另一個實體可能需要聚合數據）。理想情況下，每個實體對於性能和彈性都是完全可擴展的，因此我們有多個發佈者，多個日誌訂閱者和多個聚合訂閱者，但每個發佈的每個消息仍然由一個日誌訂閱者和一個聚合訂閱者處理。通過AMQP，我們可以通過發佈到扇出交換機來實現此目的，該交換機將消息分發到兩個隊列，其中每

0熱度

1回答

Masstransit + RabbitMQ。在兩種不同的消息類型之間共享一個隊列

我有一個發佈者，它將消息發佈到rabbitmq：// localhost/test123隊列。一條消息具有TestMessage類型，另一條是TestMessage2類型。出版商配置： sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc.UseL

2熱度

1回答

如何在RabbitMQ中實現循環法主題交換

我知道在主題交換中實現循環法行爲可能會非常棘手或根本無法實現，所以我的問題實際上是，如果我能從RabbitMQ中做出任何事情或者望向其他消息隊列支持。這裏是我的應用需求進行詳細的解釋：將有一個製片人，我們稱之爲P 有（可能）將是成千上萬的消費者，我們姑且稱之爲Cn 每消費者可以「訂閱」1個或多個話題交換並且多個消費者可以訂閱同一主題發佈到該話題中的每個消息應該僅被一個消費者消費使用案例＃1

2熱度

1回答

如何使用Twitter Heron與Storm Flux

我正在嘗試將項目從apache-storm遷移到twitter-heron。經過很多努力，我能夠擺脫大部分錯誤，例如使用className: "org.apache.storm.kafka.ZkHosts"而不是className: "storm.kafka.ZkHosts"。但是，我堅持提交拓撲。我使用Flux將拓撲提交給風暴。當我在ZkState中創建一個CuratorFramework對象

0熱度

1回答

如何在activemq中放入入隊消息？

當生產者發送消息的速度很快時，我正在處理一個項目，代理應該將所有這些消息排入隊列，但在內存（或其他消息，如最大消息數量）限制達到時丟棄最老的消息。我嘗試了一個constantPendingMessageLimitStrategy參數，但它似乎不起作用。是否可以通過編輯activemq.xml文件中的代理部分來實現它？ <destinationPolicy> <policyMap>