运用workerman完成在线谈天的要领【workerman】,workerman

workerman 是一个php编写的通信效劳。之前的项目都是用它做数据接口效劳

此次用它做一个简朴的在线谈天室~

1.下载最新版本的workerman

能够去http://www.workerman.net 去下载

我这里将service 和 client 分开了两个文件夹，轻易治理

大抵的项目构造以下。

客户端：

客户端就简朴了。一个简朴的html代码。嵌入了一个 websocket 监听效劳

var ws, name, client_list={};
function connect() {
       // 建立websocket
       ws = new WebSocket("ws://192.168.0.88:2345");
       // 当socket衔接翻开时，输入用户名
       ws.onopen = onopen;
       // 当有音讯时依据音讯范例显现差别信息
       ws.onmessage = onmessage;
       ws.onclose = function() {
          console.log("衔接封闭，定时重连");
          connect();
       };
       ws.onerror = function() {
          console.log("涌现毛病");
       };
    }

完成websocket的 翻开，message的监听，以及close

1、当翻开一个客户端，则立马弹出一个输入姓名的对话框

function onopen(){
        //console.log(name);
        //var username=connect_id="";
        if(!name)
        {
            name=prompt("请输入您的名字","");
            if(!name || name=='null'){ 
                name = '咕哒子';
            }
        }
 
        $('#curuser').text(name);
 
         data='{"type":"1","user":"'+name+'"}';
         
        ws.send(data);
    }

并将数据推送给效劳端。type =1 代表上岸。

2、当收到音讯时，推断音讯范例，是群发音讯 照样私聊音讯。进而处置惩罚。

别的，每次用户有新用户上岸上来，都邑 给各个客户端推送，用户列表。举行衬着

function onmessage(e){
        //console.log(e.data);
        var data = eval("("+e.data+")");
        var info=$('#chatinfo').html();
        if(data.type==1)
            $('#chatinfo').html(info+'<br/>'+data.data);
        else if(data.type==2)
        {
            // 在线用户列表 userinfo
            $('#userinfo').html(data.data);
        }
        else if(data.type==3)
        {
            // 在线用户列表 个人信息
            name=data.data.userinfo;
            //console.log(data.data);
        }
    }

然后别的就是 每一个用户发送音讯的代码了。能够是私聊 ，也能够是群发

$('#send').click(function(e){
        var msg=$('#msg').val();
        var tofriend=$('#tofriend').val();
        var tofriendname=$('#tofriendname').val();
        if(tofriend!="")
        {
            data='{"type":"3","user":"'+name+'","msg":"'+msg+'","friend_id":"'+tofriend+'","friendname":"'+tofriendname+'"}';
        }else{
            data='{"type":"2","user":"'+name+'","msg":"'+msg+'"}';
        }
        ws.send(data);
        $('#msg').attr("value",'');
    });

客户端差不多就是如许的了。

客户端，有几个坑 ，

坑1、变量名是 name 则革新网页不会被重置，不然就会被重置。（背面查资料发明，这个name变量 是 window.name 。所以革新网页 该值也不会被革新掉）

坑2、js组数组，变量要用"" 最外层为'' 如：data='{"type":"1","user":"'+name+'"}'; 不然剖析出问题。不能倒过来！

效劳端：

效劳端主如果workerman 组件 以及 运用 Channel分布式通信组件 完成定阅 和集群推送 分组推送 以及私聊。

起首，当然是监听，启用一个worker的websocket监听

// 建立一个Worker监听2346端口，运用websocket协定通信
$ws_worker = new Worker("websocket://0.0.0.0:2345");
$channel_server = new Channel\Server('0.0.0.0', 2206);
// 启动4个历程对外供应效劳
$ws_worker->count = 4;
$ws_worker->name="kinmoschat";

在workerman 监听启用的时刻，举行 channel通信的注册。

$ws_worker->onWorkerStart=function($ws_worker)
{
    // channel 客户端链接上 效劳器
    Channel\Client::connect('127.0.0.1',2206);
    $event_name='私聊';
    // 定阅 worker-<id 事宜，并注册事宜处置惩罚函数
    Channel\Client::on($event_name,function($event_data)use($ws_worker){
 
        //print_r($event_data);
        //print_r($ws_worker->connections);
        $to_connect_id=$event_data['to_connection_id'];
        $message=$event_data['content'];
 
        foreach ($ws_worker->connections as $connection) {
 
            if($connection->id==$to_connect_id)
            {
                $connection->send($message);
            }
                 
        }
 
        // if(!isset($ws_worker->connections[$to_connect_id]))
        // {
        //     echo 'connect is not exist\n';
        //     return;
        // }
        // $to_connection=$ws_worker->connections[$to_connect_id];
        // $to_connection->send($message);
    });
 
    // 定阅播送事宜
    $event_name = '播送';
    // 收到播送 向一切客户端发送音讯
    Channel\Client::on($event_name,function($event_data)use($ws_worker){
        //print_r($event_data);
        $message=$event_data['content'];
        foreach ($ws_worker->connections as $connection) {
            $connection->send($message);
        }
    });
};

注册两个事宜，一个播送事宜，一个私聊事宜，用以上线关照的播送，以及群发音讯。私聊 就是私聊了。。这里，还能够做 分组的群发。不过，这个版本还未完成。

然后是针对，客户端链接的回调。

