mosi-ts-mqclient

基于stomp协议使用typescript封装的MQ客户端。依赖包：

• stompjs
• @types/stompjs

安装

npm install --save mosi-ts-mqclient

使用

提供如下接口服务：

• MQ_Connect：连接服务
• MQ_Disconnect：断开连接
• MQ_Subscribe：订阅
• MQ_Unsubscribe：取消订阅
• MQ_Send：发送消息

基础：引入服务

import MosiMQClient from 'mosi-ts-mqclient';

MQ_Connect 连接服务

MosiMQClient.MQ_Connect('ws', '服务器ip地址', '服务端口号', 'ws', '账户', '密码', (e) => {
    console.log('连接成功');
}, (e) => {
    console.log('连接失败');
});

• "ws"为使用的协议

• 连接结果可以在console中查看：

  

MQ_Disconnect 断开连接

MosiMQClient.MQ_Disconnect();

MQ_Subscribe 订阅

MosiMQClient.MQ_Subscribe('队列名',(e:any)=>{
    var getMsg = e.body;
    console.log("GetMsg:"+getMsg);
});

• 订阅成功：

  

• 接收到消息：

  

MQ_Unsubscribe 取消订阅

MosiMQClient.MQ_Unsubscribe('队列名');

MQ_Send 发送消息

MosiMQClient.MQ_Send('/queue/q1','penglei','tccccccc');