| GatewayWorker 实现即时消息实现了客户端之间互相通信,本篇介绍的是使用GatewayClient推送消息到客户端 1.下载GatewayClienthttps://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);
...
 |