资讯专栏INFORMATION COLUMN

Swoole WebSocket 的应用

Wildcard / 1752人阅读

摘要:概述这是关于学习的第三篇文章的应用。第二篇的应用第一篇的应用什么是是一种在单个连接上进行全双工通信的协议。如果想了解的知识,请看第二篇的应用。温馨提示本仅仅是简单的实现,如需应用到真实场景中还要多做优化。

概述

这是关于 Swoole 学习的第三篇文章:Swoole WebSocket 的应用。

第二篇:Swoole Task 的应用

第一篇:Swoole Timer 的应用

什么是 WebSocket ?

WebSocket 是一种在单个TCP连接上进行全双工通信的协议。

WebSocket 使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。

在 WebSocket API 中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。

我们利用 WebSocket 进行及时通讯,今天实现一个 视频弹幕效果

实现弹幕其实就和群聊类似,将消息推送给所有的客户端,只不过前端的展示所有不同。

本地版本:

后端 PHP 7.2.6、Swoole 4.3.1。

前端 HTML5 WebSocket、Canvas。

废话不多说,先看效果。

批量版:

手动版:

代码

server.php

serv = new swoole_websocket_server("0.0.0.0", 9501);
        $this->serv->set([
            "worker_num"      => 2, //开启2个worker进程
            "max_request"     => 4, //每个worker进程 max_request设置为4次
            "task_worker_num" => 4, //开启4个task进程
            "dispatch_mode"   => 4, //数据包分发策略 - IP分配
            "daemonize"       => false, //守护进程(true/false)
        ]);

        $this->serv->on("Start", [$this, "onStart"]);
        $this->serv->on("Open", [$this, "onOpen"]);
        $this->serv->on("Message", [$this, "onMessage"]);
        $this->serv->on("Close", [$this, "onClose"]);
        $this->serv->on("Task", [$this, "onTask"]);
        $this->serv->on("Finish", [$this, "onFinish"]);

        $this->serv->start();
    }

    public function onStart($serv) {
        echo "#### onStart ####".PHP_EOL;
        echo "SWOOLE ".SWOOLE_VERSION . " 服务已启动".PHP_EOL;
        echo "master_pid: {$serv->master_pid}".PHP_EOL;
        echo "manager_pid: {$serv->manager_pid}".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onOpen($serv, $request) {
        echo "#### onOpen ####".PHP_EOL;
        echo "server: handshake success with fd{$request->fd}".PHP_EOL;
        $serv->task([
            "type" => "login"
        ]);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onTask($serv, $task_id, $from_id, $data) {
        echo "#### onTask ####".PHP_EOL;
        echo "#{$serv->worker_id} onTask: [PID={$serv->worker_pid}]: task_id={$task_id}".PHP_EOL;
        $msg = "";
        switch ($data["type"]) {
            case "login":
                $msg = "我来了...";
                break;
            case "speak":
                $msg = $data["msg"];
                break;
        }
        foreach ($serv->connections as $fd) {
            $connectionInfo = $serv->connection_info($fd);
            if ($connectionInfo["websocket_status"] == 3) {
                $serv->push($fd, $msg); //长度最大不得超过2M
            }
        }
        $serv->finish($data);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onMessage($serv, $frame) {
        echo "#### onMessage ####".PHP_EOL;
        echo "receive from fd{$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}".PHP_EOL;
        $serv->task(["type" => "speak", "msg" => $frame->data]);
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onFinish($serv,$task_id, $data) {
        echo "#### onFinish ####".PHP_EOL;
        echo "Task {$task_id} 已完成".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }

    public function onClose($serv, $fd) {
        echo "#### onClose ####".PHP_EOL;
        echo "client {$fd} closed".PHP_EOL;
        echo "########".PHP_EOL.PHP_EOL;
    }
}

$server = new Server();

index.php



    
        
        
        
        
        
        
        视频弹幕Demo
        
    
    
        
        
            

小结

一、单聊提供了方法,群聊提供方法了吗?

官方没有提供群聊的方法,使用循环实现的。

单聊:

$serv->push($fd, $msg);

群聊:

foreach ($serv->connections as $fd) {
    $serv->push($fd, $msg);
}

二、发送消息为什么要放到Task中,封装一个普通方法不行吗?

不能封装成一个普通的方法,要放在Task中使用多进程执行。

如果想了解 Swoole Task 的知识,请看: 第二篇:Swoole Timer 的应用。

三、如何模拟批量弹幕效果?

可以使用 swoole_timer_tick ,比如:

swoole_timer_tick(50, function () use($serv){
    $serv->task([
        "type" => "login"
    ]);
});

四、前端使用的哪个弹幕插件?还有没有其他的?

canvasBarrage.js:

http://www.zhangxinxu.com/wor...

有其他的,比如:

Jquery.barrager.js

Jquery.danmu.js

DanMuer.js

根据自己喜欢风格,进行尝试吧。

五、Demo 中视频全屏后,还显示弹幕吗?

不显示。

当点击如上图中的 “全屏” 时,弹幕就不显示了,因为这时全屏的视频已经脱离了HTML文档,具体能否实现大家可以研究研究(记得考虑 PC、Android、iOS 等兼容性)。

也可以用“伪全屏”进行实现,自定义一个全屏按钮,点击时让当前页面全屏,同时让视频尺寸变大。

六、看了这篇文章,单聊和群聊都会了,能实现一个在线IM吗?

不能。

真正使用的在线IM系统,需求落地时比我们想象到要复杂的多,自己深入研究没问题,想开发一套生产环境用的IM系统,需要慎重,特别是后端用PHP。

如果急需在线IM系统,可以使用市面上专业的IM系统。

七、弹幕有什么应用场景?

比如,办年会或活动开场时大家可以利用弹幕活跃气氛,使用微信扫码登录后进行发送实时弹幕,还可以应用到直播,只要觉得合理都可以使用。

八、Swoole WebSocket 入门还可以实现什么案例?

可以实现聊天室功能、直播功能、扫码登录功能等。

温馨提示

本 Demo 仅仅是简单的实现,如需应用到真实场景中还要多做优化。

需要Demo源码的,关注公众号,回复“swoole 弹幕”即可。

推荐阅读

系统的讲解 - SSO 单点登录

系统的讲解 - PHP WEB 安全防御

系统的讲解 - PHP 缓存技术

系统的讲解 - PHP 接口签名验证

系统的讲解 - PHP 浮点数高精度运算

本文欢迎转发,转发请注明作者和出处,谢谢!

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/31460.html

相关文章

  • php只能做网站?基于swoole+websocket开发双向通信应用

    摘要:那么,是否就无法用来开发双向通信的应用呢答案是否定的。内置通信支持,可以与程序基于进行双向通信。通信协议于年被定为标准,并由补充规范。前言 众所周知,PHP用于开发基于HTTP协议的网站应用非常便捷。而HTTP协议是一种单向的通信协议,只能接收客户端的请求,然后响应请求,不能主动向客户端推送信息。因此,一些实时性要求比较高的应用,如实时聊天、直播应用、在线网页游戏等,就不适合采用HTTP协议...

    番茄西红柿 评论0 收藏0
  • php只能做网站?基于swoole+websocket开发双向通信应用

    摘要:那么,是否就无法用来开发双向通信的应用呢答案是否定的。内置通信支持,可以与程序基于进行双向通信。通信协议于年被定为标准,并由补充规范。前言 众所周知,PHP用于开发基于HTTP协议的网站应用非常便捷。而HTTP协议是一种单向的通信协议,只能接收客户端的请求,然后响应请求,不能主动向客户端推送信息。因此,一些实时性要求比较高的应用,如实时聊天、直播应用、在线网页游戏等,就不适合采用HTTP协议...

    琛h。 评论0 收藏0
  • 压测 swoole_websocket_server 性能

    摘要:概述这是关于入门学习的第十篇文章压测性能。测试机上安装的虚拟机系统内存数量核数数量大小代码压测脚本并发量请求量压测结果第次第次第次以上是压测结果,供参考。小结通过这个压测结果,表明的执行效率是杠杠的当然还有一些参数是可以调优的,比如等。 概述 这是关于 Swoole 入门学习的第十篇文章:压测 swoole_websocket_server 性能。 第九篇:Swoole Redis ...

    余学文 评论0 收藏0
  • swoolefy-基于swoole扩展实现高性能常驻内存型API和Web应用服务框架

    摘要:是一个基于扩展实现的轻量级高性能的常驻内存型的和应用服务框架高度封装了,,服务器,以及基于实现可扩展的服务,同时支持包方式安装部署项目。基于实用,抽象事件处理类,实现与底层的回调的解耦,支持同步异步调用,内置等常用组件等。 swoolefy swoolefy是一个基于swoole扩展实现的轻量级高性能的常驻内存型的API和Web应用服务框架,高度封装了http,websocket,ud...

    lewinlee 评论0 收藏0
  • Swoole 整合成一个小框架

    摘要:概述这是关于学习的第六篇文章整合成一个小框架。相关配置,在文件夹。代码放不全,就放一个主要的文件吧。当然我自己也会继续完善它,后期的一些新知识点会集成到这里面,做成自己迭代的小项目。初版比较糙,不喜勿喷。后期会新增需要源码的,加我微信吧。 概述 这是关于 Swoole 学习的第六篇文章:Swoole 整合成一个小框架。 第五篇:Swoole 多协议 多端口 的应用 第四篇:Swool...

    bergwhite 评论0 收藏0

发表评论

0条评论

Wildcard

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<