0.1.4 • Published 4 years ago
mosi-ts-mqclient v0.1.4
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');