ssl生产消息 php CERTSPATH . '/cacertificate.pem', 'localcert' > CERTSPATH . '/clientrabbitmqcertificate.pem', 'localpk' > CERTSPATH . '/clientrabbitmqkey.pem', 'verifypeer' > true, 'verifypeername' > false, ); $connection new AMQPSSLConnection("10.10.33.196", 5671, "YOUR USERNAME", "YOUR PASSWORD", "/" , $sslOptions); $channel $connection>channel(); $channel>queuedeclare($queue, false, true, false, false); $channel>exchangedeclare($exchange, AMQPExchangeType::DIRECT, false, true, false); $channel>queuebind($queue, $exchange); $channel>queuedeclare($queue, false, true, false, false); $channel>exchangedeclare($exchange, AMQPExchangeType::DIRECT, false, true, false); $channel>queuebind($queue, $exchange); $messageBody implode(' ', arrayslice($argv, 1)); $message new AMQPMessage($messageBody, array('contenttype' > 'text/plain', 'deliverymode' > AMQPMessage::DELIVERYMODEPERSISTENT)); $channel>basicpublish($message, $exchange); $channel>close(); $connection>close(); ssl消费消息 php CERTSPATH . '/cacertificate.pem', 'localcert' > CERTSPATH . '/clientrabbitmqcertificate.pem', 'localpk' > CERTSPATH . '/clientrabbitmqkey.pem', 'verifypeer' > false, 'verifypeername' > false, ); $connection new AMQPSSLConnection("10.10.33.196", 5671, "YOUR USERNAME", "YOUR PASSWORD", "/" , $sslOptions); $channel $connection>channel(); $channel>queuedeclare($queue, false, true, false, false); $channel>exchangedeclare($exchange, AMQPExchangeType::DIRECT, false, true, false); $channel>queuebind($queue, $exchange); function processmessage($message) { echo "nn"; echo $message>body; echo "nn"; $message>ack(); // Send a message with the string "quit" to cancel the consumer. if ($message>body 'quit') { $message>getChannel()>basiccancel($message>getConsumerTag()); } } $channel>basicconsume($queue, $consumerTag, false, false, false, false, 'processmessage'); function shutdown($channel, $connection) { $channel>close(); $connection>close(); } registershutdownfunction('shutdown', $channel, $connection); $channel>consume();

ssl生产消息 plaintext package main import ( "crypto/tls" "crypto/x509" "flag" "fmt" amqp "github.com/rabbitmq/amqp091go" "io/ioutil" "log" ) var ( uri flag.String("uri", "amqps://USERNAME:PASSWORD@10.10.33.196:5671", "AMQP URI") exchangeName flag.String("exchange", "goexchange", "Durable AMQP exchange name") exchangeType flag.String("exchangetype", "direct", "Exchange type directfanouttopicxcustom") routingKey flag.String("key", "testkey", "AMQP routing key") body flag.String("body", "foobar", "Body of message") reliable flag.Bool("reliable", true, "Wait for the publisher confirmation before exiting") ) func init() { flag.Parse() } func main() { if err : publish(uri, exchangeName, exchangeType, routingKey, body, reliable); err ! nil { log.Fatalf("%s", err) } log.Printf("published %dB OK", len(body)) } func publish(amqpsURI, exchange, exchangeType, routingKey, body string, reliable bool) error { caCert, err : ioutil.ReadFile("D:tmphzmqtest0520rabbitmqsslclientcacertificate.pem") if err ! nil { return err } cert, err : tls.LoadX509KeyPair("D:tmphzmqtest0520rabbitmqsslclientclientrabbitmqcertificate.pem", "D:tmphzmqtest0520rabbitmqsslclientclientrabbitmqkey.pem") if err ! nil { return err } rootCAs : x509.NewCertPool() rootCAs.AppendCertsFromPEM(caCert) tlsConf : &tls.Config{ RootCAs: rootCAs, Certificates: []tls.Certificate{cert}, //ServerName: "localhost", // Optional InsecureSkipVerify: true, } connection, err : amqp.DialTLS(amqpsURI, tlsConf) if err ! nil { return fmt.Errorf("Dial: %s", err) } defer connection.Close() log.Printf("got Connection, getting Channel") channel, err : connection.Channel() if err ! nil { return fmt.Errorf("Channel: %s", err) } log.Printf("got Channel, declaring %q Exchange (%q)", exchangeType, exchange) if err : channel.ExchangeDeclare( exchange, // name exchangeType, // type true, // durable false, // autodeleted false, // internal false, // noWait nil, // arguments ); err ! nil { return fmt.Errorf("Exchange Declare: %s", err) } // Reliable publisher confirms require confirm.select support from the // connection. if reliable { log.Printf("enabling publishing confirms.") if err : channel.Confirm(false); err ! nil { return fmt.Errorf("Channel could not be put into confirm mode: %s", err) } confirms : channel.NotifyPublish(make(chan amqp.Confirmation, 1)) defer confirmOne(confirms) } log.Printf("declared Exchange, publishing %dB body (%q)", len(body), body) if err channel.Publish( exchange, // publish to an exchange routingKey, // routing to 0 or more queues false, // mandatory false, // immediate amqp.Publishing{ Headers: amqp.Table{}, ContentType: "text/plain", ContentEncoding: "", Body: []byte(body), DeliveryMode: amqp.Transient, // 1nonpersistent, 2persistent Priority: 0, // 09 }, ); err ! nil { return fmt.Errorf("Exchange Publish: %s", err) } return nil } func confirmOne(confirms

来自：

帮助文档

分布式消息服务RabbitMQ

开发指南

Go

本节介绍了如何实现RabbitMQ的高性能。 使用较小的队列长度 队列中存在大量消息时，会给内存使用带来沉重的负担，为了释放内存，RabbitMQ会将消息刷新到磁盘。这个过程通常需要时间，由于需要重建索引，重启包含大量消息的集群非常耗时。当刷盘的消息过多时，会阻塞队列处理消息，从而降低队列速度，对RabbitMQ节点的性能产生负面影响。 要获得最佳性能，应尽可能缩短队列。建议始终保持队列消息堆积的数量在0左右。 对于经常受到消息峰值影响的应用程序，和对吞吐量要求较高的应用程序，建议在队列上设置最大长度。这样可以通过丢弃队列头部的消息来保持队列长度，队列长度永远不会大于最大长度设置。 在队列声明时使用对应参数设置。 java //创建队列 HashMap map new HashMap<>(); //设置队列最大长度 map.put("xmaxlength",10 ); //设置队列溢出方式保留前10 map.put("xoverflow","rejectpublish" ); channel.queueDeclare(queueName,false,false,false,map); 当队列长度超过设置的最大长度时，RabbitMQ的默认做法是将队列头部的信息（队列中最老的消息）丢弃或变成死信。可以通过设置不同的overflow值来改变这种方式，如果overflow值设置为drophead，表示从队列前面丢弃或deadletter消息，保存后n条消息。如果overflow值设置为rejectpublish，表示最近发布的消息将被丢弃，即保存前n条消息。 自动删除不再使用的队列 客户端可能连接失败导致队列被残留，大量的残留队列会影响实例的性能。RabbitMQ提供三种自动删除队列的方法： 在队列中设置TTL策略：例如TTL策略设置为28天，当持续28天队列未被使用时，此队列将被删除。 使用autodelete队列：当最后一个消费者退出或通道/连接关闭（或与服务器的TCP连接丢失）时，autodelete队列会被删除。 使用exclusive queue：exclusive queue只能在创建它的连接中使用，当此连接关闭或消失时，exclusive queue会被删除。 设置方法如下： java boolean exclusive true; boolean autoDelete true; channel.queueDeclare(QUEUENAME, durable, exclusive, autoDelete, arguments);

实例连接地址与端口 实例创建后，从实例的“基本信息”页签的“连接信息”中获取。 查看RabbitMQ实例连接地址与端口 访问实例的用户名和token 实例创建后，从实例的“集群管理”页签的“用户”中获取用户名及token。如果没有则新建。

消费消息 plaintext using System; using System.Collections.Immutable; using System.Drawing; using Rabbit.Common.Data.Trades; using Rabbit.Common.Display; using RabbitMQ.Client; using RabbitMQ.Client.Events; namespace Rabbit.Example4.Consumer { internal sealed class Program { private static void Main() { var connectionFactory new ConnectionFactory { HostName "YOUR HOST IP", UserName "YOUR USER", Password "YOUR PASSWORD", Port 5672 }; using var connection connectionFactory.CreateConnection(); using var channel connection.CreateModel(); const string ExchangeName "dotnetexchange"; const string QueueName "dotnetqueue"; channel.ExchangeDeclare( exchange: ExchangeName, type: ExchangeType.Direct, durable: false, autoDelete: false, arguments: ImmutableDictionary .Empty); var queue channel.QueueDeclare( queue: QueueName, durable: false, exclusive: false, autoDelete: false, arguments: ImmutableDictionary .Empty); channel.QueueBind( queue: queue.QueueName, exchange: ExchangeName, routingKey: QueueName); var consumer new EventingBasicConsumer(channel); consumer.Received + (sender, eventArgs) > { var messageBody eventArgs.Body.ToArray(); var trade Trade.FromBytes(messageBody); DisplayInfo .For(trade) .SetExchange(eventArgs.Exchange) .SetQueue(queue.QueueName) .SetRoutingKey(eventArgs.RoutingKey) .SetVirtualHost(connectionFactory.VirtualHost) .Display(Color.Yellow); channel.BasicAck(eventArgs.DeliveryTag, multiple: false); }; channel.BasicConsume( queue: queue.QueueName, autoAck: false, consumer: consumer); Console.ReadLine(); } } } ssl生产消息 plaintext using System.Collections.Generic; using System.Collections.Immutable; using System.Drawing; using System.Threading.Tasks; using Rabbit.Common.Data.Trades; using Rabbit.Common.Display; using RabbitMQ.Client; namespace Rabbit.dotnet.Producer { internal sealed class Program { private static async Task Main() { var connectionFactory new ConnectionFactory { HostName "YOUR HOST IP", UserName "YOUR USERNAME", Password "YOUR PASSWORD", Port 5671 }; connectionFactory.AuthMechanisms new List () { new ExternalMechanismFactory() }; connectionFactory.Ssl.CertPath @"D:tmphzmqtest0520rabbitmqsslclientclientrabbitmqkey.p12"; // Ssl.CertPassphrase为固定参数，无需修改 connectionFactory.Ssl.CertPassphrase "YOUR PASSPHRASE"; connectionFactory.Ssl.Enabled true; connectionFactory.Ssl.CertificateValidationCallback (, , , ) > { return true; }; using var connection connectionFactory.CreateConnection(); using var channel connection.CreateModel(); const string ExchangeName "dotnetexchange"; const string QueueName "dotnetqueue"; channel.ExchangeDeclare( exchange: ExchangeName, type: ExchangeType.Direct, durable: false, autoDelete: false, arguments: ImmutableDictionary .Empty); var queue channel.QueueDeclare( queue: QueueName, durable: false, exclusive: false, autoDelete: false, arguments: ImmutableDictionary .Empty); channel.QueueBind( queue: queue.QueueName, exchange: ExchangeName, routingKey: QueueName, arguments: ImmutableDictionary .Empty); while (true) { var trade TradeData.GetFakeTrade(); string routingKey QueueName; channel.BasicPublish( exchange: ExchangeName, routingKey: routingKey, body: trade.ToBytes() ); DisplayInfo .For(trade) .SetExchange(ExchangeName) .SetRoutingKey(routingKey) .SetVirtualHost(connectionFactory.VirtualHost) .Display(Color.Cyan); await Task.Delay(millisecondsDelay: 1000); } } } }

总结 开源 RabbitMQ 不提供原生延时语义 可通过两种方式实现延时消息能力： 死信队列 + TTL：通用、稳定，但灵活性有限 延时消息插件：精度高、使用简单，但依赖部署环境 实际选型需综合考虑： 延迟精度要求 运维复杂度 消息规模与资源成本

本节介绍了在RabbitMQ实例中如何创建和删除交换器。 背景信息 生产者将消息发送到交换器，由交换器将消息路由到一个或多个队列中（或者丢弃）。交换器根据Routing Key和Binding Key将消息路由到Queue。不同类型的交换器的路由规则不同。 操作步骤 新建交换器 1.登录管理控制台。 2.进入RabbitMQ管理控制台。 3.在实例列表页在操作列，目标实例行点击“管理”。 4.点击“交换器管理”后，点击“新建”按钮。 5.点击“新建”后出现以下窗口，选择虚拟主机，添加交换器名字，选择交换器类型和其他参数，然后点击“确定”即可新建交换器。 各参数说明如下 参数 描述 虚拟主机 选择创建交换器所属的虚拟主机 名称 交换器名称。以amq.开头的为保留字段，因此不能使用。例如：。 类型 Exchange类型。 是否持久化 交换器是否持久化到磁盘 是否自动删除 如果是，交换器将在至少一个队列或交换器绑定到该交换器，然后所有队列或交换器都已解除绑定时删除。 是否内置 如果是，客户端不能直接发布到这个交换器。它只能与其他交换器绑定使用。 其他参数 Alternate exchange：备份交换器是为了实现没有路由到队列的消息，声明交换机的时候添加属性alternateexchange，声明一个备用交换机，一般声明为fanout类型，这样交换机收到路由不到队列的消息就会发送到备用交换机绑定的队列中。 其中交换机类型如下表所示 交换机类型 说明 Direct 完全根据key进行投递的叫做Direct交换机。如果Routing key匹配, 那么Message就会被传递到相应的queue中。其实在queue创建时，它会自动的以queue的名字作为routing key来绑定那个exchange。例如，绑定时设置了Routing key为”abc”，那么客户端提交的消息，只有设置了key为”abc”的才会投递到队列。 Fanout 不需要key的叫做Fanout交换机。它采取广播模式，一个消息进来时，投递到与该交换机绑定的所有队列。 Topic 对key进行模式匹配后进行投递的叫做Topic交换机。比如符号”

生产者代码示例 java package com.justin.kafka.service.gw.saslssl; import org.apache.kafka.clients.CommonClientConfigs; import org.apache.kafka.clients.producer.Callback; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.RecordMetadata; import org.apache.kafka.common.config.SaslConfigs; import org.apache.kafka.common.serialization.StringSerializer; import java.util.Properties; public class Producer { private final KafkaProducer producer; public final static String TOPIC "testtopic3"; public final static String BROKERADDR "192.168.0.11:8098,192.168.0.9:8098,192.168.0.10:8098"; public Producer() { Properties props new Properties(); props.put(ProducerConfig.BOOTSTRAPSERVERSCONFIG, BROKERADDR); props.put(ProducerConfig.VALUESERIALIZERCLASSCONFIG, StringSerializer.class.getName()); props.put(ProducerConfig.KEYSERIALIZERCLASSCONFIG, StringSerializer.class.getName()); props.put(ProducerConfig.ACKSCONFIG, "all"); props.put("retries",3); props.put(CommonClientConfigs.SECURITYPROTOCOLCONFIG, "SASLSSL"); props.put("sasl.mechanism", "SCRAMSHA512"); props.put(SaslConfigs.SASLJAASCONFIG, "org.apache.kafka.common.security.scram.ScramLoginModule required username"testuser" password"Kafka@Test";"); props.put("ssl.truststore.location","/kafka/client.truststore.jks"); props.put("ssl.truststore.password","sJses2tin1@23"); props.put("ssl.endpoint.identification.algorithm",""); producer new KafkaProducer<>(props); } public void produce() { try { for (int i 0; i (TOPIC, data), new Callback() { public void onCompletion(RecordMetadata metadata, Exception exception) { if (exception ! null) { // TODO: 异常处理 exception.printStackTrace(); return; } System.out.println("produce msg completed, partition id " + metadata.partition()); } }); } } catch (Exception e) { // TODO: 异常处理 e.printStackTrace(); } producer.flush(); producer.close(); } public static void main(String[] args) { Producer producer new Producer(); producer.produce(); } }

本文介绍创建用户并授权使用Redis 对资源进行精细访问控制 您可以使用统一身份认证（Identity and Access Management，简称IAM）服务对所拥有的Redis服务进行精细的权限管理。IAM用户的作用是多用户协同操作同一帐号时，避免分享帐号的密码。 您注册后，系统自动创建帐号，帐号是对其所拥有的资源具有完全控制权限，可以访问系统中所有的云服务。若您的团队或应用程序需要使用您的Redis资源，您可以为员工或应用程序创建IAM用户，并授予IAM用户刚好能完成工作所需的权限，新创建的IAM用户可以使用自己单独的用户名和密码登录云服务平台。 前提条件 基于IAM服务进行权限管理控制时，您需先了解Redis的策略管理，包含Redis所支持的系统策略管理，以及各策略间资源粒度的授权情况。 授权流程 左侧导航栏分别包含“用户组”、“用户”、“策略管理”、“企业项目”，用户根据个人需要进行操作资源的权限控制。 授权具体流程为：创建IAM用户 > 创建用户组并授权Redis资源权限 > 为IAM用户授权，具体操作步骤如下： 创建IAM用户 使用天翼云网门户的用户管理功能，给员工或应用程序创建IAM用户。 步骤 1 企业的天翼云管理员使用已注册的天翼云帐号登录天翼云网门户。 步骤 2 鼠标移动至天翼云首页右上角用户头像，进入账号中心。 步骤 3 账号中心左侧菜单中，单击“统一身份认证”。 步骤 4 在统一身份认证管理页，单击左侧导航菜单中的“用户”。 步骤 5 在“用户”管理界面中，单击“创建用户”。 步骤 6 在创建用户对话框中，输入用户信息。 步骤 7 单击“确定”，完成IAM用户创建，返回用户列表，将显示新创建的IAM用户。

本节介绍联邦资源管理概述。 概述 CCE One 联邦资源管理的目标是统一管理联邦中集群的Kubernetes资源。 联邦资源分发 联邦资源管理的一个基础能力就是Kubernetes资源分发，将Kubernetes资源按用户指定的策略分发到联邦中的集群。 为实现资源分发，将资源分发API拆分为资源模板和策略两部分，策略按需要拆分为调度策略和差异化策略。 资源模板 CCE One使用 Kubernetes 原生 API 定义联邦资源模板，以便轻松与现有 Kubernetes 采用的工具进行集成。 策略 调度策略 CCE One提供了一个独立的 Propagation(placement) Policy API 来定义多集群的调度要求。 支持 1:N 的策略映射机制。用户无需每次创建联邦应用时都标明调度约束。 差异化策略 CCE One为不同的集群提供了一个可自动化生产独立配置的 Override Policy API。例如： 基于成员集群所在区域自动配置不同镜像仓库地址。 根据集群不同的云厂商，可以使用不同的存储类。

本节介绍如何获取API接口URI参数。 集群ID(clusterId) 调用集群列表API，根据资源池、集群名称等过滤条件进行查询，通过 $.returnObj.records[].clusterId JSON路径可查询到clusterId。若集群名称为精确匹配，则只返回一条集群记录（集群名称全局唯一不重复）。 舰队ID(fleetId) 调用舰队列表API，根据资源池、舰队名称等过滤条件进行查询，通过 $.returnObj.records[].fleetId JSON路径可查询到fleetId。若舰队名称为精确匹配，则只返回一条舰队记录（舰队名称全局唯一不重复）。 联邦ID(federationId) 调用联邦列表API，根据资源池、联邦名称等过滤条件进行查询，通过 $.returnObj.records[].id JSON路径可查询到federationId。若联邦名称为精确匹配，则只返回一条联邦记录（联邦名称全局唯一不重复）。 资源池ID(regionId) 目前CCE One支持以下资源池 资源池 资源池ID（regionId） 华东1 bb9fdb42056f11eda1610242ac110002 华北2 200000001852 西南1 200000002368 华南2 200000002530

注册集群类型 集群描述 相关文档 天翼云集群 包含天翼云云容器引擎CCE专有版、托管版、智算版和Serverless版。 本地集群 由CCE提供的运行在您数据中心基础设施之上的Kubernetes集群，以及满足CNCF标准的IDC自建的Kubernetes集群。 三方云集群 三方公有云上提供的Kubernetes集群产品，如：阿里云(ACK)、腾讯云(TKE)、GCP (GKE)、AWS(EKS)等。 AnyWhere集群 由天翼云容器服务提供的，运行在您数据中心基础设施之上的Kubernetes集群。

本节介绍联邦工作负载。 阅读指引 建议先阅读以下文档： 联邦资源管理概述 策略管理 联邦工作负载概述 联邦工作负载的创建，分成负载信息创建和策略创建两个步骤。 负载信息的创建可参考单集群工作负载文档。 负载信息 负载策略 调度策略 集群策略：集群级别的调度策略。 自定义策略： 命名空间级别的调度策略。 详细说明请参考文档：调度策略。 差异化策略

本节介绍联邦命名空间。 联邦命名空间概述 用户在联邦创建的命名空间，默认会自动分发到所有成员集群，用户可设置跳过自动分发。 操作指引 创建命名空间 点击 新增 按钮，新增⼀个命名空间。 删除命名空间 在CCE ONE联邦控制台删除命名空间将会级联删除各个集群中的同名命名空间，并删除该命名空间相关的所有数据资源，请谨慎操作。 为保证CCE ONE联邦的正常运行，来源为“系统”或“默认”的命名空间无法被删除。 分发策略 默认 Namespace 分发策略 除系统保留的 Namespaces 外，其他所有 Namespaces 都会被自动分发到所有成员集群。 跳过 Namespace 自动分发 创建/更新命名空间，跳过自动分发。 注意 如果 Namespace 已经分发到了成员集群， 不会触发成员集群删除该 Namespace，但该 Namespace 将不会分发到新加入的成员集群。

本节介绍使用集群联邦实现应用多活容灾。 CCE One集群联邦支持将工作负载的实例分发至多个集群中，避免单集群故障引发业务中断，保障业务连续性。 前提条件 1. 已创建两个及以上的注册集群，具体操作参见 订购注册集群 章节。若已有集群，无需重复操作。 2. 已开通CCE One集群联邦实例。 环境搭建 1. 登录CCE One控制台，在左侧导航栏选择“集群资源” > “集群管理”，进入集群管理界面，确认待操作集群均处于“运行中”状态。 2. 在CCE One控制台左侧导航栏选择“舰队联邦” > “舰队管理”，新建一个容器舰队，并将待操作集群添加至舰队中。 3. 在CCE One控制台左侧导航栏选择“舰队联邦” > “联邦管理”，选择待操作联邦实例，进入联邦管理界面，查看“成员信息”，确认舰队及其下集群已接入联邦。 4. 在联邦管理界面左侧导航栏选择“工作负载” > “无状态”，创建一个nginx无状态负载。 填写负载名称、命名空间、实例数量、容器镜像等信息后，点击”下一步：调度与差异化“。 调度与差异化配置中，调度方式选择“集群权重”，并将两个集群权重设置为1:1。 注意 1. 如果待操作的多个集群位于不同资源池，建议打开“差异化配置”，按集群所在的资源池配置对应容器镜像，避免镜像拉取失败。 2. 配置完成后，点击“创建工作负载”进行创建，等待工作负载运行。

本节介绍联邦配置管理。 阅读指引 建议先阅读以下文档： 联邦资源管理概述。 策略管理。 联邦配置管理概述 通过联邦控制台创建配置时，默认只创建kubernetes资源，不做资源分发。 如需将配置发发到成员集群可使用以下任一方式： 创建工作负载的策略时开启依赖自动传播，工作负载依赖的资源将会被自动分发到成员集群。 手动创建策略，指定需分发的资源，将资源分发到对应的成员集群。 配置管理的创建参考 单集群配置管理文档。

本节介绍联邦网络管理。 阅读指引 建议先阅读以下文档： 联邦资源管理概述。 策略管理。 联邦网络管理概述 通过联邦控制台创建网络时，默认只创建kubernetes资源，不做资源分发。 如需将配置发发到成员集群可使用以下任一方式： 创建工作负载的策略时开启依赖自动传播，工作负载依赖的资源将会被自动分发到成员集群。 手动创建策略，指定需分发的资源，将资源分发到对应的成员集群。 网络资源的创建参考 单集群网络文档。 联邦网络管理 服务Service 控制台目前仅支持虚拟集群IP(ClusterIP)、节点端口(NodePort)两种服务类型的创建。

本节介绍联邦存储管理。 阅读指引 建议先阅读以下文档： 联邦资源管理概述。 策略管理。 联邦存储概述 存储相关概念参考单集群存储文档。 联邦存储管理 持久卷声明PVC 前提条件：用户需要在各成员集群提前创建好对应的存储类(StorageClass）。 参数说明 不同的集群选择对应的StorageClass。 根据StorageClass的类型选择卷模式和访问模式。

联邦版本发布记录 序号 联邦版本 成员集群兼容版本 关键特性 发布时间 1 v1.12.0 v1.19 ~ v1.30 支持基础的成员集群管理、多集群负载分发能力及部分高级特性，主要为： 1. 调度策略：支持集群亲和性、污点容忍、副本拆分/复制等不同调度方式； 2. 差异化策略：支持对分发到不同成员集群的workload，配置不同的差异化数据； 3. 重调度：基于实例状态触发重调度，并支持为调度器提供更精确的成员集群实例状态； 2025.03.15 2 v1.13.0 v1.19~v1.31 支持应用程序优先级调度、资源调度暂停和恢复功能，控制器性能显著优化，主要为： 1. 优先级调度：允许用户设置应用程序的优先级，以控制应用程序的调度顺序； 2. 调度暂停恢复：通过扩展ResourceBinding.ResourceBindingSpec.Spec.Suspension字段，用户可以控制调度的暂停和恢复； 3. 性能提升：解决组件重启或者master切换时耗时过长的问题。控制器重启后，workqueue 指标有显著提升，detector元素平均处理时间缩短 41.22%，总队列清除时间缩短 60%，峰值清除时间缩短33.33%。bindingcontroller元素平均处理时间缩短 51.72%，总队列清除时间缩短 25%，峰值清除时间也缩短 25%； 2025.09.26 3 v1.14.0 v1.19~v1.33 支持按条件污染集群，联邦资源配额管理增强功能Alpha版发布，控制器性能显著优化，主要为： 1. 支持按条件污染集群：此版本引入了一个新 API，ClusterTaintPolicy允许用户自定义规则，以便在满足预定义的集群状态条件时将特定污点添加到目标集群； 2. 联邦资源配额管理增强功能：增强了联邦配额管理，允许直接在控制平面进行全局资源配额检查； 3. 性能提升：冷启动时间提高了45%，资源检测器平均处理时间减少 54%，依赖项分配器平均处理时间减少 43%，执行控制器平均处理时间减少50％。CPU使用率减少 40%65%，内存峰值使用量降低 22%； 2025.09.26

弹性伸缩策略 自定义规则 规则类型 参数设置 指标触发 触发条件：当节点池内任一节点的CPU / 内存满足设置的阈值； 执行动作：达到触发条件后执行扩容 / 缩容指定数量的节点的动作； 周期触发 触发时间：可以选择扩缩容动作的间隔周期，如每天、每周、每月、每年的具体时间点； 执行动作：达到触发时间后，执行节点扩容 /缩容指定数量节点的操作； 告警触发 触发条件：当节点池内任一节点的告警指标满足设置的阈值； 执行动作：达到触发条件后对节点池进行增加 / 减少指定数量的节点； 具体细节描述可参考 节点弹性伸缩策略。

项目 约束 计费模式 当前只支持“按需计费”模式。 联邦名称 实例名称不可重复；实例名称长度4~40个字符，大小写字母开头，只能包含大小写字母、数字及分隔符()，大小写字母或数字结尾。 容器舰队 容器舰队可提供多集群的统一管理，包括统一的权限管理、统一的安全策略、统一的配置管理以及统一的多联邦管理、网格等能力。 舰队成员集群与联邦之间若存在跨资源池互通需求，后台默认尝试公网互联方式；若需调整，请在订购后至联邦控制台进行设置。 企业项目 可选择已有企业项目，或者在IAM创建新的企业项目。 虚拟私有云 建议联邦实例与成员集群间网络尽可能同资源池同 VPC，可最大化降低管理流量跨网跨资源池互通的成本。 所在子网 请选择虚拟私有云子网，集群的节点将部署在此子网中，并申请子网的 IP。当子网开启IPv6时，云资源（云主机、物理机）将开启 IPv4/IPv6 双栈。 ApiServer访问 请您根据需求选择合适的ELB规格，系统将据此创建一个私网ELB实例作为 APIServer 的负载均衡器，若删除该ELB实例会导致 APIServer 无法访问。 安全组 可自动生成或者选择已有安全组，需要确保联邦访问端口在虚拟私有云的子网里为放通状态。 是否使用EIP暴露ApiServer 获得您的授权，以委托方式新建 EIP 并按 EIP 实际使用量收费，未开启，无法通过公网访问 APIServer。 删除保护 防止通过控制台或API误删除联邦控制面，删除联邦控制面实例不会对用户容器集群造成任何影响，理论上也不影响已调度完成的应用。

本节介绍管理联邦成员集群及其网络连通方式。 前提条件 联邦实例处于运行状态。 成员集群处于运行状态。 成员集群与联邦控制面网络可达。 添加舰队成员 1. 进入到联邦总览页面，点击下方的【添加舰队】按钮。 2. 进入到添加舰队页面，选择需要添加的舰队，点击【确定】按钮。 3. 等待舰队添加成功。 添加集群成员 1. 进入舰队列表选择要添加成员集群的舰队，在右侧选择【添加集群】按钮。 2. 进入到添加集群页面，选择要添加的成员集群，点击【确定】按钮。 3. 等待成员集群添加成功。 移除集群成员 1. 进入到舰队成员列表页面，点击舰队左侧箭头，展开集群成员列表，选择要移出的集群成员，点击右侧的【移出舰队】操作选项。 2. 在移出舰队提示框，勾选同意【我已阅读并且知晓上述信息】选项，点击【确定】。 3. 等待集群成员移除成功。

场景 说明 备份恢复 实现集群中应用（资源YAML）的备份和恢复，并将备份数据安全地存储在指定的对象存储OSS Bucket中； 容灾迁移 基于多集群联邦能力，为您提供灾难情况下的应用自动容灾迁移能力，确保服务始终可用、异常后也可快速恢复； 应用迁移 本地IDC>天翼云CCE：将位于本地数据中心的Kubernetes集群迁移到天翼云CCE One管理的Kubernetes集群，实现应用程序的云端部署和运维管理。 应用迁移 三方云集群>天翼云CCE：将位于其他云服务提供商的Kubernetes集群迁移到天翼云CCE One管理的Kubernetes集群，实现跨云迁移和统一管理。 应用迁移 天翼云CCE同资源池迁移：在同一地理区域内的天翼云CCE One管理的Kubernetes集群间进行迁移，实现资源优化、应用升级或其他管理需求。 应用迁移 天翼云CCE跨资源池迁移：在天翼云CCE One管理的Kubernetes集群间进行迁移，将应用程序从一个地理区域迁移到另一个地理区域，以满足数据合规性、延迟和可用性等需求。 应用迁移 孤岛集群>天翼云CCE：若本地或三方云集群无法通过公网/内网方式纳管到天翼云CCE One时，可通过登录用户集群离线备份恢复方式进行操作。

此处为聚合了成员集群中该Deployment对应副本Pod的部署状态 applied: true clusterName: ccecceonedemo1 health: Healthy status: availableReplicas: 1 generation: 1 observedGeneration: 1 readyReplicas: 1 replicas: 1 resourceTemplateGeneration: 2 updatedReplicas: 1 applied: true clusterName: ccecceonedemo2 health: Healthy status: availableReplicas: 2 generation: 1 observedGeneration: 1 readyReplicas: 2 replicas: 2 resourceTemplateGeneration: 2 updatedReplicas: 2 conditions: lastTransitionTime: "20250530T09:52:51Z" message: Binding has been scheduled successfully. reason: Success status: "True" type: Scheduled lastTransitionTime: "20250530T09:52:51Z" message: All works have been successfully applied reason: FullyAppliedSuccess status: "True" type: FullyApplied lastScheduledTime: "20250530T09:52:51Z" schedulerObservedGeneration: 2

本节介绍常见故障原因和解决方法。 通过插件市场安装的插件，镜像拉取失败，报403错误 现象 原因及解决办法： 插件市场中相关镜像地址，默认均属于公共镜像在任意地方均可正常拉取；若出现以上403错误，请检查您本地Docker版本及相关配置：若Docker版本较低请升级到最新版Docker后重试，若有添加镜像加速等个性化配置，请恢复默认配置并重新加载配置后重试

Redis 7.0实例兼容开源7.0.14版本 本章节主要介绍Redis7.0 命令的兼容性。Redis7.0缓存实例支持绝大部分开源Redis7.0.14的命令，任何兼容Redis协议的客户端都可以访问。 为便于理解，本文的表格使用下述图标： ➖ 表示在原生Redis的该版本下，该命令尚未开始支持 ✔️表示支持该命令 ❌表示不支持该命令。 Command Family Command redis 7.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 ✔️

本文介绍Redis部分命令使用限制 大数据量命令使用限制 如果缓存实例的数据量比较大， 执行一些大数据量的命令时，可能会较长的时间内占用Redis的资源，让其他客户端的请求无法得到响应。 比如KEYS等命令。 Server命令的限制 对应经典版2.8、4.0和5.0版本，为了保护Redis的平稳运行，下面这些命令是禁止的：save、bgsave、bgrewriteaof 、sync、psync。 LUA命令使用限制 lua脚本的执行超时时间为5秒钟，不要在脚本中使用耗时的代码和命令，比如长时间的sleep、大的循环等。 注意 调用lua脚本时，建议不要使用随机函数去指定key，否则在主备节点上执行结果不一致，从而导致主备节点数据不一致。 其他限制 单个Redis命令不应执行太长。Redis本身只能单线程处理，会导致其他客户端请求无法及时处理。如果执行时间大于10秒,内部可能会触发主从切换，会导致其他客户端请求都失败。

Command Family Command redis 6.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 ✔️

本文介绍Redis弹性IP实现公网访问 限制 仅主备、单机、集群主备、集群单机、读写分离实例支持。 条件 1. 已开通Redis实例。 2. 存在空闲的弹性IP。 开启方法 1. 创建Redis实例：已有实例可忽略这步。如果没有redis实例，可以参考：创建实例。 2. 创建弹性IP： 已有弹性IP可忽略这步。如果没有弹性IP，可以参考：申请弹性IP。 3. 点击需要绑定实例的详情>公网IP绑定。 4. 选中需要绑定的弹性IP，点”确定“。 5. 稍稍等待一定时间（约1分钟），可在Redis实例详情看到公网IP。

命令 功能 ZPOPMIN 删除并返回在Sorted Set中得分最低的值。 默认是返回1个 ZPOPMAX 删除并返回在Sorted Set中得分最高的值。 默认是返回1个 BZPOPMIN 阻塞版的ZPOPMIN BZPOPMAX 阻塞版的ZPOMAX

实例版本 支持的实例变更类型 变更须知及影响 Redis 2.8/4.0/5.0 单机实例变更为主备实例 连接会有秒级中断，大约1分钟左右的只读。 Redis 2.8/4.0/5.0 集群单机实例变更为集群主备实例 每个分片节点连接会有秒级中断，大约1分钟左右的只读。 Redis 6.0/7.0 单机实例变更为主备实例 连接无影响，业务无感知。 Redis 6.0/7.0 cluster单机实例变更为cluster主备实例 连接无影响，业务无感知；建议业务方后续将新增的从节点地址加入连接地址，提高可用性。

本文介绍修改Redis实例的SSL开关 如果需要关闭SSL开关，建议按照以下操作执行： 1.打开“SSL加密”页面，在SSL加密界面可选择是否勾选SSL证书信息，选择开通SSL或关闭SSL。 2.在“SSL加密”页面，关闭“SSL加密”，单击“确定”。 3.在“SSL加密”页面的SSL证书信息区域，显示“SSL加密”为已关闭。关闭SSL加密操作完成。