gateway进程 ¶

<?php  
return [
    // 使用注解注册，存在server的路径，支持*
    'annotation_path' => [
        'addons/moduleA/worker',
        'addons/*/worker',
        'addons/*/*/worker', 
    ]
];

<?php  
return [
    // 使用注解注册，存在server的路径，支持*
    'annotation_path' => [
        'addons/moduleA/worker',
        'addons/*/worker',
        'addons/*/*/worker', 
    ]
];

<?php

namespace addons\moduleA\worker;

use shiyunWorker\annotation\GatewayBusinessWorker;
use shiyunWorker\annotation\GatewayGateway;
use shiyunWorker\annotation\GatewayRegister;
use \GatewayWorker\Lib\Gateway;

/**
 * 主逻辑
 * 主要是处理 onConnect onMessage onClose 三个方法
 * onConnect 和 onClose 如果不需要可以不用实现并删除
 */
#[GatewayBusinessWorker(registerAddress: '127.0.0.1:1238')]
#[GatewayRegister(socket: 'text://0.0.0.0:1238')]
// gateway 进程
#[GatewayGateway(
    registerAddress: '127.0.0.1:1238',
    socket: 'tcp://0.0.0.0:8282',
    startPort: 2900,
)]
class TestEvents
{
    /**
     * 当客户端连接时触发
     * 如果业务不需此回调可以删除onConnect
     * 
     * @param int $client_id 连接id
     */
    public static function onConnect($client_id)
    {
        // 向当前client_id发送数据 
        Gateway::sendToClient($client_id, "Hello $client_id\r\n");
        // 向所有人发送
        Gateway::sendToAll("$client_id login\r\n");
    }

    /**
     * 当客户端发来消息时触发
     * @param int $client_id 连接id
     * @param mixed $message 具体消息
     */
    public static function onMessage($client_id, $message)
    {
        // 向所有人发送 
        Gateway::sendToAll("$client_id said $message\r\n");
    }

    /**
     * 当用户断开连接时触发
     * @param int $client_id 连接id
     */
    public static function onClose($client_id)
    {
        // 向所有人发送 
        GateWay::sendToAll("$client_id logout\r\n");
    }
}

<?php

namespace addons\moduleA\worker;

use shiyunWorker\annotation\GatewayBusinessWorker;
use shiyunWorker\annotation\GatewayGateway;
use shiyunWorker\annotation\GatewayRegister;
use \GatewayWorker\Lib\Gateway;

/**
 * 主逻辑
 * 主要是处理 onConnect onMessage onClose 三个方法
 * onConnect 和 onClose 如果不需要可以不用实现并删除
 */
#[GatewayBusinessWorker(registerAddress: '127.0.0.1:1238')]
#[GatewayRegister(socket: 'text://0.0.0.0:1238')]
// gateway 进程
#[GatewayGateway(
    registerAddress: '127.0.0.1:1238',
    socket: 'tcp://0.0.0.0:8282',
    startPort: 2900,
)]
class TestEvents
{
    /**
     * 当客户端连接时触发
     * 如果业务不需此回调可以删除onConnect
     * 
     * @param int $client_id 连接id
     */
    public static function onConnect($client_id)
    {
        // 向当前client_id发送数据 
        Gateway::sendToClient($client_id, "Hello $client_id\r\n");
        // 向所有人发送
        Gateway::sendToAll("$client_id login\r\n");
    }

    /**
     * 当客户端发来消息时触发
     * @param int $client_id 连接id
     * @param mixed $message 具体消息
     */
    public static function onMessage($client_id, $message)
    {
        // 向所有人发送 
        Gateway::sendToAll("$client_id said $message\r\n");
    }

    /**
     * 当用户断开连接时触发
     * @param int $client_id 连接id
     */
    public static function onClose($client_id)
    {
        // 向所有人发送 
        GateWay::sendToAll("$client_id logout\r\n");
    }
}