WebScoket

#MeepoPS - 高性能高扩展高可用的PHP Socket服务 使用手册

可用与机器人客服等聊天

手册地址: http://meepops.lanecn.com Github: https://github.com/lixuancn/MeepoPS Bug提交: https://github.com/lixuancn/MeepoPS/issues 微博: http://weibo.com/lanephp

快速入门 查看项目根目录的

demo-http.php

demo-telnet.php

demo-trident.php

demo-websocket.php

//引入MeepoPS
require_once 'MeepoPS/index.php';

//使用文本协议传输的Api类
$telnet = new \MeepoPS\Api\Telnet('0.0.0.0', '19910');

//启动的子进程数量. 通常为CPU核心数
$telnet->childProcessCount = 1;

//设置MeepoPS实例名称
$telnet->instanceName = 'MeepoPS-Telnet';

//设置回调函数 - 这是所有应用的业务代码入口
$telnet->callbackStartInstance = 'callbackStartInstance';
$telnet->callbackConnect = 'callbackConnect';
$telnet->callbackNewData = 'callbackNewData';
$telnet->callbackSendBufferEmpty = 'callbackSendBufferEmpty';
$telnet->callbackInstanceStop = 'callbackInstanceStop';
$telnet->callbackConnectClose = 'callbackConnectClose';

//启动MeepoPS
\MeepoPS\runMeepoPS();

//以下为回调函数, 业务相关.
function callbackStartInstance($instance)
{
    echo '实例' . $instance->instanceName . '成功启动' . "\n";
}

//有新连接时回调
function callbackConnect($connect)
{
    foreach($connect->instance->clientList as $client){
        //上线提示就不用告诉自己了, 对吧!
        if($connect->id != $client->id){
            $client->send('新用户'.$connect->id.'已经上线了.');
        }
    }
    //定时器
//    \MeepoPS\Core\Timer::add(function($connect){
//        $connect->send('PIN广播');
//    }, array($connect), 5, true);
    var_dump('收到新链接. UniqueId=' . $connect->id . "\n");
}

//收到新连接时回调
function callbackNewData($connect, $data)
{
    $connect->send('用户' . $connect->id . '说: ' . $data . "\n");
    var_dump('UniqueId=' . $connect->id . '说:' . $data . "\n");
    //遍历每一个客户端,并用send发送消息
    foreach ($connect->instance->clientList as $client) {
        if ($connect->id != $client->id) {
            $client->send('群发: 用户' . $connect->id . '说: ' . $data . "\n");
        }
    }
}

function callbackSendBufferEmpty($connect)
{
    var_dump('用户' . $connect->id . "的待发送队列已经为空\n");
}
function callbackInstanceStop($instance)
{
    foreach ($instance->clientList as $client) {
        $client->send('服务即将停止.');
    }
}
function clientListClose($connect)
{
    var_dump('UniqueId=' . $connect->id . '断开了' . "\n");
}
function callbackConnectClose($connect)
{
    $connect->send('88');
}