一個(gè)WOKRER代理調(diào)用另外一個(gè)WORKER代理中的異步TCP連接的問題。

azafek 更新于2020-04-16

問題是這樣的
我開了一個(gè)WOKRER, WORKER A, 假設(shè)COUNT是100，在其中使用了$serverA = new AsyncTcpConnection()連接另外一家公司的服務(wù)器 SERVER A。這個(gè)SERVER A不限制連接數(shù)，所以我開了100個(gè)進(jìn)程

問題是我的WORKER B，模式一樣的，需要$serverB = new AsyncTcpConnection()連接另一臺(tái)服務(wù)器SERVER B。因?yàn)镾ERVER B中限制連接數(shù)，最多10個(gè)。所以我這個(gè)WORKER B的COUNT只有10。

我想不要WORKER B了，就用WORKER A中既連接SERVER A，又連接SERVER B。也就是兩個(gè)AsyncTcpConnection都放在WORKER A中。這樣兩個(gè)連接我都可以使用（$serverA和$serverB都在一個(gè)進(jìn)程中）。但是目前來看，因?yàn)檫B接數(shù)限制的問題。我沒有辦法，或者說有什么其他的方法??

另外一個(gè)方案。還是worker A，worker B兩個(gè)WORKER,但是我想在WORKER A中使用WORKER B里的變量 $serverB收發(fā)消息。這個(gè)應(yīng)該怎么做？

只能用ip+端口的方式請(qǐng)求嗎？有沒有可能在程序中直接調(diào)用

 2599  1 0

1個(gè)回答

phpcreeper 2020-04-16

1、進(jìn)程數(shù)和連接數(shù)搞混了，并不是一個(gè)進(jìn)程內(nèi)只能發(fā)起一個(gè)異步tcp連接；
2、另外一個(gè)問題的本質(zhì)是不同進(jìn)程間通信：
多進(jìn)程之間是不能跨進(jìn)程互相操作對(duì)方空間的變量的，方法很多比如使用官方的 globalData組件、或者redis組件、或者共享內(nèi)存等等來實(shí)現(xiàn)【當(dāng)然如果你將兩個(gè)worker都寫在同一個(gè)進(jìn)程內(nèi)，那倒是有機(jī)會(huì)可以直接調(diào)用】。