接入TDMQ

腾讯云TDMQ Pulsar版 Java Demo

DEMO 地址: GITHUB

首先吧，这个demo下载到本地，然后根据提示，进行配置，跑通了就可以继承到你的业务系统了。

---

第一步 创建资源

请先在TDMQ 控制台或者使用云API创建对应资源，包括以下：

1-0、创建角色

在左侧菜单栏找到角色鉴权/角色管理，然后新建一个角色。

1-1、集群

在左侧菜单栏找到Pulsar/集群管理，然后新建一个集群。

1-2、命名空间

1. 创建命名空间：

   在左侧菜单栏找到Pulsar/命名空间，然后新建一个命名空间。
   

​

2. 配置权限

   在上一步创建“命名空间“后，紧接着进行”配置权限“。添加1-0创建的角色，并授权“生产消息”和“消费消息“的权限。
   

1-3、Topic

在左侧菜单栏找到Pulsar/Topic管理，然后新建一个Topic。

1. 新建Topic
   

2. 新增订阅

   在上一步创建Topic后，紧接着进行“新增订阅”。

第二步

将对应资源信息复制到Config.java 内

    //图2.1
    // Topic请从控制台复制完整路径，补充在persistent://后面
    // 格式为persistent://集群（租户）ID/命名空间/Topic名称
    public static final String TOPIC = "persistent://pulsar-****/namespace/topic";
    
    //图2.2
    // Subscription请在Topic详情页创建和复制
    public static final String SUBSCRIPTION = "subscriptionName";
    
    //图2.3
    // Token请在角色管理复制
    public static final String TOKEN = "eyJr****";
    
    //图2.4
    // service url请在集群管理接入地址处复制
    public static final String SERVICE_URL = "http://pulsar-****.****.tencenttdmq.com:8080";

• 图2.1

  直接到Topic管理页面复制（https://console.cloud.tencent.com/tdmq/topic）。

  

• 图2.2

  在图2.1中在topic列表右侧点击“更多/查看订阅”（或者”新增订阅“），进入“订阅页面“，找到“订阅名称”

  

  

• 图2.3

  在“角色权限/角色管理”页面中，选择创建的角色，点击复制或查看密钥，以获取”token“。

  

• 图2.4

  在“Pulsar/集群管理”页面中，选择你的集群，点击列表右侧的“接入地址”，复制”公网接入地址“。

  

第三步

直接在IDE内部运行SimpleProducerAndConsumer.java的main方法即可快速体验消息生产和消费。

运行demo

消息查询

在TDMQ 控制台，“Pulsar/消息查询”页面中查看刚刚生产和消费的消息。

注意：消息显示会有延迟，大概5s～30s左右。