GatewayWorker 实现即时消息实现了客户端之间互相通信,本篇介绍的是使用GatewayClient推送消息到客户端
1.下载GatewayClient
https://github.com/walkor/GatewayClient/releases/tag/v3.0.0
2.使用Gateway.php类文件
<?php
/**
* gatewayClient 3.0.0及以上版本加了命名空间
**/
require_once './GW2/Applications/Gateway.php';
use GatewayClient\Gateway;
function messagePush($data)
{
// 服务注册地址 内部通信 与start_register中设置保持一致
// 不在一台服务器则填写真实的Register服务的内网ip(或者外网ip)
Gateway::$registerAddress = '127.0.0.1:1238';
// 调用示例
$request_data = json_encode($data['content']) . "\n";
// 只要在线 默认发送成功
if (Gateway::isUidOnline($data['uid'])) {
Gateway::sendToUid($data['uid'], $request_data);
} else {
return false;
}
return true;
}
$pushData = [
'uid' => 1,
'content' => [
'type' => 0,
'content' => '你好 我是后端',
'addtime' => date('Y.m.d H:i'),
],
];
if (messagePush($pushData)) {
echo '发送成功!';
} else {
echo '发送失败!';
}
die;
3.调用效果
4.其他调用示例
// 以下是调用示例,接口与GatewayWorker环境的接口一致
// 注意除了不支持sendToCurrentClient和closeCurrentClient方法
// 其它方法都支持
Gateway::sendToAll($data);
Gateway::sendToClient($client_id, $data);
Gateway::closeClient($client_id);
Gateway::isOnline($client_id);
Gateway::bindUid($client_id, $uid);
Gateway::isUidOnline($uid);
Gateway::getClientIdByUid($client_id);
Gateway::unbindUid($client_id, $uid);
Gateway::sendToUid($uid, $data);
Gateway::joinGroup($client_id, $group);
Gateway::sendToGroup($group, $data);
Gateway::leaveGroup($client_id, $group);
Gateway::getClientCountByGroup($group);
Gateway::getClientSessionsByGroup($group);
Gateway::getAllClientCount();
Gateway::getAllClientSessions();
Gateway::setSession($client_id, $session);
Gateway::updateSession($client_id, $session);
Gateway::getSession($client_id);
...
|