WebSocket实战之————GatewayWorker使用笔记例子

本文涉及的产品
.cn 域名,1个 12个月
简介: 参考文档:http://www.workerman.net/gatewaydoc/目录结构├── Applications // 这里是所有开发者应用项目│ └── YourApp // 其中一个项目目录,目录名可以自定义│ ├── Events.

 参考文档:http://www.workerman.net/gatewaydoc/

目录结构

├── Applications // 这里是所有开发者应用项目
│   └── YourApp  // 其中一个项目目录,目录名可以自定义
│       ├── Events.php // 开发者只需要关注这个文件
│       ├── start_gateway.php // gateway进程启动脚本,包括端口号等设置
│       ├── start_businessworker.php // businessWorker进程启动脚本
│       └── start_register.php // 注册服务启动脚本
│
├── start.php // 全局启动脚本,此脚本会依次加载Applications/项目/start_*.php启动脚本
│
└── vendor    // GatewayWorker框架和Workerman框架源码目录,此目录开发者不用关心

!!!特别注意:

[1]客户端的事件及数据全部由Gateway转发给BusinessWorker处理,BusinessWorker默认调用Events.php中的onConnect onMessage onClose处理业务逻辑。

<script language="javascript" type="text/javascript">
    var $URL = "__APP__/Home/GatewayWorker/bindUid";
    // 与GatewayWorker建立websocket连接,域名和端口改为你实际的域名端口
    ws = new WebSocket("ws://127.0.0.1:8384");
    // 服务端主动推送消息时会触发这里的onmessage
    ws.onmessage = function(e){
        // json数据转换成js对象
        var data = eval("("+e.data+")");
        var type = data.type || '';
        switch(type){
            // Events.php中返回的init类型的消息,将client_id发给后台进行uid绑定
            case 'init':
                // 利用jquery发起ajax请求,将client_id发给后端进行uid绑定
                $.post($URL, {client_id: data.clientId}, function(data){}, 'json');
                break;
            default :
                alert(e.data);
        }
    };
</script>

[2]通过GatewayClient发送的数据不会经过Event.php,而是直接经由Gateway进程转发给客户端。GatewayClient无法接收客户端发来的数据。

Gateway::$registerAddress = '127.0.0.1:1236';
$message = [
            'type' => 4002,
            'clientId' => $clientId,
            'publish_time' => date('Y-m-d h:i:s', time())
        ];
Gateway::bindUid($clientId,$uid);
//在这里发送的信息是不走Event.php文件的,直接广播出去了
Gateway::sendToClient($clientId,json_encode($message));

如果GatewayClient和GatewayWorker不是在同一台服务器上,则需要先将start_gateway.php中的lanIp改成当前服务器的内网ip(如果不在一个内网可改成公网ip)。
如果GatewayClient和GatewayWorker在同一台服务器上运行,则不用做任何更改,直接按照示例使用GatewayClient即可。

一、start_gateway.php文件,这个文件是默认的文件,默认协议是text协议:

// gateway 进程,这里使用Text协议,可以用telnet测试
$gateway = new Gateway("Text://0.0.0.0:8383");

本地测试text协议是否正常命令:

telnet 127.0.0.1 8383

二、测试结果,启动服务器

输入命令:

telnet 127.0.0.1 8282

重新打开一个窗口:Windows 测试结果:

Linux测试结果:

测试成功:

三、自定义一个Websocket连接

例如:copy一个start_gateway_ws.php文件,如图所示:

修改文件内容:

// gateway_ws 进程
$gateway_ws = new Gateway("Websocket://0.0.0.0:8384");
// gateway名称,status方便查看
$gateway_ws->name = 'YourAppGatewayWS';

在HTMl页面调用:

<script language="javascript" type="text/javascript">
    var $URL = "__APP__/Home/GatewayWorker/bindUid";
    console.log($URL);
    // 与GatewayWorker建立websocket连接,域名和端口改为你实际的域名端口
    ws = new WebSocket("ws://127.0.0.1:8384");
    // 服务端主动推送消息时会触发这里的onmessage
    ws.onmessage = function(e){
        // json数据转换成js对象
        var data = eval("("+e.data+")");
        var type = data.type || '';
        switch(type){
            case 'init':
               $.post($URL,$data,success,'json');
                break;
            default :
                alert(e.data);
        }
    };

