当前位置 博文首页 > json_li的博客：GatewayClient客户端推送
GatewayWorker 实现即时消息实现了客户端之间互相通信，本篇介绍的是使用GatewayClient推送消息到客户端
https://github.com/walkor/GatewayClient/releases/tag/v3.0.0
<?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;
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);
...