A用戶發(fā)起http請求，服務器發(fā)起ws獲取客戶端B數(shù)據(jù)，收到B數(shù)據(jù)后回復給A

Mruos 2022-11-03

問題描述

1、A用戶發(fā)起http請求，
2、http服務端，通過調(diào)用讓Gateway的ws服務端向ws客戶端B發(fā)送請求，
3、ws客戶端B收到數(shù)據(jù)后，發(fā)送回復給ws服務端，
4、ws服務端收到數(shù)據(jù)后，讓http服務器響應A的http請求

請問怎么實現(xiàn)，ws過程是異步的，好像A用戶的http請求處理過程必須有等待，類似sleep來等待ws通訊完，才能拿到數(shù)據(jù)響應給A。等待就堵塞，不好，還有什么好的方案嗎？

想到的方案

A用戶也發(fā)起ws數(shù)據(jù)，這樣大家都異步了，有個標識符，來回傳就行了；還有其他出路嗎？

有沒有什么方案、插件、工具，可以讓A用戶的請求掛起不堵塞，收到ws數(shù)據(jù)后，在響應A的http請求

 1494  2 1

2個回答

Dalong 2022-11-04

等老大的1.5版本出來目測就能解決你的問題。

暫無評論

tianyiw 2022-11-05

Revolt很簡單，我剛改造了我的代碼。。。下面的代碼是從我項目里精簡復制出來的，需要自己整理一下，無法直接運行。。。僅供參考


// 將事件循環(huán)換成Revolt
\Workerman\Worker::$eventLoopClass = \Workerman\Events\Revolt::class;

// 代碼不完整，僅供參考，下面的代碼需放入onWorkerStart()中運行

$listens = [];

// websocket服務端收到信息后，進行[$command, $hash, $data] = unserialize($data)反序列化，
// 然后回復消息時$connection->send(serialize([$hash, $result]))
// 保證收到消息、回復消息時$hash值一致

$connection = new AsyncTcpConnection('ws://127.0.0.1:8877');
$connection->onMessage = function (TcpConnection $connection, $data) use ($listens) {
    [$hash, $data] = unserialize($data);
    if (!isset($listens[$hash])) {
        return;
    }

    [$timerid, $suspension] = $listens[$hash];
    unset($listens[$hash]);
    \Workerman\Timer::del($timerid);
    $suspension->resume($data);
};
$connection->connect();

function post(string $command, array $data, int $timeout = 10): mixed
{
    global $listens, $connection;

    $suspension = \Revolt\EventLoop::getSuspension();
    $hash = intval(microtime(true) * 1000);

    $timerid = \Workerman\Timer::add(
        $timeout,
        function () use ($hash, $listens, $suspension) {
            if (isset($listens[$hash])) {
                $suspension->throw(new \Exception('超時了'));
            }
        },
        [],
        false
    );

    $listens[$hash] = [$timerid, $suspension];

    $connection->send(serialize([
        $command,
        $hash,
        $data,
    ]));

    return $suspension->suspend();
}

// 執(zhí)行
$value = $this->post('get', ['key'=>'good']);
var_dump($value);