讲师中心 微信公众号
AI工具推荐 视频效率加速

Node.js 结合 Web-STOMP 插件实现 Vue/React 前端直接订阅 RabbitMQ 实现实时弹幕

老杰小哥_7064

老杰小哥_7064

发布时间:2026-06-02 18:36:35

|

239人浏览过

|

来源于php中文网

原创

不能直接用 Web-STOMP 让 Vue/React 前端订阅 RabbitMQ 弹幕,因 RabbitMQ 默认禁用 STOMP 插件、未开放跨域、未配置 vhost 权限及用户认证,导致连接失败或 403;必须通过 Node.js 代理转发并统一处理鉴权、重连与消息格式。

node.js 结合 web-stomp 插件实现 vue/react 前端直接订阅 rabbitmq 实现实时弹幕

不能直接用 Web-STOMP 让 Vue/React 前端订阅 RabbitMQ 弹幕 —— RabbitMQ 的 STOMP over WebSocket 默认不开放跨域,且默认禁用 STOMP 插件、未配置 vhost 权限、缺少用户认证凭据,前端直连会卡在 WebSocket connection failed 或 403 Forbidden。

为什么 Web-STOMP 在浏览器里大概率连不上 RabbitMQ

RabbitMQ 自带的 web-stomp 插件只是把 STOMP 协议桥接到 WebSocket,它本身不处理:跨域(CORS)、身份校验(需显式启用 auth 机制)、vhost 权限绑定、心跳保活策略。前端用 new Stomp.Client() 直连 ws://rabbitmq:15674/ws 时,常见失败点包括:

  • 浏览器报错 Connection refused:RabbitMQ 未启用 web-stomp 插件(需运行 rabbitmq-plugins enable rabbitmq_web_stomp)
  • 返回 403 Forbidden:用户没有对应 vhost 的 configure/write/read 权限(例如 rabbitmqctl set_permissions -p / myuser ".*" ".*" ".*")
  • 连接立即关闭:STOMP 客户端未发送 CONNECT 帧,或帧格式错误(如缺少 login/passcode header)
  • 消息收不到:Exchange 绑定错误,或前端 subscribe 的 destination 路径与后端 routing key 不匹配(例如 RabbitMQ 默认 topic exchange 要求 /topic/danmaku,不是 /danmaku)

Node.js 必须做一层代理转发

绕过 RabbitMQ 的安全限制,最稳妥的方式是让 Node.js 充当 STOMP 客户端 + WebSocket 服务端:它用 stompit 连 RabbitMQ,再用 ws 或 express-ws 向前端暴露干净的 WebSocket 接口。这样能控制鉴权、重连、消息格式、错误降级。

  • 前端只连自己的 ws://your-api.com/danmaku,完全不感知 RabbitMQ
  • Node.js 用 stompit 连接 stomp://rabbitmq:61613,监听 /topic/danmaku
  • 收到弹幕后,Node.js 将其转成纯 JSON(去掉 STOMP headers),再 ws.send(JSON.stringify({content, color, time}))
  • 前端用原生 WebSocket 或 @stomp/stompjs 都可以,但推荐原生 —— 没必要再套一层 STOMP 解析逻辑

Vue/React 中建立弹幕连接的关键代码

前端不用碰 STOMP 协议细节。以 React 为例,在 useEffect 里管理连接即可:

Json Schema Toolkit
Json Schema Toolkit

使用 JSON Schema 验证 JSON 数据,从示例 JSON 生成 schema,并将其转换为 TypeScript 接口、Python 数据类或 Markdown 文档。

下载

立即学习“前端免费学习笔记(深入)”;

const danmuSocket = useRef(null);
<p>useEffect(() => {
danmuSocket.current = new WebSocket('ws://your-api.com/danmaku');</p><p>danmuSocket.current.onmessage = (e) => {
const msg = JSON.parse(e.data);
setDanmus(prev => [...prev.slice(-99), msg]); // 限制最多显示 100 条
};</p><p>danmuSocket.current.onclose = () => {
// 触发自动重连,但加退避(1s → 2s → 4s)
setTimeout(() => {
if (danmuSocket.current?.readyState !== WebSocket.OPEN) {
danmuSocket.current = new WebSocket('ws://your-api.com/danmaku');
}
}, 1000 * Math.min(4, reconnectCount));
};</p><p>return () => danmuSocket.current?.close();
}, [reconnectCount]);

