关于数据恢复 数据恢复流程 a. 您通过控制台发起数据恢复请求。 b. DCS从对象存储服务（OBS）获取数据备份文件。 c. 暂停实例数据读写服务。 d. 替换主实例的持久化文件。 e. 重新加载新的持久化文件。 f. 完成数据恢复，对外提供数据读写服务。 数据恢复对业务系统的影响 恢复操作是将备份文件在主节点执行，实例数据恢复期间需暂停数据读写服务，直到主实例完成数据恢复。 数据恢复异常处理 数据恢复文件如果被损坏，DCS在恢复过程中会尝试修复。修复成功则继续进行数据恢复，修复失败，DCS主备实例会将实例还原到执行恢复前的状态。

慢查询是Redis用于记录命令执行时间过长请求的机制。您可以在DCS控制台查看慢请求日志，帮助解决性能问题。 慢查询是Redis用于记录命令执行时间过长请求的机制。您可以在DCS控制台查看慢请求日志，帮助解决性能问题。 查询结果中，涉及的慢语句命令详情，请前往Redis官方网站查看。 慢查询结果由实例两个配置参数决定，如下： slowloglogslowerthan：如果在Redis实例的数据节点中执行一个命令，执行时间超过了slowloglogslowerthan参数设置的阈值（单位为微秒），则会被记录到慢查询中。该参数的默认值为10000，即10ms，当Redis命令执行时间超过10ms，则生成慢查询。 slowlogmaxlen：Redis记录的慢查询个数由slowlogmaxlen参数的值决定，默认值为128个。当慢查询个数超过128时，会将旧的慢查询删除，记录新的慢查询。 实例配置参数的修改以及参数解释，请参考修改实例配置参数。 控制台查看慢查询 步骤 1 单击左侧菜单栏的“缓存管理”。进入缓存管理页面。 步骤 2 单击需要进行慢查询的DCS缓存实例名称，进入该实例的基本信息页面。 步骤 3 单击“慢查询”。 步骤 4 设置查询时间，查看慢查询记录。 说明 如果您想了解返回查询结果中慢语句命令详情，请前往

本章介绍使用同一VPC内弹性云主机ECS上的SpringBoot集成Lettuce实例的方法。 前提条件 已成功申请Redis实例，且状态为“运行中”。 已创建弹性云主机，创建弹性云主机的方法，请参见《弹性云主机用户指南》。 如果弹性云主机为Linux系统，该弹性云主机必须已经安装java编译环境。 操作步骤 步骤 1 查看并获取待连接Redis实例的IP地址和端口。 具体步骤请参见查看实例信息。 步骤 2 登录弹性云主机。 步骤 3 首先使用maven在pom.xml添加如下依赖。 说明 SpringBoot从2.0起默认使用lettuce客户端进行连接。 此次使用的版本：springboot：2.6.6，lettuce：6.1.8。 org.springframework.boot springbootstarterweb org.springframework.boot springbootstarterdataredis 步骤 4 使用SpringBoot集成Lettuce连接实例。 Springboot+Lettuce单连方式连接Redis单机/主备/Proxy集群示例。 a. 在application.properties配置文件中加上redis相关配置。 spring.redis.hosthost spring.redis.database0 spring.redis.passwordpwd spring.redis.portport b. Redis配置类RedisConfiguration。 @Bean public RedisTemplate redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) { RedisTemplate template new RedisTemplate<>(); template.setConnectionFactory(lettuceConnectionFactory); //使用Jackson2JsonRedisSerializer替换默认的JdkSerializationRedisSerializer来序列化和反序列化redis的value值 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer new Jackson2JsonRedisSerializer<>(Object.class); ObjectMapper mapper new ObjectMapper(); mapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); mapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NONFINAL, JsonTypeInfo.As.PROPERTY); jackson2JsonRedisSerializer.setObjectMapper(mapper); StringRedisSerializer stringRedisSerializer new StringRedisSerializer(); //key采用String的序列化方式 template.setKeySerializer(stringRedisSerializer); // hash的key也采用String的序列化方式 template.setHashKeySerializer(stringRedisSerializer); // value序列化方式采用jackson template.setValueSerializer(jackson2JsonRedisSerializer); // hash的value序列化方式采用jackson template.setHashValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; } c. Redis操作类RedisUtil。 / 普通缓存获取 @param key 键 @return 值 / public Object get(String key){ return keynull?null:redisTemplate.opsForValue().get(key); } / 普通缓存放入 @param key 键 @param value 值 @return true成功 false失败 / public boolean set(String key,Object value) { try { redisTemplate.opsForValue().set(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } d. 编写controller类进行测试。 @RestController public class HelloRedis { @Autowired RedisUtil redisUtil; @RequestMapping("/setParams") @ResponseBody public String setParams(String name) { redisUtil.set("name", name); return "success"; } @RequestMapping("/getParams") @ResponseBody public String getParams(String name) { System.out.println("" + name + ""); String retName redisUtil.get(name) + ""; return retName; } } SpringBoot+Lettuce连接池方式连接Redis单机/主备/Proxy集群示例。 e. 在以上maven依赖的基础上添加以下依赖。 org.apache.commons commonspool2 f. 在application.properties配置文件中加上redis相关配置。 spring.redis.hosthost spring.redis.database0 spring.redis.passwordpwd spring.redis.portport

创建安全组 说明 仅Redis 3.0实例需要安全组。 步骤 1 登录虚拟私有云管理控制台。 步骤 2在左侧导航选择“访问控制 > 安全组”，单击“创建安全组”。根据界面提示创建安全组。如无特殊需求，界面参数均可保持默认。 创建安全组时，“模板”选择“自定义”。 安全组创建后，请保留系统默认添加的入方向“允许安全组内的弹性云主机彼此通信”规则和出方向“放通全部流量”规则。 使用DCS服务要求必须添加下表所示安全组规则，其他规则请根据实际需要添加。 表 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 6379 0.0.0.0/0 通过内网访问Redis 3.0。 结束 申请弹性公网IP（可选） 说明 仅创建Redis 3.0实例，且需要通过公网访问DCS时，需要申请弹性公网IP，否则不需要申请弹性公网IP。 步骤 1 登录管理控制台。 步骤 2 单击页面上方的“服务列表”，选择“网络 > 弹性公网IP”。 步骤 3 单击“购买弹性IP”。 结束

Predis 介绍使用同一VPC内弹性云主机ECS上的Predis连接Redis的方法。更多的客户端的使用方法请参考Redis客户端。 前提条件 已成功申请Redis实例，且状态为“运行中”。 已创建弹性云主机，创建弹性云主机的方法，请参见《弹性云主机用户指南》。 如果弹性云主机为Linux系统，该弹性云主机必须已经安装php编译环境。 操作步骤 步骤 1 查看并获取待连接Redis实例的IP地址和端口。 具体步骤请参见查看实例信息。 步骤 2 登录弹性云主机。 步骤 3 安装php开发包与命令行工具。执行如下命令，使用yum方式直接安装。 yum install phpdevel phpcommon phpcli 步骤 4 安装完后可查看版本号，确认成功安装。 php version 步骤 5 将Predis包下载到/usr/share/php目录下。 1. 通过以下命令下载Predis源文件。 wget 说明 仅以该版本作为示例，您还可以去redis官网或者php官网下载其他版本的predis客户端。 2. 解压Predis源文件包。 tar zxvf predis1.1.10.tar.gz 3. 将解压好的predis目录重命名为“predis”，并移动到/usr/share/php/下。 mv predis1.1.10 predis 步骤 6 编辑一个文件连接redis。 使用redis.php文件连接Redis单机/主备/Proxy集群示例： 'tcp' , 'host' > '{redisinstanceaddress}' , 'port' > {port} , 'password' > '{password}' ]); $client>set('foo', 'bar'); $value $client>get('foo'); echo $value; ?> 使用rediscluster.php连接Redis Cluster集群代码示例： 'redis'); $client new PredisClient($servers, $options); $client>set('foo', 'bar'); $value $client>get('foo'); echo $value; ?> 其中， {redisinstanceaddress} 为Redis实例真实的IP地址， {port} 为Redis实例真实的端口。IP地址和端口获取见步骤1，请按实际情况修改后执行。 {password} 为创建Redis实例时自定义的密码，请按实际情况修改后执行。如果免密访问，请将password行去掉。 步骤 7 执行php redis.php连接Redis实例。

