<?php
use Workerman\Worker;
require_once './Workerman/Autoloader.php';
// 创建一个Worker监听2345端口,使用http协议通讯
$http_worker = new Worker("http://0.0.0.0:2345");
// 启动4个进程对外提供服务
$http_worker->count = 4;
// 接收到浏览器发送的数据时回复hello world给浏览器
$http_worker->onMessage = function($connection, $data)
{
// 向浏览器发送hello world
$connection->send('hello world');
};
// 运行worker
Worker::runAll();
手册中这个简单的实例中,
$http_worker->onMessage = function($connection, $data)
$connection
是从哪传过来的?
workerman框架传过来的。
在Connections/TcpConnection.php baseRead方法,
call_user_func($this->onMessage, $this, $parser::decode($one_request_buffer, $this));