pauseRecv

Mô tả:

void Connection::pauseRecv(void)

Làm cho kết nối hiện tại ngừng nhận dữ liệu. Callback onMessage của kết nối này sẽ không được kích hoạt. Phương thức này rất hữu ích cho việc kiểm soát lưu lượng tải lên.

Tham số

Không có tham số

Ví dụ

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

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onConnect = function($connection)
{
    // Thêm một thuộc tính cho đối tượng connection để lưu trữ số lượng yêu cầu đã nhận từ kết nối hiện tại
    $connection->messageCount = 0;
};
$worker->onMessage = function(TcpConnection $connection, $data)
{
    // Mỗi kết nối sẽ không nhận thêm dữ liệu sau khi nhận 100 yêu cầu
    $limit = 100;
    if(++$connection->messageCount > $limit)
    {
        $connection->pauseRecv();
    }
};
// Chạy worker
Worker::runAll();

Tham khảo

void Connection::resumeRecv(void) Làm cho đối tượng kết nối tương ứng phục hồi việc nhận dữ liệu.