node-amqp

0熱度

2回答

我正在使用amqlib模塊構建帶有rabbitmq和nodejs的後臺任務管理系統。我的服務器可能會被殺死（使用太多的CPU）。如果我啓動了很多這些任務，並且我只有幾個工作站，那麼我的服務器可能會被殺死（使用太多的CPU）。我想知道是否有辦法創建一個amqp隊列，以便我的消費者一次只能使用此隊列中的一個任務（即在確認或拒絕之前，請不要發送此類任務對這個消費者）。或者我應該在代碼中自己處理這個問

1熱度

1回答

RxJS使用異步訂戶功能的Observable

我試圖做一些感覺應該是直截了當的事情，但證明出人意料的困難。我有一個訂閱RabbitMQ隊列的函數。具體來說，這裏是Channel.consume函數：http://www.squaremobius.net/amqp.node/channel_api.html#channel_consume 它返回一個承諾，該承諾用訂閱ID解析 - 稍後需要取消訂閱 - 還有一個回調參數，用於在消息從隊列中拉出

0熱度

2回答

如何在MQRabbit隊列的末尾添加消息

我正在處理能夠處理RabbitMQ消息的工作人員。但是，我不確定如何做到這一點。如果我收到一條消息，並在我的治療期間發生錯誤，如何將消息放入隊列末尾？我試圖使用nack或拒絕，但消息總是重新放在第一個位置，並且其他消息保持凍結！我不明白爲什麼消息必須放在第一位，我試圖「玩」與其他選項如requeue或AllupTo但他們都沒有工作。預先感謝您！

0熱度

1回答

捕獲並顯示來自IP攝像頭源的視頻（Unity3d + c＃）

需要您的幫助。我正在做簡單的應用程序（我也是Unity3d的新手），它從IP攝像頭獲取視頻並將其顯示到Texture2D上。視頻格式是MJPG。對於簡單的jpg圖像下面的代碼工作正常，但是當我嘗試顯示MJPG時，我只是得到灰色屏幕。我在代碼中犯了錯誤嗎？ public class testVid : MonoBehaviour { //public string uri = "

0熱度

1回答

我可以在瀏覽器中使用amqplib嗎？

我是AMQP/RabbitMQ新手，和相關的Node.js新手。我可以使用amqplib NPM庫客戶端嗎？我希望能夠從我的Angular應用程序直接將消息推送到RabbitMQ。我用Browserify模塊化了很多客戶端代碼。我現在開始嘗試使用RabbitMQ，並希望通過amqp協議將消息直接從瀏覽器推送到基於雲的隊列。我已經通過NPM安裝amqplib並寫入/粘貼以下模塊： var amq

4熱度

1回答

每次發佈後我應該關閉頻道/連接嗎？

我在Node.js中使用amqplib，我不清楚我的代碼中的最佳實踐。基本上，我當前的代碼在節點服務器啓動時調用amqp.connect()，然後爲每個生產者和每個消費者使用不同的渠道，從不實際關閉它們中的任何一個。我想知道這是否有意義，或者我應該創建頻道，每次發佈消息時發佈並關閉它。那麼連接呢？這是連接一次的「良好做法」，然後在服務器的整個生命週期中保持打開狀態？在消費者方面 - 我可以使用

0熱度

1回答

使用senecajs實現扇出策略

我正在開發一個使用senecajs的node.js社交網絡應用程序，並且需要實現一個生產者可以將相同消息發送給多個消費者的場景。我發現一篇文章似乎說明了使用senecajs來解決這個問題的示例代碼。問題是，我試圖翻譯這到我的情況，這裏是例子，從這篇文章（https://github.com/senecajs/seneca-amqp-transport/issues/27）：我有1個客戶發佈事件給

1熱度

1回答

如何在實體框架3.5（VS 2008）中實現多層「包含」

我的數據庫有兩個表格 - 問題和主題。爲了實現許多一對多的關係，有其具有以下結構的映射表：表TopicQuestionMapping INT ID（主鍵） INT QuestionID（外鍵到問題表） INT TopicID（外鍵主題表）現在，在我的EF我有類似 ViewData.Model = DB.QuestionMaster.Include("TopicQuestionMapping

0熱度

2回答

是否可以在amqp中獲得未路由的消息？

使用RabbitMQ Web UI時，當我發佈到沒有當前隊列綁定的主題交換時，rabbitmq表示郵件已發佈但未路由。使用amqp.node，當我將隊列綁定到交換機並開始使用「＃」（全部）使用時，我沒有收到任何東西。我期待得到以前發佈但未路由的消息。這可能嗎？

0熱度

1回答

rabbitmq - 每個消費者的預取計數

我想用node-amqp庫爲RabbitMQ創建多個消費者，但我不明白prefetch-count選項是否指的是每個消費者的計數。我希望每個消費者都有自己的預取計數，而不依賴於其他消費者。謝謝。