reactor

1熱度

1回答

發送請求創建「服務器客戶端」我想創造這樣的事情：，我不知道，如何「在服務器客戶端」，在扭曲的創建，用於發送響應另一臺服務器我的意思是sheme：例如，有人已經寫了一些文件到FS1：客戶端 - >服務器 - > FSClient（創建成Server.onMessage（）） - >文件服務器並得到響應：文件服務器 - > FSClient - >服務器 - >客戶端 client.py：

2熱度

1回答

Spring中的@Async與Reactor線程池

@Async帶註釋的方法與Reactor設置爲使用相同大小的線程池有什麼區別。這種方法之一有什麼優勢嗎？它會是什麼？對於我的使用，我不在乎用以往的方法返回任何價值。

0熱度

1回答

在我的反應堆模式回調中獲取正確的對象作爲「this」

首先，我想說這是我第一次使用反應堆模式。我已經嘗試了一些知識，但沒有任何成功。這是迄今爲止我的腳本： function Reactor(){ this.events = {}; } Reactor.prototype.registerEvent = function(eventName){ this.events[eventName] = {name: eventNam

1熱度

1回答

扭曲的Python暫停/推遲反應堆

我很新的扭曲，我有查詢有限速，當我打這個限制的服務器的HTTP響應204的服務器的HTTP客戶端，所以，當我處理響應我可能做一些討厭的，就像這樣： def handleResponse(r, ip): if r.code == 204: print 'Got 204, sleeping' time.sleep(120) return None else:

0熱度

2回答

Python的扭停止反應堆多個客戶端

如果我創建通過這樣多個客戶端： def main(): clients = [None]*10 for i in range(0, 10): clients[i] = ClientFactory() reactor.connectTCP('192.168.0.1', 8000, clients[i]) reactor.run() 如何我

4熱度

1回答

反應堆將提供遠程處理嗎？

我試圖找出我們是否應該爲我們的下一個項目使用Akka或Reactor。最重要的問題之一是如果未來的選擇框架將提供遠程處理。正如我所看到的，Akka以我們想要的方式提供。在GitHub wiki中，不幸的是TCP服務器/客戶端部分是空白的，我還找不到其他信息。反應堆將提供遠程？

4熱度

1回答

扭曲：等待推遲到'完成'

我怎樣才能'推遲'進入反應堆，所以它得到處理的道路上的某個地方？形勢我有2個項目在本地主機上運行。一個扭曲jsonrpc服務（本地主機：30301）一個扭曲的web服務（本地主機：4000）當有人連接到Web服務，它需要將查詢發送到jsonrpc服務，等待它返回結果，然後在用戶的Web瀏覽器中顯示結果（返回jsonrpc調用的值）。我似乎無法弄清楚如何返回延遲的jsonrpc調用的值。

8熱度

2回答

Python中的「Actor模型」和「Reactor模式」之間有什麼區別？

https://en.wikipedia.org/wiki/Actor_model，該項目被稱爲「pulsar」 https://en.wikipedia.org/wiki/Reactor_pattern，項目被扭曲和龍捲風是什麼在理論和實踐上的區別？

2熱度

2回答

我應該在node.js中的本地文件的同步等效項上使用異步文件IO方法嗎？

我有一個非常簡單的實用程序腳本，我用JavaScript編寫了node.js，它讀取文件，進行一些計算，然後寫入輸出文件。在目前形式的源看起來是這樣的： fs.readFile(inputPath, function (err, data) { if (err) throw err; // do something with the data fs.writeFile

0熱度

2回答

UDP處理器與反應器在春天

我正在評估春天和它的生態系統爲新項目如此裸露與我。我希望我的應用程序對來自數千個不同客戶端的UDP事件做出反應。每個客戶端每隔5-10s發送1-10個UDP數據包。每個數據包都將被處理得非常快（主要在內存和小型計算中，只有偶爾的數據庫調用纔會幫助使用redis）。將不會有數據返回給調用者。我在Spring中實現了Reactor，就像他們在wiki上描述的一樣。然後我實現了像Spring集成文檔