检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。
订阅：表示用户可以使用消费组消费消息。 如果在为指定消费组设置特殊权限，则特殊权限会覆盖默认权限，此消费组的实际权限为特殊权限。例如：默认权限为订阅，指定消费组的权限为禁止，则此消费组实际权限为禁止。 5.x基础版不支持配置此参数。 密钥 设置用户的密钥。 密钥设置规则如下： 长度为8~32个字符。
-g ${消费组名称} 连接地址：购买RocketMQ实例后，获取实例的连接地址。 Topic名称：创建Topic时设置的Topic名称。 消费组名称：创建消费组时设置的消费组名称。 测试结果参考 表4 测试结果参考 性能指标 rocketmq.b2.large.4 rocketmq
通过Topic和Tag实现消息分类 在RocketMQ中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。本章节介绍如何搭配使用Topic和Tag来实现消息过滤。 实现订阅关系一致 订阅关系不一致，可能导致消息消费逻辑混乱，消息被重复消费或遗漏。本章节介绍订阅关系一致的概念、原理以及实施方法。
数值。 topic：表示Topic名称。 name_srv：表示实例连接地址和端口。 set_keys：设置消息索引键，可根据关键字精确查找某条消息。 set_tags：设置消息Tag，用于消费端根据指定Tag过滤消息。 ACL_User_Name：表示用户名。创建用户的步骤，请参见创建用户。
进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。
详情页面。 在左侧导航栏，单击“消息查询”，进入“消息查询”页面。 在页面顶部设置查询条件，查询待重新发送的消息。 在待重新发送的消息所在行，单击“消费验证”，弹出“消费验证”对话框。 参考表1，设置消费验证参数。 表1 消费验证参数说明 参数 说明 Group ID 选择待进行消费验证的消费组名称。
Topic的权限，包括发布+订阅、发布和订阅。 关联代理 选择在某个代理上创建Topic，并设置Topic的队列个数。 如果实例部署在多个代理上，单击“添加关联代理”，可以在其他代理上创建Topic，并设置Topic的队列个数。 如果需要新增关联代理，则需要先扩容代理个数，具体操作请参见变
进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。
通过suspendTimeMillis设置重试时间间隔。 默认值为1000ms，即1s。 通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表2所示。 创建消费组时设置。 取值范围：1-16。
进行投递。 由于客户端和服务端可能存在时间差，消息的实际投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。
-g ${消费组名称} 连接地址：购买RocketMQ实例后，获取实例的连接地址。 Topic名称：创建Topic时设置的Topic名称。 消费组名称：创建消费组时设置的消费组名称。 测试结果参考 表4 测试结果参考 性能指标 rocketmq.4u8g.cluster.small
IoT场景 IoT场景典型特点为海量终端接入，在大量终端接入的情况下，大量的数据汇聚在一起，实际不同的业务组件需要关注的信息只是其中某些类型的数据，如何在大量数据中快速识别出业务感兴趣的数据将会显得尤为重要。分布式消息服务RocketMQ版提供的消息过滤的能力，可以完好的支持该场景，终端写
客户端数 定时/延时消息 事务消息 顺序消息 Min(单客户端线程数 * 客户端数，队列数) 单客户端线程数的调整需谨慎，不能盲目调大线程数，如果设置过大的线程数反而会带来大量的线程切换开销。 理想环境下单客户端的最优线程数计算模型为：C *（T1+T2）/T1。 其中，C为单机vCPU
// 设置订阅关系 .setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression)) // 设置监听器，用于处理接收到的消息，并返回消费结果。
已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取RocketMQ实例的实例ID，以及实例所在区域的项目ID。 使用华为云SDK 5.x版本批量创建不同类型的Topic 新建“topics.txt”文件，用于存放待创建的Topic信息。 文件内容格式为“Topic名称
跟唐老师学习云网络 唐老师将自己对网络的理解分享给大家 智能客服 您好！我是有问必答知识渊博的智能问答机器人，有问题欢迎随时求助哦！ 社区求助 华为云社区是华为云用户的聚集地。这里有来自容器服务的技术牛人，为您解决技术难题。
由于ClientId生成时会拼接消费者的clientIP属性，同一 IP下不同消费者的clientIP相同会导致ClientId相同，所以建议添加如下代码手动设置instanceName。 producer.setInstanceName(String.valueOf(System.nanoTime()))
数值。 topic：表示Topic名称。 name_srv：表示实例连接地址和端口。 set_keys：设置消息索引键，可根据关键字精确查找某条消息。 set_tags：设置消息Tag，用于消费端根据指定Tag过滤消息。 事务消息生产者需要实现两个回调函数，其中local_exe
享版页面。 在左侧导航栏选择“回收站”，进入“回收站”页面。 单击“回收站策略”，弹出“回收站策略”对话框。 开启启用回收站，并设置保留天数（只能设置为1~7天），单击“确定”。 修改保留天数仅对修改后删除的实例生效，修改前已在回收站中的实例依然按照修改前的天数保留实例。 恢复RocketMQ实例
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
您即将访问非华为云网站，请注意账号财产安全
