使用 WebSocket 连接 RabbitMQ

栏目: Html5 · 发布时间: 5年前

内容简介:版权声明:版权归博主所有,转载请带上本文链接!联系方式:abel533@gmail.com https://blog.csdn.net/isea533/article/details/85119617

版权声明:版权归博主所有,转载请带上本文链接!联系方式:abel533@gmail.com https://blog.csdn.net/isea533/article/details/85119617

相关文章

RabbitMQ 安装配置和 Spring 集成

https://blog.csdn.net/isea533/article/details/84545484

RabbitMQ 启用 HTTP 后台认证

https://blog.csdn.net/isea533/article/details/85096253

由于使用 WebSocket 连接 RabbitMQ 时需要身份认证,而默认认证方式的账号密码都是固定的,使用这种方式时,任何人都能通过前端 JS 代码中的用户密码连接到 RabbitMQ 服务器,不管用什么样的权限进行限制,都不够安全。

因此,为了安全的使用 WebSocket,需要先配合上一篇 RabbitMQ 启用 HTTP 后台认证 。使用自定义的后台认证后,可以使用的用户不限于 RabbitMQ 内置方式创建的用户了。

本文假设用户已经登陆系统,然后使用用户的 TOKEN 或者 SESSIONID 作为连接 RabbitMQ 的用户名,密码直接为空进行连接。通过用户的某些信息创建一个临时的消息队列(需要和前台订阅的队列一致)

后台 HTTP 中,会通过接口或者 Redis 的统一认证方式对 TOKEN 或者 SESSIONID 进行认证,所有授权接口也会对用户名进行鉴权,只有保持登陆的用户才有权连接到 RabbitMQ 服务。

启用 Web STOMP 插件

通过下面命令启用 Web STOPM 插件:

rabbitmq-plugins enable rabbitmq_web_stomp

参考地址: https://www.rabbitmq.com/web-stomp.html

此时已经可以通过 websocket 进行连接了,官方推荐使用 stomp-websocket

下面编写前端 JS 代码

JS WebSocket 连接

引入 stomp-websocket 提供的 stomp.js 文件。

<!-- include the client library -->
<script src="stomp.js"></script>

示例代码如下:

var ws = new WebSocket('ws://127.0.0.1:15674/ws');
var client = Stomp.over(ws);

var on_connect = function() {
    console.log('connected');
};
var on_error =  function() {
    console.log('error');
};
//参数依次为:用户名,密码,连接后,出错,虚拟主机名
client.connect('用户TOKEN', '', on_connect, on_error, '/');

on_connect 连接成功中可以定义自己的逻辑进行封装。

后台需要自己实现对 TOKEN 等自定义方式的认证。

比如要发送消息:

//参数依次为:目的地,消息头,消息体
client.send('/exchange/交换机名/路由键', {}, "Hello");

比如要订阅某个交换机:

//参数依次为:目的地,消息体,消息头
client.subscribe('/exchange/交换机名/路由键', function(frame){}, {});

此时会自动创建一个非持久化的队列,名字为随机生成,类似 stomp-subscription-***** 的队列名。

同时还可以以下面的方式创建指定的队列名(本例还增加了持久化):

//参数依次为:目的地,消息头,消息体
client.subscribe('/exchange/wf/wf.warn', function(frame){}, {
	'x-queue-name': 'liuzh',
	'durable': true
});

还可以继续给该队列绑定其他路由键:

//参数依次为:目的地,消息头,消息体
client.subscribe('/exchange/wf/wf.error', function(frame){}, {
	'x-queue-name': 'liuzh',
	'durable': true
});

此时队列 liuzh 状态如下:

使用 WebSocket 连接 RabbitMQ

绑定情况如下:

使用 WebSocket 连接 RabbitMQ

除了这里用到的参数外,还支持下面的队列参数:

  • durable (aliased as persistent):持久化
  • auto-delete:自动删除
  • exclusive:独占

还额外支持 x- 参数控制死信、队列和消息等:

  • x-dead-letter-exchange
  • x-dead-letter-routing-key
  • x-expires
  • x-message-ttl
  • x-max-length
  • x-max-length-bytes
  • x-overflow
  • x-max-priority

这里只是列举了几个比较重要的例子, 完整的语法可以查看 STOMP Plugin 页面的详细介绍

参考资料


以上所述就是小编给大家介绍的《使用 WebSocket 连接 RabbitMQ》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

算法交易:制胜策略与原理

算法交易:制胜策略与原理

[美]欧内斯特·陈(Ernest P. Chan) / 高闻酉、黄蕊 / 机械工业出版社 / 49.00

本书是一本引人入胜、信息量大、覆盖各类交易策略的图书。无论个人投资者,还是机构投资者,都可以借鉴和使用其中的策略。本书中的策略大致可分为均值回归系统和动量系统两大类。书中不仅介绍了如何使用每种类别的交易策略,更解释了各种策略之所以有效的原因。本书始终以简单、线性的交易策略为重心,因为复杂的交易策略容易受到过度拟合及数据窥探的侵害。数学和软件是算法交易的两条腿。本书用到了一定程度的数学知识,使其对各......一起来看看 《算法交易:制胜策略与原理》 这本书的介绍吧!

URL 编码/解码
URL 编码/解码

URL 编码/解码

MD5 加密
MD5 加密

MD5 加密工具

html转js在线工具
html转js在线工具

html转js在线工具