执行Redis订阅后,无法执行其他操作了

发表新帖

hkargv

11天前

### 问题描述

执行Redis订阅后,无法执行其他操作了
### Swoole版本，PHP版本，以及操作系统版本信息
swoole-4.5.7 
php-7.4.12
CentOS 8

### 相关代码
```php
<?php
error_reporting(0);
if (php_sapi_name() !== 'cli') {
    die();
}

$a = swoole_get_local_ip();
$ip = $a['ens32'] ? $a['ens32'] : $a['eth0'];

try {
    $server = new Swoole\WebSocket\Server($ip, 843, SWOOLE_PROCESS, SWOOLE_SOCK_TCP | SWOOLE_SSL);
} catch (Exception $e) {
    echo $e->getMessage();
    die();
}
$GLOBALS['server'] = $server;
$server->set([
    'daemonize' => false,
    'pid_file' => '/tmp/qot_websocket_server1.pid',
    'log_file' => '/tmp/qot_websocket_server1.log',
    'worker_num' => 1,
    'ssl_cert_file' => __DIR__ . '/../config/fullchain.pem',
    'ssl_key_file' => __DIR__ . '/../config/privkey.pem'
]);
$server->on('open', function (Swoole\WebSocket\Server $server, Swoole\Http\Request $request) {
    $GLOBALS["fd"] = $request->fd;
    $redis = new Redis();
    $redis->connect('/tmp/redis.sock');
    $redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
    $redis->subscribe(['order'], function ($redis, $chan, $msg) {
        var_dump($redis);
        var_dump($chan);
        var_dump($msg);
        $GLOBALS['server']->push($GLOBALS["fd"], $msg);
    });
});
$server->on('message', function (Swoole\WebSocket\Server $server, Swoole\WebSocket\Frame $frame) {
    echo 'OK'; //客户端发消息过来,不会输出
});
$server->on('close', function (Swoole\WebSocket\Server $server, $fd, $reactorId) {});
$server->start();
```

### 你期待的结果是什么？实际看到的错误信息又是什么？
期待echo 'OK';被执行,实际未被执行
另外请看下$GLOBAL是不是这么用的

2020-11-17

鲁飞

2020-11-18

hkargv

```php
<?php
error_reporting(0);
if (php_sapi_name() !== 'cli') {
    die();
}

$a = swoole_get_local_ip();
$ip = $a['ens32'] ? $a['ens32'] : $a['eth0'];

Co::set(['hook_flags'=> SWOOLE_HOOK_ALL]);

try {
    $server = new Swoole\WebSocket\Server($ip, 843, SWOOLE_PROCESS, SWOOLE_SOCK_TCP | SWOOLE_SSL);
} catch (Exception $e) {
    echo $e->getMessage();
    die();
}
$server->set([
    'daemonize' => false,
    'pid_file' => '/tmp/qot_websocket_server1.pid',
    'log_file' => '/tmp/qot_websocket_server1.log',
    'worker_num' => 1,
    'ssl_cert_file' => __DIR__ . '/../config/fullchain.pem',
    'ssl_key_file' => __DIR__ . '/../config/privkey.pem'
]);
$server->on('open', function (Swoole\WebSocket\Server $server, Swoole\Http\Request $request) {
    $redis = new Redis();
    $redis->connect('/tmp/redis.sock');
    $redis->setOption(Redis::OPT_READ_TIMEOUT, -1);
    $redis->subscribe(['order'], function ($redis, $chan, $msg) use ($server, $request) {
        var_dump($redis);
        var_dump($chan);
        var_dump($msg);
        $server->push($request->fd, $msg);
    });
});
$server->on('message', function (Swoole\WebSocket\Server $server, Swoole\WebSocket\Frame $frame) {
    echo 'OK'; //客户端发消息过来,正常输出
});
$server->on('close', function (Swoole\WebSocket\Server $server, $fd, $reactorId) {});
$server->start();
```

今天深入学习了一下协程,发现有一个 一键协程 功能
于是在第十行加入: Co::set(['hook_flags'=> SWOOLE_HOOK_ALL]);

发现不堵塞了,我用这个实现是否是正确的?谢谢

2020-11-18

鲁飞回复 hkargv

2020-11-17

hkargv

2020-11-17

鲁飞回复 hkargv