/publish post: {"channel":"....","content":"...."} * 给所有客户端发送消息接口: http:///publish post: {"content":"...."} * @package app\http\command */ class SocketIO extends Command { /** * @var object */ protected $io = null; /** * 命令行配置 * * @author 许祖兴 < zuxing.xu@lettered.cn> * @date 2020/3/26 20:14 * @return void */ protected function configure() { $this->setName('mni:socket') ->addArgument('action', Argument::REQUIRED, "start | restart | reload | stop | status | connetions") ->addOption('mode', '-m', Option::VALUE_OPTIONAL, 'Start in daemon mode or debug mode') ->setDescription('phpsocket.io'); } /** * 执行方法 * * @author 许祖兴 < zuxing.xu@lettered.cn> * @date 2020/3/26 20:15 * * @param Input $input * @param Output $output * @return int|void|null */ protected function execute(Input $input, Output $output) { global $argv; // 命令行适配 linux $argv[1] = $input->getArgument('action'); // start | restart | reload(平滑重启) | stop | status | connetions // die; // 默认执行模式 if (!empty($input->getOption('mode'))){ if (!in_array($input->getOption('mode'),['daemon','debug'])){ $output->writeln('mode must be daemon or debug'); die; } $argv[2] = '-d'; } // PHPSocketIO服务 $this->io = new ISocketIO(2120); $this->io->on('connection', function($socket) { $socket->on('disconnect', function () use($socket) { }); }); // 当$sender_io启动后监听一个http端口，通过这个端口可以给任意uid或者所有uid推送数据 $this->io->on('workerStart', function(){ // 监听一个http端口 $inner_http_worker = new Worker('http://0.0.0.0:2121'); // 当http客户端发来数据时触发 $inner_http_worker->onMessage = function(TcpConnection $http_connection, Request $request){ $post = $request->post(); $post = $post ? $post : $request->get(); // 推送处理 if (!empty($post )){ $this->io->emit('message', $post); return $http_connection->send('ok'); } return $http_connection->send('fail'); }; // 执行监听 $inner_http_worker->listen(); }); Worker::runAll(); } }