注意:setDanmus 更新时别用 unshift,V8 对长数组头部插入性能差;slice(-99) 是简单有效的内存控制手段。

容易被忽略的 RabbitMQ 配置项

即使开了 web-stomp 插件,以下三项不配,前端永远连不上:

  • rabbitmqctl add_user myapp mypass:必须创建非 guest 用户(guest 只允许本地登录)
  • rabbitmqctl set_user_tags myapp management:赋予 management tag 才能使用 STOMP over WebSocket
  • rabbitmqctl set_permissions -p / myapp ".*" ".*" ".*":权限必须覆盖读写,且 -p / 要和你连接时指定的 vhost 一致

另外,RabbitMQ 的 web-stomp 默认监听 15674 端口,但该端口只响应 HTTP Upgrade 请求,不能直接用 fetch 或 XMLHttpRequest 访问 —— 它专为 WebSocket 设计,但依然要过权限关。

热门AI工具

更多
Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

相关专题

更多
python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2283

2023.08.11

前端如何实现即时通讯
前端如何实现即时通讯

实现即时通讯的方法有WebSocket、Long Polling、Server-Sent Events、WebRTC等等。详细介绍:1、WebSocket,它可以在客户端和服务器之间建立持久连接,实现实时的双向通信,前端可以使用 WebSocket API来创建WebSocket连接,并通过发送和接收消息来实现即时通讯;2、Long Polling,是一种模拟实时通信的技术等等。

4943

2023.10.09

前端和后端的区别
前端和后端的区别

前端关注的是用户界面的设计和交互,而后端则注重数据处理和逻辑控制。想了解更多前端后端的相关内容,可以阅读本专题下面的文章。

6030

2024.03.19

php和前端的关联介绍
php和前端的关联介绍

php既可以作为前端语言,也可以作为后端语言。想了解更多php和前端的相关内容,可以阅读本专题下面的文章。

5538

2024.03.22

前端外包工作内容有哪些
前端外包工作内容有哪些

前端外包工作内容包括:1. 网站和应用程序开发;2. 用户界面和交互设计;3. 用户体验优化;4. 设计和视觉开发;5. 跨浏览器兼容性;6. 性能优化;7. 维护和更新;8. 项目管理和沟通。想了解更多前端的相关内容,可以阅读本专题下面的文章。

783

2024.05.22

C语言变量命名
C语言变量命名

c语言变量名规则是:1、变量名以英文字母开头;2、变量名中的字母是区分大小写的;3、变量名不能是关键字;4、变量名中不能包含空格、标点符号和类型说明符。php中文网还提供c语言变量的相关下载、相关课程等内容,供大家免费下载使用。

2909

2023.06.20

c语言入门自学零基础
c语言入门自学零基础

C语言是当代人学习及生活中的必备基础知识,应用十分广泛,本专题为大家c语言入门自学零基础的相关文章,以及相关课程,感兴趣的朋友千万不要错过了。

2208

2023.07.25

c语言运算符的优先级顺序
c语言运算符的优先级顺序

c语言运算符的优先级顺序是括号运算符 > 一元运算符 > 算术运算符 > 移位运算符 > 关系运算符 > 位运算符 > 逻辑运算符 > 赋值运算符 > 逗号运算符。本专题为大家提供c语言运算符相关的各种文章、以及下载和课程。

1180

2023.08.02

LLVM自定义Pass怎么写
LLVM自定义Pass怎么写

本专题聚焦LLVM自定义Pass开发,整理Pass类结构、run()方法、PreservedAnalyses、CMake构建、插件注册、-load-pass-plugin加载和测试用例编写流程。

80

2026.09.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
WebStorm 官方调试文档
WebStorm 官方调试文档

共0课时 | 0人学习

RabbitMQ 教程手册
RabbitMQ 教程手册

共0课时 | 0人学习

Node.js 教程
Node.js 教程

共57课时 | 25.1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn