发表新帖

reids无法正确读取数据

### 问题描述
redis 无法正确读取出数据，websocket启动后，一分钟内会有1000个用户连接上，前1分钟可以正确读取出数据，是一个json字符串，但是一分钟之后，读取出来的数据是类似 :5814 +OK 这种莫名奇妙的字符串

Redis服务使用的是腾讯云的云redis，但是使用自己安装的redis一样有问题

redis类是用的是thinkphp5.0 的二次封装 Cache类，但是使用最原始的new \redis（）一样不行

### Swoole版本，PHP版本，以及操作系统版本信息
Swoole版本 ：4
PHP版本 :7.2
Redis：腾讯云

### 相关代码
```php
<?php

namespace app\swoole\service;

use app\outpatient\model\Outpatient;
use think\Cache;

class Ws
{
    public $server;

public $redis;

public function __construct()
    {

$this->server = new \Swoole\WebSocket\Server("0.0.0.0", 8881);

$this->server->set([
            'daemonize' => 0, //守护进程
//            'reactor_num' => swoole_cpu_num() * 4,  //设置启动的 Reactor 线程数
//            'worker_num' => swoole_cpu_num() * 1000, //设置启动的 Worker 进程数。
//            'max_connection' => 1000000,             //服务器程序，最大允许的连接数
            'log_file' => ROOT_PATH . 'websocket_log',
//            'log_rotation' => SWOOLE_LOG_ROTATION_HOURLY, //设置 Server 日志分割
            'heartbeat_idle_time' => 600, // 表示一个连接如果600秒内未向服务器发送任何数据，此连接将被强制关闭
            'heartbeat_check_interval' => 60,  // 表示每60秒遍历一次
            'task_worker_num' => 1,  // 表示每60秒遍历一次
        ]);

//建立连接
        $this->server->on('open', function (\Swoole\WebSocket\Server $server, $request) {

});

//接收消息
        $this->server->on('message', function (\Swoole\WebSocket\Server $server, $frame) {

$result = $this->redis->get("outpatient:7:info");
            dump($result);
            if (!empty($result)) {
                return json_decode($result,true);
            }

$outpatientModel = new Outpatient();
            $outpatient = $outpatientModel->where('id', 7)->find();
            if (empty($outpatient)) {
                return false;
            }
            $outpatient = $outpatient->toArray();
            $this->redis->set("outpatient:7:info", json_encode($outpatient), 86400 * 3);
        });

//断开连接
        $this->server->on('close', function (\Swoole\WebSocket\Server $server, $fd) {

});

//处理异步任务
        $this->server->on('task', function ($serv, $task_id, $from_id, $data) {

});

//处理异步任务的结果
        $this->server->on('finish', function ($serv, $task_id, $data) {

});
        $this->server->start();
    }
}
```

### 你期待的结果是什么？实际看到的错误信息又是什么？

发布于3年前 · 23 次浏览 · 来自提问

.co