npm install rbmq-vue -S
main.js
import RMBQ from "rbmq-vue"
Vue.prototype.$RBMQ=RMBQ.vue
//demo
export default {
name: 'App',
mounted() {
var client=null
var subscribe={}
var config={
address:"ws://192.168.4.69:25412/ws",
MQ_ACCOUNT:"webalert",
MQ_PASSWORD:"webalert",
}
var MQ_SUBSCRIPT = "/exchange/iacp.topic/iacp.biz.job.alert.handler" //订阅topic 路由key
const myRMBQ = new this.$RBMQ(this,client,config,subscribe,(client,subscribes)=>{
subscribes[MQ_SUBSCRIPT] = client.subscribe(MQ_SUBSCRIPT,(e)=>{
//业务代码
})
})
myRMBQ.connect()
}
}RMBQ第一个参数为执行上下文,第二个参数用于接收rabbitMq对象,第三个参数为配置信息对象 address 为url地址 MQ_ACCOUNT 为rabbitMQ账号 MQ_PASSWORD 为rabbitMQ账号,回调函数中第一个参数为RBMQ返回的rabbitmq连接对象,subscribes为已订阅对象
client.subscribe为rabbitmq订阅,具体订阅可根据需求按照规则修改, 第一个参数为订阅规则(它是一个字符串排列顺序为exchange/topic/路由key 路由key之间用"."衔接),第二个参数为回调函数用来写具体的业务代码,回调函数中第一个参数为后台推送的数据,它是一个json字符串,使用时需要将它转成json对象
connect() 连接rabbitMQ
disconnect() 断开连接