ThinkPHP6 和 GatewayWorker 简单的示例

作者：💥 玩命不玩心💥

2022 年 1 月 17 日
本文字数：2588 字
阅读完需：约 8 分钟

1.下载 GatewayWorker www.workerman.net/doc/gateway…

安装如图下载解压就行

以次开启端口： 8282，1238，2900，2901，2902，2903

启动以 debug（调试）方式启动

php start.php start

以 daemon（守护进程）方式启动

php start.php start -d

停止 php start.php stop

重启 php start.php restart

平滑重启 php start.php reload

查看状态 php start.php status

debug 和 daemon 方式区别 1、以 debug 方式启动，代码中 echo、var_dump、print 等打印函数会直接输出在终端。

2、以 daemon 方式启动，代码中 echo、var_dump、print 等打印会默认重定向到/dev/null 文件，可以通过设置 Worker::$stdoutFile = '/your/path/file';来设置这个文件路径。

3、以 debug 方式启动，终端关闭后 workerman 会随之关闭并退出。

4、以 daemon 方式启动，终端关闭后 workerman 继续后台正常运行。

业务开发只需要关注 Applications/项目/Events.php 一个文件即可。

2.默认 ThinkPHP6 已经安装好了安装扩展

composer require workerman/gatewayclient 复制代码创建一个控制器

namespace app\api\controller;

use GatewayClient\Gateway;use think\Request;use think\facade\db;USE think\facade\Cookie;

class Swoole extends Base{public function initialize(){header('Access-Control-Allow-Origin: *');header("Access-Control-Allow-Headers: token,random,Origin, X-Requested-With, Content-Type, Accept");header('Access-Control-Allow-Methods: POST,GET');if(request()->isOptions()){exit();}Gateway::$registerAddress = "192.168.3.116:1238";}

public function index(Request $request){    $post = $request->post();    $user = Db::name('user')->field('id,name')->where('status',0)->find();    if (!$user) {        $data = [            'style'=>'yue',//you            'data' => '人数已满，你连个屁',            'name' => '机器人'
        ];        return json($data);
    }    Db::name('user')->where('id',$user['id'])->update(['client_id'=>$post['Client_id'],'status'=>1]);    $data = [        'style'=>'me',//you        'data' => '链接成功',        'name' => $user['name']    ];    return json($data);}
public function send(Request $request){    $post = $request->post();    $name = Db::name('user')->field('name')->where('client_id',$post['client_id'])->find();    $cid = Db::name('user')->where('status',1)->where('client_id','<>',$post['client_id'])->select();    $data = json_encode([        'style'=>'yue',//you        'data' => $post['msg'],        'name' => $name['name']    ]);    $c_id = [];    foreach ($cid as $v){        $c_id[] = $v['client_id'];    }    Gateway::sendToAll($data,$c_id);    return json($data);}
public function close(Request $request){    $post = $request->param();    Db::name('user')->where('client_id',$post['Client_id'])->update(['client_id'=>'','status'=>0]);}

复制代码

}复制代码后台代码就完成了

前端代码 js

        };        ws.onclose = data => {            // 监听连接关闭            console.log("WebSocket连接已关闭");            console.log((new Date()).getTime());            $.ajax({                type: "post",                url: "//192.168.3.122:83/api/swoole/close",                data: {                    Client_id:this.Client_id,
                },                dataType: "json",                success: function (data) {
                }            });            //console.log(data);        };
    },    methods:{        send:function () {            $.ajax({                type: "post",                url: "//192.168.3.122:83/api/swoole/send",                data: {                    msg:this.content,                    client_id:this.Client_id,                },                dataType: "json",                success: function (data) {                    //console.log(data.data);                    //that.information.push(data.data);                }            });            this.information.push({style:'me',data:this.content,name:this.name});            this.content="";
        },        close:function(){            ws.close();        },        heartbeat:function () {            ws.send("1")        },
    },    beforeUpdate:function(){        setInterval(this.heartbeat,14000);    }})