nats.io

0熱度

1回答

我打了一下NATS流媒體，並且我遇到了用戶速率限制問題。當我將飛行中的最大值設置爲1，將超時設置爲1秒，並且我有一個基本上是Thread.sleep（1000）的消費者時，則會多次獲得同一事件。我想通過限制在飛行和使用手動確認這不應該發生。一旦交付給非常緩慢的消費者，我怎樣才能得心應手？ case class EventBus[I, O](inputTopic: String, outputTop

0熱度

1回答

NATS IO性能調優

我已經用Java編寫了發佈者Subscriber。在服務器級別也進行了羣集。能夠以500 TPS（每秒交易）的速率發佈和訂閱30 KB的消息。但我想提高我們的性能高達2000 TPS。請建議如何實現相同。我已經使用Java與Apache Camel。

0熱度

1回答

Nats.io隊列訂閱行爲超時

我正在評估NATS以遷移現有的基於msg的軟件我沒有找到有關msg超時異常和過載的文檔。例如：認購後一直選擇，是不是意識到發表出版商超時設置？是否可以通知額外的時間延長？如果當選用戶注意到某些DBMS連接丟失，無法完成，便有可能反彈的消息 NATS服務器將皮卡另一個用戶，並重新發布了同樣的信息？僑迭戈

0熱度

1回答

NATS IO內部架構

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

0熱度

1回答

NATS爲答覆創建重複收件箱

我一直在玩使用C＃客戶端的NATS消息傳遞。我創建一個發送同步請求消息公佈： IConnection connection = new ConnectionFactory().CreateConnection(); Msg rsp = connection.Request("subject", Encoding.ASCII.GetBytes("some text")); 我創建使用隊列組中的

0熱度

2回答

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

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

1熱度

2回答

對請求的NATS異步回覆不是異步

我試圖在GO使用GO語言在gnatsd中實現請求/響應functinonality，並且我意識到gnatsd不會以異步方式回覆請求。我開始使用NATS github示例https://github.com/nats-io/go-nats/tree/master/examples進行調查 - 示例nats-req.go和nats-rply.go。這些例子效果很好。然後，我修改它們只是爲了測試gn

0熱度

1回答

如何使用Python Tornado爲NATS客戶端設置延遲的非阻塞自停止

我試圖讓Tornado在超時後停止，而不阻塞任何現有功能。我可能會錯過一個Tornado約定，但是如果我使用spawn_callback，Task或Thread，這並不重要，我似乎在阻止主循環。首先，我這樣做的原因是因爲我想在客戶端應用程序中使用世界着名的NATS消息總線來發布消息（而不是通常的直接HTTP功能），然後等待訂閱的響應。異步行爲的典型問題，以及官方的NATS Python客戶端使用

0熱度

1回答

協同程序收益繼續主

我試圖使用協程來發送數據到NATS（nats.io消息系統）。當我嘗試調用這個代碼沒有參數和循環它的工作完美。但是當我添加參數時，產生nc.connect函數不會返回任何東西並繼續執行main函數。如何用參數調用任何協程？ @tornado.gen.coroutine def process_events_list(events): try: nc = NATS()

0熱度

1回答

NATS服務器配置中的字符串串聯

我可以在NATS配置文件中串聯變量和字符串。例如： authorization { VERSION = "v1" REQUSTOR = { publish = ["msg." + $VERSION + ".bazz", "msg." + $VERSION + ".spam"] subscribe = "inbox." + $VERSION }