本章节会介绍Redis版本间的主要差异。 DCS在创建实例时，Redis可选择“版本号”、“实例类型”。 版本号 版本号共有3.0，4.0，5.0，6.0版本可以选择，它们的区别如下。 不同版本支持的特性、性能差异说明 比较项 Redis 3.0 Redis 4.0 & Redis 5.0 Redis 6.0 兼容开源版本 Redis 3.0兼容开源3.0.7版本 Redis 4.0兼容开源4.0.14版本，Redis 5.0兼容开源5.0.14版本 Redis 6.0兼容开源6.2.7版本 实例部署模式 采用虚机部署 在物理机上容器化部署 在物理机上容器化部署 创建实例耗时 315分钟，集群约1030分钟 约8秒 约8秒 QPS 单节点约10万QPS 单节点约10万QPS 单节点约10万QPS 可视化数据管理 不支持 提供Web CLI访问Redis，管理数据 提供Web CLI访问Redis，管理数据 实例类型 支持单机、主备、Proxy集群 支持单机、主备、Proxy集群、Cluster集群、读写分离 支持单机、主备 扩容/缩容 支持在线扩容和缩容 支持在线扩容和缩容 支持在线扩容和缩容 备份恢复 主备和集群实例支持 主备、读写分离和集群实例支持 主备实例支持 说明 由于Redis不同版本的底层架构不一样，在创建Redis实例时，确定Redis版本后，将不能修改，如Redis3.0暂不支持升级到Redis4.0或者Redis5.0。如果需要由低版本升级到高版本，建议重新创建高版本实例，然后进行数据迁移。 由于Redis不同版本的底层架构不一样，在创建Redis实例时，确定Redis版本后，将不能修改，如Redis3.0暂不支持升级到Redis4.0或者Redis5.0。如果需要由低版本升级到高版本，建议重新创建高版本实例，然后进行数据迁移。 实例类型 实例类型分为单机、主备、集群和读写分离，它们的架构与应用场景，请参考实例类型章节。

Keys String List Set Sorted Set Server DEL APPEND RPUSH SADD ZADD FLUSHALL OBJECT BITCOUNT RPUSHX SCARD ZCARD FLUSHDB EXISTS BITOP BRPOPLRUSH SDIFF ZCOUNT DBSIZE EXPIRE BITPOS LINDEX SDIFFSTORE ZINCRBY TIME MOVE DECR LINSERT SINTER ZRANGE INFO PERSIST DECRBY LLEN SINTERSTORE ZRANGEBYSCORE CLIENT KILL PTTL GET LPOP SISMEMBER ZRANK CLIENT LIST RANDOMKEY GETRANGE LPUSHX SMEMBERS ZREMRANGEBYRANK CLIENT GETNAME RENAME GETSET LRANGE SMOVE ZREMRANGEBYCORE CLIENT SETNAME RENAMENX INCR LREM SPOP ZREVRANGE CONFIG GET SCAN INCRBY LSET SRANDMEMBER ZREVRANGEBYSCORE SLOWLOG SORT INCRBYFLOAT LTRIM SREM ZREVRANK ROLE TTL MGET RPOP SUNION ZSCORE SWAPDB TYPE MSET RPOPLPU SUNIONSTORE ZUNIONSTORE MEMORY MSETNX RPOPLPUSH SSCAN ZINTERSTORE PSETEX ZSCAN SET ZRANGEBYLEX SETBIT ZLEXCOUNT SETEX SETNX SETRANGE STRLEN BITFIELD

本章节主要介绍DCS服务的Redis 4.0/5.0版本的读写分离实例，读写分离实例默认为从服务端侧实现的读写分离，通过Proxy节点识别用户读写请求，如果是写请求，则转发给主节点，如果是读请求，则转发给备节点。 读写分离主要适用于读高并发、写请求较少的业务场景，解决高并发的性能问题，节约运维成本。 说明 读写分离功能，仅在部分Region支持，具体请以控制台显示为准。 读写分离实例 实例示意图说明： 终端节点服务 终端节点服务，主要是将Redis缓存实例配置为VPC终端节点支持的服务，用户可以直接通过终端节点服务的地址访问。 Redis读写分离实例提供的IP地址和域名，即为终端节点服务的地址。 ELB 弹性负载均衡服务器，采用集群高可用方式，支持多可用区部署。 Proxy 代理服务器集群。通过Proxy节点识别用户读写请求，如果是写请求，则转发给主节点，如果是读请求，则转发给备节点，不需要用户在客户端做任何配置。 Sentinel集群 监控主备节点状态，当主节点出现故障或异常时，进行主备倒换，保证服务不中断。 主备实例 读写分离实例，后端是一个主备实例，包含了主和备两个节点。默认开启数据持久化功能，同时保持节点间数据同步。 主备节点支持跨可用区部署。

