broker

    6熱度

    2回答

    我指的的Zeromq文檔中的「請求 - 應答經紀人:http://zguide.zeromq.org/chapter:all 我得到了應用程序的一般要點是:它就像從客戶的中介和消息路由到服務器然後再回來。 我不明白的是它如何確保服務器的正確響應被髮送到最初發出請求的正確客戶端。我沒有看到代碼示例中的任何內容確保了這一點。 現在在這個例子中,他們只發送1條消息(hello)和1個響應(world),

    0熱度

    1回答

    我想寫一個修改過的ActiveMQ代理,當他收聽生產者'消息的特定主題來處理它們(例如使用HDFS API而不使用默認Persisten存儲)。你有什麼想法從哪裏開始? 在此先感謝, 彼得魯奇

    2熱度

    1回答

    我正在創建一個嵌入式activemq實例,以便通過JMX測試創建/刪除主題。代碼看起來有點像以下內容。 broker.connectorPort是我嘗試設置JMX端口但它不起作用。 String connectString="vm://localhost?broker.persistence=false&broker.useJmx=true&broker.connectorPort=2011"

    2熱度

    2回答

    我正在閱讀關於設計模式(舊版本)「Pattern-oriented software architecture」的書籍。在專用於Client-Dispatcher-Server的章節中,SunRPC被引用爲Client-Dispatcher-Server體系結構,portmapper在客戶機 - 服務器協商中充當Dispatcher。我從來沒有用過SunRPC,雖然我多少知道它是如何工作的。 我有

    3熱度

    2回答

    我的項目一直在嘗試使用scrypt來實現憑證檢查器。我們嘗試過實施我們自己的憑證和檢查器對象,但是我們在使用pb時遇到了很多麻煩。 鉛似乎硬編碼爲使用過線,這絕對不會在我們的實施工作MD5哈希值;我們沒有辦法在服務器端以純文本的形式獲取正確的密碼,因爲我們使用的是scrypt,所以我們需要一種方式來傳輸密碼,以明文形式進行驗證。我們已經嘗試過使用twisted.cred.credentials.U

    0熱度

    1回答

    我想玩扭曲。我已經嘗試使用適當的Factory創建服務器和客戶端。這是一個奇妙的框架,但只有字符串可以發送:( 我想發送一些列表或數組對象作爲開始,也許以後使用客戶端內的服務器對象。但目前我堅持一些簡單的問題: 1)在Factory模型中,我使用了諸如「clientConnectionFailed」或「clientConnectionLost」之類的方法,如何使用PB獲得相同的方法?它們對於防止客

    0熱度

    1回答

    關於ActiveMQ:我有一個場景,我有一個生產者向用戶發送小文件(大約10KB)。雖然文件很小,但消費者需要大約10秒來分析它們並將結果返回給製作人。我已經研究了很多,但我仍然無法找到以下問題的答案: 如何讓代理存儲隊列中的文件(完全)? 我應該使用ObjectMessage(因爲文件很小)還是blob消息? 由於消費者處理緩慢,我應該降低他們的prefetchLimit還是使用循環調度策略?哪

    1熱度

    1回答

    請考慮以下情形: VNC客戶端嘗試與一個VNC服務器,該服務器是一個NAT後面連接。 我已經寫了一個java端口轉發器,它可以幫助我實現上述任務,並且工作正常。 現在我需要以某種方式在此轉發器中添加連接代理功能,以便我還可以攔截VNC客戶端 - 服務器之間的通信,並在轉發實用程序中驗證VNC客戶端。 您可能已經猜到實際上我正在使用從VNC客戶端接收的密碼進行一些身份驗證。由於RFB服務器可以在應用

    0熱度

    1回答

    我們有一個帶有主題和持久訂閱者的activemq的hub-and-spoke網絡拓撲。 (嵌入式)代理程序斷開連接後,它不會獲得在斷開連接期間發送的消息,而是發送其本地未決消息。 實施例: 代理A(嵌入)< --->中央代理(獨立)< --->經紀人B(嵌入) 後經紀人A已經斷開爲超過30s(最大innactivity超時對於openwire),它不會從中央代理那裏獲得斷開連接時發送的消息。然而,

    2熱度

    3回答

    我正在處理.NET服務的計劃階段,該服務持續處理傳入的消息,這涉及到各種轉換,數據庫插入和更新等。整體而言,服務非常龐大且複雜,但它執行的各項任務是小,簡單,明確。爲了這個原因,並且爲了在將來容易擴展,我想將服務拆分成幾個較小的服務,這些服務基本上在執行部分處理之前將其傳遞給鏈中的下一個服務。 爲了達到這個目標,我需要某種中介消息系統,將消息從一個服務傳遞到另一個服務。我希望這種情況發生的方式是,