CMQSDK
nodejs 操作 cmq
点击查看腾讯云 cmqapi 文档
已经实现的方法
- createQueue 创建队列
- sendMsgtoQueue 发送消息到队列
- batchSendMsgToQueue 批量发送消息到队列
- createTopic 创建主题
- sendMsgtoTopic 发送消息到主题
- batchSendMsgToTopic 批量发送消息到主题
- queueMsgRecive 从队列消费消息
- batchQueueMsgReceive 从队列批量消费消息
// 有很多没有实现的 api 接口 一样可以调用
// https://cloud.tencent.com/document/api/406/5852// 获取队列列表// arg1:操作ID// optts 参数,根据api参数 自行传入cmq
创建实例
const cmq = host: 'https://cmq-queue-bj.api.qcloud.com' Region: 'ap-beijing' SecretId: '' SecretKey: ''
发送消息到队列
cmq
批量发送消息到队列
数据可以是字符串,也可以是JSON
|Array
// 批量发送消息到队列cmq
## 单条消费 队列 消息
```js
cmq.queueMsgRecive({queueName:'pms_one_dev'}).then(res=>{
console.log(`收到一条消息:${res.msgBody}`)
}).catch(err=>{
console.log(err)
})
批量消费队列 信息
cmq
获取队列
cmq