重慶分公司
重慶分公司
最近自學(xué)了swoole，想做點(diǎn)東西試試看，剛好看到可以簡單做個聊天室，于是自己研究研究搞了一個。websocket是不同于http的另外一種網(wǎng)絡(luò)通信協(xié)議，能夠進(jìn)行雙向通信，基于此，可開發(fā)出各種實(shí)時通信產(chǎn)品，我簡單做了個聊天室demo，順便分享一下。
在翠屏等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供成都網(wǎng)站建設(shè)、網(wǎng)站制作 網(wǎng)站設(shè)計制作按需設(shè)計,公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站制作,營銷型網(wǎng)站,外貿(mào)網(wǎng)站建設(shè),翠屏網(wǎng)站建設(shè)費(fèi)用合理。
這里我簡單把websocket服務(wù)器分配的fd（文件描述,可以理解為用戶id）在文本（user.txt）,
然后進(jìn)行遍歷群發(fā)送消息，不啰嗦，核心代碼如下：websocket.phpserver = new swoole_websocket_server("0.0.0.0", 9502);
//監(jiān)聽WebSocket連接打開事件
$this->server->on('open', function (swoole_websocket_server $server, $request) {
echo "server: handshake success with fd{$request->fd}\n";
$array = [];
if (file_exists($this->userFile)) {
$array = array_filter(explode(',', file_get_contents($this->userFile)));
}
array_push($array, $request->fd);
file_put_contents($this->userFile, join(',', $array), LOCK_EX);
});
//監(jiān)聽WebSocket消息事件
$this->server->on('message', function (swoole_websocket_server $server, $frame) {
echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
//獲取聊天用戶數(shù)組
$array = explode(',', file_get_contents($this->userFile));
foreach ($array as $key => $val) {
$array[$key] = intval($val);
}
//組裝消息數(shù)據(jù)
$msg = json_encode([
'fd' => $frame->fd,//客戶id
'msg' => $frame->data,//發(fā)送數(shù)據(jù)
'total_num' => count($array)//聊天總?cè)藬?shù)
], JSON_UNESCAPED_UNICODE);
//發(fā)送消息
foreach ($array as $fdId) {
$server->push($fdId, $msg);
}
});
//監(jiān)聽WebSocket連接關(guān)閉事件
$this->server->on('close', function ($server, $fd) {
//獲取聊天用戶數(shù)組
$array = explode(',', file_get_contents($this->userFile));
foreach ($array as $key => $val) {
$array[$key] = intval($val);
}
///組裝消息數(shù)據(jù)
$msg = json_encode(
[
'fd' => $fd,
'msg' => '離開聊天室!',
'total_num' => count($array) - 1
],
JSON_UNESCAPED_UNICODE);
//發(fā)送消息
foreach ($array as $key => $fdId) {
if ($fdId == $fd) {
unset($array[$key]);
} else {
$server->push($fdId, $msg);
}
}
//更新聊天用戶數(shù)組
file_put_contents($this->userFile, join(',', $array), LOCK_EX);
echo "client {$fd} closed\n";
});
//監(jiān)聽Http請求事件
$this->server->on('request', function ($request, $response) {
// 接收http請求從get獲取message參數(shù)的值，給用戶推送
// $this->server->connections 遍歷所有websocket連接用戶的fd，給所有用戶推送
foreach ($this->server->connections as $fd) {
$this->server->push($fd, $request->get['message']);
}
});
$this->server->start();
}
}
new Websocket();安裝完php 和swoole擴(kuò)展之后，直接執(zhí)行：
php websocket.php
并可以觀察下輸出，看看websocket服務(wù)器是否正常。
效果如下：
1代碼中不要用,exit()/die(),socket會報 ERROR zm_deactivate_swoole (ERROR 9003): worker process is terminated by exit()/die()，因?yàn)樽舆M(jìn)程沒有處理就退出了,主進(jìn)程又會重新拉起。這樣就造成死循環(huán)了。
2.進(jìn)程隔離也是很多新手經(jīng)常遇到的問題。修改了全局變量的值，為什么不生效，原因就是全局變量在不同的進(jìn)程，內(nèi)存空間是隔離的，所以無效。
3.因?yàn)槲业拇a都是在虛擬機(jī)上跑，想讓其他PC訪問，需要做NAT端口映射。
其中,192.168.1.119是我本地ip，192.168.33.10是我虛擬機(jī)的ip,socket服務(wù)是在虛擬機(jī)的9520端口跑的，最后前端代碼的socket端口也相應(yīng)改下就可以了。
前后端代碼在我的git有,有興趣的同學(xué)自行下載~git地址：https://github.com/onebig32/swoole
歡迎star！
參考:
https://segmentfault.com/a/1190000003057118
NAT端口映射:http://blog.csdn.net/hitabc141592/article/details/31778923
swoole手冊：https://wiki.swoole.com/wiki/page/397.html
