0.1.4 • Published 4 years ago

mosi-ts-mqclient v0.1.4

Weekly downloads
20
License
-
Repository
-
Last release
4 years ago

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中查看:

    npm.io

MQ_Disconnect 断开连接

MosiMQClient.MQ_Disconnect();

MQ_Subscribe 订阅

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

    npm.io

  • 接收到消息:

    npm.io

MQ_Unsubscribe 取消订阅

MosiMQClient.MQ_Unsubscribe('队列名');

MQ_Send 发送消息

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

npm.io