成員變量數(shù)據(jù)映射不一致
問題描述 代碼中定義map變量保存映射關(guān)系，偶爾出現(xiàn)一種情況，machineConnectionMap與connectionMachineMap的數(shù)據(jù)不對等，比如machineConnectionMap為[1=>2],connectionMachineMap為[1=>2,2=>3]，machineConnectionMap中少了一條映射。 整個代碼中僅在onClose中有unset掉map，對于這個...
多數(shù)據(jù)庫怎么維護連接
多進程處理任務(wù)，但每個任務(wù)涉及的數(shù)據(jù)庫可能不一樣（多租戶），怎么維護數(shù)據(jù)連接呢 目的是開多個worker進程處理不同租戶的異步任務(wù) 最大總連接數(shù) = 進程數(shù)量 * 租戶數(shù)量 租戶有1000，進程10個，那么每個進程維護的數(shù)量就是1萬...
消息隊列，消費者可以同時處理多條消息嗎？
RabbmitMQ隊列里都是耗時任務(wù)：請求第三方的API(http)。 當(dāng)開啟一個消費worker時，能否在產(chǎn)生IO時繼續(xù)處理下一條消息。 場景：同步第三方平臺的產(chǎn)品數(shù)據(jù)，比如發(fā)起同步某個賬號的產(chǎn)品，一個賬號下面的產(chǎn)品可以最少也有幾千條，多達十幾萬的也有。 注：考慮第三方API是沒有批量查詢接口的。 將產(chǎn)品ID放在隊列里，開啟worker消費，消費者可以在遇到IO等待時繼續(xù)處理下一條消費嗎，需要對每條消息ACK（主要...
RabbitMQ中消費時，是不是能使用異步（如異步http）組件嗎？
例： $channel->basic_qos(0, 5, false); $channel->basic_consume('name', '', false, false, false, false, function(AMQPMessage $message) { echo 'Rec:', $message->getBody(), "\n"; $http = new Http();...
進程占用內(nèi)存太多
開啟多個進程，每個進程內(nèi)能過定時來執(zhí)行任務(wù)。 項目描述：相于當(dāng)爬蟲，只是調(diào)用的是平臺提供的API，抓去產(chǎn)品列表、對手價格，然后實現(xiàn)自動改價格（大部分都是平臺提供的API）。 目前賬號已經(jīng)在達到150個。有的賬號下的產(chǎn)品有2-3千。服務(wù)器配置還是最近才升到8核16G。CPU和內(nèi)存使用率特別高。最近我發(fā)現(xiàn)有進程占用的內(nèi)存超過1G（SHR）了，有的才幾十。我猜測是某些賬號下產(chǎn)品太多導(dǎo)致內(nèi)存占用過高。根據(jù)文檔查找進程ID，基...
隊列和異步任務(wù)
應(yīng)用： 通過API向物流提交訂單信息，物流返回追蹤號和快遞單(label)，一般一次請求在1-2秒之間（暫不考慮是國外還是國內(nèi)） 問題： 目前很笨的辦法是利用循環(huán)一個一個的獲取，處理慢，客戶需要等待的時間太久（就不能操作其它了），體驗非常不好 目前想到兩種方案： 1、利用消息隊列和workerman多進程 在N臺機器上部署workerman，每臺服務(wù)器開M個進程，即共有 N*M 個進程處理消息 保存處理結(jié)果...
