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

老杰小哥_7064

老杰小哥_7064

2026-06-02

239人浏览

原创

不能直接用 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 里管理连接即可:

Browser Js
Browser Js

轻量级CDP浏览器控制,适用于AI代理。相较于内置浏览器工具,token消耗降低3‑10倍,仅在浏览时使用。

下载
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]);
</p>

注意: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 设计,但依然要过权限关。

前端入门到VUE实战笔记:立即使用
在学习笔记中,你将探索 前端 的入门与实战技巧!

相关专题

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

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

2023.08.11

2303

5

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

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

2023.10.09

4983

6

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

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

2024.03.19

6070

13

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

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

2024.03.22

5578

10

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

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

2024.05.22

783

5

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

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

2023.06.20

2929

3

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

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

2023.07.25

2208

9

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

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

2023.08.02

1180

5

c语言数据结构
c语言数据结构

数据结构是指将数据按照一定的方式组织和存储的方法。它是计算机科学中的重要概念,用来描述和解决实际问题中的数据组织和处理问题。数据结构可以分为线性结构和非线性结构。线性结构包括数组、链表、堆栈和队列等,而非线性结构包括树和图等。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.09

1118

4

热门下载

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

精品课程

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

共0课时 | 0人学习

RabbitMQ 教程手册
RabbitMQ 教程手册

共0课时 | 0人学习

Node.js 教程
Node.js 教程

共57课时 | 25.1万人学习