PHP-swoole 聊天室
生活随笔
收集整理的這篇文章主要介紹了
PHP-swoole 聊天室
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
最近用Swoole寫了一個聊天室?http://cs.whliu.com/blog/chat/swoole
下面發(fā)下聊天室的代碼
server.php
<?php require_once("redisDb.php" ); //自己簡單些的redis類 require_once("rndChinaName.php" ); //用于隨機(jī)生成名字 class server{private $redis;private $randName;public function __construct(){$this->redis = new redisDb();$this->randName = new rndChinaName();$this->redis->flushAll();echo "redis is connect";}public function getChar($num) // $num為生成漢字的數(shù)量{$b = '';for ($i=0; $i<$num; $i++) {// 使用chr()函數(shù)拼接雙字節(jié)漢字，前一個chr()為高位字節(jié)，后一個為低位字節(jié)$a = chr(mt_rand(0xB0,0xD0)).chr(mt_rand(0xA1, 0xF0));// 轉(zhuǎn)碼$b .= iconv('GB2312', 'UTF-8', $a);}return $b;}public function getName(){return $this->randName->getName();}public function socket(){//創(chuàng)建websocket服務(wù)器對象，監(jiān)聽0.0.0.0:9502端口$ws = new swoole_websocket_server("0.0.0.0", 9502);$ws->set([ // 'socket_buffer_size' => 128 * 1024 *1024, //必須為數(shù)字'worker_num' => 2,'task_worker_num' =>4,]);//監(jiān)聽WebSocket連接打開事件$ws->on('open', function ($ws, $request) {$room = "xyf";$name = $this->getName();$this->redis->hset($room,$request->fd,$name);$Pnum = $this->redis->hlen($room);$json = array('type'=>'3','message'=>"歡迎 <span class='text-navy'>$name</span> 加入聊天室",'time'=>date('Y-m-d H:i:s',time()),'num'=>"在線人數(shù)：".$Pnum);$str = json_encode($json);foreach($ws->connections as $fd){$ws->push($fd,$str);}});//監(jiān)聽WebSocket消息事件$ws->on('message', function ($ws, $frame) {echo "message:{$frame->data}";$task_id = $ws->task($frame); });//監(jiān)聽WebSocket連接關(guān)閉事件$ws->on('close', function ($ws, $fd) {$name = $this->redis->hget("xyf",$fd);$this->redis->hdel("xyf",$fd);$Pnum = $this->redis->hlen("xyf");$json = array('type'=>'3','message'=>"<span class='text-navy'>$name</span> 離開聊天室",'time'=>date('Y-m-d H:i:s',time()),'num'=>"在線人數(shù)：".$Pnum);$str = json_encode($json);foreach($ws->connections as $fd1){if($fd1 != $fd){$ws->push($fd1,$str);}}echo "client-{$fd} is closed\n";});$ws->on('Receive', function(swoole_server $ws, $fd, $from_id, $data) {echo "接收數(shù)據(jù)" . $data . "\n";$data = trim($data);$task_id = $ws->task($data, 0); $ws->send($fd, "分發(fā)任務(wù)，任務(wù)id為$task_id\n");});$ws->on('Task', function (swoole_server $ws, $task_id, $from_id,$frame) {echo "Tasker進(jìn)程接收到數(shù)據(jù)";foreach($ws->connections as $fd){echo "task_id:".$task_id."\n";$num = $frame->fd%10;$data = htmlspecialchars($frame->data);$name = $this->redis->hget("xyf",$frame->fd);if($fd==$frame->fd){$json = array('name'=>"$name",'message'=>"$data",'time'=>date('Y-m-d H:i:s',time()),'type'=>'1','img'=>$num);}else{$json = array('name'=>"$name",'message'=>"$data",'time'=>date('Y-m-d H:i:s',time()),'type'=>'2','namet'=>"中文",'img'=>$num);}$str = json_encode($json,JSON_UNESCAPED_UNICODE);$ws->push($fd,$str);}$ws->finish($data);});$ws->on('Finish', function (swoole_server $ws, $task_id, $data) {echo "Task#$task_id finished, data_len=".strlen($data).PHP_EOL."\n";});$ws->start();} } $wser = new server(); $wser->socket(); ?>index.html 客戶端頁面
<!DOCTYPE html> <html> <head><meta charset="utf-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>PHP聊天室</title><meta name="keywords" content="PHP聊天室"><meta name="description" content="PHP聊天室"><link rel="shortcut icon" href="favicon.ico"> <link href="css/bootstrap.min.css?v=3.3.6" rel="stylesheet"><link href="css/font-awesome.css?v=4.4.0" rel="stylesheet"><link href="css/plugins/jsTree/style.min.css" rel="stylesheet"><link href="css/animate.css" rel="stylesheet"><link href="css/style.css" rel="stylesheet"><!--?v=4.1.0 --> <style>.wrapper-content{padding:0px;}.ibox{margin-bottom: 0px; }.ibox-title{height:10vh;}.chat-discussion{min-height:74vh; }.chat-message-form{height:14vh;}#message{height:14vh;}.alert{padding:4px 8px;text-align:center;width:auto;font-size: 4px;border-radius:10px;}.come{padding:5px;margin-bottom:5px;} </style> </head><body class="gray-bg"><div class="wrapper wrapper-content animated fadeInRight"><div class="row"><div class="col-sm-12"><div class="ibox chat-view"><div class="ibox-title"><center><h4 class="text-navy">PHP-Swoole聊天室<span class="pull-right label label-primary" id="num"></span></h4></center></div><div class="ibox-content"><div class="row"><div cass="col-md-12"><div class="chat-discussion"></div></div><div class="col-sm-12"><div class="chat-message-form"><textarea class="form-control" name="message" id="message" placeholder="輸入消息內(nèi)容，按回車鍵發(fā)送"></textarea></div></div></div></div></div></div></div></div><!-- 全局js --><script src="js/jquery.min.js?v=2.1.4"></script><script src="js/bootstrap.min.js?v=3.3.6"></script><script src="js/message.js?v=1.0.5"></script><!-- 自定義js --> </body> </html>message.js 客戶端websocket的連接
if(window.WebSocket){var webSocket = new WebSocket("ws://服務(wù)端IP:端口號");webSocket.onopen = function (event) {};webSocket.onmessage = function (event) { // console.log(event.data);var data = JSON.parse(event.data); // console.log(event.data);var message = "";if(data.type==3){$('#num').html(data.num);message += '<center><p class="come"><span class="alert alert-success">'+data.message+'</span></p></center>';}else{if(data.type==1){message += '<div class="chat-message">';}else{message += '<div class="chat-message1">';}message += '<img class="message-avatar" src="img/a'+data.img+'.jpg" alt="">';message += '<div class="message">'message += '<span class="message-author">'+data.name+'</span>';message += '<span class="message-date">'+data.time+'</span>';message += '<span class="message-content">'+data.message+'</span>';message += '</div>';message += '</div>';}$('.chat-discussion').append(message);$(".chat-discussion").scrollTop($(".chat-discussion")[0].scrollHeight);};var sendMessage = function(){var message = $('#message').val();if($.trim(message)==""){$('#message').val("");return false;}else{webSocket.send(message);$('#message').val("");}}}else{console.log("您的瀏覽器不支持WebSocket");}$(document).keyup(function(event){if(event.keyCode ==13){sendMessage();}});以上是主要的代碼內(nèi)容，若有什么疑問可以在下面留言
總結(jié)
以上是生活随笔為你收集整理的PHP-swoole 聊天室的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： UDP聊天室（代码）
- 下一篇： 天使投资人杨宁：百度轻应用让移动时代很多