关于php:ThinkPHP6和GatewayWorker简单的示例

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

// 创立一个webSocket对象const ws = new WebSocket("ws:192.168.3.116:8502");const token = {    name:''};// 创立VUE对象const app = new Vue({    el:"#app",    data () {        return {            information:[],            content:"",            name:'',            Client_id:0,        };    },    created:function(){        let that = this;        ws.onmessage = e => {            //console.log((new Date()).getTime());            const receiveing = JSON.parse(e.data);            if (receiveing.type=="start"){                this.Client_id = receiveing.client_id;                $.ajax({                    type: "post",                    url: "//192.168.3.122:83/api/Swoole/index",                    data: {                        Client_id:receiveing.client_id,                    },                    dataType: "json",                    success: function (data) {                        //console.log(3);                        that.information.push(data);                        that.name = data.name;                    }                });            }else {                console.log(2);                this.information.push(receiveing);                console.log(this.information);            }        };        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);    }})

</script>
复制代码
页面就本人写基本功能进去了，剩下的依据本人的需要来改

最初
如果你感觉此文对你有一丁点帮忙，点个赞。或者能够退出我的开发交换群：1025263163互相学习，咱们会有业余的技术答疑解惑

如果你感觉这篇文章对你有点用的话，麻烦请给咱们的开源我的项目点点star:http://github.crmeb.net/u/defu不胜感激！

PHP学习手册：https://doc.crmeb.com
技术交换论坛：https://q.crmeb.com