onMessage

Açıklama:

callback Worker::$onMessage

Müşteri veri gönderdiğinde (Workerman veriyi aldığında) tetiklenen geri çağırma işlevi.

Geri Çağırma İşlevinin Parametreleri

$connection

Bağlantı nesnesi, yani TcpConnection örneği, müşteri bağlantısını yönetmek için kullanılmaktadır, örneğin veri göndermek, bağlantıyı kapatmak vb.

$data

Müşteri bağlantısı üzerinden gönderilen veri, eğer Worker protokolü belirlediyse, o zaman $data ilgili protokolün decode (çözümleme) edilmiş verisidir. Veri türü, protokolün decode() uygulamasına bağlıdır, websocket text frame bir dizedir, HTTP protokolü ise Workerman\Protocols\Http\Request nesnesidir.

Örnek

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');
};
// Çalıştırma
Worker::runAll();

Not: Anonim işlev kullanmanın yanı sıra, buraya bakarak diğer geri çağırma yazım şekillerini de kullanabilirsiniz.