<?php
|
include_once "/Common/Logging.php";
|
include_once '/db/RedisOper.php';
|
|
\Logging\CreateLogging("chatmonitorserver.php");
|
|
$interfaceConfig = parse_ini_file("/InterfaceConfig.php", true);
|
$GameName = $interfaceConfig["ServerInfo"]["GameName"];
|
$ChannelList = explode(",", $interfaceConfig["ServerInfo"]["ChannelList"]);
|
$address = $interfaceConfig["Chatmonitor"]["SocketHost"];
|
$port = $interfaceConfig["Chatmonitor"]["SocketPort"];
|
|
$logDate = date("Y-m-d");
|
LogConsole("");
|
LogConsole("GameName:" . $GameName);
|
LogConsole("ChannelList:" . json_encode($ChannelList));
|
|
if (($master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) == false) {
|
LogConsole("socket_create() failed: reason: " . socket_strerror(socket_last_error()), true);
|
}
|
if (($ret = socket_bind($master, $address, $port)) == false) {
|
LogConsole("socket_bind() failed: reason: " . socket_strerror(socket_last_error($master)), true);
|
}
|
if (($ret = socket_listen($master, 3)) == false) {
|
LogConsole("socket_listen() failed: reason: " . socket_strerror(socket_last_error($master)), true);
|
}
|
|
LogConsole("chatmonitor server start ok. " . $address . ":" . $port);
|
|
// $master = null; //socket的resource，即前期初始化socket时返回的socket资源
|
$all_sockets = [$master]; // socket 集合
|
$channelInfo = array(); // 渠道对应socket信息
|
foreach ($ChannelList as $spid) {
|
$channelInfo[$spid] = array(
|
"clients" => array(),
|
"broadcastTime" => 0
|
);
|
}
|
|
do {
|
$copy_sockets = $all_sockets; // 单独拷贝一份
|
|
// 因为客户端是长连接，如果客户端非正常断开，服务端会在 socket_accept 阻塞，现在使用 select 非阻塞模式 socket
|
$num_changed_sockets = socket_select($copy_sockets, $write, $except, 0);
|
if ($num_changed_sockets === false) {
|
/* 错误处理 */
|
LogConsole("sosket_select error: " . socket_strerror(socket_last_error()), true);
|
continue;
|
} else if ($num_changed_sockets > 0) {
|
/*至少有一个套接字发生改变 */
|
}
|
// echo "all_sockets count:", count($all_sockets), " num_changed_sockets:", $num_changed_sockets, PHP_EOL;
|
|
// 接收第一次 socket 连入，连入后移除服务端 socket
|
if (in_array($master, $copy_sockets)) {
|
$client = socket_accept($master);
|
if ($client) {
|
$buf = socket_read($client, 1024);
|
// echo $buf;
|
|
// 匹配 Sec-Websocket-Key 标识
|
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/i", $buf, $match)) {
|
// 需要将 Sec-WebSocket-Key 值累加字符串，并依次进行 SHA-1 加密和 base64 加密
|
$key = base64_encode(sha1($match[1] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
|
// 拼凑响应内容
|
$res = "HTTP/1.1 101 Switching Protocol" . PHP_EOL
|
. "Upgrade: WebSocket" . PHP_EOL
|
. "Connection: Upgrade" . PHP_EOL
|
. "WebSocket-Location: ws://" . $address . ":" . $port . PHP_EOL
|
. "Sec-WebSocket-Accept: " . $key . PHP_EOL . PHP_EOL; // 注意这里，需要两个换行
|
// 向客户端应答 Sec-WebSocket-Accept
|
socket_write($client, $res, strlen($res));
|
|
$key = uniqid(rand(1000, 9999), true);
|
|
// 加入客户端 socket
|
$all_sockets[$key] = $client;
|
LogConsole("new client key:" . $key . " now count:" . (count($all_sockets) - 1));
|
}
|
// 移除服务端 socket
|
$key = array_search($master, $copy_sockets);
|
unset($copy_sockets[$key]);
|
}
|
}
|
|
// 循环所有客户端 sockets
|
foreach ($copy_sockets as $key => $s) {
|
// 获取客户端发给服务端的内容
|
$buf = socket_read($s, 8024);
|
// echo strlen($buf), '---', PHP_EOL;
|
// 代表客户端主动关闭
|
if (strlen($buf) < 9) {
|
$key = array_search($s, $all_sockets);
|
unset($all_sockets[$key]);
|
LogConsole("client close key:" . $key . " remain client count:" . (count($all_sockets) - 1));
|
foreach ($channelInfo as $spid => $info) {
|
$clients = $info["clients"];
|
if (array_key_exists($key, $clients)) {
|
unset($clients[$key]);
|
$channelInfo[$spid]["clients"] = $clients;
|
LogConsole(" remove from spid:" . $spid . " key:" . $key . " spid clients count:" . count($channelInfo[$spid]["clients"]));
|
break;
|
}
|
}
|
socket_close($s);
|
continue;
|
}
|
|
$data = message($buf);
|
$data = json_decode($data, true);
|
if (!isset($data)) {
|
send($s, "HEARTBEAT", "hello");
|
continue;
|
}
|
|
if ($data["MsgType"] == "SPID") {
|
$spid = $data["Msg"];
|
if (!in_array($spid, $ChannelList)) {
|
continue;
|
}
|
$clients = $channelInfo[$spid]["clients"];
|
$clients[$key] = $s;
|
$channelInfo[$spid]["clients"] = $clients;
|
LogConsole("update spid client spid:" . $spid . " key:" . $key . " spid clients count:" . count($channelInfo[$spid]["clients"]));
|
// 同步最近历史聊天，待扩展，有需要再说
|
}
|
|
$curSpid = "";
|
foreach ($channelInfo as $spid => $info) {
|
if (array_key_exists($key, $info["clients"])) {
|
$curSpid = $spid;
|
break;
|
}
|
}
|
if ($curSpid && broadcastChat($curSpid)) {
|
continue;
|
}
|
send($s, "HEARTBEAT", "hello");
|
}
|
|
// 广播最新消息
|
|
} while (true);
|
socket_close($master);
|
|
function broadcastChat($spid)
|
{
|
global $channelInfo, $GameName;
|
|
$info = $channelInfo[$spid];
|
$broadcastTime = $info["broadcastTime"];
|
|
$curTime = time();
|
// 1 秒最多广播一次
|
if (($curTime - $broadcastTime) < 1) {
|
return;
|
}
|
$channelInfo[$spid]["broadcastTime"] = $curTime;
|
if (count($info["clients"]) <= 0) {
|
return;
|
}
|
|
$redisKey = \RedisOper\GetFCRedisKey($GameName, "Chatmonitor", $spid);
|
if (!\RedisOper\ListRange($redisKey, $retArray, 0, -1)) {
|
return;
|
}
|
if (!isset($retArray) || count($retArray) <= 0) {
|
return;
|
}
|
\RedisOper\DelKey($redisKey);
|
LogConsole("broadcast spid:" . $spid . " clients count:" . count($info["clients"]) . " chatCount:" . count($retArray));
|
sendAll($info["clients"], "CHAT", $retArray);
|
return true;
|
}
|
|
function LogConsole($msg, $isErr = false)
|
{
|
global $logDate;
|
if ($logDate != date("Y-m-d")) {
|
$logDate = date("Y-m-d");
|
echo "new logDate", $logDate, PHP_EOL;
|
\Logging\CreateLogging("chatmonitorserver.php", true);
|
}
|
echo date("Y-m-d H:i:s"), " ", $msg, PHP_EOL;
|
if ($isErr) {
|
\Logging\LogError($msg);
|
} else {
|
\Logging\LogInfo($msg);
|
}
|
}
|
|
/**
|
* 解析接收数据
|
* @param $buffer
|
* @return null|string
|
*/
|
function message($buffer)
|
{
|
$len = $masks = $data = $decoded = null;
|
$len = ord($buffer[1]) & 127;
|
if ($len === 126) {
|
$masks = substr($buffer, 4, 4);
|
$data = substr($buffer, 8);
|
} else if ($len === 127) {
|
$masks = substr($buffer, 10, 4);
|
$data = substr($buffer, 14);
|
} else {
|
$masks = substr($buffer, 2, 4);
|
$data = substr($buffer, 6);
|
}
|
for ($index = 0; $index < strlen($data); $index++) {
|
$decoded .= $data[$index] ^ $masks[$index % 4];
|
}
|
return $decoded;
|
}
|
|
/**
|
* 消息广播
|
*/
|
function sendAll($clients, $msgType, $msg)
|
{
|
global $all_sockets, $master;
|
$sendData = getsenddata($msgType, $msg);
|
foreach ($clients as $key => $so) {
|
if ($so != $master && array_key_exists($key, $all_sockets)) {
|
socket_write($so, $sendData, strlen($sendData));
|
}
|
}
|
}
|
|
/**
|
* 发送数据
|
*/
|
function send($client, $msgType, $msg)
|
{
|
$sendData = getsenddata($msg, $msgType, $msg);
|
socket_write($client, $sendData, strlen($sendData));
|
}
|
|
function getsenddata($msgType, $msg)
|
{
|
// HEARTBEAT MSG CHAT
|
$msg = array("MsgType" => $msgType, "Msg" => $msg);
|
$msg = json_encode($msg) . "#end#";
|
$msg = frame($msg);
|
return $msg;
|
}
|
|
/**
|
* 处理数据帧
|
*
|
* @param [type] $s
|
*/
|
function frame($s)
|
{
|
$a = str_split($s, 125);
|
if (count($a) == 1) {
|
return "\x81" . chr(strlen($a[0])) . $a[0];
|
}
|
$ns = "";
|
foreach ($a as $o) {
|
$ns .= "\x81" . chr(strlen($o)) . $o;
|
}
|
return $ns;
|
}
|
