## SocketIO消息推送
PHP系列 | PHP跨平臺實時通訊框架 Socket.IO 的應用
## PHPSocket.IO 是什么?
1. PHPSocket.IO是PHP版本的Socket.IO服務端實現,基于workerman開發,用于替換node.js版本Socket.IO服務端。
2. PHPSocket.IO底層采用websocket協議通訊,如果客戶端不支持websocket協議, 則會自動采用http長輪詢的方式通訊。
3. PHPSocket.IO實現的Polling通信機制包括Adobe Flash Socket、AJAX長輪詢、JSONP輪詢等。具體采用哪種機制通訊對于開發者完全透明, 開發者使用的是統一的接口。
## 設計的目標
利用PHP構建能夠在不同瀏覽器和移動設備上良好運行的實時應用,如實時分析系統、在線聊天室、在線客服系統、評論系統、WebIM等。 PHPSocket.IO與workerman的區別是,PHPSocket.IO基于workerman開發,workerman有的特性PHPSocket.IO都支持。 PHPSocket.IO最大的優勢是對各種瀏覽器的兼容性更好。
## 文檔&&安裝
文檔倉庫:[https://github.com/walkor/phpsocket.io](https://github.com/walkor/phpsocket.io)
使用composer安裝
```
composer require workerman/phpsocket.io
```
## 應用案例
#### Nginx 主機配置
```nginx
server {
listen 443 ssl http2;
server_name www.tinywan.com;
ssl_certificate letsencrypt/iot.tinywan.com/full_chain.pem;
ssl_certificate_key letsencrypt/iot.tinywan.com/private.key;
set $root_path /var/www/iot.tinywan.com/public;
root $root_path;
more_set_headers "X-Frame-Options: SAMEORIGIN";
location / {
if (!-e $request_filename) {
rewrite ^(.*)$ /index.php?s=/$1 last;
break;
}
}
location ~ \.php$ {
fastcgi_index index.php;
fastcgi_pass unix:/var/run/php-fpm.sock;
fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
include fastcgi_params;
fastcgi_buffer_size 128k;
fastcgi_buffers 4 256k;
fastcgi_busy_buffers_size 256k;
}
location ~ .*\.(gif|jpg|jpeg|png|bmp|swf)$ {
access_log off;
error_log off;
expires 30d;
}
location ~ .*\.(js|css)?$ {
access_log off;
error_log off;
expires 12h;
}
# SocketIO 配置
location /socket.io {
proxy_pass http://127.0.0.1:2120;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "Upgrade";
proxy_set_header X-Real-IP $remote_addr;
}
}
```
#### 服務端完整代碼
```php
<?php
namespace app\http\controller;
use PHPSocketIO\SocketIO;
use think\facade\Log;
use Workerman\Worker;
class Server
{
/**
* @desc: Socket Server
* @time: 2019/4/22 19:51
*/
public function server()
{
// 全局數組保存uid在線數據
$uidConnectionMap = array();
// 記錄最后一次廣播的在線用戶數
$last_online_count = 0;
// 記錄最后一次廣播的在線頁面數
$last_online_page_count = 0;
// PHPSocketIO服務
$sender_io = new SocketIO(2120);
// 客戶端發起連接事件時,設置連接socket的各種事件回調
$sender_io->on('connection', function ($socket) {
Log::info('客戶端發起連接事件 ');
// 當客戶端斷開連接是觸發(一般是關閉網頁或者跳轉刷新導致)
$socket->on('login', function ($uid) use ($socket) {
Log::info('客戶端登錄uid ' . $uid);
global $uidConnectionMap, $last_online_count, $last_online_page_count;
// 已經登錄過了
if (isset($socket->uid)) {
return;
}
// 更新對應uid的在線數據
$uid = (string)$uid;
if (!isset($uidConnectionMap[$uid])) {
$uidConnectionMap[$uid] = 0;
}
// 這個uid有++$uidConnectionMap[$uid]個socket連接
++$uidConnectionMap[$uid];
// 將這個連接加入到uid分組,方便針對uid推送數據
$socket->join($uid);
$socket->uid = $uid;
});
// 當客戶端斷開連接是觸發(一般是關閉網頁或者跳轉刷新導致)
$socket->on('disconnect', function () use ($socket) {
Log::info('客戶端斷開 ' . json_encode($socket));
if (!isset($socket->uid)) {
return;
}
global $uidConnectionMap, $sender_io;
// 將uid的在線socket數減一
if (--$uidConnectionMap[$socket->uid] <= 0) {
unset($uidConnectionMap[$socket->uid]);
}
});
});
// 當$sender_io啟動后監聽一個http端口,通過這個端口可以給任意uid或者所有uid推送數據
$sender_io->on('workerStart', function () use ($sender_io) {
// 監聽一個http端口
$inner_http_worker = new Worker('http://0.0.0.0:2121');//這里IP不用改變,用的內網通訊,端口不能與socket端口想通
$inner_http_worker->onMessage = function ($http_connection, $data) use ($sender_io) {
$postData = $data['post'];
$to = $postData['to'] ?? '';
Log::info('發送到用戶to ' . json_encode($to));
$content = htmlspecialchars($postData['content']);
// 有指定uid則向uid所在socket組發送數據
if ($to) {
$sender_io->to($to)->emit('new_msg', $content);
} else {
// 否則向所有uid推送數據
$sender_io->emit('new_msg', $content);
}
// http接口返回,如果用戶離線socket返回fail
if ($to && !isset($uidConnectionMap[$to])) {
return $http_connection->send('offline');
} else {
return $http_connection->send('ok');
}
};
// 執行監聽
$inner_http_worker->listen();
});
Worker::runAll();
}
}
```
1、啟動服務端端:`php web_msg.php start -d`
```
$ php web_msg.php start -d
Workerman[web_msg.php] start in DAEMON mode
------------------------------------------- WORKERMAN -------------------------------------------
Workerman version:3.5.20 PHP version:7.2.9
-------------------------------------------- WORKERS --------------------------------------------
proto user worker listen processes status
tcp www PHPSocketIO socketIO://0.0.0.0:2120 1 [OK]
```
2、發送消息
```
function send_web_msg($to_uid = 1, $content)
{
if (empty($content)) {
return ["error_code" => 404, "reason" => '缺少參數'];
}
$push_api_url = "http://127.0.0.1:2121/";
$post_data = [
"type" => "publish",
"content" => $content,
"to" => $to_uid
];
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $push_api_url);
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_HEADER, 0);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);
curl_setopt($ch, CURLOPT_HTTPHEADER, array("Expect:"));
$return = curl_exec($ch);
curl_close($ch);
return $return;
}
send_web_msg(1, "哈嘍,Tinywan先生");
```
#### 客戶端完整代碼
html 代碼
```
<div><p id="notice-content" style="float: left">系統公告</p></div>
```
JS 代碼
```
<script src='https://cdn.bootcss.com/socket.io/2.0.3/socket.io.js'></script>
<script src="https://cdn.bootcss.com/notify.js/3.0.0/notify.js"></script>
<script>
$(document).ready(function () {
$uid = "1";
var socket = io("https://www.tinywan.com", { path: '/socket.io' });
socket.on('connect', function () {
console.log('連接成功');
socket.emit('login', $uid);
});
socket.on('new_msg', function (msg) {
console.log('系統消息:' + msg);
$('#notice-content').html('系統提示:' + msg);
$('.notification.sticky').notify();
});
});
</script>
```
### 效果圖

- 序言
- 專題一 PHP基礎教程
- 1、empty、isset、is_null的用法
- 2、線程安全與非線程
- 3、大文件上傳需要修改的配置
- 10、魔術方法
- 4、編譯安裝PHP7
- 5、編譯安裝PHP7.4
- 6、PECL 安裝 PHP 擴展庫
- 專題二 PHP高級教程
- 1、類和對象
- 2、繼承
- 3、魔術方法
- 4、抽象類
- 5、接口
- 6、反射機制實現自動依賴注入
- 7、服務容器與依賴注入的思想
- 8、并發解決方案之opcache
- 9、Composer自動加載原理
- 1、安裝與使用
- 10、抽象類和接口的區別
- 11、self和static的區別
- 12、PHP7 變量
- 13、PHP8.3 錯誤 Error 和 異常 Exception 樹列表
- 專題三 ThinkPHP6專題
- 1、DI容器
- 2、AUTH權限認證
- 3、Nginx URI重寫方式
- 4、并發鎖問題
- 5、自定義全局異常
- 6、CLI 模式跨模塊查詢數據庫
- 7、數據庫優化方案
- 附錄一 常見錯誤
- 附錄二 自定義分頁類
- 附錄三 cropper.js圖片上傳和裁剪
- 附錄四 數據庫和模型源碼解讀
- 1、Db類
- 2、查詢構造器
- 3、模型
- 附錄五 權限認證Auth類
- 附錄六 ThinkPHP5.1 源碼分析
- (一)類的自動加載
- (二)配置文件Config類
- (三)容器Container類
- (四)門面Facade
- (五)框架執行流程
- (六)路由解析
- 附錄七 官方擴展
- 1、think-queue 隊列
- 附錄八 易錯整理
- 附錄九 問題列表
- 附錄十 任務隊列異步通過視圖導出PDF
- 專題四 Docker教程
- 1、Docker安裝
- 2、如何在本地構建鏡像
- 3、鏡像、容器以及命令操作
- 4、容器進入的4種方式
- 5、Dockerfile常用指令詳解
- 6、發布自己的鏡像
- 7、數據卷管理
- 8、docker-compose概念
- 9、docker-compose入門
- 10、如何構建docker-compose
- 11、Docker網絡
- 12、搭建私有倉庫
- 13、Docker部署方式
- 14、推送到Github倉庫
- 附錄一 PHPStrom 調試XDebug
- 附錄二 安裝RabbitMQ
- 附錄 日常使用筆記
- 附錄四 Docker 調試XDebug
- 專題五 Redis教程
- 1、編譯安裝
- 2、配置文件詳解
- 3、Lua 腳本的應用和實踐
- 4、Redis實現分布式鎖(集群版)
- 5、Redis鍵空間通知
- 6、Redis5.0 搭建集群
- (1)、創建和使用Redis群集
- (2)、新增節點
- 7、限流器的實現
- 8、Redis5.0 新特性
- 8.1、注意要點
- 8.2 xreadgroup 命令
- 9、延遲任務隊列
- 10 Stream 消息隊列
- 11、基于 Redis 的 Stream 類型的完美消息隊列解決方案
- 12、Streams 實現延遲消息隊列
- 13、Stream流三種ACK機制
- 14、read error on connection排查
- 附錄一 常見問題
- 附錄二 Redis面試大全
- 附錄三 有序集合使用場景
- 附錄四 Lua腳本調試
- 附錄五 高性能、高可擴展關鍵技術
- 專題六 MySQL教程
- 1-1、二進制安裝
- 1-2、安裝包安裝(推薦)
- 2、索引、鎖、事務
- 3、字符集
- 4、導出導入數據
- 5、5.7版本兼容性
- 6、數據庫自動備份
- 7、如何重置MySQL 5.7 root密碼
- 8、MySQL自動完成和語法突出
- 9、普通索引和唯一索引的區別
- 10、深入了解行鎖、表鎖、索引
- 11、索引數據結構
- 12、MySQL規范
- 13、開發高頻面試題精選(重要)
- 14、鎖專題
- 1、可重復讀(REPEATABLE_READ)
- 2、事務隔離級別概述
- 15、MySQL外鍵約束
- 16、left join 查詢
- 17、 MySQL設計三范式和反范式
- 18、性能分析-Profiling
- 19、查詢好慢,除了索引,還能因為什么?(重要)
- 20、常用日期字段
- MYSQL 5.7 VARCHAR 類型詳解
- 專題七 Nginx教程
- 1、什么是Nginx?
- 2、編譯安裝
- 3、日志配置和模塊講解
- 4、靜態資源和緩存服務
- 5、正向和反向服務
- 6、Rewrite規則
- 7、HTTP負載均衡(七層)
- 8、TCP負載均衡(四層)
- 9、如何配置HTTPS服務
- 10、Nginx的負載均衡算法
- 11、如何配置http和https同時訪問
- 12、灰度發布
- 13、常見負載均衡算法
- 14、Openresty 專題
- 15、如何改進 NGINX 配置文件節省帶寬?
- 16、談談基于 OpenResty 的接口網關設計
- 附錄一 阿里云負載均衡配置
- 附錄二、基礎配置文件
- nginx.conf
- 附錄三、Nginx+lua+Memcache 實現灰度發布
- 附錄四 視頻監控RTSP轉HLS解決方案
- 附錄五 Openresty 編譯
- 附錄六 Vod模塊
- 1、本地模式
- 2、映射模式
- 專題八 Git版本管理
- 1、Git 基礎知識
- 2、團隊分支模型
- 3、儲藏與清理
- 4、如何同步Fork
- 5、多Git賬戶id_rsa私鑰
- 6、高效規范使用Git
- 7、遠程分支的創建
- 8、GitFlow工作流
- 9、Git撤銷&回滾操作(git reset 和 get revert)
- 10、合并時 --no-ff 的作用
- 11、 刪除本地、遠程、緩存分支
- 13、Git和Windows的大小寫不敏感產生的問題
- 附錄一 、一次記錄
- 附錄二、常用工作流程
- 附錄三、每次更新代碼都要輸入用戶名密碼
- 附錄四、OEM版本控制
- 附錄五 常用記錄
- 1、查看某一個文件修改的具體內容
- 2、強制推送到遠程分支
- 3、生產環境代碼回滾
- 附錄六 三年 Git 使用心得 & 常見問題整理
- 附錄七 Git 忽略文件,不提交文件 清空緩存
- 12/找回歷史刪除分支
- 專題九 WorkerMan服務
- 3、SocketIO消息推送
- 4、master和worker模型
- 5、GatewayWorker
- 6、使用systemd管理workerman
- 7、TCP長連接應用GatewayWorker心跳檢測
- 附錄一 運行問題
- 附錄二 問題與解決方法
- 專題十 MQ消息中間件
- 1、為什么要使用消息隊列
- 2、RabbitMQ
- 『1』AMQP核心概念
- 『2』交換機模式講解
- 『3』RabbitMQ高級特性
- (1)hello
- 3、NSQ
- 4、RabbitMQ延遲隊列
- 附件一 RabbitMQ 注意要點
- 5、RocketMQ PHP 生產端和消費端代碼優雅實現
- 專題十一 PHP函數整理
- 1、系統函數
- 2、自定義函數
- 3、回調函數
- 4、匿名函數
- 5、遞歸函數
- 6、常用函數庫
- 7、call_user_func函數
- 8、preg_replace_callback函數
- 專題十二 常用設計模式
- 1、創建型模式
- (1)單例模式
- (2)工廠模式
- (3)抽象工廠模式
- (4)建造者模式(Builder)
- (5)原型模式(Prototype)
- 2、結構型模式
- (1)適配器模式(Adapter)
- (2)橋接模式(Bridge)
- (3)合成模式(Composite)
- (4)裝飾器模式(Decorator)
- (5)代理模式(Proxy)
- (6)享元模式(Flyweight)
- 3、行為型模式
- 2、策略模式( Strategy)
- 4、六大原則
- 1、依賴注入
- 5、其他
- 6、Presenter模式
- 4、Service 模式
- 5、Repository模式
- 外觀設計模式示例
- 專題十三 實時通信
- 1、pusher 入門教程
- 2、pusher 演示與頻道實時通信
- 3、pusher 如何使用私有頻道
- 4、pusher 實時圖表展示
- 11、webman插件push入門教程
- 12、webman插件push如何使用私有頻道
- 13、webman插件push私有頻道客戶端推送
- 14、webman插件push的webhooks
- 15、webman插件push的實時動態圖表
- 專題十四 PHP異常處理
- 1、Exception 類
- 2、如何自定義異常?
- 3、處理PHP重錯誤
- 4、自定義錯誤處理器
- 專題十五 Shell腳本案例
- 1、crontab任務腳本無法執行問題
- 專題十六 Jenkins自動化部署
- 1、Jenkins安裝
- 2、Pipeline插件
- 3、BlueOcean
- 4、OPENSSH PRIVATE KEY轉換為RSA PRIVATE KEY
- 專題十七 常用工具整理
- 1、證書在線打印
- 2、密碼生成規則
- 3、vscode插件
- 專題十八 常用功能列表
- 1、frp 內網穿透工具
- (1)如何做成一個服務
- (2)代理Websocket服務
- (3)代理N個Web服務
- (4)設置為系統服務
- (5)Https 配置
- 附錄一 常見問題排查
- 2、如何美化文檔
- 3、如何提高訪問github的速度?
- 4、Vultr搭建SS教程
- 5、PPH編譯安裝
- 6、Supervisor進程管理工具
- 7、Umeditor 上傳文件阿里云和本地
- 8、scp 遠程上傳或下載 文件/文件夾
- 9、安裝和使用守護進程Supervisor
- 10、人臉識別
- 專題十九 流媒體直播實戰
- 1、什么是視頻直播?
- 2、如何使用推流軟件OBS?
- 3、基于Nginx 的RTMP模塊搭建系統
- 4、直播流程
- 附錄一 阿里云直播
- 5、典型業務場景
- 8、直播回調授權觀看
- 9、視頻直播源如何加密
- 10、如何實現視頻在線云剪輯
- 11、視頻點播以及加密技術實現
- 12、FFmpeg 入門教程
- 13、HLS 直播加密播放
- 14、nginx-vod-module 模塊
- 15、車輛維修直播系統
- 『16』HLS-m3u8專題
- 附件一 FFmpeg 命令
- 附件二 阿里云點播
- 專題二十 微信
- 附錄一 遇到的坑
- 專題二十一 支付專題
- 『1』支付寶支付
- 『2』微信支付
- 『3』支付寶直付通
- 「1」什么是直付通?
- 「2」二級商戶進件
- 「3」統一交易收款
- 「4」資金結算
- 「5」分賬
- 「6」支付接入流程
- 「?」問題列表
- 附錄一 return_url和notify_url的區別
- 附錄二 常見錯誤信息
- 附錄三 電腦端支付案例
- 附錄四 其他問題
- 1、購買了線上課程后不能退款 這樣的現象合法嗎?
- 專題二十二 Vue3筆記
- 1、開發環境搭建
- 專題二十三 開放API專題
- 1、錯誤碼
- 2、O??Auth2流的簡單說明
- 『3』HTTP API 身份驗證和授權
- 專題二十四 測試專題
- 1、并發測試
- 專題二十五 DevOps專題
- 『1』PHP代碼質量實戰
- 專題二十六 前后端分離
- 『1』前后端分離介紹
- 『2』控制權限管理
- 專題二十七 微服務專題
- 1、服務發現 Nacos
- 1.1 服務發現
- 專題二十八 Casbin權限專題
- 1、設置超級管理員的三種方法
- 2、多租戶權限和基本設置
- 3、casbin簡化策略數據
- 4、多個RBAC
- 5、身份驗證和基于角色的RBAC授權
- 6、Casbin在RESTful及中間件使用
- 7、Casbin 中 ABAC 的使用方法
- 8、Model語法和策略存儲
- 9、Casbin的Model和Policy
- 10、RBAC的RESTful完全匹配訪問模型
- 11、自定義函數使用
- 12、webman中使用
- 13、分布式服務中如何使用Watcher
- 14、Casbin 項目實戰ABAC模型策略
- 附錄一 源碼解讀
- 附錄二 常見問題
- 專題二十九 PHP 常見錯誤處理
- 專題三十 ELK日志系統
- 1、docker-elk
- 專題三十一 Swoole專題
- 1、ThinkPHP6中RPC服務
- 專題三十二 Webman框架
- 1、自定義進程執行異步任務
- 2、實現WebRTC信令服務器
- 3、實現一個RPC服務
- 4、對象和資源的持久化
- 5、ThinkORM持久化連接
- 6、ThinkORM悲觀鎖解決商品超賣問題的實現
- 7、monolog日志神器
- 附錄一 為什么?
- 附錄二 編碼規范
- 附錄一 游戲
- 1、初級程序員常犯的錯誤
- 附錄三 設計模式
- 1、單例模式
- 2、工廠方法模式
- 3、抽象工廠模式
- 4、裝飾器模式
- 附錄四 Docker安裝SqlServer
- 專題二十一 Layui
- 我的技術棧【重要】
- 附錄四 Linux 日常運維
- 1、sudo 權限
- 2、用戶和用戶組管理
- 3、grep 多條件查詢
- 其他系列
- 1、fnm:基于Rust開發的高效Node版本管理工
- 樣式
- Mall商城
- 1、系統架構
- 1.1 mall整合ThinkPHP+ThinkORM搭建基本骨架
- 1.2 mall整合Elasticsearch實現商品搜索
- 1.3 mall整合OSS實現文件上傳
- 2、業務篇