kainonly/cmq-node-sdk

支持 Node 的 CMQ 消息队列 SDK

CMQ NODE SDK

CMQ 消息队列 NODE SDK

开始

安装依赖

npm install cmq-sdk

创建客户端

import { CMQ } from 'cmq-sdk';

const client = new CMQ({
  // protocol: 'https://',
  // path: '/v2/index.php',
  host: 'cmq-gz.public.tencenttdmq.com',
  secretId: '<访问密钥 Id>',
  secretKey: '<访问密钥 Key>',
  region: 'gz',
  // 如果要使用控制流，则需要设置云 API 配置
  api: {
    endpoint: 'tdmq.tencentcloudapi.com',
    region: 'ap-guangzhou'
  }
});

使用

async function bootstrap() {
  // 使用控制流创建队列
  const r1 = await client.api.CreateCmqQueue({
    QueueName: 'dev'
  });
  console.log(r1);

  // 投递消息
  const r2 = await client.sendMessage({
    queueName: 'dev',
    msgBody: 'hi'
  });

  console.log(r2);
}

bootstrap();

方法与相关文档参数一致：

• 数据流文档
• 控制流文档

控制流是引入 tencentcloud-sdk-nodejs 腾讯云开发者工具套件实现的