本节主要介绍数据迁移指南概述 由于用户对Redis的使用环境和场景各有差异，具体的迁移方案需要用户根据实际需求完善与细化。迁移耗时也与数据量大小、源Redis部署出处、网络带宽等相关，具体耗时需要在演练过程中记录与评估。 在迁移时需要分析业务系统使用到的缓存相关命令（附：DCS命令兼容性说明参考），在演练阶段对命令逐一验证。如有需要，可联系技术支持人员。 注意 数据迁移是一项重要且严肃的工作，准确性与时效性要求非常高，且与具体业务和操作环境相关。 本文提供的案例仅供参考，实际迁移应考虑具体的业务场景和需求，请勿直接套用。 本文提供的迁移操作，部分命令中包含了实例密码，这会导致密码记录到操作系统中，请注意保护密码不被泄露，并及时清除历史操作记录。

增加 Consumer 实例本质上也是增加线程的方式来提升速度，因此更加重要的性能提升方式是增加消费线程，最基本的步骤如下： 1. 定义一个线程池； 2. Poll 数据； 3. 把数据提交到线程池进行并发处理； 4. 等并发结果返回成功后，再次 poll 数据执行。

为了进一步提升云服务的安全性，加强实例访问的默认保护机制，对新创建Kafka实例的默认安全组策略进行优化调整。 调整内容 自本公告发布之日起，新开通Kafka实例使用的安全组未配置vpc内入方向安全组规则，将默认禁止同VPC内访问Kafka实例服务端口。此变更旨在遵循最小权限安全原则，降低因配置疏忽导致的安全风险。 影响说明 若您使用的安全组未进行额外配置，新建的实例将无法被同VPC内的云主机访问。 应对措施 如需恢复VPC内访问，请您手动配置安全组规则，具体操作如下： 在安全组入方向规则中添加以下策略： 授权策略：允许。 协议类型：TCP。 端口范围：Kafka实例服务端口。 源地址：您的VPC网段（如：192.168.0.0/16）。 配置完成后，同VPC内的云主机即可正常访问Kafka实例服务。 建议 为保障业务安全，建议您根据实际需求精确设置访问源IP或网段，避免开放不必要的访问权限。 此次调整仅影响新创建的实例，已有实例的访问策略保持不变，不受此次调整影响。感谢您对云服务安全的支持与理解。如有疑问，请联系技术支持。 特此公告。

本文介绍如何配置MQTT开源Java SDK的客户端自动连接。 要配置MQTT开源Java SDK的客户端自动连接，你需要设置以下参数和逻辑： 1、 设置自动重连：首先，你需要设置客户端的自动重连功能。在MQTT开源Java SDK中，你可以使用setAutomaticReconnect(true)方法来启用自动重连功能。这将使客户端在连接丢失后自动尝试重新连接。 MqttClient client new MqttClient(brokerUrl, clientId); client.setAutomaticReconnect(true); 2、 设置重连间隔：接下来，你可以设置自动重连的时间间隔。这将确定客户端在连接丢失后尝试重新连接的时间间隔。在MQTT开源Java SDK中，你可以使用setReconnectDelay方法来设置重连间隔，单位为毫秒。 client.setReconnectDelay(5000); // 设置重连间隔为5秒 3、 处理连接丢失事件：当连接丢失时，你可以通过实现MqttCallback接口来处理连接丢失事件。在connectionLost方法中，你可以添加自定义的处理逻辑，例如记录日志或触发重新连接。 client.setCallback(new MqttCallback() { @Override public void connectionLost(Throwable cause) { // 处理连接丢失事件 // 添加自定义的处理逻辑，例如记录日志或触发重新连接 } // 其他回调方法... }); 4、 处理重新连接事件：当客户端尝试重新连接时，你可以在reconnectComplete方法中添加自定义的处理逻辑。这个方法会在客户端成功重新连接到MQTT Broker后被调用。 client.setCallback(new MqttCallback() { // 其他回调方法... @Override public void reconnectComplete(boolean reconnect) { // 处理重新连接完成事件 // 添加自定义的处理逻辑 } }); 通过以上配置和逻辑，你可以实现MQTT开源Java SDK的客户端自动连接功能。当连接丢失时，客户端将自动尝试重新连接，并在重新连接完成后触发相应的事件回调方法。你可以根据需要添加自定义的处理逻辑来处理连接丢失和重新连接事件。

集群类型 计费单位 计费方式 按需标准价格（元/vCPU/小时） 按需标准价格（元/vCPU/月） 按需标准价格（元/vCPU/年） 天翼云集群 vCPU 按量计费 0.0556 40.032 487.056 三方云集群 vCPU 按量计费 0.0556 40.032 487.056 本地集群 vCPU 按量计费 0.1668 120.096 1461.168 AnyWhere集群 vCPU 按量计费 0.1668 120.096 1461.168 天翼云集群 GPU 按量计费 0.2223 160.056 1947.348 三方云集群 GPU 按量计费 0.2223 160.056 1947.348 本地集群 GPU 按量计费 0.3335 240.12 2921.46 AnyWhere集群 GPU 按量计费 0.3335 240.12 2921.46 集群联邦 vCPU/GPU 按量计费 0 0 0 AnyWhere集群通道 vCPU/GPU 按量计费 0 0 0

本文介绍使用Rediscli迁移自建Redis(AOF文件) 迁移介绍 Rediscli 是 Redis 自带的命令行客户端工具，它允许用户通过命令行与 Redis 服务器进行交互。 在本章节中，我们将重点介绍如何使用 Rediscli 工具以 AOF 文件的方式，将自建的 Redis 数据迁移到 DCS 缓存实例。 说明 进行迁移操作前，建议暂停相关业务，以避免数据丢失或不完整。 建议业务空闲时间进行迁移操作。 步骤1：生成AOF文件 使用以下命令来开启缓存持久化并生成 AOF 持久化文件： ./rediscli h {redisaddress} p {redisport} a {password} config set appendonly yes 如果 AOF 文件的大小不再变化，说明AOF文件为全量缓存数据。 说明 使用 Rediscli 工具登录 Redis 实例，输入命令“config get dir”可以查找生成的AOF文件保存路径。 如果没有进行特殊指定，该文件的文件名默认为 appendonly.aof。 如果需要关闭同步，可以使用 Rediscli 工具登录 Redis 实例，并输入命令 “config set appendonly no” 来关闭同步。 步骤2：上传AOF文件至天翼云ECS 为节省传输时间，请先压缩AOF文件再传输。 将压缩文件（如以SFTP/SCP等方式）上传到天翼云ECS。 说明 ECS需保证有足够的磁盘空间，供数据文件存储，同时需要与缓存实例网络互通，通常要求相同VPC和相同子网，且安全组规则不限制访问端口。 步骤3：导入数据 ./rediscli h {redisaddress} p {redisport} a {password} pipe < appendonly.aof 步骤4：迁移后验证 数据导入成功后，连接DCS缓存实例，通过dbsize命令，确认数据是否导入成功 如果导入不成功，需要分析原因，修正导入语句，然后使用flushall或者flushdb命令清理实例中的缓存数据，并重新导入。

