发表新帖

swoole_table的应用场景是什么？我现在做一个视频弹幕功能，能否用到swoole_table?

### 问题描述
swoole_table的应用场景是什么？我现在做一个视频弹幕功能，能否用到swoole_table?

### Swoole版本，PHP版本，以及操作系统版本信息
php7.1 centos7

### 相关代码
```php
请将代码粘贴至此处（请勿用截图）
```
/**
     * 建立连接
     * @method onOpen
     * @author chengzhigang<1256699215@qq.com>
     */
    public function onOpen($serv, $request)
    {
        Log::info('onOpen');
        $param = $request->get;
        $room_id = $param['room_id'];
        $result = $this->getRoomSpeck($serv,$room_id);
        $this->addRoom($room_id,$request->fd);//加入房间
        return ['status'=>1,'msg'=>'请求成功','data'=>['active'=>'connect','data'=>$result]];
    }

public function onMessage($serv, $frame)
    {
        $data = json_decode($frame->data,true);
        $room_id = $data['room_id'];
        $result = [];
        if($data['active']=='speck'){
            $result = $this->addSpeck($room_id,$frame->fd,$data);
        }
        return ['status'=>1,'msg'=>'请求成功','data'=>['active'=>$data['active'],'data'=>$result]];
    }

//加入房间
    public function addRoom($room_id,$fd){
        $roomInfo = [
            'room_id' => $room_id,
            'fd' => $fd,
            'nick_name' => createNickname()
        ];
        Redis::hSet('Room:'.$room_id,$fd,json_encode($roomInfo));
    }

//删除弹幕
    public function clearRoomSpeck($serv,$room_id){
        $fds = Redis::hKeys('Room:'.$room_id);
        foreach ($fds as $fd) {
            Redis::del('Speck:' . $room_id.':'.$fd);
        }
    }

//获取历史弹幕
    public function getRoomSpeck($serv,$room_id){
        $historySpeck = [];
        $fds = Redis::hKeys('Room:'.$room_id);
        foreach ($fds as $fd) {
            $speckData = Redis::lRange('Speck:' . $room_id.':'.$fd,0,-1);
            foreach($speckData as $v){
                $historySpeck[] = $v;
            }
        }
        return $historySpeck;
    }

//存储弹幕
    public function addSpeck($room_id,$fd,$data){
        $speckInfo = [
            'room_id' => $room_id,
            'fd' => $fd,
            'msg' => $data['msg'],
            'time' => $data['time'],
            'speed' => $data['speed'],
            'color' => $data['color']
        ];
        Redis::rPush('Speck:'.$room_id.':'.$fd,json_encode($speckInfo));
        return $speckInfo;
    }

### 你期待的结果是什么？实际看到的错误信息又是什么？
上面的代码我其实已经实现了弹幕功能，建立连接时将用户加入房间，发送弹幕时存储弹幕信息，用了两个redis分别存储用户信息和弹幕信息，即使重启websocket，数据也是不会丢失的。
但是我想用swoole_table,不知道重启websocket后，table中的数据是否会丢失，而且table存储数据方式是key-value形式的，无法像redis的list方法存储弹幕信息。不知道用swoole_table能否实现上述的弹幕功能，能实现的话具体怎么实现？不能实现的话，swoole_table的应用场景在哪？

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