onMessage

Giới thiệu:

callback Connection::$onMessage

Chức năng giống như callback của Worker::$onMessage, điểm khác biệt là chỉ có hiệu lực đối với kết nối hiện tại, tức là có thể thiết lập callback onMessage cho một kết nối cụ thể.

Ví dụ

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

$worker = new Worker('websocket://0.0.0.0:8484');
// Khi có sự kiện kết nối từ khách hàng
$worker->onConnect = function(TcpConnection $connection)
{
    // Thiết lập callback onMessage cho kết nối
    $connection->onMessage = function(TcpConnection $connection, $data)
    {
        var_dump($data);
        $connection->send('receive success');
    };
};
// Chạy worker
Worker::runAll();

Mã ở trên có hiệu ứng giống như mã bên dưới

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

$worker = new Worker('websocket://0.0.0.0:8484');
// Thiết lập callback onMessage cho tất cả các kết nối
$worker->onMessage = function(TcpConnection $connection, $data)
{
    var_dump($data);
    $connection->send('receive success');
};
// Chạy worker
Worker::runAll();