亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

php使用swoole的應用場景

jsliang / 2204人閱讀

摘要：單進程讀寫性能可達萬，不同的進程使用不同的管道通信，可以最大化利用多核。但這任務如果是調(diào)用程序接口時，由于網(wǎng)絡的延遲，增加的任務大于消費的任務時，內(nèi)存占用會不斷的增加，導致服務器的內(nèi)存被占滿。

應用場景簡介

與硬件設(shè)備連接通訊(定位設(shè)備)

IM系統(tǒng)(用于直播頁面的聊天通訊)

場景1 - 實時收集定位數(shù)據(jù)實時輸出（例 滴滴司機行駛軌跡）

說明：
需要將所有的定位設(shè)備實時的接收，將實時的軌跡記錄顯示在地圖上

注意點：
第一點：
web1服務器 連接的用戶1,2,3，web1廣播信息時只能廣播用戶1，2，3,不能廣播web2連接的用戶4，5，6，假設(shè)場景是聊天，用戶1發(fā)送一消息，只有web1 服務器的用戶能看到，web2的用戶全部不能收到

第二點：消息的頻率控制，例：100個設(shè)備，100個用戶， 100個設(shè)備每秒上傳一條數(shù)據(jù)，需要實時廣播給每個用戶，就是每秒要100*100 = 1W次，所以可以匯總每秒數(shù)據(jù)廣播給所有用戶等等方法

數(shù)據(jù)傳輸?shù)牧鞒虉D：
不包含業(yè)務邏輯，將web1,web2,接收的消息匯總?cè)缓笤購V播給web1,web2,再廣播給用戶

場景2 - 只收集定位設(shè)備入庫

說明：需要把所有的定位設(shè)備上傳的數(shù)據(jù)入庫，設(shè)備7個，每秒一條數(shù)據(jù)，個人使用swoole 的task 函數(shù)（投遞一個異步的任務到 task_worker池中，此函數(shù)是非阻塞的， worker進程數(shù)同樣可以配置） 后調(diào)用接口方式入庫

服務器內(nèi)存報警問題

原因： 在于swoole_server->task 函數(shù)
官方介紹task底層使用Unix Socket管道通信，是全內(nèi)存的，沒有IO消耗。單進程讀寫性能可達100萬/s，不同的進程使用不同的管道通信，可以最大化利用多核。

但這任務如果是調(diào)用程序接口時，由于網(wǎng)絡的延遲，增加的任務大于消費的任務時，內(nèi)存占用會不斷的增加，導致服務器的內(nèi)存被占滿。

解決方法：消息針對入任務的頻率控制，可以根據(jù)自己的業(yè)務場景定義這個時間與是否可延遲等情況，匯總1秒內(nèi)的所有數(shù)據(jù)再調(diào)用程序接口（匯總時個人使用redis），最好能直接入庫，不必調(diào)用接口

簡單代碼片段，不全(供初學者了解,官方網(wǎng)站demo相似)

function __construct($config) 
{
    $this->config = $config;


    $this->serv = new SwooleServer($config["server"]["host"], $config["server"]["port"]);
    // 連接redis
    $this->redis = new PredisClient($config["redis"]);
    $this->storage = new Storage($this->config);

    $this->serv->set([
        "worker_num"      => $this->config["server"]["workerNum"],   //工作進程數(shù)量
        "daemonize"       => $this->config["server"]["daemonize"], //是否作為守護進程
        "task_worker_num" => $this->config["server"]["taskWorkerNum"],
    ]);
    $this->serv->on("connect", function ($serv, $fd){
        $this->onConnect($fd, $serv);
    });
    
    $this->serv->on("receive", function ($serv, $fd, $from_id, $data)  {
        $this->onReceive($fd, $serv, $data);
    });

    $this->serv->on("Close", function($server, $fd) {
        $this->onClose($fd, $server);
        
    });
    $this->serv->on("Task", function($server, $task_id, $from_id, $data) {
        $this->onTask($server, $task_id, $from_id, $data);
        
    });
    $this->serv->on("Finish", function($server, $task_id, $data) {
        $this->onFinish($server, $task_id, $data);
        
    });

    $this->serv->start();
}

public function onTask($serv, $task_id, $from_id, $data){
    // insert 方法是通過接口入庫
    $this->storage->insert($data);
}
public function onReceive($fd, $serv, $data)
{
    $this->storage->writeLog("message:".$data);
    $data = $this->formatData($data, $fd);
    $serv->task($data);
}
public function onClose($fd, $serv) 
{
    // writeLog 方法是寫入log
    $this->storage->writeLog("close fd:".$fd);
}
public function onFinish($serv, $task_id, $data)
{
    return "";
}
場景-IM系統(tǒng)

