hyperf框架WebSocket 服务
1：安装
composer require hyperf/websocket-server
2：配置 Server 修改 config/autoload/server.php，增加以下配置。
return ['servers' => [['name' => 'ws','type' => Server::SERVER_WEBSOCKET,'host' => '0.0.0.0','port' => 9502,'sock_type' => SWOOLE_SOCK_TCP,'callbacks' => [Event::ON_HAND_SHAKE => [Hyperf\WebSocketServer\Server::class, 'onHandShake'],Event::ON_MESSAGE => [Hyperf\WebSocketServer\Server::class, 'onMessage'],Event::ON_CLOSE => [Hyperf\WebSocketServer\Server::class, 'onClose'],],],],
];
3：配置路由 在 config/routes.php 文件内增加对应 ws 的 Server 的路由配置，这里的 ws 值取决于您在 config/autoload/server.php 内配置的 WebSocket Server 的 name 值。
Router::addServer('ws', function () {Router::get('/', 'App\Controller\WebSocketController');
});4：创建控制器
<?php
declare(strict_types=1);namespace App\Controller;use Hyperf\Contract\OnCloseInterface;
use Hyperf\Contract\OnMessageInterface;
use Hyperf\Contract\OnOpenInterface;
use Hyperf\WebSocketServer\Constant\Opcode;
use Swoole\Server;
use Swoole\WebSocket\Server as WebSocketServer;class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
{public function onMessage($server, $frame): void{// $frame->data 前端发过来的数据$data = ["小敏!","小明","小米","华维","苹果"];$rand = rand(0,4);$server->push($frame->fd, '后端: ' . $data[$rand]);}public function onClose($server, int $fd, int $reactorId): void{echo $fd . '断开连接,处理线程是 ' . $reactorId . PHP_EOL;}public function onOpen($server, $request): void{$server->push($request->fd, $request->fd . ' 号客户端已连接!' . PHP_EOL);}
}
5：前端页面测试
<!doctype html>
<html lang="en">
<head><meta charset="UTF-8"><meta name="viewport"content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0"><meta http-equiv="X-UA-Compatible" content="ie=edge"><title>websocket</title>
</head>
<body>
<div><textarea name="content" id="content" cols="30" rows="10"></textarea><button onclick="send();">发送</button>
</div>
<ul id="messageList"></ul><script>let ws = new WebSocket('ws://127.0.0.1:9101')ws.onopen = event => {console.log('连接服务器成功');}ws.onmessage = event => {let data = event.data;let ul = document.getElementById('messageList');let li = document.createElement('li');li.innerHTML = data;ul.appendChild(li);}ws.onclose = event => {console.log('客户端连接关闭');}function send() {let obj = document.getElementById('content');let content = obj.value;let ul = document.getElementById('messageList');let li = document.createElement('li');li.innerHTML = "我："+content;ul.appendChild(li);ws.send(content);obj.value = '';}
</script>
</body>
</html>
相关文章：
hyperf框架WebSocket 服务
1：安装 composer require hyperf/websocket-server2：配置 Server 修改 config/autoload/server.php，增加以下配置。 return [servers > [[name > ws,type > Server::SERVER_WEBSOCKET,host > 0.0.0.0,port > 9502,sock_typ…...
前端模块化
当我们从公司招聘上看到要求模块化的内容。 能从这几个角度回答，就说明我们是懂模块化的。 1. 模块化的本意，是当遇到一个复杂项目的时候（简单的不建议用），把这个复杂的问题拆分成相对独立的模块，降低程序…...
如何使用Docker轻松构建和管理应用程序（一）
如今Docker的使用已经非常普遍，特别在一线互联网公司。使用Docker技术可以帮助企业快速水平扩展服务，从而到达弹性部署业务的能力。在云服务概念兴起之后，Docker的使用场景和范围进一步发展，如今在微服务架构越来越流行的情况下&a…...
uniapp 获取地理位置（uni#getLocation和高德sdk获取中文地址）
参考 https://uniapp.dcloud.net.cn/api/location/location.html https://ask.dcloud.net.cn/article/35070 1. uniapp api获取经纬度 uni.getLocation({type: wgs84,success: function (res) {console.log(当前位置的经度： res.longitude);console.log(当前位…...
openmp 通用核心 学习 2 数据环境—任务-内存模型
目录 openmp 数据环境 子句： 在上述三个子句中也可以传入指针和数组 openmp 任务： openmp内存模型： openmp 数据环境 子句： shared(list) private(list)//默认构造 值未被初始化 对于图6-5： //File #1 int tm…...
Linux有哪些指令
Linux操作系统提供了许多指令，可以帮助用户进行各种操作。以下是一些常见的Linux指令： ls：列出当前目录下的文件和目录。cd：改变当前工作目录。pwd：显示当前工作目录。mkdir：创建新的目录。rm：…...
图扑 HT for Web 风格属性手册教程
图扑软件明星产品 HT for Web 是一套纯国产化独立自主研发的 2D 和 3D 图形界面可视化引擎。HT for Web（以下简称 HT）图元的样式由其 Style 属性控制，并且不同类型图元的 Style 属性各不相同。为了方便查询和理解图元的 Style 属性࿰…...
oracle 数据库删除序列
oracle 数据库删除序列 要删除 Oracle 数据库中的序列，你可以使用以下的 SQL 命令： DROP SEQUENCE sequence_name;其中，sequence_name 是你想删除的序列的名称。你需要确保当前用户对序列拥有适当的权限。 请注意，删除序列将永…...
JAVA毕业设计098—基于Java+Springboot的在线教育课程视频(源码+数据库)
基于JavaSpringboot的在线教育课程视频(源码数据库)098 一、系统介绍 本系统分为管理员、教师、用户三种角色(角色菜单可自行分配) 用户功能： 注册、登录、课程搜索、视频观看、课程资料发布、资料浏览、用户中心、我的发布、通知信息、密码修改 教师功能&…...
如何在雷电模拟器上安装Magisk并加载movecert模块抓https包（二）
接来下在PC端安装和配置Charles，方法同下面链接，不再赘述。在模拟器上安装magisk实现Charles抓https包（二）_小小爬虾的博客-CSDN博客 一、记录下本机IP和代理端口 二、在手机模拟器上设置代理192.168.31.71:8888，设置…...
基于web的酒店客房管理系统
目录 前言 一、技术栈 二、系统功能介绍 用户信息管理 会员信息管理 客房信息管理 收藏客房管理 用户入住管理 客房清扫管理 三、核心代码 1、登录模块 2、文件上传模块 3、代码封装 前言 随着信息技术在管理上越来越深入而广泛的应用，管理信息系统的实施…...
linux查看系统信息
Linux查看当前操作系统版本信息 cat /proc/version Linux version 2.6.32-696.el6.x86_64 (mockbuildc1bm.rdu2.centos.org) (gcc version 4.4.7 20120313 (Red Hat 4.4.7-18) (GCC) ) #1 SMP Tue Mar 21 19:29:05 UTC 2017 Linux查看版本当前操作系统内核信息 uname -a Linux…...
蓝牙官网demo的记录
目录 一、官网蓝牙demo 二、可以参考的博客带蓝牙demo 一、官网蓝牙demo 平常看android官网，发现有两个不同的文档地址： 连接 | Android 开源项目 | Android Open Source Project 蓝牙概览 | Connectivity | Android Developers 蓝牙demo在 …...
Linux相关概念及常见指令
注意：本篇博客除了讲解Linux的相关指令，还穿插着Linux相关概念及原理的讲解。 账号相关指令 whoami:查看当前用户 adduser 用户名: 添加新用户 passwd 用户名：为这个用户设置密码 ls指令 1.Linux中文件的理解 文件是Linux中存储数据的基本单…...
CentOS 系统如何在防火墙开启端口
在 CentOS 上，你可以使用 firewall-cmd 命令来开启防火墙的特定服务或端口。以下是在 CentOS 上开启 3306 端口的步骤： 检查防火墙状态：可以使用以下命令检查防火墙的状态： sudo firewall-cmd --state如果防火墙处于活动状态&…...
2023年电工（初级）证考试题库及电工（初级）试题解析
题库来源：安全生产模拟考试一点通公众号小程序 2023年电工（初级）证考试题库及电工（初级）试题解析是安全生产模拟考试一点通结合（安监局）特种作业人员操作证考试大纲和（质检局&#…...
vue拦截器是什么，如何使用
Vue拦截器是一种用来拦截并处理HTTP请求和响应的机制，它可以在请求或响应发送前或后进行一些预处理或处理。在Vue中，可以使用axios库来实现拦截器，axios库是一个基于Promise的HTTP客户端，可以用于浏览器和Node.js平台。 使用axio…...
CSS 之 table 表格布局
一、简介 除了使用HTML的<table>元素外，我们还可以通过display: table/inline-table; 设置元素内部的布局类型为表格布局。并结合table-cell、table-row等相关CSS属性值可以实现HTML中<table>系列元素的效果，具有表头、表尾、行、单元格…...
【Kotlin精简】第2章 集合
1 简介 在 Kotlin 中集合主要分为可变集合与只读集合，其中可变集合使用 “Mutable” 前缀 集合类名表示，比如 MutableList、MutableSet、MutableMap 等。而对于只读集合就是和 Java 中集合类名是一致。 Java 中的 List 非 Kotlin 中的 List , 因为 Kot…...
VSCODE+PHP8.2配置踩坑记录
VSCODEPHP8.2配置踩坑记录 – WhiteNights Site 我配置过的最恶心的环境之一：windows上的php。另一个是我centos服务器上的php。 进不了断点 端口配置和xdebug的安装 这个应该是最常见的问题了。从网上下载完php并解压到本地，打开vscode，安装…...
【Linux】shell脚本忽略错误继续执行
在 shell 脚本中，可以使用 set -e 命令来设置脚本在遇到错误时退出执行。如果你希望脚本忽略错误并继续执行，可以在脚本开头添加 set e 命令来取消该设置。 举例1 #!/bin/bash# 取消 set -e 的设置 set e# 执行命令，并忽略错误 rm somefile…...
AtCoder 第409场初级竞赛 A~E题解
A Conflict 【题目链接】 原题链接：A - Conflict 【考点】 枚举 【题目大意】 找到是否有两人都想要的物品。 【解析】 遍历两端字符串，只有在同时为 o 时输出 Yes 并结束程序，否则输出 No。 【难度】 GESP三级 【代码参考】 #i…...
Python实现prophet 理论及参数优化
文章目录 Prophet理论及模型参数介绍Python代码完整实现prophet 添加外部数据进行模型优化 之前初步学习prophet的时候，写过一篇简单实现，后期随着对该模型的深入研究，本次记录涉及到prophet 的公式以及参数调优，从公式可以更直观…...
oracle与MySQL数据库之间数据同步的技术要点
Oracle与MySQL数据库之间的数据同步是一个涉及多个技术要点的复杂任务。由于Oracle和MySQL的架构差异，它们的数据同步要求既要保持数据的准确性和一致性，又要处理好性能问题。以下是一些主要的技术要点： 数据结构差异 数据类型差异ÿ…...
k8s业务程序联调工具-KtConnect
概述 原理 工具作用是建立了一个从本地到集群的单向VPN，根据VPN原理，打通两个内网必然需要借助一个公共中继节点，ktconnect工具巧妙的利用k8s原生的portforward能力，简化了建立连接的过程，apiserver间接起到了中继节…...
uniapp中使用aixos 报错
问题： 在uniapp中使用aixos，运行后报如下错误： AxiosError: There is no suitable adapter to dispatch the request since : - adapter xhr is not supported by the environment - adapter http is not available in the build 解决方案&…...
是否存在路径（FIFOBB算法）
题目描述 一个具有 n 个顶点e条边的无向图，该图顶点的编号依次为0到n-1且不存在顶点与自身相连的边。请使用FIFOBB算法编写程序，确定是否存在从顶点 source到顶点 destination的路径。 输入 第一行两个整数，分别表示n 和 e 的值（1…...
项目部署到Linux上时遇到的错误（Redis，MySQL，无法正确连接，地址占用问题）
Redis无法正确连接 在运行jar包时出现了这样的错误 查询得知问题核心在于Redis连接失败，具体原因是客户端发送了密码认证请求，但Redis服务器未设置密码 1.为Redis设置密码（匹配客户端配置） 步骤： 1）.修…...
2025季度云服务器排行榜
在全球云服务器市场，各厂商的排名和地位并非一成不变，而是由其独特的优势、战略布局和市场适应性共同决定的。以下是根据2025年市场趋势，对主要云服务器厂商在排行榜中占据重要位置的原因和优势进行深度分析： 一、全球“三巨头”…...
JAVA后端开发——多租户
数据隔离是多租户系统中的核心概念，确保一个租户（在这个系统中可能是一个公司或一个独立的客户）的数据对其他租户是不可见的。在 RuoYi 框架（您当前项目所使用的基础框架）中，这通常是通过在数据表中增加一个…...