socketIo

功能描述

WebSocket用于在Web浏览器和服务器之间进行任意的双向数据传输的一种技术。WebSocket协议基于TCP协议实现，包含初始的握手过程，以及后续的多次数据帧双向传输过程。其目的是在WebSocket应用和WebSocket服务器进行频繁双向通信时，可以使服务器避免打开多个HTTP连接进行工作来节约资源，提高了工作效率和资源利用率。

依赖的插件

无依赖插件

安装

建议使用workerman做后端搭建 ,也可以加QQ79177618交流

快速使用：

<script>
// 连接服务端，workerman.net:2120换成实际部署web-msg-sender服务的域名或者ip
var socket = io('http://workerman.net:2120');
// uid可以是自己网站的用户id，以便针对uid推送以及统计在线人数
uid = 123;
// socket连接后以uid登录
socket.on('connect', function(){
    socket.emit('login', uid);
});
// 后端推送来消息时
socket.on('new_msg', function(msg){
    console.log("收到消息："+msg);
});
// 后端推送来在线数据时
socket.on('update_online_count', function(online_stat){
    console.log(online_stat);
});
</script>

自定义事件

<?php
// 指明给谁推送，为空表示向所有在线用户推送
$to_uid = "";
// 推送的url地址，使用自己的服务器地址
$push_api_url = "http://workerman.net:2121/";
$post_data = array(
   "type" => "publish",
   "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 );
var_export($return);

自定义事件

    客户端通过下面的方法触发服务端的chat message事件。

    <script>
    // 连接服务端
    var socket = io('http://127.0.0.1:3120');
    // 触发服务端的chat message事件
    socket.emit('chat message', '这个是消息内容...');
    // 服务端通过emit('chat message from server', $msg)触发客户端的chat message from server事件
    socket.on('chat message from server', function(msg){
        console.log('get message:' + msg + ' from server');
    });
    </script>

分组

    socket.io提供分组功能，允许向某个分组发送事件，例如向某个房间广播数据。

    1、加入分组（一个连接可以加入多个分组）

    $connection->join('group name');
    2、离开分组（连接断开时会自动从分组中离开）

    $connection->leave('group name');

向客户端发送事件的各种方法

    $io是SocketIO对象。$connection是客户端连接

    $data可以是数字和字符串，也可以是数组。当$data是数组时，客户端会自动转换为javascript对象。

    同理如果客户端向服务端emit某个事件传递的是一个javascript对象，在服务端接收时会自动转换为php数组。

    1、向当前客户端发送事件

    $connection->emit('event name', $data);
    2、向所有客户端发送事件

    $io->emit('event name', $data);
    3、向所有客户端发送事件，但不包括当前连接。

    $connection->sockets->emit('event name', $data);
    4、向某个分组的所有客户端发送事件

    $io->to('group name')->emit('event name', $data);

特别说明

使用时建议参考 workerman官方提供的PHPSocket.IO，PHP跨平台实时通讯框架
是否仍需要帮助？ 请保持联络！
最后更新于 2024/11/18