onMessage

Описание:

callback Worker::$onMessage

Функция обратного вызова, срабатывающая при получении данных от клиента через соединение (когда Workerman получает данные).

Параметры функции обратного вызова

$connection

Объект соединения, то есть экземпляр TcpConnection, используемый для управления клиентским соединением, такой как отправка данных, закрытие соединения и т. д.

$data

Данные, присланные клиентским соединением. Если Worker определяет протокол, то $data является декодированными данными соответствующего протокола. Тип данных зависит от реализации метода decode() протокола, например, для websocket, text и frame данные представлены строкой, а для протокола HTTP - объектом Workerman\Protocols\Http\Request.

Пример

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

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onMessage = function(TcpConnection $connection, $data)
{
    var_dump($data);
    $connection->send('receive success');
};
// Запуск worker
Worker::runAll();

Примечание: помимо использования анонимной функции в качестве обратного вызова, также можно посмотреть здесь, где представлены другие способы обратного вызова.