參考官方github: webim系統(tǒng).
官方wiki: swoole 框架wiki

好處

封裝了數(shù)據(jù)庫的model類，數(shù)據(jù)庫的ORM接口

redis的封裝，可以實現(xiàn)多實例訪問

框架有一些常用的方法，像log 等等（我只用到了log）

webim 官方有demon，可以參考

壞處：

文檔特別不全，一個簡單的實現(xiàn)會折騰半天

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/26116.html

相關(guān)文章

  • swoolefy-基于swoole擴展實現(xiàn)的高性能的常駐內(nèi)存型API和Web應用服務框架

    摘要：是一個基于擴展實現(xiàn)的輕量級高性能的常駐內(nèi)存型的和應用服務框架高度封裝了，，服務器，以及基于實現(xiàn)可擴展的服務，同時支持包方式安裝部署項目?；趯嵱?，抽象事件處理類，實現(xiàn)與底層的回調(diào)的解耦，支持同步異步調(diào)用，內(nèi)置等常用組件等。 swoolefy swoolefy是一個基于swoole擴展實現(xiàn)的輕量級高性能的常駐內(nèi)存型的API和Web應用服務框架,高度封裝了http，websocket，ud...

    lewinlee 評論0 收藏0

  • Swoole 4.0 正式版，面向生產(chǎn)環(huán)境的 PHP 協(xié)程引擎

    摘要：在禁止場景中使用協(xié)程會出現(xiàn)各種莫名其妙的問題發(fā)生。限制了協(xié)程的應用范圍。新版本基于匯編代碼實現(xiàn)了全新的協(xié)程內(nèi)核。實現(xiàn)了對所有語法的支持。穩(wěn)定性和健壯性均已達到工業(yè)級的水準。完全可用于大型項目的生產(chǎn)環(huán)境中。 Swoole雖然在2016年就支持了協(xié)程特性，但由于底層是基于setjmp/longjmp實現(xiàn)的stackless方案。因此在某些場景下，如call_user_func、array_...

    Zack 評論0 收藏0

  • Swoole 在 Swoft 中的應用

    摘要：在中的應用官網(wǎng)源碼解讀號外號外歡迎大家我們開發(fā)組定了一個就線下聚一次的小目標上一篇源碼解讀反響還不錯不少同學推薦再加一篇講解一下中使用到的功能幫助大家開啟的實戰(zhàn)之旅服務器開發(fā)涉及到的相關(guān)技術(shù)領(lǐng)域的知識非常多不日積月累打好基礎(chǔ)是很難真正 date: 2017-12-14 21:34:51title: swoole 在 swoft 中的應用 swoft 官網(wǎng): https://www.sw...

    EscapedDog 評論0 收藏0

  • PHP異步操作(swoole, gearman)

    摘要：異步操作廢話不說直接進入正題應用場景業(yè)務邏輯中經(jīng)常會出現(xiàn)發(fā)送信息發(fā)送郵件記錄日志等等這個時候用異步再好不過了用戶直接的體驗就是使用的賊流暢使用技術(shù)這個不僅僅支持了其他語言也支持有的擴展用起來更方便感覺上異步隊列不同點有個隊列專門用來存儲發(fā)送 PHP異步操作 廢話不說直接進入正題: 應用場景: 業(yè)務邏輯中經(jīng)常會出現(xiàn)發(fā)送信息,發(fā)送郵件,記錄日志等等,這個時候用異步再好不過...

    Fundebug 評論0 收藏0

  • Swoole 4.4 協(xié)程搶占式調(diào)度器詳解

    摘要：搶占式調(diào)度我們在今年年初就計劃實現(xiàn)的搶占式調(diào)度，以滿足實現(xiàn)有些場景下的不均衡調(diào)度帶來的問題?？紤]開線程，負責檢查當前執(zhí)行協(xié)程執(zhí)行時間。達到我們的第二個協(xié)程主動搶占第一個協(xié)程的效果。 前言 Swoole內(nèi)核團隊開設(shè)的專欄，會逐漸投入精力寫文章介紹Swoole的開發(fā)歷程，實現(xiàn)原理，應用實踐等，大家可以更好的交流，共同學習，建設(shè)PHP生態(tài)。 協(xié)程調(diào)度 去年Swoole推出了4.0版本后，完整...

    Bowman_han 評論0 收藏0

發(fā)表評論

0條評論

閱讀需要支付1元查看
<