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:发送消息
基础:引入服务
;
MQ_Connect 连接服务
MosiMQClient.MQ_Connect'ws', '服务器ip地址', '服务端口号', 'ws', '账户', '密码',,;
-
"ws"为使用的协议
-
连接结果可以在console中查看:
MQ_Disconnect 断开连接
MosiMQClient.MQ_Disconnect;
MQ_Subscribe 订阅
MosiMQClient.MQ_Subscribe'队列名',;
-
订阅成功:
-
接收到消息:
MQ_Unsubscribe 取消订阅
MosiMQClient.MQ_Unsubscribe'队列名';
MQ_Send 发送消息
MosiMQClient.MQ_Send'/queue/q1','penglei','tccccccc';