<?phpuseWorkerman\Worker; require_once'./Workerman/Autoloader.php'; // Create a Websocket server$ws_worker = newWorker("websocket://0.0.0.0:2346"); // 4 processes$ws_worker->count = 4; // Emitted when new connection come$ws_worker->onConnect = function($connection){echo"New connection\n"}; // Emitted when data received$ws_worker->onMessage = function($connection, $data){// Send hello $data$connection->send('hello ' . $data)}; // Emitted when connection closed$ws_worker->onClose = function($connection){echo"Connection closed\n"}; // Run worker Worker::runAll();

require_once'./Workerman/Autoloader.php'; useWorkerman\Worker; // #### http worker ####$http_worker = newWorker("http://0.0.0.0:2345"); // 4 processes$http_worker->count = 4; // Emitted when data received$http_worker->onMessage = function($connection, $data){// $_GET, $_POST, $_COOKIE, $_SESSION, $_SERVER, $_FILES are availablevar_dump($_GET, $_POST, $_COOKIE, $_SESSION, $_SERVER, $_FILES); // send data to client$connection->send("hello world \n")}; // run all workers Worker::runAll();

require_once'./Workerman/Autoloader.php'; use \Workerman\WebServer; // WebServer$web = newWebServer("http://0.0.0.0:80"); // 4 processes$web->count = 4; // Set the root of domains$web->addRoot('www.your_domain.com', '/your/path/Web'); $web->addRoot('www.another_domain.com', '/another/path/Web'); // run all workers Worker::runAll();

require_once'./Workerman/Autoloader.php'; useWorkerman\Worker; // #### create socket and listen 1234 port ####$tcp_worker = newWorker("tcp://0.0.0.0:1234"); // 4 processes$tcp_worker->count = 4; // Emitted when new connection come$tcp_worker->onConnect = function($connection){echo"New Connection\n"}; // Emitted when data received$tcp_worker->onMessage = function($connection, $data){// send data to client$connection->send("hello $data\n")}; // Emitted when new connection come$tcp_worker->onClose = function($connection){echo"Connection closed\n"}; Worker::runAll();

namespaceProtocols; /** * User defined protocol * Format Text+"\n" */class MyTextProtocol{publicstaticfunctioninput($recv_buffer){// Find the position of the first occurrence of "\n"$pos = strpos($recv_buffer, "\n"); // Not a complete package. Return 0 because the length of package can not be calculatedif($pos === false){return0} // Return length of the packagereturn$pos+1} publicstaticfunctiondecode($recv_buffer){returntrim($recv_buffer)} publicstaticfunctionencode($data){return$data."\n"} }

require_once'./Workerman/Autoloader.php'; useWorkerman\Worker// #### MyTextProtocol worker ####$text_worker = newWorker("MyTextProtocol://0.0.0.0:5678"); $text_worker->onConnect = function($connection){echo"New connection\n"}; $text_worker->onMessage = function($connection, $data){// send data to client$connection->send("hello world \n")}; $text_worker->onClose = function($connection){echo"Connection closed\n"}; // run all workers Worker::runAll();

require_once'./Workerman/Autoloader.php'; useWorkerman\Worker; useWorkerman\Lib\Timer; $task = newWorker(); $task->onWorkerStart = function($task){// 2.5 seconds$time_interval = 2.5; $timer_id = Timer::add($time_interval, function(){echo"Timer run\n"} )}; // run all workers Worker::runAll();

<?phpuseWorkerman\Worker; $worker = newWorker('tcp://0.0.0.0:1234'); $worker->count=3; $worker->onMessage = function($connection, $data){$connection->send("HTTP/1.1 200 OK\r\nConnection: keep-alive\r\nServer: workerman\1.1.4\r\n\r\nhello")}; Worker::runAll();