tencent cloud

PrevNext

文档反馈

请输入关键字

Recent Pages

文档
消息队列 Pulsar 版
    文档
    Download PDF

    使用消息重试和死信队列

    最后更新时间：2024-08-19 16:04:55
    下载PDF

      操作背景

      重试 Topic 是一种为了确保消息被正常消费而设计的 Topic 。当某些消息第一次被消费者消费后，没有得到正常的回应，则会进入重试 Topic 中，当重试达到一定次数后，停止重试，投递到死信 Topic 中。
      当消息进入到死信队列中，表示 TDMQ Pulsar 版已经无法自动处理这批消息，一般这时就需要人为介入来处理这批消息。您可以通过编写专门的客户端来订阅死信 Topic，处理这批之前处理失败的消息。
      更多关于消息重试与死信的介绍请参考文档消息重试与死信机制。
      本文以官网提供的 Demo 为例，介绍消息重试与死信队列功能与使用方式。

      操作步骤

      步骤1. 在控制台新建 Pulsar 资源

      1. 登录 TDMQ Pulsar 版控制台，创建一个集群和命名空间。
      2. 在左侧导航栏选择 Topic 管理页签，当前集群和命名空间分别勾选入门课程中创建好的集群和命名空间。
      3. 单击新建，输入 Topic 名称和说明，其他选项可保持默认，单击保存，创建一个 topic。
      
      4. 单击新建好的 Topic 操作列的新增订阅，输入订阅名称，开启自动创建重试&死信队列，重试和死信默认后缀选择 Pulsar 社区版（大写），为刚新建好的 Topic 创建一个订阅关系并开启重试&死信队列。
      
      5. 提交后，可以看到系统自动创建好的重试队列和死信队列。
      
      6. 单击操作列的更多 > 查看订阅/消费者，可看到刚创建好的订阅。
      

      步骤2. 下载 Demo 并配置相关参数

      1. 下载官方 Demo并解压。
      
      2. 修改 Constant.java 参数。
      
      参数
      说明
      SERVICE_URL
      集群接入地址，可以在控制台集群管理页面查看并复制。
      
      
      
      AUTHENTICATION
      角色的密钥，角色密钥可以在角色管理中复制。
      
      
      

      步骤3. 生产消息

      1. 进入/deadletter目录下，修改 SimpleProducer.java 参数。
      
      topic：填写创建好的 topic 名称，需要填入完整路径，即persistent://clusterid/namespace/Topic，clusterid/namespace/topic 的部分可以从控制台上 Topic管理页面直接复制。
      
      2. 编译并运行 SimpleProducer.java 程序发送消息。运行结果如下：
      
      3. 登录 TDMQ Pulsar 版控制台，在消息查询页面，可以看到向 topic 中生产的消息。
      
      
      

      步骤4. 消费消息

      1. 修改 RetryConsumer.java 程序参数。
      
      .retryLetterTopic：重试topic名称。
      .deadLetterTopic：死信topic名称。
      .topic：topic名称。
      以上3个 topic 需要填入完整路径，即 persistent://clusterid/namespace/Topic，clusterid/namespace/topic的部分可以从控制台上 Topic 管理页面直接复制。
      
      .subscriptionName：需要写入订阅名，可在 Topic 消费者界面查看。
      
      2. 编译并运行消息重试程序 RetryConsumer.java 。运行结果如下：
      
      3. 登录 TDMQ Pulsar 版控制台，在消息查询页面可以看到，重试 topic 中展示了2条消息，死信 topic 中展示了1条消息，代表消息经过2次重试投递后，被投递到死信队列。
      
      
      
      

      步骤5. 消费死信消息

      1. 修改 DeadConsumer.java 参数。
      
      .topic：填写死信topic名称， 需要填入完整路径，即 persistent://clusterid/namespace/Topic，clusterid/namespace/topic的部分可以从控制台上 Topic 管理页面直接复制。
      
      
      
      .subscriptionName：需要写入订阅名，可在 Topic 消费者界面查看。
      
      2. 编译并运行消息重试程序 RetryConsumer.java 。运行结果如下：
      
      3. 登录 TDMQ Pulsar 版控制台，在死信 topic 消费者页面，消息堆积量变为0条，证明消息已经被消费。
      
      
      
      联系我们

      联系我们，为您的业务提供专属服务。

      联系我们
      技术支持

      如果你想寻求进一步的帮助，通过工单与我们进行联络。我们提供7x24的工单服务。

      提交工单
      7x24 电话支持
      Copyright © 2013-2024 Tencent Cloud. All Rights Reserved.
      隐私条款服务条款缓存条款