tencent cloud

CMQ 目前已开放基于 TCP 协议的 SDK 调用，支持普通消息、事务消息、延迟消息、异步消息的收发功能。其中，事务消息特性仅通过 TCP 方式实现。
TCP 协议目前支持公网访问以及同地域的私有网络的 CVM 内网访问方式，暂时不支持基础网络的内网访问方式。
本文主要介绍 TCP SDK 使用方式，提供 Demo 工程的安装、下载、配置及运行示例，帮助工程师快速搭建 CMQ 测试工程。

TCP 协议优势

• 更少的计算资源
  HTTP 针对请求鉴权，每次请求都需要签名；TCP 针对链接鉴权，只需要建立连接的时候对链接鉴权，节约客户端计算资源。
• 更安全的客户端线程
  TCP 客户端线程安全，多个线程可使用相同的链接，节省链接资源。
• 更高效的传输效率
  TCP 传输提高有效数据占比，在相同客户端下，拥有更高的吞吐量和 QPS，相比 HTTP 具有更高效的传输效率。
• 更优的使用体验
  TCP 支持异步接口，支持回调。
• 更多样的特性支持
  TCP 支持 CMQ 最新的分布式消息事务。

Demo工程使用

准备 Demo 环境

1. 安装 IDE
   您可以安装 IntelliJ IDEA 或者 Eclipse，本文以 IntelliJ IDEA 为例进行说明。
   请在 下载 IntelliJ IDEA Ultimate 版本，并参考 IntelliJ IDEA 说明进行安装。
2. 下载 Demo 工程
   请在 下载 CMQ 的 Demo 工程 到本地，解压后即可看到本地新增的 cmq-java-tcp-sdk-master 文件夹。

配置 Demo 工程

1. 创建资源
   您需要在控制台创建所需消息队列资源，包括 CMQ 队列名、SecretID、SecretKey。
   具体创建过程请参考 队列模型快速入门 和 主题模型快速入门。
2. 导入 Demo 工程文件
   在 IDEA 的开机界面打开文件夹。
   
   打开文件夹后，文件层级关系如下，Demo 工程文件存于 Demo 文件夹下。
   
3. 配置 Demo 参数
   修改文件 NameServer 地址、密钥对及消息队列名，NameServer 地址请参考 NameServer 对照表。
   以 ProducerDemo 为例，配置如下：

   producer.setNameServerAddress(“对应的NameSever”)；
   producer.setSecretID(“获取的SecretID”)
   producer.setSecretKey(“获取的SecretKey”)
   String queue = “创建的队列名”

   具体图示如下：
   

运行 Demo

使用队列模型收发消息

1. 配置 Demo 参数。
2. 执行文件 ProducerDemo，成功后显示日志如下：
   
   ProducerDemo 支持普通消息、延时消息、异步消息的发送。
   
3. 执行文件 ConsumerDemo，可接收消息。

使用主题模型收发消息

1. 运行 PublishDemo 类以主题模型进行消息发送。
2. 运行 SubscriberDemo 类以主题模式进行消息接收。

收发事务消息

1. 运行 ProducerTransactionDemo 类进行事务消息发送。
2. 运行 SubscriberTransactionDemo 类进行事务消息接收。

">

Nameserver 对照表