workerman 实现推送实时数据到前端

首先要说明一下,实时推送是有两个socket服务端和两个socket的客户端
我们分别起名叫做
外层服务端 (开启服务主进程 创建一个 websoket 连接)ws://
内层服务端 (在开户主进程的时候,内部又创建的一个 socket)text://
外层客户端 (这是由前端的用户端 使用js 创建的一个 websocket 客户端)
内层客户端 (这是php 使用 stream_socket_client 创建的一个客户端)

上代码(说明在代码的注释中)
服务端代码 (websocket 的创建)

  1. 安装 workerman (因为使用的是 tp框架,所以安装的 topthink/think-worker ,它已经包含了 workerman)
composer install topthink/think-worker

这个服务端是一个 挂起的操作, 所以不需要过 tp 的入口文件,直接使用 php 命令行运行就可以了
本人在 app\worker\Testworker.php 新建了这个服务端的文件

require __DIR__ . '/../../vendor/autoload.php';   //因为是独立运行的,所以要引入 autoload.php
use Workerman\Worker;
$worker = new Worker("websocket://0.0.0.0:2345");   //创建了一个 websocket 的服务端,端口是 2345 (记得打开阿里云 或 宝塔的 2345端口)
$worker->count=1; //count属性windows中的配置就写1  linux中可以配多个$worker->uidConnections = [];  //自定义了一个空数组,用来存放所有的 连接对象//当连接成功时
$worker->onConnect = function($connection){dump($connection);//这里只是显示一下连接是否成功,没有什么作用
};//workerman 收到消息时的监听,前端可能发过来不同种类的消息,所以消息上都带有type字段,根据 type 类型的不同做相应的处理
//参数 $connection 表示 这个 websocket连接的资源操作符 是一个非常有用的数据后续我们是在保存起来的
//参数 $msg 就是前端发过来的数据 格式是 {type:"bind",uid:1},自已定义就可以了 我这里bind就是绑定用户的意思
$worker->onMessage = function($connection,$msg) use ($worker){$msg = json_decode($msg,true);if($msg["type"] == "bind"){//如果前端传来的消息类型是 bind 就是绑定用户的消息类型if(!isset($connection->uid)){$connection->uid<

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/12859.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

论文阅读 - Anatomy of an AI-powered malicious social botnet

论文链接&#xff1a; https://arxiv.org/pdf/2307.16336.pdf 目录 摘要 1引言 2 相关工作 2.1 LLM驱动的网络威胁 2.2 LLM生成的内容检测 2.3 社交机器人检测 2.4 由 LLM 增强的机器人 3 Fox8僵尸网络的识别 4 特性 4.1 配置文件 4.2 社交网络 4.3内容类型 4.4放…

lightdb plorasql存储过程支持SQLCODE和SQLERRM

文章目录 背景用法总结 背景 LightDB PLOraSQL存储过程在执行异常时支持通过sqlcode和sqlerrm拿到错误码和错误信息&#xff0c;这点与Oracle是类似的。但是在Oracle中存储过程未执行异常也能获取到错误码和错误信息&#xff0c;而LightDB会找不到对应的变量。因此计划在24.2版…

性能测试学习二

瓶颈的精准判断 TPS曲线 tps图 响应时间图 拐点在哪里呢? 这是一个阶梯式增加的场景,拐点在第二个压力阶梯上就出现了,因为响应时间增加了,tps增加的却不多,在第三个阶段时,tps增加的就更少了,响应时间也在不断增加,所以性能瓶颈在加剧,越往后越明显【tps的增长,…

Windows下编译RTTR

虽然C11引入了RTTI、Metaprogramming 等技术&#xff0c;但C在Reflection编程方面依旧功能有限。在社区上&#xff0c;RTTR则提供了一套C编写的反射库&#xff0c;补充了C在Reflection方面的缺陷。 零、环境 操作系统Windows 11Visual StudioVisual Studio Community 2022 CMa…

C++ STL概念之 迭代器

什么是迭代器 迭代器&#xff08;Iterator&#xff09;是一个在容器中访问元素的对象&#xff0c;提供了一种方法来顺序访问容器中的元素&#xff0c;而无需暴露容器的底层表示。 或者说 行为像指针一样的类型。可能是指针也可能是被类封装的指针&#xff0c;不关注容器底层细…

搭建内网穿透服务(frp)

搭建内网穿透服务(frp&#xff09; 一、为什么 在平时工作当中&#xff0c;我们经常会遇到需要将自己本地的服务暴露在公网上&#xff0c;方便与他人进行接口对接、或者进行演示等等&#xff0c;虽然有一些免费的内网穿透服务&#xff0c;但是大都很不稳定或者带宽太低&#x…

让调用者自己干活的特殊线程池

让调用者自己干活的特殊线程池 1. 相关背景 单元测试时, 我们的某些业务代码可能是在线程池中运行的&#xff0c;可能会出现各种不一致的情况。 这时候可以hack一下, 创建一个调用者直接执行的线程池&#xff0c;避免干扰; 2. 实现代码 import java.util.concurrent.*;// 让…

【永洪BI】资源导出

路径&#xff1a;管理系统>资源部署>资源导出 1.页面介绍 选择左侧面板中的管理系统&#xff0c;点击资源部署&#xff0c;选择资源导出&#xff0c;进入资源导出页面。 【名称】导出的 jar 文件的名称&#xff0c;必填项。 【描述】导出的 jar 文件中包含的描述信息…

Gateway基本配置的参数以及yml示例

Spring Cloud Gateway作为API网关&#xff0c;可以通过配置文件来定义路由规则、过滤器和相关参数。 参入如下&#xff1a; routes: 定义了一组路由规则&#xff0c;每个路由规则包含了路由的ID、目标URI、断言集合和过滤器集合。 id: 路由的唯一标识符&#xff0c;用于区分不同…

华为昇腾310B1平台视频解码失败[ERROR] Send frame to vdec failed, errorno:507018

目录 1 [ERROR] Send frame to vdec failed, errorno:507018 2 bug解决尝试1 3 bug解决尝试2 4 最终解决方法 参考文献&#xff1a; 1 [ERROR] Send frame to vdec failed, errorno:507018 某项目中的代码运行报错 [ERROR] Send frame to vdec failed, errorno:507018 Ac…

Linux系统 -目录结构与配网

目录的特点 Windows中有C盘、D盘等&#xff0c;每个都是一个根系统是个多根系统 Linux中只有一个根是个单根系统 Linux-目录存储的内容 1、/root&#xff1a;管理员的家目录 2、/home&#xff1a;存储普通用户家目录的目录/3、/tmp&#xff1a;临时目录&#xff0c;这个目录存储…

linux系统管理面试题

用户管理&#xff1a; 1. 如何在Linux中创建一个新用户并设置密码&#xff1f; 在Linux中创建一个新用户并设置密码&#xff0c;可以使用以下步骤&#xff1a; 打开终端或命令行界面。使用root权限登录或使用sudo命令获取管理员权限。运行以下命令来创建新用户&#xff08;将…

了解 Robot Framework :接口自动化测试教程!

开源自动化测试利器&#xff1a;Robot Framework Robot Framework 是一个用于实现自动化测试和机器人流程自动化&#xff08;RPA&#xff09;的开放源代码框架。它由一个名为 Robot Framework Foundation 的组织得到推广&#xff0c;得到了多家领军企业在软件开发中的广泛应用。…

运营商三要素核验接口如何对接

运营商三要素核验接口又叫运营商手机号三要素验证接口、运营商手机号实名认证接口、运营商手机号三要素核验接口&#xff0c;指的是输入姓名、身份证号码及手机号&#xff0c;通过运营商数据库实时校验此三项是否匹配。那么运营商三要素核验接口如何对接呢&#xff1f; 首先我…

Java SE入门及基础(51) Queue 接口 比较器接口

目录 Queue 接口 1. 特性描述 Queue 接口常用方法 2. LinkedBlockingQueue 用法示例 3. PriorityQueue 用法示例 思考&#xff1a;如果 PriorityQueue 队列中存储的是对象&#xff0c;会怎么排序&#xff1f; 比较器接口 1. 比较器接口的作用 2. Comparable 接口 示…

【设计模式】JAVA Design Patterns——Abstract Factory(抽象工厂模式)

&#x1f50d;目的 提供一个用于创建相关对象家族的接口&#xff0c;而无需指定其具体类 &#x1f50d;解释 真实世界例子 要创建一个王国&#xff0c;我们需要具有共同主题的对象。精灵王国需要精灵国王、精灵城堡和精灵军队&#xff0c;而兽人王国需要兽人国王、兽人城堡和兽…

项目路由分模块A模块B模块C......模块N使用

路由分模块原因&#xff1a; vue框架中会有router文件&#xff0c;但是路由文件下只有一个路由文件&#xff0c;在实际项目开发中会有多人负责多模块的情况&#xff0c;若都在一个文件内编辑路由名称&#xff0c;就相当于是机房里的数据线&#xff0c;会很乱七八糟&#xff0c;…

1. go语言初识(一)

本篇博客涉及到的内容&#xff1a;变量和常量、iota常量生成器、类型转换 变量&#xff08;Variables&#xff09;和常量&#xff08;Constants&#xff09; 变量&#xff08;Variables&#xff09; 1. 定义变量 在Go中&#xff0c;可以使用’var‘关键字来声明一个变量&…

【十大排序算法】----选择排序(详细图解分析+实现,小白一看就会)

目录 一&#xff1a;选择排序——原理 二&#xff1a;选择排序——分析 三&#xff1a;选择排序——实现 四&#xff1a;选择排序——优化 五&#xff1a;选择排序——效率 一&#xff1a;选择排序——原理 选择排序的原理&#xff1a;通过遍历数组&#xff0c;选出该数组…

使用Docker配置深度学习环境——以diffusers为例

Docker的其他信息可以在我的网站上找到&#xff0c;这里假设安装完成了&#xff0c;直接上手。 git clone 仓库地址打开docker目录&#xff0c;找到目标版本&#xff1a; sudo docker build diffusers-pytorch-cuda如果失败&#xff0c;尝试使用换源&#xff1a; sudo nano …