<?php
require_once './workman/Autoloader.php';

use Workerman\Worker;
// use Workerman\WebServer;

// run MainThread
$tcp_worker = new Worker ( "tcp://0.0.0.0:2347" );
// MainThread
$tcp_worker->onMessage = function ($connection, $data) {
	// child Thread
	var_dump ( $data );
	$arr = array (
			'tag' => 'Test msg',
			'type' => 'from server',
			'data' => $data 
	);
	$connection->send ( json_encode ( $arr, JSON_UNESCAPED_UNICODE ) );
	// $connection->send ( "this is Msg from Server" );
	// $connection->send ( $data );
};

Worker::runAll ();
 

客戶端程式碼