</script>

四、start_businessworker.php文件

注意:以上的HTML页面的WebSocket的端口号必须的同时对应哦!

// 服务注册地址
$worker->registerAddress = '你的外网IP地址:1236';

可以看出:start_register.php这个文件是专门管理其他的三个文件的

注意:一下的register和worker的这个注册地址必须是一样的,也就是说,worker的注册地址必须和register的一样的

// register 服务必须是text协议
$register = new Register('text://0.0.0.0:1236');
// 服务注册地址
$worker->registerAddress = '120.120.120.120:1236';

 例如在TP的Controller中使用的时候这样连接:调用的是这个文件中的地址(服务注册地址):start_businessworker.php

 Gateway::$registerAddress = '120.120.120.120:1236'; //这个链接的地址是start_register.php
 Gateway::bindUid($clientId,$uid);
 Gateway::sendToAll(json_encode($clientId));

 

目录
相关文章
|
2月前
|
前端开发 JavaScript Python
Python Web应用中的WebSocket实战:前后端分离时代的实时数据交换
在前后端分离的Web应用开发模式中,如何实现前后端之间的实时数据交换成为了一个重要议题。传统的轮询或长轮询方式在实时性、资源消耗和服务器压力方面存在明显不足,而WebSocket技术的出现则为这一问题提供了优雅的解决方案。本文将通过实战案例,详细介绍如何在Python Web应用中运用WebSocket技术,实现前后端之间的实时数据交换。
92 0
|
5月前
|
监控 前端开发 API
实战指南:使用Python Flask与WebSocket实现高效的前后端分离实时系统
【7月更文挑战第18天】构建实时Web应用,如聊天室,可借助Python的Flask和WebSocket。安装Flask及Flask-SocketIO库,创建Flask应用,处理WebSocket事件。前端模板通过Socket.IO库连接服务器,发送和接收消息。运行应用,实现实时通信。此示例展现了Flask结合WebSocket实现前后端实时交互的能力。
539 3
|
6月前
|
JavaScript 网络协议 前端开发
【Nodejs】WebSocket 全面解析+实战演练——(Nodejs实现简易聊天室)
【Nodejs】WebSocket 全面解析+实战演练——(Nodejs实现简易聊天室)
600 0
|
5月前
|
前端开发 JavaScript UED
Python Web应用中的WebSocket实战:前后端分离时代的实时数据交换
【7月更文挑战第16天】在前后端分离的Web开发中,WebSocket解决了实时数据交换的问题。使用Python的Flask和Flask-SocketIO库,后端创建WebSocket服务,监听并广播消息。前端HTML通过JavaScript连接到服务器,发送并显示接收到的消息。WebSocket适用于实时通知、在线游戏等场景,提升应用的实时性和用户体验。通过实战案例,展示了如何实现这一功能。
319 2
|
存储 数据安全/隐私保护
Netty实战(十三)WebSocket协议(一)
WebSocket 协议是完全重新设计的协议,旨在为 Web 上的双向数据传输问题提供一个切实可行的解决方案,使得客户端和服务器之间可以在任意时刻传输消息,因此,这也就要求它们异步地处理消息回执。
315 0
|
7月前
|
传感器 监控 网络协议
WebSocket 实战:构建高效的实时应用
WebSocket 实战:构建高效的实时应用
WebSocket 实战:构建高效的实时应用
|
7月前
|
前端开发 网络协议 Java
WebSocket理论和实战
WebSocket详解与实战操作
|
7月前
|
前端开发 Java Spring
WebSocket心跳机制(笔记大全)
WebSocket心跳机制(笔记大全)
1018 0
|
消息中间件 缓存 前端开发
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
2102 1
Springboot 整合 WebSocket ,使用STOMP协议 ,前后端整合实战 (一)
|
移动开发 前端开发 网络协议
WebSocket从入门到实战
WebSocket从入门到实战
278 0