web-msg-sender的使用 · zsq_php小知识

``` 使用的宝塔需要去掉的禁用函数可能有 pcntl_alarm pcntl_fork putenv pcntl_signal pcntl_wait stream_socket_server pcntl_signal_dispatch 开放端口 /sbin/iptables -I INPUT -p tcp --dport 2120 -j ACCEPT /sbin/iptables -I INPUT -p tcp --dport 2121 -j ACCEPT /sbin/iptables -I INPUT -p tcp --dport 2123 -j ACCEPT ``` 只需要开启 start_io.php ``` <?php use Workerman\Worker; use Workerman\Timer; use PHPSocketIO\SocketIO; use Workerman\Protocols\Http\Request; use Workerman\Connection\TcpConnection; include __DIR__ . '/vendor/autoload.php'; // 全局数组保存uid在线数据 $uidConnectionMap = array(); // 记录最后一次广播的在线用户数 $last_online_count = 0; // 记录最后一次广播的在线页面数 $last_online_page_count = 0; // 这个是设置https的如果不用设置就这样 //$context = array( // 'ssl' => array( // 'local_cert' => '/www/server/panel/vhost/ssl/test.erhas.cn/fullchain.pem', // pem 文件一样的 // 'local_pk' => '/www/server/panel/vhost/ssl/test.erhas.cn/privkey.pem', // 'verify_peer' => false, // ) //); // PHPSocketIO服务 //$sender_io = new SocketIO(2120,$context); $sender_io = new SocketIO(2120); // 客户端发起连接事件时，设置连接socket的各种事件回调 $sender_io->on('connection', function($socket){ // 当客户端发来登录事件时触发 $socket->on('login', function ($uid)use($socket){ 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对应页面的在线数据共打开{$last_online_page_count}个页面 $socket->emit('update_online_count', "当前{$last_online_count}人在线"); }); // 当客户端断开连接是触发（一般是关闭网页或者跳转刷新导致） $socket->on('disconnect', function () use($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(){ // 监听一个http端口 // $context = array( // 'ssl' => array( // 'local_cert' => '/www/server/panel/vhost/ssl/test.erhas.cn/fullchain.pem', // pem 文件一样的 // 'local_pk' => '/www/server/panel/vhost/ssl/test.erhas.cn/privkey.pem', // 'verify_peer' => false, // ) // ); // $inner_http_worker = new Worker('https://0.0.0.0:2121',$context); $inner_http_worker = new Worker('http://192.168.1.185:2121'); // 当http客户端发来数据时触发 $inner_http_worker->onMessage = function(TcpConnection $http_connection, Request $request){ global $uidConnectionMap; $post = $request->post(); $post = $post ? $post : $request->get(); // 推送数据的url格式 type=publish&to=uid&content=xxxx switch(@$post['type']){ case 'publish': global $sender_io; $to = @$post['to']; $post['content'] = htmlspecialchars(@$post['content']); // 有指定uid则向uid所在socket组发送数据 if($to){ $sender_io->to($to)->emit('new_msg', $post['content']); // 否则向所有uid推送数据 }else{ $sender_io->emit('new_msg', @$post['content']); } // http接口返回，如果用户离线socket返回fail if($to && !isset($uidConnectionMap[$to])){ return $http_connection->send('offline'); }else{ return $http_connection->send('ok'); } } return $http_connection->send('fail'); }; // 执行监听 $inner_http_worker->listen(); // 一个定时器，定时向所有uid推送当前uid在线数及在线页面数 Timer::add(1, function(){ global $uidConnectionMap, $sender_io, $last_online_count, $last_online_page_count; $online_count_now = count($uidConnectionMap); $online_page_count_now = array_sum($uidConnectionMap); // 只有在客户端在线数变化了才广播，减少不必要的客户端通讯 if($last_online_count != $online_count_now || $last_online_page_count != $online_page_count_now) { $sender_io->emit('update_online_count', "当前{$online_count_now}人在线，共打开{$online_page_count_now}个页面"); $last_online_count = $online_count_now; $last_online_page_count = $online_page_count_now; } }); }); if(!defined('GLOBAL_START')) { Worker::runAll(); } ``` ``` socket() { let that = this // const socket = io('https://127.0.0.1:2120') // 这里当然填写真实的地址了 const socket = io('http://127.0.0.1:2120') // 这里当然填写真实的地址了 // uid可以是自己网站的用户id，以便针对uid推送以及统计在线人数 let userInfoId=JSON.parse(window.localStorage.getItem('userInfoId')).data; let id=userInfoId ? userInfoId : that.$store.getters.userInfo.id // 用户ID const uid = id // socket连接后以uid登录 socket.on('connect', function() { socket.emit('login', uid) console.log('已连接，用户00' + uid) }) // 后端推送来消息时 socket.on('new_msg', function(msg) { console.log('收到消息：' + msg) that.$message.success({ message: msg, showClose:true }); }) // 后端推送来在线数据时 socket.on('update_online_count', function(online_stat) { // console.log(online_stat) }) }, ```