onBufferFull

說明:

callback Worker::$onBufferFull

每個連接都有一個單獨的應(yīng)用層發(fā)送緩沖區(qū)，如果客戶端接收速度小于服務(wù)端發(fā)送速度，數(shù)據(jù)會在應(yīng)用層緩沖區(qū)暫存，如果緩沖區(qū)滿則會觸發(fā)onBufferFull回調(diào)。

緩沖區(qū)大為TcpConnection::$maxSendBufferSize，默認值為1MB，可以為當前連接動態(tài)設(shè)置緩沖區(qū)大小例如：

// 設(shè)置當前連接發(fā)送緩沖區(qū)，單位字節(jié)
$connection->maxSendBufferSize = 102400;

也可以利用TcpConnection::$defaultMaxSendBufferSize 設(shè)置所有連接默認緩沖區(qū)的大小，例如代碼：

use Workerman\Connection\TcpConnection;
// 設(shè)置所有連接的默認應(yīng)用層發(fā)送緩沖區(qū)大小，單位字節(jié)
TcpConnection::$defaultMaxSendBufferSize = 2*1024*1024;

該回調(diào)可能會在調(diào)用Connection::send后立刻被觸發(fā)，比如發(fā)送大數(shù)據(jù)或者連續(xù)快速的向?qū)Χ税l(fā)送數(shù)據(jù)，由于網(wǎng)絡(luò)等原因數(shù)據(jù)被大量積壓在對應(yīng)連接的發(fā)送緩沖區(qū)，當超過TcpConnection::$maxSendBufferSize上限時觸發(fā)。

當發(fā)生onBufferFull事件時，開發(fā)者一般需要采取措施，例如停止向?qū)Χ税l(fā)送數(shù)據(jù)，等待發(fā)送緩沖區(qū)的數(shù)據(jù)被發(fā)送完畢(onBufferDrain事件)等。

當調(diào)用Connection::send($A)后導(dǎo)致觸發(fā)onBufferFull時，不管本次send的數(shù)據(jù)$A多大，即使大于TcpConnection::$maxSendBufferSize，本次要發(fā)送的數(shù)據(jù)仍然會被放入發(fā)送緩沖區(qū)。也就是說發(fā)送緩沖區(qū)實際放入的數(shù)據(jù)可能遠遠大于TcpConnection::$maxSendBufferSize，當發(fā)送緩沖區(qū)的數(shù)據(jù)已經(jīng)大于TcpConnection::$maxSendBufferSize時，仍然繼續(xù)Connection::send($B)數(shù)據(jù)，則這次send的$B數(shù)據(jù)不會放入發(fā)送緩沖區(qū)，而是被丟棄掉，并觸發(fā)onError回調(diào)。

總結(jié)來說，只要發(fā)送緩沖區(qū)還沒滿，哪怕只有一個字節(jié)的空間，調(diào)用Connection::send($A)肯定會把$A放入發(fā)送緩沖區(qū)，如果放入發(fā)送緩沖區(qū)后，發(fā)送緩沖區(qū)大小超過了TcpConnection::$maxSendBufferSize限制，則會觸發(fā)onBufferFull回調(diào)。

回調(diào)函數(shù)的參數(shù)

$connection

連接對象，即TcpConnection實例，用于操作客戶端連接，如發(fā)送數(shù)據(jù)，關(guān)閉連接等

范例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onBufferFull = function(TcpConnection $connection)
{
    echo "bufferFull and do not send again\n";
};
// 運行worker
Worker::runAll();

提示：除了使用匿名函數(shù)作為回調(diào)，還可以參考這里使用其它回調(diào)寫法。

參見

onBufferDrain 當連接的應(yīng)用層發(fā)送緩沖區(qū)數(shù)據(jù)全部發(fā)送完畢時觸發(fā)