解析laravel使用workerman用户交互、服务器交互

2022-05-15 0 544

下面由laravel教程栏目给大家介绍laravel使用workerman用户交互、服务器交互,希望对需要的朋友有所帮助!

laravel使用workerman 用户交互、服务器交互

使用workeman实现浏览器相互通信、服务器浏览器交互

一、安装workerman

composer require workerman/workerman

二、生成命令文件

php artisan make:command Workerman

修改文件

<?phpnamespace App\\Console\\Commands;use Illuminate\\Console\\Command;use Workerman\\Worker;class Workerman extends Command{    protected $signature = 'Workerman {action} {--daemonize}';    protected $description = 'Command description';    public function __construct()    {        parent::__construct();    }    public function handle()    {        global $argv;//定义全局变量        $arg = $this->argument('action');        $argv[1] = $arg;        $argv[2] = $this->option('daemonize') ? '-d' : '';//该参数是以daemon(守护进程)方式启动        global $text_worker;        // 创建一个Worker监听2345端口,使用websocket协议通讯        $text_worker = new Worker("websocket://0.0.0.0:2345");        $text_worker->uidConnections = array();//在线用户连接对象        $text_worker->uidInfo = array();//在线用户的用户信息        // 启动4个进程对外提供服务        $text_worker->count = 4;        //当启动workerman的时候 触发此方法        $text_worker->onWorkerStart =function(){        };        //当浏览器连接的时候触发此函数        $text_worker->onConnect = function($connection){        };        //向用户发送信息的时候触发        //$connection 当前连接的人的信息 $data 发送的数据        $text_worker->onMessage = function($connection,$data){        };        //浏览器断开链接的时候触发        $text_worker->onClose = function($connection){};    }}

三、启动命令

$ php artisan Workerman start --daemonizeDeprecated: Directive 'track_errors' is deprecated in Unknown on line 0----------------------- WORKERMAN -----------------------------Workerman version:4.0.19          PHP version:7.2.9------------------------ WORKERS -------------------------------worker               listen                              processes statusnone                 websocket://0.0.0.0:2345            4         [ok]

四、浏览器之间通信

1. HTML代码 两个html做交互
 var socket = new WebSocket("ws://localhost:2345//ws");         // 建立连接时触发 建立链接的时候,需要向workerman发送一条指令,告诉他我是谁,使用id或者用户标识作为uid,告诉workerman 例如,当前html 用户id是37         socket.onopen = function(event) {            console.log('连接开始...');            socket.send('{"uid":36,"type":'login'}');         }         //workerman发送消息的时候,接收并打印         socket.onmessage = function(event) {            var msg = event.data;            console.log(msg );         }
2. 设置uid

浏览器发来了用户uid,需要workerman保留一下,网上有文档说在触发的时候保存,还有用session的,我试验了没成功,所有用浏览器建立链接的时候,向workerman发送一条信息来创建uid,在workerman上接收一下

//$connection 当前连接的人的信息 $data 发送的数据$text_worker->onMessage = function($connection,$data){      $data = json_decode($data);      if($data['type']=='login'){         $this->create_uid($connection,$data);      }};//创建uid方法 public function create_uid($connection,$data){        global $text_worker;        $connection->uid = $data['uid'];        //保存用户的uid        $text_worker->uidConnections["{$connection->uid}"] = $connection;        //向自己的浏览器返回创建成功的信息        $connection->send("用户:[{$connection->uid}] 创建成功");    }

这时候浏览器就会出现打印信息

解析laravel使用workerman用户交互、服务器交互

3. 向其他用户发送信息

向用户是37的浏览器发送信息

//js代码 socket.send('{"type":"login","to_uid":36,"uid":36,"message":"nihao"}'); //workerman  //$connection 当前连接的人的信息 $data 发送的数据        $text_worker->onMessage = function($connection,$data){            $data = json_decode($data,true);            var_dump($data);            if($data['type']=='login'){                $this->create_uid($connection,$data);            }            if($data['type']=='send_message'){                $this->send_message($connection,$data);            }        };        public function send_message($connection,$data){            global $text_worker;            if(isset($data['to_uid'])){            var_dump($data['to_uid']);            if(isset($text_worker->uidConnections["{$data['to_uid']}"])){                $to_connection=$text_worker->uidConnections["{$data['to_uid']}"];                $to_connection->send($data['uid'].$data['message']);            }        }    }

解析laravel使用workerman用户交互、服务器交互

五、服务器向浏览器通信

1. workeman监听一个本地发送的端口,在启动的时候
//当启动workerman的时候 触发此方法        $text_worker->onWorkerStart =function(){            //监听一个内部端口,用来接收服务器的消息,转发给浏览器            $inner_text_worker = new Worker('Text://127.0.0.1:5678');            $inner_text_worker->onMessage = function($connection_admin, $data)            {                global $text_worker;                // $data数组格式,里面有uid,表示向那个uid的页面推送数据                $data = json_decode($data, true);                var_dump($data);                $to_uid = $data['to_uid'];                var_dump($to_uid);                // 通过workerman,向uid的页面推送数据                // $ret = sendMessageByUid($uid, $buffer);                $connection = $text_worker->uidConnections[$to_uid];                $connection->send($buffer);                // 返回推送结果                $connection_admin->send(true ? 'ok' : 'fail');            };            $inner_text_worker->listen();        };//控制器代码class TestController extends Controller{    public function send(){        $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);        // 推送的数据,包含用户,表示是给这个用户推送        $data = array('uid'=>37,'group'=>'admin', 'message'=>'发送成功啦');        // 发送数据,注意5678端口是Text协议的端口,Text协议需要在数据末尾加上换行符        fwrite($client, json_encode($data)."\\n");}}

解析laravel使用workerman用户交互、服务器交互

结语

有不足之处,请大家指正!谢谢!

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

【声明:根据2013年1月30日《计算机软件保护条例》2次修订第17条规定: 为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存 储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬! 鉴于此,也希望大家按此说明研究软件!】
本站所有源码尽量保证原汁原味,如有特殊情况会作出声明及标注,网站资源不做任何二次加密(原版加密除外,不影响程序使用的不会做解密处理),方便您更好的学习参考。 在您的能力范围内,为了大环境的良性发展,请尽可能的选择正版资源。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

即刻码站__国内靠谱的站长资源下载平台 php教程 解析laravel使用workerman用户交互、服务器交互 https://www.jike1995.com/36554.html

常见问题
  • 本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用
查看详情
  • 最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度
查看详情

相关文章

发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务