workerman的websocket的send如何實(shí)現(xiàn)同步發(fā)送到客戶端呢?

ragnar 2023-03-27

workerman的websocket的send如何實(shí)現(xiàn)同步發(fā)送到客戶端呢,就是在chatgpt的流式返回回調(diào)函數(shù)中每一次回調(diào)都send到客戶端,現(xiàn)在是等chatgpt全部回調(diào)結(jié)束才循環(huán)發(fā)送到客戶端,這個(gè)問(wèn)題有沒(méi)有解決方案呢?

 1394  1 0

1個(gè)回答

ersic 2023-03-27

參考這個(gè)帖子
http://wtbis.cn/q/10107

ragnar 2023-03-27

您好,這個(gè)客戶端用的是websocket鏈接服務(wù)器,不是hs的eventsource,這樣服務(wù)器返回的時(shí)候只能用完websocket返回字符串,這個(gè)情況怎么解決上面的問(wèn)題呢

ragnar 2023-03-27

    for ($i = 0;$i<5;$i++){
        $connection->send('111');
        sleep(1);
    }

這種怎么分開(kāi)返回呢

ragnar 2023-03-27

maxSendBufferSize
說(shuō)明:
int Connection::$maxSendBufferSize
每個(gè)連接都有一個(gè)單獨(dú)的應(yīng)用層發(fā)送緩沖區(qū)，如果客戶端接收速度小于服務(wù)端發(fā)送速度，數(shù)據(jù)會(huì)在應(yīng)用層緩沖區(qū)暫存等待發(fā)送。

此屬性用來(lái)設(shè)置當(dāng)前連接的應(yīng)用層發(fā)送緩沖區(qū)大小。不設(shè)置默認(rèn)為Connection::defaultMaxSendBufferSize(1MB)。

此屬性影響onBufferFull回調(diào)。
ragnar 2023-03-27

每個(gè)連接都有一個(gè)單獨(dú)的應(yīng)用層發(fā)送緩沖區(qū)，如果客戶端接收速度小于服務(wù)端發(fā)送速度，數(shù)據(jù)會(huì)在應(yīng)用層緩沖區(qū)暫存等待發(fā)送。

這個(gè)要怎么直接發(fā)送,而不繼續(xù)在應(yīng)用層緩沖區(qū)暫存等待發(fā)送呢?