onBufferFull

說明:

callback Worker::$onBufferFull

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

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

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

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

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

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

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

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

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

回調函數(shù)的參數(shù)

$connection

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

范例

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ù)作為回調，還可以參考這里使用其它回調寫法。

參見

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