應(yīng)用場(chǎng)景簡(jiǎn)介
- 與硬件設(shè)備連接通訊(定位設(shè)備)
- IM系統(tǒng)(用于直播頁面的聊天通訊)
場(chǎ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è)場(chǎng)景是聊天，用戶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è)缓笤購(gòu)V播給web1,web2,再?gòu)V播給用戶
場(chǎng)景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ù)場(chǎng)景定義這個(gè)時(shí)間與是否可延遲等情況，匯總1秒內(nèi)的所有數(shù)據(jù)再調(diào)用程序接口（匯總時(shí)個(gè)人使用redis），最好能直接入庫，不必調(diào)用接口
簡(jiǎn)單代碼片段，不全(供初學(xué)者了解,官方網(wǎng)站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'], //工作進(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 '';
}
場(chǎng)景-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è)簡(jiǎn)單的實(shí)現(xiàn)會(huì)折騰半天
點(diǎn)關(guān)注，不迷路
好了各位，以上就是這篇文章的全部?jī)?nèi)容了，能看到這里的人呀，都是人才。之前說過，PHP方面的技術(shù)點(diǎn)很多，也是因?yàn)樘嗔?，?shí)在是寫不過來，寫過來了大家也不會(huì)看的太多，所以我這里把它整理成了PDF和文檔，如果有需要的可以
點(diǎn)擊進(jìn)入暗號(hào): PHP+「平臺(tái)」
更多學(xué)習(xí)內(nèi)容可以訪問【對(duì)標(biāo)大廠】精品PHP架構(gòu)師教程目錄大全，只要你能看完保證薪資上升一個(gè)臺(tái)階（持續(xù)更新）
以上內(nèi)容希望幫助到大家，很多PHPer在進(jìn)階的時(shí)候總會(huì)遇到一些問題和瓶頸，業(yè)務(wù)代碼寫多了沒有方向感，不知道該從那里入手去提升，對(duì)此我整理了一些資料，包括但不限于：分布式架構(gòu)、高可擴(kuò)展、高性能、高并發(fā)、服務(wù)器性能調(diào)優(yōu)、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql優(yōu)化、shell腳本、Docker、微服務(wù)、Nginx等多個(gè)知識(shí)點(diǎn)高級(jí)進(jìn)階干貨需要的可以免費(fèi)分享給大家，需要的可以加入我的 PHP技術(shù)交流群
