成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

php使用swoole的應(yīng)用場景

jsliang / 2159人閱讀

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

應(yīng)用場景簡介

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

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

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

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

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

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

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

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

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

服務(wù)器內(nèi)存報(bào)警問題

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

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

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

簡單代碼片段,不全(供初學(xué)者了解,官方網(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"],   //工作進(jìn)程數(shù)量
        "daemonize"       => $this->config["server"]["daemonize"], //是否作為守護(hù)進(jìn)程
        "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的封裝,可以實(shí)現(xiàn)多實(shí)例訪問

框架有一些常用的方法,像log 等等(我只用到了log)

webim 官方有demon,可以參考

壞處:

文檔特別不全,一個(gè)簡單的實(shí)現(xiàn)會(huì)折騰半天

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

轉(zhuǎn)載請(qǐng)注明本文地址:http://systransis.cn/yun/26116.html

相關(guān)文章

  • swoolefy-基于swoole擴(kuò)展實(shí)現(xiàn)高性能常駐內(nèi)存型API和Web應(yīng)用服務(wù)框架

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

    lewinlee 評(píng)論0 收藏0
  • Swoole 4.0 正式版,面向生產(chǎn)環(huán)境 PHP 協(xié)程引擎

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

    Zack 評(píng)論0 收藏0
  • Swoole 在 Swoft 中應(yīng)用

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

    EscapedDog 評(píng)論0 收藏0
  • PHP異步操作(swoole, gearman)

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

    Fundebug 評(píng)論0 收藏0
  • Swoole 4.4 協(xié)程搶占式調(diào)度器詳解

    摘要:搶占式調(diào)度我們?cè)诮衲昴瓿蹙陀?jì)劃實(shí)現(xiàn)的搶占式調(diào)度,以滿足實(shí)現(xiàn)有些場景下的不均衡調(diào)度帶來的問題??紤]開線程,負(fù)責(zé)檢查當(dāng)前執(zhí)行協(xié)程執(zhí)行時(shí)間。達(dá)到我們的第二個(gè)協(xié)程主動(dòng)搶占第一個(gè)協(xié)程的效果。 前言 Swoole內(nèi)核團(tuán)隊(duì)開設(shè)的專欄,會(huì)逐漸投入精力寫文章介紹Swoole的開發(fā)歷程,實(shí)現(xiàn)原理,應(yīng)用實(shí)踐等,大家可以更好的交流,共同學(xué)習(xí),建設(shè)PHP生態(tài)。 協(xié)程調(diào)度 去年Swoole推出了4.0版本后,完整...

    Bowman_han 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<