應用場景簡介

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

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

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

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

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

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

數據傳輸的流程圖：
不包含業務邏輯，將web1,web2,接收的消息匯總然后再廣播給web1,web2,再廣播給用戶

場景2 - 只收集定位設備入庫

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

服務器內存報警問題

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

但這任務如果是調用程序接口時，由于網絡的延遲，增加的任務大于消費的任務時，內存占用會不斷的增加，導致服務器的內存被占滿。

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

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

function __construct($config) {$this->config = $config;$this->serv = new Swoole\Server($config['server']['host'], $config['server']['port']);// 連接redis$this->redis = new Predis\Client($config['redis']);$this->storage = new Storage($this->config);$this->serv->set(['worker_num' => $this->config['server']['workerNum'], //工作進程數量'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系統

參考官方github: webim系統.
官方wiki: swoole 框架wiki

好處

封裝了數據庫的model類，數據庫的ORM接口

redis的封裝，可以實現多實例訪問

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

webim 官方有demon，可以參考

壞處：

文檔特別不全，一個簡單的實現會折騰半天

總結

以上是生活随笔為你收集整理的php使用swoole的应用场景的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。