onBufferFull

설명:

callback Worker::$onBufferFull

각 연결에는 개별 애플리케이션 계층 전송 버퍼가 있으며, 클라이언트의 수신 속도가 서버의 전송 속도보다 느린 경우 데이터가 애플리케이션 계층 버퍼에 임시 저장됩니다. 만약 버퍼가 가득 차면 onBufferFull 콜백이 호출됩니다.

버퍼 크기는 TcpConnection::$maxSendBufferSize로 설정되며, 기본값은 1MB입니다. 현재 연결의 버퍼 크기를 동적으로 설정할 수 있습니다. 예를 들어:

// 현재 연결 전송 버퍼 설정, 단위 바이트
$connection->maxSendBufferSize = 102400;

모든 연결의 기본 버퍼 크기를 TcpConnection::$defaultMaxSendBufferSize를 이용해 설정할 수도 있습니다. 예를 들어:

use Workerman\Connection\TcpConnection;
// 모든 연결의 기본 애플리케이션 계층 전송 버퍼 크기 설정, 단위 바이트
TcpConnection::$defaultMaxSendBufferSize = 2*1024*1024;

이 콜백은 어쩌면 Connection::send 호출 직후에 즉시 호출될 수 있습니다. 예를 들어 큰 데이터 전송이나 빠르게 상대방에게 데이터를 연속으로 전송하는 경우, 네트워크 등의 이유로 데이터가 해당 연결의 전송 버퍼에 대량으로 쌓이게 되어 TcpConnection::$maxSendBufferSize 한계를 초과하면 호출됩니다.

onBufferFull 이벤트가 발생할 때, 개발자는 일반적으로 조치를 취해야 합니다. 예를 들어 상대방에게 데이터 전송을 중단하거나 전송 버퍼의 데이터가 모두 전송될 때까지 기다리는 것(onBufferDrain 이벤트) 등이 있습니다.

Connection::send($A)를 호출하여 onBufferFull이 발생하면, 이번 전송 데이터 $A가 얼마든지, 심지어 TcpConnection::$maxSendBufferSize보다 크더라도, 이번 전송 데이터는 전송 버퍼에 여전히 저장됩니다. 즉, 전송 버퍼에 실제로 저장되는 데이터는 TcpConnection::$maxSendBufferSize보다 훨씬 클 수 있으며, 전송 버퍼의 데이터가 이미 TcpConnection::$maxSendBufferSize를 초과한 상태에서 계속 Connection::send($B) 데이터를 전송하면, 이번 전송 데이터 $B는 전송 버퍼에 저장되지 않고 버려지며, onError 콜백이 호출됩니다.

요약하자면, 전송 버퍼가 아직 가득 차지 않으면 단 한 바이트의 공간만 있어도 Connection::send($A)를 호출하면 반드시 $A가 전송 버퍼에 저장됩니다. 만약 전송 버퍼에 저장된 후 전송 버퍼의 크기가 TcpConnection::$maxSendBufferSize 제한을 초과하면 onBufferFull 콜백이 호출됩니다.

콜백 함수의 매개변수

$connection

연결 객체, 즉 TcpConnection 인스턴스로, 클라이언트 연결을 조작하는 데 사용됩니다. 예를 들어 데이터 전송, 연결 종료 등.

예제

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::runAll();

팁: 익명 함수를 콜백으로 사용하는 것 외에도 여기를 참조하여 다른 콜백 작성 방법을 사용할 수 있습니다.

참조

onBufferDrain 연결의 애플리케이션 계층 전송 버퍼 데이터가 모두 전송 완료될 때 발생합니다.