Topic与Tag释义 1）Topic：消息主题，通过Topic对不同的业务消息进行分类。 2）Tag：消息标签，用来进一步区分某个Topic下的消息分类，消息队列RocketMQ允许消费者按照Tag对消息进行过滤，确保消费者最终只消费到他关注的消息类型。 Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以说是二级分类。 适用场景 什么时候该用Topic，什么时候该用Tag，可以参考下面的一些考虑进行权衡： 考虑消息类型：如普通消息、顺序消息，事务消息、定时（延时）消息，不同消息类型是无法通过Tag区分的，这种情况就需要我们创建不同的Topic。 业务关联性：如果是不同业务之间没有直关联的消息，建议按照Topic进行区分；而同一个业务只是子类型不一样的消息可以用Tag进行区分。 消息优先级：不同的业务场景可能会导致消费端对于消息的优先级需求不同，有的紧急，有的相对来说对于延时的接收程度更大，不同优先级的消息用不同的Topic进行区分。 消息量级：如果量小但延时要求高的消息，跟超大量级（如万亿）的消息使用同一个Topic，则有可能排队时间过长导致延时无法接受，所以不同量级的消息不要使用不同的Tag，需要用不同的Topic。 总结起来就是，在消息分类实践中，有创建多个Topic，以及在同一个Topic下创建多个Tag两种常见做法。一般来说，不同的Topic之间的消息不产生直接业务上的关联，而同一个Topic下相互之间产生联系的消息可以选择用Tag来区分，一般是相同业务下的不同板块不同类型。

RocketMQ无法避免消息重复，原因主要有以下几点： 签收的偏移量是定时（每5秒/次）同步到服务端的。 为保证消息不丢失，SDK每次提交的总是队列未签收的最小偏移量（比如无序消费，offset为1、2、3、4、5 的消息，1、3、4、5消费并已签收，2未签收，签收时最后提交的偏移量将会是2，如果此时客户端重启，会从2这个位置开始消费）。 有网络交互就不能确保每一次的交互数据都是送达的，为保证数据不丢失就要进行重试，有重试就存在重复的可能。 如果业务对消费重复非常敏感，务必要注意，建议可以采用以下两种方式处理： 业务层面可以根据msgId做去重处理，如果key字段为业务唯一字段，也可采用key去重。 业务逻辑实现消费幂等，即多次处理同一消息，对业务的影响是幂等的。

API

本节介绍了在RabbitMQ实例中如何创建、修改和删除虚拟主机限制策略。 背景信息 RabbitMQ虚拟主机限制管理是一种用于管理RabbitMQ虚拟主机的功能，它允许管理员对虚拟主机的资源和权限进行限制和管理。 虚拟主机是RabbitMQ中的逻辑隔离单位，它允许在同一台RabbitMQ服务器上创建多个独立的消息队列环境。每个虚拟主机都有自己的队列、交换机、绑定和权限设置。通过虚拟主机限制管理，管理员可以对RabbitMQ服务器上的虚拟主机进行细粒度的控制和管理。这有助于确保不同的应用程序或用户之间的隔离性、安全性和资源利用率，提高整个消息队列系统的可靠性和性能。 操作步骤 1.登录管理控制台。 2.进入RabbitMQ管理控制台。 3.在实例列表页在操作列，目标实例行点击“管理”。 4.点击“集群管理”后点击“虚拟主机限制”到达虚拟主机页面，点击“新建”按钮。 5.点击“新建”后出现以下界面，选择虚拟主机，添加限制策略内容。 限制项参数 说明 maxconnections 最大TCP连接。 maxqueues 最大队列数。 6.在目标虚拟主机限制行点击“删除”或“修改”，即可删除当前虚拟主机策略。

如何通过仪表盘发现问题 以下指标是最基础也是最重要的指标，用于快速判断RabbitMQ实例健康状况。 指标1：可消费消息数 （Ready Messages） 正常情况：这个数值应该保持在一个相对稳定的水平，或者有轻微波动。 异常情况 ：如果这个数值持续快速增长 ，通常意味着生产速度远大于消费速度 ，消费者处理能力不足、数量不够，或者出现了故障。这是消息堆积的直接体现。 指标2：连接数 （Connections） 正常情况：连接数应与系统设计的客户端数量匹配。 异常情况1 ：连接数过多 ：可能导致服务器资源（内存、文件描述符）耗尽，影响性能甚至崩溃。这通常是由于客户端没有正确关闭连接（连接泄漏）。 异常情况2：连接数骤降：可能表示大量客户端离线或网络中断。 指标3：信道数 （Channels） 正常情况：信道数通常远大于连接数。 异常情况1 ：信道数过多：即使连接数不多，过多的信道也会增加服务器的内存消耗和管理负担。 异常情况2：信道数与连接数比例异常：如果每个连接只使用一个信道，可能没有充分利用 TCP 连接的多路复用优势。 指标4：消费者数（Consumers） 正常情况：消费者数量应足以处理预期的消息流量。 异常情况1 ：消费者数为零：对于需要即时处理的队列来说是严重问题，会导致消息堆积。 异常情况2：消费者数不足：会导致消息处理缓慢，Ready 消息数增长。 异常情况3：消费者数过多：可能导致资源竞争，反而降低整体效率，需要根据实际情况进行压测和调优。

本节介绍了RabbitMQ 接入方式。 安全接入点 RabbitMQ 安全接入点支持 "PLAIN"、"AMQPLAIN" 授权机制。 1、访问控制 RabbitMQ "PLAIN"、"AMQPLAIN"授权机制需要创建用户，从而获得对应虚拟主机的访问权限。 2、接入步骤 （1）新建用户（集群管理>用户>新建用户） （2）运行demo 客户端关键参数设置 "PLAIN"、"AMQPLAIN" 授权机制的客户端关键参数配置 String host "192.168.0.0"; //安全接入点ip Integer port 5672; //安全接入点port String username "xxx"; //集群管理用户列表的用户名 String password "xxx"; String vhost "/"; ConnectionFactory connectionFactory new ConnectionFactory(); connectionFactory.setHost(host); connectionFactory.setPort(port); connectionFactory.setUsername(username); connectionFactory.setPassword(password); connectionFactory.setVirtualHost(vhost); SSL接入点 RabbitMQ 安全接入点支持 "EXTERNAL" 授权机制 1、访问控制 无 2、接入步骤 （1）下载SSL证书（实例概览>导出服务>下载SSL文件） （2）运行demo 客户端关键参数设置 "EXTERNAL" 授权机制的客户端关键参数配置 java String host "192.168.0.0"; //SSL接入点ip int port 5671; //SSL接入点port //以下2个ssl文件可通过控制台获取安装包, 具体的获取方式可以查看2.2.1接入步骤的第二小节 String ksFile "D:tmpsslclientrabbitmqkey.p12"; String tksFile "D:tmpssltruststore"; String vhost "/"; char[] keyPassphrase "W3zT98Zz9Io".toCharArray(); KeyStore ks KeyStore.getInstance("PKCS12"); ks.load(new FileInputStream(ksFile), keyPassphrase); KeyManagerFactory kmf KeyManagerFactory.getInstance("SunX509"); kmf.init(ks, keyPassphrase); char[] trustPassphrase null; trustPassphrase "W3zT98Zz9Io".toCharArray(); KeyStore tks KeyStore.getInstance("JKS"); tks.load(new FileInputStream(tksFile), trustPassphrase); TrustManagerFactory tmf TrustManagerFactory.getInstance("SunX509"); tmf.init(tks); SSLContext c SSLContext.getInstance("tlsv1.2"); c.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null); ConnectionFactory connectionFactory new ConnectionFactory(); connectionFactory.setHost(host); connectionFactory.setPort(port); connectionFactory.setVirtualHost(vhost); connectionFactory.setSaslConfig(DefaultSaslConfig.EXTERNAL); connectionFactory.useSslProtocol(c);

