這是連接仍然存在時(shí)我正在運(yùn)行的當(dāng)前 WebSocket 循環(huán)。但是連續(xù)連接11個(gè)小時(shí)后，我收到了異常"exception":"[object] (Amp\\Websocket\\ClosedException(code: 1006): The connection was closed: Client closed the underlying TCP connection at ...如何檢查關(guān)閉的連接或異常本身？，這樣我就可以正確結(jié)束腳本邏輯而不會(huì)突然失敗。 \Amp\Loop::run(function () use ($fn, $st) { $connection = yield \Amp\Websocket\connect('wss://URL'); yield $connection->send('{"action":"auth","params":"KEYID"}'); yield $connection->send('{"action":"subscribe","params":"'.$st.'"}'); $i = 0; while ($message = yield $connection->receive()) { $i++; $payload = yield $message->buffer(); $r = $fn($payload, $i); if ($r == false) { $connection->close(); break; } } } );我正在使用這個(gè) Amphp Websocket：https ://github.com/amphp/websocket-client
1 回答
RISEBY
TA貢獻(xiàn)1856條經(jīng)驗(yàn) 獲得超5個(gè)贊
ClosedException我確實(shí)找到了解決這個(gè)問(wèn)題的方法，方法是在它被拋出后尋找并運(yùn)行其他任務(wù)。
\Amp\Loop::run(function () use ($fn, $st)
{
try
{
$connection = yield \Amp\Websocket\connect('wss://URL');
yield $connection->send('{"action":"auth","params":"KEYID"}');
yield $connection->send('{"action":"subscribe","params":"'.$st.'"}');
$i = 0;
while ($message = yield $connection->receive())
{
$i++;
$payload = yield $message->buffer();
$r = $fn($payload, $i);
if ($r == false) {
$connection->close();
break;
}
}
}
catch (\Amp\Websocket\ClosedException $e)
{
// do something here
}
}
);
- 1 回答
- 0 關(guān)注
- 127 瀏覽
添加回答
舉報(bào)
0/150
提交
取消