vue-rbq

Project download

npm install rbmq-vue -S

How to use

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对象

API

connect() 连接rabbitMQ

disconnect() 断开连接