本节介绍了RabbitMQ接入的代码示例。 安全接入点(PLAIN、AMQPLAIN授权机制) java import com.rabbitmq.client.; import java.io.IOException; public class RabbitmqAmqpDemo { public static void main(String[] args) throws Exception { String host "192.168.0.0"; //安全接入点ip Integer port 5672; //安全接入点port String username "xxx"; //集群管理用户列表的用户名 String password "xxx"; //集群管理用户列表的密码 String vhost "/"; String exchangeName "extest"; String queueName "qutest"; ConnectionFactory connectionFactory new ConnectionFactory(); connectionFactory.setHost(host); connectionFactory.setPort(port); connectionFactory.setUsername(username); connectionFactory.setPassword(password); connectionFactory.setVirtualHost(vhost); Connection connection connectionFactory.newConnection(); Channel channel connection.createChannel(); channel.exchangeDeclare(exchangeName, BuiltinExchangeType.DIRECT, true); channel.queueDeclare(queueName, true, false, false, null); channel.queueBind(queueName, exchangeName, "test"); String message "Hello Aop"; for (int i 0; i < 10; i++) { channel.basicPublish(exchangeName, "test", null, message.getBytes()); System.out.println("消息发送成功"); } Channel consumeChannel connection.createChannel(); Consumer consumer new DefaultConsumer(consumeChannel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String messageGet new String(body, "UTF8"); if (messageGet.equals(message)) { System.out.println("消息消费成功"); } } }; consumeChannel.setDefaultConsumer(consumer); consumeChannel.basicConsume(queueName, false, consumer); Thread.sleep(10000); } } SSL接入点(EXTERNAL授权机制) java import com.rabbitmq.client.; import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory; import java.io.FileInputStream; import java.io.IOException; import java.security.KeyStore; public class RabbitmqExternalDemo { public static void main(String[] args) throws Exception { String host "192.168.0.0"; //SSL接入点ip int port 5671; //SSL接入点port //以下2个ssl文件可通过控制台获取安装包, 具体的获取方式可以查看2.2.1接入步骤的第二小节 String ksFile "D:tmpsslclientrabbitmqkey.p12"; String tksFile "D:tmpssltruststore"; String vhost "/"; String exchangeName "extest"; String queueName "qutest"; char[] keyPassphrase "W3zT98Zz9Io".toCharArray(); KeyStore ks KeyStore.getInstance("PKCS12"); ks.load(new FileInputStream(ksFile), keyPassphrase); KeyManagerFactory kmf KeyManagerFactory.getInstance("SunX509"); kmf.init(ks, keyPassphrase); char[] trustPassphrase null; trustPassphrase "W3zT98Zz9Io".toCharArray(); KeyStore tks KeyStore.getInstance("JKS"); tks.load(new FileInputStream(tksFile), trustPassphrase); TrustManagerFactory tmf TrustManagerFactory.getInstance("SunX509"); tmf.init(tks); SSLContext c SSLContext.getInstance("tlsv1.2"); c.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null); ConnectionFactory connectionFactory new ConnectionFactory(); connectionFactory.setHost(host); connectionFactory.setPort(port); connectionFactory.setVirtualHost(vhost); connectionFactory.setSaslConfig(DefaultSaslConfig.EXTERNAL); connectionFactory.useSslProtocol(c); Connection connection connectionFactory.newConnection(); Channel channel connection.createChannel(); channel.exchangeDeclare(exchangeName, BuiltinExchangeType.DIRECT, true); channel.queueDeclare(queueName, true, false, false, null); channel.queueBind(queueName, exchangeName, "test"); String message "Hello Aop"; for (int i 0; i < 10; i++) { channel.basicPublish(exchangeName, "test", null, message.getBytes()); System.out.println("消息发送成功"); } Channel consumeChannel connection.createChannel(); Consumer consumer new DefaultConsumer(consumeChannel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String messageGet new String(body, "UTF8"); if (messageGet.equals(message)) { System.out.println("消息消费成功"); } } }; consumeChannel.setDefaultConsumer(consumer); consumeChannel.basicConsume(queueName, false, consumer); Thread.sleep(10000); } }

本节主要介绍如何下载备份数据 Redis 管理控制台支持备份数据下载。 备份完成后，您可根据需求获取公网或内网下载地址进行下载。 前提条件 只有当缓存实例处于“运行中”状态，才能执行此操作。 操作步骤 1. 登录 Redis管理控制台。 2. 在管理控制台右上角选择实例所在的区域。 3. 在实例列表页，单击目标实例名称进入实例详情页面。 4. 左侧菜单点击备份与恢复，进入备份管理操作页面。 5. 点击【下载】按钮，弹框展示公网和内网下载地址，根据需求获取下载地址。 6. 访问下载地址，获取备份文件。 说明 仅当备份成功后，方可下载备份数据。

本节主要介绍如何下载备份数据 Redis 管理控制台支持备份数据下载。 备份完成后，您可根据需求获取公网或内网下载地址进行下载。 前提条件 只有当缓存实例处于“运行中”状态，才能执行此操作。 操作步骤 1. 登录 Redis管理控制台。 2. 在管理控制台右上角选择实例所在的区域。 3. 在实例列表页，单击目标实例名称进入实例详情页面。 4. 左侧菜单点击备份与恢复，进入备份管理操作页面。 5. 点击【下载】按钮，弹框展示公网和内网下载地址，根据需求获取下载地址。 6. 访问下载地址，获取备份文件。 说明 仅当备份成功后，方可下载备份数据。

本节介绍联邦资源调度策略。 调度策略概述 调度策略分为自定义调度策略和集群调度策略，自定义调度策略是命名空间级别的，集群调度策略是集群级别的， 自定义调度策略的优先级高于集群调度策略。 调度策略说明 自定义调度策略和集群调度策略配置数据一致。 基础配置 配置说明 优先级： 策略优先级，值越高，优先级越高。 冲突解决策略：资源冲突处理策略，默认“Abort”表示停止传播避免意外覆盖；可选“Overwrite”表示通过主动覆盖来接管资源。 依赖自动传播: 关联的资源是否自动传递，比如工作负载Deployment依赖配置资源ConfigMap，如果开启该配置，配置资源ConfigMap会自动传播，否则不自动传播。 资源选择 选择需要调度的资源，支持多选。支持指定资源名称，也支持通过标签选择资源。 调度配置 调度方式支持集群权重、自动均衡、复制分发三种方式。 集群权重 以静态权重比例方式分配成员集群Pod群。存在余数时，剩余Pod数将按照权重继续分配，如权重相同，则随机选择集群进行分配。

本节介绍联邦资源差异化策略。 差异化策略概述 差异化策略分为自定义差异化策略和集群差异化策略，自定义差异化策略是命名空间级别的，集群差异化策略是集群级别的， 多种差异化策略会同时生效。 差异化策略说明 基础配置&资源选择 资源选择： 选择需要调度的资源，支持多选。支持指定资源名称，也支持通过标签选择资源。 差异化策略 目标集群选择 可选择规则对所有成员集群生效。 可根据过滤条件指定生产的集群，过滤条件支持：指定集群、排除集群、标签过滤、字段过滤四种方式。 差异化配置 差异化配置说明 差异项 差异化配置说明 镜像差异化(imageOverrider) 指定容器镜像参数差异化配置 命令差异化(commandOverrider) 指定容器运行命令的差异化配置 参数差异化(argsOverrider) 指定容器运行参数的差异化配置，与commandOverrider类似 标签差异化(labelsOverrider) 指标资源标签的差异化配置 注解差异化(annotationsOverrider) 指定资源注解的差异化配置 字段差异化(fieldOverrider) 支持内置yaml、json的差异化 文本差异化(plaintext) 泛指任意资源，与kubectl patch方式类似

本节介绍如何统一管理任意环境下的Kubernetes集群。 概述 CCE One 注册集群可以帮助您快速实现Kubernetes集群注册到云端，使用天翼云容器管理控制台对注册集群进行统一管理，赋予云下集群使用云上资源能力。 场景描述 统一管理天翼云集群：天翼云CCE专有版、托管版、智算版以及Serverless容器引擎等。 统一管理本地集群：由CCE提供的运行在您数据中心基础设施之上的Kubernetes集群，以及满足CNCF标准的IDC自建的Kubernetes集群。 统一管理三方集群：三方公有云上提供的Kubernetes集群产品，如阿里云(ACK)、腾讯云(TKE)、GCP (GKE)、AWS(EKS)等。 产品优势 云上云上集群统一管理，通过天翼云容器管理控制台，赋予云上云下集群可观测、权限管理等能力。 云下集群赋予云上能力，如通过接入云上ECS、虚拟节点等扩展云下集群算力。 产品架构 操作步骤 1. 创建注册集群并接入Kubernetes集群，详细步骤见 本地注册集群、三方云注册集群。 2. 集群接入后，使用天翼云容器管理控制台对接入集群进行管理，如 Kubernetes RBAC授权、运维等。

本节介绍计费模式。 按量计费 适用场景 按需付费是一种灵活的计费模式，适用于需要灵活调整资源、业务不稳定或资金有限的场景。在选择计费模式时，应结合业务需求和实际情况来做出合适的选择。 收费方式 一种后付费模式，即先使用再付费。 计费说明 开通按需计费资源时，您的天翼云账户余额+通用代金券须大于100元，并且大于按需计费资源（当前已开通+即将要开通）1小时费用的总和。 按需计费根据资源的结算周期进行结算。一般按需计费的结算周期有小时/日/月等，在达到结算周期时，系统会生成账单，进行扣费。 如果账户余额不足，资源将进入保留期，需要在保留期完成缴费，超过保留期，所使用资源将被关停并收回资源。

本节介绍资源委托协议。 使用 CCE One 服务需要授予访问以下云资源的权限： 访问计算类服务 注册集群按需弹性云上资源时会关联创建云服务器，需要获取访问弹性云服务器、弹性裸金属服务器的权限。 访问存储类服务 为注册集群关联云上节点和容器挂载存储，需要获取访问云硬盘、弹性文件、对象存储等服务的权限。 访问网络类服务 为注册集群及联邦提供网络代理及服务对外暴露，需要获取访问虚拟私有云、弹性负载均衡、弹性IP、NAT网关等服务的权限。 访问容器与监控类服务 为三方注册集群下容器提供镜像拉取、监控和日志分析等功能，需要获取访问容器镜像、应用运维管理等服务的权限同意授权后，CCE One 将在统一身份认证服务为您创建名为 CtyunAssumeRoleForCCEONE 的 委托，为保证服务正常使用，在使用 CCE One 服务期间请不要删除或修改 CtyunAssumeRoleForCCEONE 委托。

Command Family Command redis 5.0 Bitmap BITCOUNT ✔️ Bitmap BITFIELD ✔️ Bitmap BITFIELDRO ✔️ Bitmap BITOP ✔️ Bitmap BITPOS ✔️ Bitmap GETBIT ✔️ Bitmap SETBIT ✔️ Cluster management ASKING ✔️ Cluster management CLUSTER ADDSLOTS ✔️ Cluster management CLUSTER ADDSLOTSRANGE ➖ Cluster management CLUSTER BUMPEPOCH ✔️ Cluster management CLUSTER COUNTFAILUREREPORTS ✔️ Cluster management CLUSTER COUNTKEYSINSLOT ✔️ Cluster management CLUSTER DELSLOTS ✔️ Cluster management CLUSTER DELSLOTSRANGE ➖ Cluster management CLUSTER FAILOVER ✔️ Cluster management CLUSTER FLUSHSLOTS ✔️ Cluster management CLUSTER FORGET ✔️ Cluster management CLUSTER GETKEYSINSLOT ✔️ Cluster management CLUSTER INFO ✔️ Cluster management CLUSTER KEYSLOT ✔️ Cluster management CLUSTER LINKS ➖ Cluster management CLUSTER MEET ✔️ Cluster management CLUSTER MYID ✔️ Cluster management CLUSTER MYSHARDID ➖ Cluster management CLUSTER NODES ✔️ Cluster management CLUSTER REPLICAS ✔️ Cluster management CLUSTER REPLICATE ✔️ Cluster management CLUSTER RESET ✔️ Cluster management CLUSTER SAVECONFIG ✔️ Cluster management CLUSTER SETCONFIGEPOCH ✔️ Cluster management CLUSTER SETSLOT ✔️ Cluster management CLUSTER SHARDS ➖ Cluster management CLUSTER SLAVES ✔️ Cluster management CLUSTER SLOTS ✔️ Cluster management READONLY ✔️ Cluster management READWRITE ✔️ Connection AUTH ✔️ Connection CLIENT CACHING ➖ Connection CLIENT GETNAME ✔️ Connection CLIENT GETREDIR ➖ Connection CLIENT ID ✔️ Connection CLIENT INFO ➖ Connection CLIENT KILL ✔️ Connection CLIENT LIST ✔️ Connection CLIENT NOEVICT ➖ Connection CLIENT NOTOUCH ➖ Connection CLIENT PAUSE ✔️ Connection CLIENT REPLY ✔️ Connection CLIENT SETINFO ➖ Connection CLIENT SETNAME ✔️ Connection CLIENT TRACKING ➖ Connection CLIENT TRACKINGINFO ➖ Connection CLIENT UNBLOCK ✔️ Connection CLIENT UNPAUSE ➖ Connection ECHO ✔️ Connection HELLO ➖ Connection PING ✔️ Connection QUIT ✔️ Connection RESET ➖ Connection SELECT ✔️ Generic COPY ➖ Generic DEL ✔️ Generic DUMP ✔️ Generic EXISTS ✔️ Generic EXPIRE ✔️ Generic EXPIREAT ✔️ Generic EXPIRETIME ➖ Generic KEYS ✔️ Generic MIGRATE ✔️ Generic MOVE ✔️ Generic OBJECT ENCODING ✔️ Generic OBJECT FREQ ✔️ Generic OBJECT IDLETIME ✔️ Generic OBJECT REFCOUNT ✔️ Generic PRESIST ✔️ Generic PEXPIRE ✔️ Generic PEXPIREAT ✔️ Generic PEXPIRETIME ➖ Generic PTTL ✔️ Generic RANDOMKEY ✔️ Generic RENAME ✔️ Generic RENAMENX ✔️ Generic RESTORE ✔️ Generic SCAN ✔️ Generic SORT ✔️ Generic SORTRO ➖ Generic TOUCH ✔️ Generic TTL ✔️ Generic TYPE ✔️ Generic UNLINK ✔️ Generic WAIT ✔️ Generic WAITAOF ➖ Hash HDEL ✔️ Hash HEXISTS ✔️ Hash HGET ✔️ Hash HGETALL ✔️ Hash HINCRBY ✔️ Hash HINCRBYFLOAT ✔️ Hash HKEYS ✔️ Hash HLEN ✔️ Hash HMGET ✔️ Hash HMSET ✔️ Hash HRANDFIELD ➖ Hash HSCAN ✔️ Hash HSET ✔️ Hash HSETNX ✔️ Hash HSTRLEN ✔️ Hash HVALS ✔️ HyperLogLog PFADD ✔️ HyperLogLog PFMERGE ✔️ HyperLogLog PFCOUNT ✔️ HyperLogLog PFDEBUG ✔️ HyperLogLog PFSELFTEST ✔️ List BLMOVE ➖ List BLMPOP ➖ List BLPOP ✔️ List BRPOP ✔️ List BRPOPLPUSH ✔️ List LINDEX ✔️ List LINSERT ✔️ List LLEN ✔️ List LMOVE ➖ List LMPOP ➖ List LPOP ✔️ List LPOS ➖ List LPUSH ✔️ List LPUSHX ✔️ List LRANGE ✔️ List LREM ✔️ List LSET ✔️ List LTRIM ✔️ List RPOP ✔️ List RPOPLPUSH ✔️ List RPUSH ✔️ List RPUSHX ✔️ PubSub PSUBSCRIBE ✔️ PubSub PUBLISH ✔️ PubSub PUBSUB CHANNELS ✔️ PubSub PUBSUB NUMPAT ✔️ PubSub PUBSUB NUMSUB ✔️ PubSub PUBSUB SHARDCHANNELS ➖ PubSub PUBSUB SHARDNUMSUB ➖ PubSub PUNSUBSCRIBE ✔️ PubSub SPUBLISH ➖ PubSub SSUBSCRIBE ➖ PubSub SUBSCRIBE ✔️ PubSub SUNSUBSCRIBE ➖ PubSub UNSUBSCRIBE ✔️ Scripting EVAL ✔️ Scripting EVALRO ➖ Scripting EVALSHA ✔️ Scripting EVALSHARO ➖ Scripting FCALL ➖ Scripting FCALLRO ➖ Scripting FUNCTION DELETE ➖ Scripting FUNCTION DUMP ➖ Scripting FUNCTION FLUSH ➖ Scripting FUNCTION KILL ➖ Scripting FUNCTION LIST ➖ Scripting FUNCTION LOAD ➖ Scripting FUNCTION RESTORE ➖ Scripting FUNCTION STATS ➖ Scripting SCRIPT DEBUG ✔️ Scripting SCRIPT EXISTS ✔️ Scripting SCRIPT FLUSH ✔️ Scripting SCRIPT KILL ✔️ Scripting SCRIPT LOAD ✔️ Server ACL CAT ➖ Server ACL DELUSER ➖ Server ACL DRYRUN ➖ Server ACL GENPASS ➖ Server ACL GETUSER ➖ Server ACL LIST ➖ Server ACL LOAD ➖ Server ACL LOG ➖ Server ACL SAVE ➖ Server ACL SETUSER ➖ Server ACL USERS ➖ Server ACL WHOAMI ➖ Server BGREWRITEAOF ✔️ Server BGSAVE ✔️ Server COMMAND ✔️ Server COMMAND COUNT ✔️ Server COMMAND DOCS ➖ Server COMMAND GETKEYS ✔️ Server COMMAND GETKEYSANDFLAGS ➖ Server COMMAND INFO ✔️ Server COMMAND LIST ➖ Server CONFIG GET ✔️ Server CONFIG RESETSTAT ✔️ Server CONFIG REWRITE ✔️ Server CONFIG SET ✔️ Server DBSIZE ✔️ Server FAILOVER ➖ Server FLUSHALL ✔️ Server FLUSHDB ✔️ Server INFO ✔️ Server LASTSAVE ✔️ Server LATENCY DOCTOR ✔️ Server LATENCY GRAPH ✔️ Server LATENCY HISTOGRAM ➖ Server LATENCY HISTORY ✔️ Server LATENCY LATEST ✔️ Server LATENCY RESET ✔️ Server LOLWUT ✔️ Server MEMORY DOCTOR ✔️ Server MEMORY MALLOCSTATS ✔️ Server MEMORY PURGE ✔️ Server MEMORY STATS ✔️ Server MEMORY USAGE ✔️ Server MODULE LIST ✔️ Server MODULE LOAD ✔️ Server MODULE LOADEX ➖ Server MODULE UNLOAD ✔️ Server MONITOR ✔️ Server PSYNC ✔️ Server REPLCONF ✔️ Server REPLICAOF ✔️ Server RESTOREASKING ✔️ Server ROLE ✔️ Server SAVE ✔️ Server SHUTDOWN ✔️ Server SLAVEOF ✔️ Server SLOWLOG GET ✔️ Server SLOWLOG LEN ✔️ Server SLOWLOG RESET ✔️ Server SWAPDB ✔️ Server SYNC ✔️ Server TIME ✔️ Set SADD ✔️ Set SCARD ✔️ Set SDIFF ✔️ Set SDIFFSTORE ✔️ Set SINTER ✔️ Set SINTERCARD ➖ Set SINTERSTORE ✔️ Set SISMEMBER ✔️ Set SMEMBERS ✔️ Set SMISMEMBER ➖ Set SMOVE ✔️ Set SPOP ✔️ Set SRANDMEMBER ✔️ Set SREM ✔️ Set SSCAN ✔️ Set SUNION ✔️ Set SUNIONSTORE ✔️ Sorted Set BZMPOP ➖ Sorted Set BZPOPMAX ✔️ Sorted Set BZPOPMIN ✔️ Sorted Set ZADD ✔️ Sorted Set ZCARD ✔️ Sorted Set ZCOUNT ✔️ Sorted Set ZDIFF ➖ Sorted Set ZDIFFSTORE ➖ Sorted Set ZINCRBY ✔️ Sorted Set ZINTER ➖ Sorted Set ZINTERCARD ➖ Sorted Set ZINTERSTORE ✔️ Sorted Set ZLEXCOUNT ✔️ Sorted Set ZMPOP ➖ Sorted Set ZMSCORE ➖ Sorted Set ZPOPMAX ✔️ Sorted Set ZPOPMIN ✔️ Sorted Set ZRANDMEMBER ➖ Sorted Set ZRANGE ✔️ Sorted Set ZRANGEBYLEX ✔️ Sorted Set ZRANGEBYSCORE ✔️ Sorted Set ZRANGESTORE ➖ Sorted Set ZRANK ✔️ Sorted Set ZREM ✔️ Sorted Set ZREMRANGEBYLEX ✔️ Sorted Set ZREMRANGEBYRANK ✔️ Sorted Set ZREMRANGEBYSCORE ✔️ Sorted Set ZREVRANGE ✔️ Sorted Set ZREVRANGEBYLEX ✔️ Sorted Set ZREVRANGEBYSCORE ✔️ Sorted Set ZREVRANK ✔️ Sorted Set ZSCAN ✔️ Sorted Set ZSCORE ✔️ Sorted Set ZUNION ➖ Sorted Set ZUNIONSTORE ✔️ Stream XACK ✔️ Stream XADD ✔️ Stream XAUTOCLAIM ➖ Stream XCLAIM ✔️ Stream XDEL ✔️ Stream XGROUP ✔️ Stream XINFO ✔️ Stream XLEN ✔️ Stream XPENDING ✔️ Stream XRANGE ✔️ Stream XREAD ✔️ Stream XREADGROUP ✔️ Stream XREVRANGE ✔️ Stream XSETID ✔️ Stream XTRIM ✔️ String APPEND ✔️ String DECR ✔️ String DECRBY ✔️ String GET ✔️ String GETDEL ➖ String GETEX ➖ String GETRANGE ✔️ String GETSET ✔️ String INCR ✔️ String INCRBY ✔️ String INCRBYFLOAT ✔️ String LCS ➖ String MGET ✔️ String MSET ✔️ String MSETNX ✔️ String PSETEX ✔️ String SET ✔️ String SETEX ✔️ String SETNX ✔️ String SETRANGE ✔️ String STRLEN ✔️ String SUBSTR ✔️ Transactions DISCARD ✔️ Transactions EXEC ✔️ Transactions MULTI ✔️ Transactions UNWATCH ✔️ Transactions WATCH ✔️

RocketMQ实例是否支持扩容？ 可以扩容。登录RocketMQ控制台，在包周期实例所在行，单击“更多 > 扩容”，即答完成实例的扩容。 消费的最长保留时间是多久？ 一般情况下消息如果未被消费会一直保留，只有被消费后，才会被删除。但是如果设置了过期时间（TTL），则以TTL时间为准。

在业务场景允许的情况下，优先选择无序消息，或者在业务能变通的情况下，将有序消息转化为无序消息。 无序消息的优点： 生产者可以使用多进程、多线程往同一个Topic发送消息，性能更好。 消费者可以使用多进程、多线程同时消费，性能较好。 可以充分使用集群的Failover特点，无须依赖自动主备切换（切换过程服务会中断），包括： 当集群中某一Broker节点故障时，不影响业务消息生产，消息将failover发送到其它节点； 当集群中某一Broker节点故障时，不影响其它节点数据消费，故障恢复后即可消费。 能动态地扩容。 有序消息的缺点： 对于有序消息，当节点故障时，Queue数不会变化，生产与消费都会出现异常，直到故障节点恢复。 对于有序消息，需要将所有消息消费完，并且停止客户端，才能扩容。

场景描述 在RocketMQ中，删除Topic是一个比较重要且敏感的操作，需要谨慎处理。一般来说，删除Topic的场景有以下几种情况： 业务不再需要该Topic：当某个Topic对应的业务已经结束或不再需要时，可以考虑删除该Topic，以释放资源和减少管理工作。 Topic配置错误或不合适：如果创建Topic时配置错误或者配置不合适，可以考虑删除该Topic，并重新创建一个正确的Topic。 数据归档或清理：在某些情况下，可能需要对Topic中的数据进行归档或清理，以释放存储空间。在归档或清理之前，需要先将Topic中的消息备份或迁移到其他地方，确保数据的完整性和可恢复性。 无论是哪种场景，删除Topic都需要注意以下几点： 确保Topic中的消息已经被正确处理和消费：在删除Topic之前，需要确保Topic中的消息已经被正确地处理和消费，以避免数据丢失或处理中断。 停止生产者和消费者对该Topic的操作：在删除Topic之前，需要停止生产者和消费者对该Topic的操作，以避免数据冲突或丢失。 确保删除操作的权限和安全性：删除Topic通常需要管理员或具有相应权限的用户来执行，确保只有授权人员可以进行删除操作。 慎重操作，备份重要数据：在删除Topic之前，建议备份Topic中的重要数据，以防止误操作或数据丢失。 总之，删除Topic是一个敏感操作，需要在慎重考虑和评估后进行，以确保不会对业务和数据产生不可逆的影响。 操作步骤 1、进入Topic管理菜单。 2、在Topic管理菜单选择将要删除的主题，在更多下拉框选择删除，即可完成删除 注意事项： ● 删除主题前必须确保该主题对应的生产消费实例已经全部停止。 ● 删除主题后消息数据会发生丢失。