Workerman怎么实现网关？Workerman网关服务器搭建？

composer require workerman/workerman workerman/gateway-worker

start_register.php

<?php
// start_register.php
use Workerman\Worker;
use GatewayWorker\Register;

// 确保Composer autoload文件被加载
require_once __DIR__ . '/vendor/autoload.php';

// Register服务，用于管理所有Gateway和BusinessWorker的注册信息
// 这里使用text协议，监听1238端口
$register = new Register('text://0.0.0.0:1238');
$register->name = 'Register'; // 给进程起个名字，方便管理

// 如果不是全局启动模式，则直接运行所有Worker
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

start_gateway.php

<?php
// start_gateway.php
use Workerman\Worker;
use GatewayWorker\Gateway;

require_once __DIR__ . '/vendor/autoload.php';

// Gateway服务，用于接收客户端连接，并转发数据
// 这里使用websocket协议，监听8080端口，方便浏览器客户端连接
$gateway = new Gateway("websocket://0.0.0.0:8080");
$gateway->name = 'Gateway';
$gateway->count = 4; // 启动4个Gateway进程，根据CPU核心数调整
$gateway->lanIp = '127.0.0.1'; // Gateway内部通讯IP，多服务器部署时需改为实际内网IP
$gateway->startPort = 2900; // Gateway内部通讯起始端口，Gateway进程会占用2900-2900+count-1的端口
$gateway->registerAddress = '127.0.0.1:1238'; // 注册服务地址，必须与Register服务监听的地址一致

// 心跳检测，确保客户端在线状态，及时清理死连接
$gateway->pingInterval = 10; // 每10秒向客户端发送一次心跳
$gateway->pingNotResponseLimit = 1; // 客户端1次未响应心跳则认为掉线
$gateway->pingData = '{"type":"ping"}'; // 心跳数据，可以自定义，客户端收到后需要回复

// 如果不是全局启动模式，则直接运行所有Worker
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

start_worker.php

<?php
// start_worker.php
use Workerman\Worker;
use GatewayWorker\BusinessWorker;
use GatewayWorker\Lib\Gateway; // 注意：这里的Gateway是Lib下的，用于业务逻辑中调用网关功能

require_once __DIR__ . '/vendor/autoload.php';

// BusinessWorker服务，用于处理具体的业务逻辑
$worker = new BusinessWorker();
$worker->name = 'BusinessWorker';
$worker->count = 8; // 启动8个业务进程，根据业务复杂度和CPU核心数调整
$worker->registerAddress = '127.0.0.1:1238'; // 注册服务地址

// 当BusinessWorker进程启动时触发
$worker->onWorkerStart = function($worker) {
    // 可以在这里进行一些初始化操作，比如数据库连接、Redis连接等
    echo "BusinessWorker {$worker->id} started.\n";
};

// 当客户端连接到Gateway时（Gateway会通知BusinessWorker）
$worker->onConnect = function($client_id) {
    echo "New client connected: $client_id\n";
    // 可以向新连接的客户端发送欢迎消息
    Gateway::sendToClient($client_id, json_encode(['type' => 'welcome', 'message' => 'Hello, welcome!']));
};

// 当收到客户端消息时
$worker->onMessage = function($client_id, $message) {
    echo "Received message from $client_id: $message\n";
    // 假设消息是JSON格式，解析并根据type字段处理
    $data = json_decode($message, true);
    if ($data && isset($data['type'])) {
        switch ($data['type']) {
            case 'login':
                // 绑定UID，方便后续根据UID进行定向推送
                if (isset($data['uid'])) {
                    Gateway::bindUid($client_id, $data['uid']);
                    Gateway::sendToClient($client_id, json_encode(['code' => 0, 'msg' => "Login success for UID: {$data['uid']}"]));
                    // 广播通知所有人有新用户上线
                    Gateway::sendToAll(json_encode(['type' => 'user_online', 'uid' => $data['uid']]));
                } else {
                    Gateway::sendToClient($client_id, json_encode(['code' => 1, 'msg' => 'UID is required for login.']));
                }
                break;
            case 'say':
                // 群发消息
                if (isset($data['content'])) {
                    $uid = Gateway::getUidByClientId($client_id); // 获取当前客户端绑定的UID
                    Gateway::sendToAll(json_encode(['type' => 'msg', 'from_uid' => $uid, 'content' => $data['content']]));
                }
                break;
            case 'private_chat':
                // 私聊消息
                if (isset($data['to_uid'], $data['content'])) {
                    $from_uid = Gateway::getUidByClientId($client_id);
                    Gateway::sendToUid($data['to_uid'], json_encode(['type' => 'private_msg', 'from_uid' => $from_uid, 'content' => $data['content']]));
                    Gateway::sendToClient($client_id, json_encode(['type' => 'private_msg_sent', 'to_uid' => $data['to_uid'], 'content' => $data['content']])); // 回复发送者
                }
                break;
            default:
                Gateway::sendToClient($client_id, json_encode(['code' => 1, 'msg' => 'Unknown message type.']));
        }
    } else {
        Gateway::sendToClient($client_id, json_encode(['code' => 1, 'msg' => 'Invalid message format.']));
    }
};

// 当客户端断开连接时
$worker->onClose = function($client_id) {
    echo "Client disconnected: $client_id\n";
    // 清理工作，例如解除UID绑定，通知其他用户下线
    $uid = Gateway::getUidByClientId($client_id);
    if ($uid) {
        Gateway::unbindUid($client_id, $uid);
        Gateway::sendToAll(json_encode(['type' => 'user_offline', 'uid' => $uid]));
    }
};

// 如果不是全局启动模式，则直接运行所有Worker
if(!defined('GLOBAL_START')) {
    Worker::runAll();
}

start.php

<?php
// start.php
use Workerman\Worker;

require_once __DIR__ . '/vendor/autoload.php';

// 导入所有启动文件
require_once __DIR__ . '/start_register.php';
require_once __DIR__ . '/start_gateway.php';
require_once __DIR__ . '/start_worker.php';

// 运行所有服务
Worker::runAll();

php start.php start -d  // -d 参数表示以后台守护进程方式运行

php start.php status

php start.php stop

Gateway::sendToClient($client_id, $message)

Gateway::sendToUid($uid, $message)

Gateway::sendToGroup($group, $message)

Gateway::sendToAll($message)

net.ipv4.tcp_tw_reuse

net.ipv4.tcp_max_syn_backlog

net.core.somaxconn