发表新帖

MQTT 添加配置后，无响应，这是为什么？

### 问题描述
终端运行：telnet 127.0.0.1 9501 无响应

[root@VM_0_8_centos ~]# telnet 127.0.0.1 9501
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
222

### 相关代码
```php
    //多进程管理模块                                                                                              
    $pool = new Swoole\Process\Pool(2);  
    //让每个OnWorkerStart回调都自动创建一个协程                                                                                         
    $pool->set(['enable_coroutine' => true, 'open_mqtt_protocol' => true]);                                                                                     
    $pool->on("workerStart", function ($pool, $id) {                                            
        //每个进程都监听9501端口
        $server = new Swoole\Coroutine\Server('127.0.0.1', '9501' , false, true);                                      
        //收到15信号关闭服务                                                              
        Swoole\Process::signal(SIGTERM, function () use ($server) {                                                                      
            $server->shutdown();                                                                                                  
        });
        //接收到新的连接请求                                                                                                                       
        $server->handle(function (Swoole\Coroutine\Server\Connection $conn) {                                                                             
            //接收数据                                                                                                    
            $data = $conn->recv();                                                                                                
            if (empty($data)) {
                //关闭连接                                                                                                   
                $conn->close();                                                                                                   
            } 
            //发送数据                                                                                                                    
            $conn->send("hellooooooo");                                                                    
        });
        //开始监听端口                                                                                                                       
        $server->start();                                                                                                         
    });                                                                                                                           
    $pool->start(); 
 
```

发布于4年前 · 1 次浏览 · 来自提问