记一次使用vue连接rabbitMq

  • 连接rabbitMq需要使用stompjs
  • npm i stompjs
    下下面是连接代码
import Stomp from 'stompjs'onConnected(frame) {// 绑定交换机exchange_pushmsg是交换机的名字rk_pushmsg是绑定的路由keyvar exchange = this.rabbitMqexchange || 'queue.device.zzzz'// 创建随机队列用上面的路由key绑定交换机,放入收到消息后的回调函数和失败的回调函数this.client.subscribe(exchange, this.responseCallback, this.onFailed)},onFailed(frame) {console.log(frame)},responseCallback(frame) {if (frame.body != '' && frame.body != null) {const formatter = (data, params) => {this.dataOldChart = data;if (typeof this.dataFormatter === 'function') {try {data = this.dataFormatter(data, params, this.getItemRefs());} catch (err) {console.log(new Error(err))data = err + ''}}this.handleCommonBind(data, -1, 'dataAfterFormatter')return data}console.log('-----[' + frame.body);let result = typeof frame.body == 'string' ? JSON.parse(frame.body) : frame.bodythis.dataChart = formatter(result, this.dataParams)setTimeout(() => { this.updateChart() }, 100)}},connect() {this.client = Stomp.client(this.rabbitMqUrl || 'ws://172.16.0.97:15670')// 填写你rabbitMQ登录的用户名和密码var headers = {'login': this.rabbitMqUser || '','passcode': this.rabbitMqPass || '',// 虚拟主机,默认“/”'host': this.rabbitMqHost || '/'}let safe = this// 创建连接,放入连接成功和失败回调函数this.client.connect(headers, this.onConnected, this.onFailed)this.client.debug = (message) => {console.log('对接:' + message)this.mqDockingMessage = message}},

后端端口一搬都是15670或者15672 、我们这后端就因为端口问题搞啦好久 一直以为是我的问题
我这里得dataChart 就是页面想要的数据、基本上代码都在这啦 直接this.connect()接可以啦
之后在关闭页面时断开if (this.client !== null) { this.client.disconnect(); // 关闭连接 }

虽然都是复制粘贴 、但是也是创作不易、结尾出给个小连接、如果你得后端不会rabbitMq抓紧让他看这个、-> 学学吧、别硬挺

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

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

相关文章

安全编织:Eureka驱动的分布式服务网格安全策略

安全编织:Eureka驱动的分布式服务网格安全策略 在微服务架构的复杂网络中,服务的安全性是维护系统稳定运行的基石。服务网格(Service Mesh)作为微服务间通信的代理层,承担着保障服务间通信安全的重要职责。Eureka&…

vi 编辑器快捷生成 main 函数和基本框架

step1: 执行 sudo vi /etc/vim/vimrc &#xff08;修改vimrc需要管理员权限&#xff1a;sudo&#xff09; step2:输入用户密码&#xff0c;回车, 编辑vimrc文件 step3:在尾行输入以下代码&#xff08;可复制&#xff09; map mf i#include<stdio.h><ESC>o#includ…

Web3发展的基本要素

区块链&#xff1a;分布式数据库 1 区块链是一种新型的分布式数据库协议&#xff0c;是实现Web3的最核心技术。 2 区块链的技术特性使其能够&#xff1a; 1&#xff09;安全地存储数据&#xff0c;得益于现代计算机密码学&#xff0c;用户可以获得自己独特、安全的账户&…

java itextPdf根据pdf模板,编辑保存pdf后可二次编辑处理

java 支持pdf 多次编辑的重点只有两个 1&#xff1a;flat属性 2&#xff1a;设置文本域只读属性 看似简单的两个问题&#xff0c;却耗费了一天的时间。pdf没有官方文档太难受了&#xff0c;只能在网上查找相关的案 例。但是很多文章都是copy别人的。没有实际效果。皇天不负有…

uniapp 微信小程序根据后端返回的文件链接打开并保存到手机文件夹中【支持doc、docx、txt、xlsx等类型的文件】

项目场景&#xff1a; 我们在使用uniapp官方提供的uni.downloadFile以及uni.saveFile时&#xff0c;会发现这个文件下载的默认保存位置和我们预想的不太一样&#xff0c;容易找不到&#xff0c;而且没有提示&#xff0c;那么我们就需要把文件打开自己保存并且有提示保存到哪个…

探索前沿科技:从迁移学习看人工智能的无限可能性

从迁移学习看人工智能的无限可能性 1 引言1.1 什么是迁移学习1.1.1 迁移学习的定义1.1.2 迁移学习的起源和背景 1.2 迁移学习的重要性1.2.1 解决小数据集问题1.2.2 提高模型训练效率1.2.3 应用于不同领域的广泛性 1.3 迁移学习的前景 2 迁移学习的基本概念2.1 源域和目标域2.1.…

【区块链 + 智慧政务】涉税行政事业性收费“e 链通”项目 | FISCO BCOS应用案例

国内很多城市目前划转至税务部门征收的非税收入项目已达 17 项&#xff0c;其征管方式为行政主管部门核定后交由税务 部门征收。涉税行政事业性收费受限于传统的管理模式&#xff0c;缴费人、业务主管部门、税务部门、财政部门四方处于 相对孤立的状态&#xff0c;信息的传递靠…

模板方法原理与C++实现

定义 定义一个操作中的算法骨架&#xff08;稳定的&#xff09;&#xff0c;而将一些步骤的实现延迟到子类中&#xff08;变化的&#xff09;。模板方法使得子类可以复用一个算法的结构&#xff0c;而只改变&#xff08;重写&#xff09;这个算法的特定步骤。 C实现 class L…

ns3-gym入门(二):linear-mesh例子详解

一、问题背景&#xff1a;Random Access Controlling the random access in an IEEE 802.11 mesh network is challenging as the network nodes compete for the shared radio resources. It is known that assigning the same channel access probability to each node is no…

无人机之机架类型篇

碳纤维机架 具有低密度、高强度和高刚度的特点&#xff0c;非常适合商业或工业级无人机的设计。碳纤维机架在飞行过程中具有良好的减振效果&#xff0c;使飞行更加稳定&#xff0c;但制作工艺复杂&#xff0c;成本较高。 工程塑料机架 以其轻便、耐冲击和易加工等特点受到一…

Vue 3 组件通信与状态管理:从基础到Pinia的全面解析

引言 Vue 3引入了Composition API&#xff0c;这为组件通信提供了更多的灵活性和强大的功能。例如&#xff0c;使用provide和inject可以轻松实现跨层级组件的数据传递&#xff0c;而setup函数则为组件提供了更早的生命周期钩子&#xff0c;使得在组件初始化阶段就能进行通信设…

Chrome调试工具

一、Chrome调试工具 1.Ctrl滚轮 可以放大开发者工具代码大小。 2.左边是 HTML 元素结构&#xff0c;右边是 CSS 样式。 3.右边 CSS 样式可以改动数值&#xff08;左右箭头或者直接输入&#xff09;和查看颜色。 4.Ctrl 0 复原浏览器大小。 5.如果点击元素&#xff0c;发现右侧…

Netfilter之连接跟踪(Connection Tracking)和反向 SNAT(Reverse SNAT)

连接跟踪&#xff08;Connection Tracking&#xff09; 连接跟踪是 Netfilter 框架中的一个功能&#xff0c;用于跟踪网络连接的状态和元数据。它使防火墙能够识别和处理数据包属于哪个连接&#xff0c;并在双向通信中正确匹配请求和响应数据包。 工作原理 建立连接&#xf…

微服务节流控制:Eureka中服务速率限制的精妙配置

微服务节流控制&#xff1a;Eureka中服务速率限制的精妙配置 在微服务架构中&#xff0c;服务的可用性和稳定性对于整个系统的性能至关重要。Eureka作为Netflix开源的服务发现框架&#xff0c;虽然主要用于服务注册与发现&#xff0c;但合理地配置服务的速率限制也是确保服务健…

【C语言】深入解析选择排序

文章目录 什么是选择排序&#xff1f;选择排序的基本实现代码解释选择排序的优化选择排序的性能分析选择排序的实际应用结论 在C语言编程中&#xff0c;选择排序是一种简单且直观的排序算法。尽管它在处理大型数据集时效率不高&#xff0c;但由于其实现简单&#xff0c;常常用于…

基于协同过滤混合算法的餐饮推荐系统设计与实现

基于协同过滤混合算法的餐饮推荐系统设计与实现 Design and Implementation of Restaurant Recommendation System Based on Hybrid Collaborative Filtering Algorithm 完整下载链接:基于协同过滤混合算法的餐饮推荐系统设计与实现 文章目录 基于协同过滤混合算法的餐饮推荐…

牛客TOP101:反转链表

文章目录 1. 题目描述2. 解题思路3. 代码实现 1. 题目描述 2. 解题思路 简单粗暴的写法&#xff0c;就是从头到尾挨个将所有结点的指向翻转即可。需要注意的是&#xff0c;翻转之后会失去原有指向的结点&#xff0c;所以需要提前保存。   具体做法就是&#xff0c;使用cur标记…

面试必备!Redis面试题合集

目录 1.Redis简介 2. 分布式缓存常见的技术选型方案有哪些? 3. 说一下 Redis 和 Memcached 的区别和共同点 4. 缓存数据的处理流程是怎样的? 5. 为什么要用 Redis/为什么要用缓存? 6. Redis 常见数据结构以及使用场景分析 6.1. string 6.2. list 6.3. hash 6.4. s…

Spring源码注解篇二:手写@Component注解

Component注解的功能 在Spring框架中&#xff0c;Component 注解是一个核心特性&#xff0c;用于自动检测类并将其注册为Spring应用上下文中的Bean。这大大简化了Bean的配置过程&#xff0c;使得开发者能够通过注解的方式快速地将类标记为组件&#xff0c;并由Spring容器进行管…

硬件检测工具 | CPU-Z v2.10.0 官方中文绿色版

软件简介 CPU-Z是一款广受欢迎的硬件检测工具&#xff0c;主要用于收集电脑处理器的详细信息。这款软件能够提供关于CPU的详细数据&#xff0c;包括处理器名称、编号、代号、进程和缓存等信息。此外&#xff0c;CPU-Z还能实时监测每个内核的内部频率和内存频率&#xff0c;以及…