workerman实现tcp客户端中间件，该用什么样的方法提供服务？

问题描述得很详细，非常赞，一看就有回答的欲望。
workerman做这样的业务非常擅长，以下是示例代码

安装 workerman/http-client

为了异步执行http回调，要装下 workerman/http-client

composer require workerman/http-client

服务端代码

以下是服务端代码示例 start.php

<?php

use Workerman\Connection\TcpConnection;
use Workerman\Http\Client;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:2345');

// 保存订阅主题->回调url的数组
global $subjects;
$subjects = [];

// 进程启动时建立一个到A服务的连接
$worker->onWorkerStart = function() {
    $con = new AsyncTcpConnection('ws://echo.websocket.org:443');
    $con->transport = 'ssl'; // tcp协议不需要设置
    $con->onWebSocketConnect = function(AsyncTcpConnection $con, ) {
        $con->send('hello');
    };
    // 收到A服务的订阅数据后转发给订阅者
    $con->onMessage = function(AsyncTcpConnection $con, $subject) {
        global $subjects;
        foreach ($subjects[$subject] ?? [] as $callbackUrl) {
            $httpClient = new Client();
            $httpClient->post($callbackUrl, ['subject' => $subject]);
            echo "callback $callbackUrl\n";
        }
    };
    // 为了模拟A主动推送订阅消息，这里定时向A服务发送数据，A会返回hello
    \Workerman\Timer::add(10, function () use ($con) {
        $con->send('hello');
    });
    $con->connect();
};

$worker->onMessage = function (TcpConnection $httpConnection, Request $request) {
    $callbackUrl = $request->get('callback');
    // 订阅主题
    $subject = $request->get('subject');
    // 没有回调url或者订阅主题认为是同步指令
    if (!$callbackUrl || !$subject) {
        $con = new AsyncTcpConnection('ws://echo.websocket.org:443');
        $con->transport = 'ssl'; // tcp协议不需要设置
        $con->onWebSocketConnect = function (AsyncTcpConnection $con) {
            $con->send('hello');
        };
        $con->onMessage = function (AsyncTcpConnection $con, $data) use ($httpConnection) {
            $httpConnection->send($data);
            $con->close();
        };
        $con->connect();
        return;
    }
    // 记录主题和回调之间的关系
    global $subjects;
    if (!isset($subjects[$subject])) {
        $subjects[$subject] = [];
    }
    if (in_array($callbackUrl, $subjects[$subject])) {
        $httpConnection->send('already subscribed');
        return;
    }
    $subjects[$subject][] = $callbackUrl;
    $httpConnection->send('subscribed');
};

Worker::runAll();

启动

php start.php start

测试

同步请求url类似 http://127.0.0.1:2345
订阅测试url类似 http://127.0.0.1:2345/?subject=hello&callback=<url地址>

说明

为了方便测试，上面代码用的wss协议测试，你需要改成自己的协议

多进程时要加一句 $worker->reusePort = true;

$worker = new Worker('http://0.0.0.0:2345');
$worker->reusePort = true;

学习了。