首页
仓库
文档
nginx手册
Docker手册
workerman
Flask
PHP
python
RabbitMQ
其他
Linux
占位1
占位2
目录
###服务端 ```php <?php use Workerman\Worker; use Workerman\Connection\TcpConnection; require_once __DIR__ . '/vendor/autoload.php'; // 注意:这里与上个例子不同,使用的是websocket协议 $worker = new Worker("websocket://0.0.0.0:4333"); // 启动4个进程对外提供服务 $worker->count = 1; $worker->onConnect = function(TcpConnection $connection) use($worker) { echo "new user : " .$worker->id.'-'. $connection->id.'-'. $connection->getRemoteIp() . "\n"; }; // 当收到客户端发来的数据后返回hello $data给客户端 $worker->onMessage = function(TcpConnection $connection, $json) use ($worker) { file_put_contents('log_'.date('d').'.txt',$json." ==>".date('Y-m-d G:i:s')."\r\n",FILE_APPEND); echo date('Y-n-j g:i:s')."======> from :".$worker->id.'-'.$connection->id.'--->'.$json."\n"; $connection->send($json.' -- 123'); echo "=====================================================> \n"; }; $worker->onClose = function(TcpConnection $connection)use($worker) { echo "connection closed".$worker->id.'-'. $connection->id."\n"; }; $worker->onError = function(TcpConnection $connection, $code, $msg) { echo "error $code $msg\n"; }; // 运行worker Worker::runAll(); ```