PHP+swoole实现简单多人在线聊天群发

5年以前 | 阅读数：1035 次 | 编程语言：PHP

由于本文的能力有限，有好多聊天逻辑的细节没有实现，只实现了群发，具体代码如下所示：

php代码：


    $serv = new swoole_websocket_server("127.0.0.1",3999);
    //服务的基本设置
    $serv->set(array(
    'worker_num' => 2,
    'reactor_num'=>8,
    'task_worker_num'=>1,
    'dispatch_mode' => 2,
    'debug_mode'=> 1,
    'daemonize' => true,
    'log_file' => __DIR__.'/log/webs_swoole.log',
    'heartbeat_check_interval' => 60,
    'heartbeat_idle_time' => 600,
    ));
    $serv->on('connect', function ($serv,$fd){
    // echo "client:$fd Connect.".PHP_EOL;
    });
    //测试receive
    $serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){
    // echo "receive#{$from_id}: receive $data ".PHP_EOL;
    });
    $serv->on('open', function($server, $req) {
    // echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;;
    // echo PHP_EOL;
    });
    $serv->on('message',function($server,$frame) {
    // echo "message: ".$frame->data.PHP_EOL;
    $msg=json_decode($frame->data,true);
    switch ($msg['type']){
    case 'login':
    $server->push($frame->fd,"欢迎欢迎~");
    break;
    default:
    break;
    }
    $msg['fd']=$frame->fd;
    $server->task($msg);
    });
    $serv->on("workerstart",function($server,$workerid){
    // echo "workerstart: ".$workerid.PHP_EOL;
    // echo PHP_EOL;
    });
    $serv->on("task","on_task");
    $serv->on("finish",function($serv,$task_id,$data){
    return ;
    });
    $serv->on('close', function($server,$fd,$from_id) {
    // echo "connection close: ".$fd.PHP_EOL;
    // echo PHP_EOL;
    });
    $serv->start();
    function on_task($serv,$task_id,$from_id,$data) {
    switch ($data['type']){
    case 'login':
    $send_msg="说:我来了~";
    break;
    default:
    $send_msg="说:{$data['msg']['speak']}";
    break;
    }
    foreach ($serv->connections as $conn){
    if ($conn!=$data['fd']){
    if (strpos($data['msg']['name'],"游客")===0){
    $name=$data['msg']['name']."_".$data['fd'];
    }else{
    $name=$data['msg']['name'];
    }
    }else{
    $name="我";
    }
    $serv->push($conn,$name.$send_msg);
    }
    return;
    }
    function on_finish($serv,$task_id,$data){
    return true;
    }

前端代码：


    <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    <html>
    <head>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
    <title>WebSocket测试</title> 
    <script language="javascript"type="text/javascript" src="jquery-1.12.0.min.js"> 
    </script>
    </head>
    <body>
    <h2>WebSocket Test</h2> 
    昵称：<input type="text" id="name" size="5" value="游客"/> <input type="text" id="content"> 
    <button onclick="speak_to_all()">发送</button>
    <br/><br/>
    <textarea id="message" style="overflow-x:hidden" rows="10" cols="50"></textarea> 
    <div id="output"></div>
    </body> 
    <script language="javascript"type="text/javascript"> 
    var wsUri ="ws://127.0.0.1:3999/"; 
    var output; 
    function init() { 
    output = document.getElementById("output"); 
    testWebSocket();
    }
    function testWebSocket() { 
    websocket = new WebSocket(wsUri); 
    websocket.onopen = function(evt) { 
    onOpen(evt) 
    }; 
    websocket.onclose = function(evt) { 
    onClose(evt) 
    }; 
    websocket.onmessage = function(evt) { 
    onMessage(evt) 
    }; 
    websocket.onerror = function(evt) { 
    onError(evt) 
    }; 
    }
    function get_speak_msg(){
    var name=document.getElementById("name").value;
    var speak=document.getElementById("content").value;
    var json_msg='{"name":"'+name+'","speak":\"'+speak+'"}';
    return json_msg;
    }
    function pack_msg(type,msg){
    return '{"type":"'+type+'","msg":'+msg+'}';
    }
    function onOpen(evt) {
    append_speak("已经联通服务器.........");
    speak_msg=get_speak_msg();
    send_msg=pack_msg("login",speak_msg);
    doSend(send_msg);
    }
    function onClose(evt) { 
    append_speak("俺老孙去也！");
    } 
    function onMessage(evt) {
    append_speak(evt.data);
    }
    function onError(evt) {
    alert(evt.data);
    }
    function doSend(message) { 
    websocket.send(message);
    }
    function append_speak(new_msg){
    document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n";
    document.getElementById('message').scrollTop = document.getElementById('message').scrollHeight;
    }
    function speak_to_all(){
    send_msg=pack_msg("speak",get_speak_msg());
    if(document.getElementById("content").value==""){
    return;
    }
    doSend(send_msg);
    document.getElementById("content").value="";
    }
    init();
    </script>
    </html>

以上代码给大家分享了PHP+swoole实现简单多人在线聊天群发的相关代码，希望本文所述对大家有所帮助。