• 技术文章 >php框架 >Laravel

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

    藏色散人藏色散人2021-04-29 09:01:28转载187
    下面由laravel教程栏目给大家介绍laravel使用workerman用户交互、服务器交互,希望对需要的朋友有所帮助!

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

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

    一、安装workerman

    composer require workerman/workerman

    二、生成命令文件

    php artisan make:command Workerman

    修改文件

    <?php
    namespace 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 --daemonize
    Deprecated: 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 status
    none                 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 用户交互、服务器交互

    结语

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

    以上就是解析laravel使用workerman用户交互、服务器交互的详细内容,更多请关注php中文网其它相关文章!

    声明:本文转载于:learnku,如有侵犯,请联系admin@php.cn删除
    专题推荐:laravel
    上一篇:详解怎么在Laravel中创建自己的PHP帮助函数 下一篇:你知道为什么Laravel会重复执行同一个队列任务吗?
    第16期线上培训班

    相关文章推荐

    • laravel8.0 + vue 安装方法详解• 介绍Laravel unit test : 模拟认证的用户• 关于 Laravel Hprose RPC 服务• 详解怎么在Laravel中创建自己的PHP帮助函数

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网