$ws_worker->onConnect=function($connection){
    $connection->id = md5($connection->id."_".time()."_".rand(10000,99999));
};

这里，客户端回调，我会将客户端的 connectid修改掉。一个简朴的md5 主如果为了防备 流水id太轻易被应用吧。。

然后，全部项目的主体，效劳端音讯的处置惩罚回调。

针对每一个进来的客户端，分派一个唯一 id

保护一个 connectid=>user 的关联表

因为开启了多个历程致使 存到 session中无效，故而 盘算存到 数据库中

断开链接的时刻，删除数据

$ws_worker->onMessage = function($connection, $data)
{
    $res=array('code'=>200, 'msg'=>'ok', 'data'=>null,'type'=>1);
    // 向客户端发送hello $data
    //print_r($data);
    $data=json_decode($data,true);
    //print_r($data);
    if(!isset($data['type'])||empty($data['type']))// type 1  2
    {
        $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null);
    }else{
        switch ($data['type']) {
            case '1': // 客户端上线音讯
                //print_r($connection->id);
                 
                if(!isset($data['user'])||empty($data['user']))
                {
                    $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null);
                    break;
                }
                // 保护一个数组 保留 用户 connection_id => user
 
                $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;';
                $pdo=new PDO($dsn,'root','123456');
                //预备SQL语句
                $sql = "INSERT INTO `user`(`connect_id`,`username`) VALUES (:connect_id,:username)";
 
                //挪用prepare要领预备查询
                $stmt = $pdo->prepare($sql);
 
                //通报一个数组为预处置惩罚查询中的定名参数绑定值，并实行SQL
                $stmt->execute(array(':connect_id' => $connection->id,':username' => $data['user']));
                //猎取末了一个插进去数据的ID值
                //echo $pdo->lastInsertId() . '<br />';
 
                // 向本身推送一条音讯
                $res2['type']=3;// 体系信息
                $res2['data']=array('userinfo' =>$data['user']);// 体系信息
                $connection->send(json_encode($res2));
 
                $msg="用户 ".$data['user']." 上线了~~";
                $res['data']=$msg;
                break;
            case '2': // 客户端群发送音讯
                if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg']))
                {
                    $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null);
                    break;
                }
                $msg="用户 ".$data['user']."说：".$data['msg'];
                $res['data']=$msg;
                break;
            case '3': // 客户端私聊
                if(!isset($data['user'])||empty($data['user'])||!isset($data['msg'])||empty($data['msg'])||!isset($data['friend_id'])||empty($data['friend_id']))
                {
                    $res=array('code'=>301, 'msg'=>'音讯包花样毛病', 'data'=>null);
                    break;
                }
                $msg="用户 ".$data['user']."对您说：".$data['msg'];
                $res['data']=$msg;
                $res['type']=1;// 谈天音讯
                $res1=json_encode($res);
                // 推送给单个用户
                $event_name = '私聊';
                Channel\Client::publish($event_name, array(
                    'content'          => $res1,
                    'to_connection_id' =>$data['friend_id']
                ));
                // 别的还要给本身推条音讯
                $msg="您对 ".$data['friendname']."说：".$data['msg'];
                $res['data']=$msg;
                $res['type']=1;// 谈天音讯
                $res2=json_encode($res);
                Channel\Client::publish($event_name, array(
                    'content'          => $res2,
                    'to_connection_id' =>$connection->id
                ));
                return;
                break;
             
            default:
                # code...
                break;
        }
    }
    $res['type']=1;// 谈天音讯
    $res=json_encode($res);
    // 播送给一切客户端
    $event_name = '播送';
    Channel\Client::publish($event_name, array(
        'content'          => $res
    ));
 
    $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;';
    $dbh=new PDO($dsn,'root','123456');
    $stmt=$dbh->query('SELECT connect_id,username FROM user');
    $row=$stmt->fetchAll();
    $uerHtml="";
    foreach ($row as $key => $value) {
 
        $uerHtml.='<a class="user" onclick="userclick(\''.$value['username'].'\',\''.$value['connect_id'].'\');" value="'.$value['connect_id'].'" href="javascript:void(0);">'.$value['username'].'</a><br/>';
    }
    //print_r($row);
    $res1['type']=2;// 用户音讯
    $res1['data']=$uerHtml;
    $res1=json_encode($res1);
     
 
    $event_name = '播送';
    Channel\Client::publish($event_name, array(
        'content'          => $res1
    ));
};

这里会将每一个用户的 connectid=>name 存入数据库。。

当收到一条 上线音讯的时刻，播送给一切用户。

收到一条群发音讯。。播送给一切客户端。

收到一条私聊音讯。则单个推送给本身以及发送的人。

监听 客户端封闭事宜，当客户端封闭，删除用户表相干纪录

// 封闭链接 将数据库中的该数据删除
$ws_worker->onClose=function($connection)
{
    //echo 3233;
    $dsn='mysql:host=127.0.0.1;dbname=kinmoschat;';
    $pdo=new PDO($dsn,'root','123456');
    $sql="delete from user where connect_id='".$connection->id."'";
    //print_r($sql);
    $pdo->exec($sql);
};

更多workerman学问请关注workerman教程栏目。

以上就是运用workerman完成在线谈天的要领的细致内容，更多请关注ki4网别的相干文章！

标签：workerman