开发手册

# AMDC开发指南

# 概述

金蝶Apusic分布式缓存软件（Apusic In-Memory Data Cache，简称：AMDC）是一款企业级高性能分布式缓存中间件，100%兼容Redis协议及开发生态，无需改造现有业务应用即可无缝迁移。AMDC具有高性能毫秒级响应、高可用多副本容错、高扩展弹性扩容的核心能力以及精细化的web可视化管控功能，为高并发、分布式场景下的关键业务提供安全可靠的高频数据存取支撑，降低数据库压力、提升系统整体吞吐量。

AMDC产品打造完完全自主的缓存框架并100%兼容Redis的各项功能与接口，这就意味着,AMDC能够被所有语言的流行的Redis客户端连接并实现数据的读写操作，在使用上也和Redis一致，没有额外的成本。

# Java、Python、Golang

我们将使用3种比较常用的开发语言去展示AMDC核心对Redis客户端的兼容性。

# Java

单节点连接与使用

Jedis amdc = new Jedis("172.24.4.212", 16359);
System.out.println(amdc.ping());
System.out.println(amdc.set("key11", "value11"));
System.out.println(amdc.get("key11"));

1
2
3
4

哨兵模式连接与使用

Set<String> sentinels = new HashSet<String>(Arrays.asList(
    "172.24.6.110:27000",
    "172.24.6.110:27001",
    "172.24.6.110:27002"
));
JedisSentinelPool pool = new JedisSentinelPool("mymaster", sentinels, jedisPoolConfig);
Jedis jedis = pool.getResource();
System.out.println(jedis.set("key12", "value12"));
System.out.println(jedis.get("key12"));

1
2
3
4
5
6
7
8
9

集群模式连接与使用

Set<HostAndPort> clusterNodes = new HashSet<>();
clusterNodes.add(new HostAndPort("172.24.6.110", 7000));
clusterNodes.add(new HostAndPort("172.24.6.110", 7001));
clusterNodes.add(new HostAndPort("172.24.6.110", 7002));
clusterNodes.add(new HostAndPort("172.24.6.110", 7003));
clusterNodes.add(new HostAndPort("172.24.6.110", 7004));
clusterNodes.add(new HostAndPort("172.24.6.110", 7005));
JedisCluster ac = new JedisCluster(clusterNodes, genericObjectPoolConfig);
System.out.println(ac.set("test1", "a"));
System.out.println(ac.set("1test", "b"));
System.out.println(ac.set("aaatest", "c"));
System.out.println("------------------------");
System.out.println(ac.get("test1"));
System.out.println(ac.get("1test"));
System.out.println(ac.get("aaatest"));

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

# Python

单节点连接与使用

amdc = redis.Redis(host=ip, port=port, db=0, decode_responses=True)
# 测试一下get set expire ttl命令
print(amdc.set("key1", "value1"))
print(amdc.get("key1"))
amdc.expire(name="key1", time=10)
print(amdc.ttl(name="key1"))
time.sleep(1)
print(amdc.ttl(name="key1"))

1
2
3
4
5
6
7
8

哨兵模式连接与使用

SENTINELADDRS = [{"172.21.33.69", "26359"}, {"172.21.33.69", "26360"}, {"172.21.33.69", "26361"}]
def sentinel():
    amdc = redis.Sentinel(sentinels=SENTINELADDRS)
    # 获取主实例
    master = amdc.master_for("mymaster")
    # 获取从实例
    slave = amdc.slave_for("mymaster")
    # 主实例中写入
    print(master.set("key2"))
    time.sleep(2)
    # 从实例中获取
    print(slave.get("key2"))

1
2
3
4
5
6
7
8
9
10
11
12

集群模式连接与使用

CLUSTERADDRS = [{"172.21.33.69", "6359"}, {"172.21.33.69", "6360"}, {"172.21.33.69", "6361"}]
def cluster():
   amdc_cluster=RedisCluster(startup_nodes=CLUSTERADDRS,decode_responses=True,socket_keepalive=True)
   print(amdc_cluster.set("key3","value3"))
   print(amdc_cluster.get("key3"))

1
2
3
4
5

# Golang

单节点连接与使用

amdc:=redis.NewClient(&redis.Options{
  Addr: "172.21.33.69:6359",
})
if res,err:=amdc.Ping().Result();err!=nil{
  fmt.Println(err)
  return
}else{
  fmt.Println(res)
}

1
2
3
4
5
6
7
8
9

哨兵模式连接与使用

//获取哨兵提供的主节点地址
amdc := redis.NewFailoverClient(&redis.FailoverOptions{
MasterName:    "mymaster",
  SentinelAddrs: []string{"172.21.33.69:26359", "172.21.33.69:26360", "172.21.33.69:26361"},
})
defer amdc.Close()
res, err := amdc.Set("hahakey", "hahavalue", 0).Result()
if err != nil {
  fmt.Println(err)
  return
}
fmt.Println(res)
 //连接哨兵节点
sentinel := redis.NewSentinelClient(&redis.Options{
  Addr: "172.21.33.69:26380",
})
defer sentinel.Close()
addr, err := sentinel.GetMasterAddrByName("mymaster").Result()
if err != nil {
  fmt.Println(err)
  return
}
fmt.Println(addr)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

集群模式连接与使用

addrs:=[]string{"172.21.33.69：6359","172.21.33.69:2360","172.21.33.69:6361"}
redis.NewClusterClient(&redis.ClusterOptions{
  Addrs: addrs,
})
if res,err:=amdc.Ping().Result();err!=nil{
  fmt.Println(err)
  return
}else{
  fmt.Println(res)
}

1
2
3
4
5
6
7
8
9
10

# AMDC命令

命令	说明
ACL LOAD	从配置的ACL文件中重新加载ACL
ACL SAVE	在已配置的ACL文件中保存当前的ACL规则
ACL LIST	列出ACL配置文件格式的当前ACL规则
ACL USERS	列出所有已配置的ACL规则的用户名
ACL GETUSER username	获取特定ACL用户的规则
ACL SETUSER username [rule [rule ...]]	修改或创建特定ACL用户的规则
ACL DELUSER username [username ...]	删除指定的ACL用户和相关规则
ACL CAT [categoryname]	列出类别内的ACL类别或命令
ACL GENPASS [bits]	为ACL用户生成伪谐像安全密码
ACL WHOAMI	返回与当前连接关联的用户的名称
ACL LOG [count or RESET]	列出最新事件因ACL而拒绝
ACL HELP	显示有关不同的子命令的有用文本
APPEND key value	将值附加到键
ASKING	在-ask重定向后由群集客户端发送
AUTH [username] password	对服务器进行身份验证
BGREWRITEAOF	异步重写仅附加文件
BGSAVE [SCHEDULE]	异步将数据集保存到磁盘
BITCOUNT key [start end [BYTE\|BIT]]	计数字符串中的设置位
BITFIELD key [GET encoding offset] [SET encoding offset value] [INCRBY encoding offset increment] [OVERFLOW WRAP\|SAT\|FAIL]	在字符串上执行任意位字段整数操作
BITFIELD_RO key GET encoding offset	在字符串上执行任意位字段整数操作。禁区的只读变体
BITOP operation destkey key [key ...]	在字符串之间执行按位操作
BITPOS key bit [start [end [BYTE\|BIT]]]	在字符串中找到第一个位设置或清除
BLPOP key [key ...] timeout	删除并获取列表中的第一个元素，或块直到可用
BRPOP key [key ...] timeout	删除并获取列表中的最后一个元素，或块直到可用
BRPOPLPUSH source destination timeout	弹出列表中的一个元素，将其推到另一个列表并返回;或阻止直到一个可用
BLMOVE source destination LEFT\|RIGHT LEFT\|RIGHT timeout	弹出列表中的一个元素，将其推到另一个列表并返回;或阻止直到一个可用
LMPOP numkeys key [key ...] LEFT\|RIGHT [COUNT count]	从列表中弹出元素
BLMPOP timeout numkeys key [key ...] LEFT\|RIGHT [COUNT count]	从列表中弹出元素，或块直到可用
BZPOPMIN key [key ...] timeout	删除并将成员从一个或多个排序集中返回最低分数，或块直到可用
BZPOPMAX key [key ...] timeout	从一个或多个排序集中删除并返回最高分数的成员，或块直到可用
BZMPOP timeout numkeys key [key ...] MIN\|MAX [COUNT count]	删除并返回具有分类集或块中的分数的成员，直到可用
CLIENT CACHING YES\|NO	指示服务器在下一个请求中跟踪或不键
CLIENT ID	返回当前连接的客户端ID
CLIENT INFO	返回有关当前客户端连接的信息。
CLIENT KILL [ip:port] [ID client-id] [TYPE normal\|master\|slave\|pubsub] [USER username] [ADDR ip:port] [LADDR ip:port] [SKIPME yes/no]	杀死客户的连接
CLIENT LIST [TYPE normal\|master\|replica\|pubsub] [ID client-id [client-id ...]]	获取客户端连接列表
CLIENT GETNAME	获取当前的连接名称
CLIENT GETREDIR	获取跟踪通知重定向客户端ID（如果有）
CLIENT UNPAUSE	恢复暂停的客户的处理
CLIENT PAUSE timeout [WRITE\|ALL]	停止客户端的处理命令一段时间
CLIENT REPLY ON\|OFF\|SKIP	指示服务器是否回复命令
CLIENT SETNAME connection-name	设置当前连接名称
CLIENT TRACKING ON\|OFF [REDIRECT client-id] [PREFIX prefix [PREFIX prefix ...]] [BCAST] [OPTIN] [OPTOUT] [NOLOOP]	启用或禁用服务器辅助客户端缓存支持
CLIENT TRACKINGINFO	返回关于当前连接的服务器辅助客户端缓存的信息
CLIENT UNBLOCK client-id [TIMEOUT\|ERROR]	取消阻止从不同连接中阻止阻止命令的客户端
CLIENT NO-EVICT ON\|OFF	为当前连接设置客户端驱逐模式
COMMAND	获取 Redis 命令详细信息数组
COMMAND COUNT	获取Redis命令的总数
COMMAND GETKEYS	给定完整的 Redis 命令提取键
COMMAND INFO command-name [command-name ...]	获取特定Redis命令详细信息的数组
CONFIG GET parameter [parameter ...]	获取配置参数的值
CONFIG REWRITE	用内存配置重写配置文件
CONFIG SET parameter value [parameter value ...]	将配置参数设置为给定的值
CONFIG RESETSTAT	重置 INFO 返回的统计信息
COPY source destination [DB destination-db] [REPLACE]	复制一个键
DBSIZE	返回所选数据库中的键数
DEBUG OBJECT key	获取有关键的调试信息
DEBUG SEGFAULT	使服务器崩溃
DECR key	一个键的整数值减一
DECRBY key decrement	按给定的数字减少一个键的整数值
DEL key [key ...]	删除一个键
DISCARD	放弃在多次执行后发出的所有命令
DUMP key	返回存储在指定键中的值的序列化版本。
ECHO message	回显给定的字符串
EVAL script numkeys [key [key ...]] [arg [arg ...]]	执行一个Lua脚本服务器端
EVAL_RO script numkeys key [key ...] arg [arg ...]	执行只读的 Lua 脚本服务器端
EVALSHA sha1 numkeys [key [key ...]] [arg [arg ...]]	执行 Lua 脚本服务器端
EVALSHA_RO sha1 numkeys key [key ...] arg [arg ...]	执行一个只读的 Lua 脚本服务器端
EXEC	执行 MULTI
EXISTS key [key ...]	判断key是否存在
EXPIRE key seconds [NX\|XX\|GT\|LT]	以秒为单位设置键的生存时间
EXPIREAT key timestamp [NX\|XX\|GT\|LT]	将键的到期时间设置为 UNIX 时间戳
EXPIRETIME key	获取键的到期 Unix 时间戳
FAILOVER [TO host port [FORCE]] [ABORT] [TIMEOUT milliseconds]	在此服务器与其副本之一之间启动协调故障转移。
FLUSHALL [ASYNC\|SYNC]	从所有数据库中删除所有键
FLUSHDB [ASYNC\|SYNC]	从当前数据库中删除所有键
GEOADD key [NX\|XX] [CH] longitude latitude member [longitude latitude member ...]	在使用排序集表示的地理空间索引中添加一个或多个地理空间项目
GEOHASH key member [member ...]	将地理空间索引的成员作为标准 geohash 字符串返回
GEOPOS key member [member ...]	返回地理空间索引成员的经度和纬度
GEODIST key member1 member2 [m\|km\|ft\|mi]	返回地理空间索引的两个成员之间的距离
GEORADIUS key longitude latitude radius m\|km\|ft\|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count [ANY]] [ASC\|DESC] [STORE key] [STOREDIST key]	查询表示地理空间索引的排序集，以获取与点的给定最大距离匹配的成员
GEORADIUSBYMEMBER key member radius m\|km\|ft\|mi [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count [ANY]] [ASC\|DESC] [STORE key] [STOREDIST key]	查询表示地理空间索引的排序集以获取与成员的给定最大距离匹配的成员
GEOSEARCH key [FROMMEMBER member] [FROMLONLAT longitude latitude] [BYRADIUS radius m\|km\|ft\|mi] [BYBOX width height m\|km\|ft\|mi] [ASC\|DESC] [COUNT count [ANY]] [WITHCOORD] [WITHDIST] [WITHHASH]	查询表示地理空间索引的排序集以获取框或圆区域内的成员。
GEOSEARCHSTORE destination source [FROMMEMBER member] [FROMLONLAT longitude latitude] [BYRADIUS radius m\|km\|ft\|mi] [BYBOX width height m\|km\|ft\|mi] [ASC\|DESC] [COUNT count [ANY]] [STOREDIST]	查询表示地理空间索引的排序集以获取框或圆区域内的成员，并将结果存储在另一个键中。
GET key	获取一个键的值
GETBIT key offset	返回存储在 key
GETDEL key	的字符串值中偏移量处的位值。获取某个key的值并删除key
GETEX key [EX seconds\|PX milliseconds\|EXAT timestamp\|PXAT milliseconds-timestamp\|PERSIST]	获取一个键的值并可选择设置它的过期时间
GETRANGE key start end	获取存储在键中的字符串的子字符串
GETSET key value	设置一个键的字符串值并返回它的旧值
HDEL key field [field ...]	删除一个或多个哈希字段
HELLO [protover [AUTH username password] [SETNAME clientname]]	与 Redis 握手
HEXISTS key field	判断一个hash字段是否存在
HGET key field	获取哈希字段的值
HGETALL key	获取哈希中的所有字段和值
HINCRBY key field increment	将散列字段的整数值增加给定的数字
HINCRBYFLOAT key field increment	将哈希字段的浮点值增加给定的数量
HKEYS key	获取散列中的所有字段
HLEN key	获取哈希中的字段数
HMGET key field [field ...]	获取所有给定哈希字段的值
HMSET key field value [field value ...]	将多个哈希字段设置为多个值
HSET key field value [field value ...]	设置一个哈希字段的字符串值
HSETNX key field value	设置一个哈希字段的值，仅当该字段不存在时
HRANDFIELD key [count [WITHVALUES]]	从散列中获取一个或多个随机字段
HSTRLEN key field	获取哈希字段值的长度
HVALS key	获取散列中的所有值
INCR key	键的整数值加一
INCRBY key increment	将键的整数值增加给定的数量
INCRBYFLOAT key increment	将键的浮点值增加给定的数量
INFO [section]	获取有关服务器的信息和统计信息
LOLWUT [VERSION version]	展示一些计算机艺术和 Redis 版本
KEYS pattern	找到所有匹配给定模式的键
LASTSAVE	获取上次成功保存到磁盘的 UNIX 时间戳
LINDEX key index	通过索引从列表中获取元素
LINSERT key BEFORE\|AFTER pivot element	在列表中的另一个元素之前或之后插入一个元素
LLEN key	获取列表的长度
LPOP key [count]	删除并获取列表中的第一个元素
LPOS key element [RANK rank] [COUNT num-matches] [MAXLEN len]	返回列表中匹配元素的索引
LPUSH key element [element ...]	将一个或多个元素添加到列表中
LPUSHX key element [element ...]	将元素添加到列表中，仅当列表存在时
LRANGE key start stop	从列表中获取一系列元素
LREM key count element	从列表中删除元素
LSET key index element	通过索引设置列表中元素的值
LTRIM key start stop	将列表修剪到指定范围
MEMORY DOCTOR	输出内存问题报告
MEMORY HELP	显示有关不同子命令的有用文本
MEMORY MALLOC-STATS	显示分配器内部统计信息
MEMORY PURGE	要求分配器释放内存
MEMORY STATS	显示内存使用详情
MEMORY USAGE key [SAMPLES count]	估计一个key的内存占用
MGET key [key ...]	获取所有给定键的值
MIGRATE host port key\| destination-db timeout [COPY] [REPLACE] [AUTH password] [AUTH2 username password] [KEYS key [key ...]]	以原子方式将键从 Redis 实例传输到另一个实例。
MODULE LIST	列出服务器加载的所有模块
MODULE LOAD path [ arg [arg ...]]	加载一个模块
MODULE UNLOAD name	卸载模块
MONITOR	实时监听服务器收到的所有请求
MOVE key db	移动一个键到另一个数据库
MSET key value [key value ...]	将多个键设置为多个值
MSETNX key value [key value ...]	仅当不存在任何键时才将多个键设置为多个值
MULTI	标记一个事务块的开始
OBJECT ENCODING key	检查 Redis 对象的内部编码
OBJECT FREQ key	获取Redis对象的对数访问频率计数器
OBJECT IDLETIME key	获取自上次访问 Redis 对象以来的时间
OBJECT REFCOUNT key	获取键值的引用次数
OBJECT HELP	显示有关不同子命令的有用文本
PERSIST key	从键中删除过期时间
PEXPIRE key milliseconds [NX\|XX\|GT\|LT]	以毫秒为单位设置键的生存时间
PEXPIREAT key milliseconds-timestamp [NX\|XX\|GT\|LT]	将键的到期时间设置为以毫秒为单位指定的 UNIX 时间戳
PEXPIRETIME key	以毫秒为单位获取键的到期 Unix 时间戳
PFADD key [element [element ...]]	将指定的元素添加到指定的 HyperLogLog.
PFCOUNT key [key ...]	返回 HyperLogLog 在 key(s) 处观察到的集合的近似基数。
PFMERGE destkey sourcekey [sourcekey ...]	将 N 个不同的 HyperLogLog 合并为一个。
PING [message]	Ping 服务器
PSETEX key milliseconds value	以毫秒为单位设置键值和过期时间
PSUBSCRIBE pattern [pattern ...]	侦听发布到与给定模式匹配的频道的消息
PUBSUB CHANNELS [pattern]	列出活动频道
PUBSUB NUMPAT	获取独特模式模式订阅的计数
PUBSUB NUMSUB [channel [channel ...]]	获取频道的订阅者数量
PUBSUB HELP	显示有用的文字 ab输出不同的子命令
PTTL key	以毫秒为单位获取键的生存时间
PUBLISH channel message	向频道发布消息
PUNSUBSCRIBE [pattern [pattern ...]]	停止收听发布到与给定模式匹配的频道的消息
QUIT	关闭连接
RANDOMKEY	从键空间返回一个随机键
READONLY	启用对集群副本节点连接的读取查询
READWRITE	禁用对集群副本节点连接的读取查询
RENAME key newkey	重命名一个键
RENAMENX key newkey	重命名键，仅当新键不存在时
RESET	重置连接
RESTORE key ttl serialized-value [REPLACE] [ABSTTL] [IDLETIME seconds] [FREQ frequency]	使用提供的序列化值创建一个键，之前使用 DUMP 获得。
ROLE	返回实例在复制上下文中的角色
RPOP key [count]	删除并获取列表中的最后一个元素
RPOPLPUSH source destination	删除列表中的最后一个元素，将其添加到另一个列表中并返回它
LMOVE source destination LEFT\|RIGHT LEFT\|RIGHT	从列表中弹出一个元素，将其推送到另一个列表并返回它
RPUSH key element [element ...]	将一个或多个元素附加到列表中
RPUSHX key element [element ...]	仅当列表存在时才将元素附加到列表中
SADD key member [member ...]	将一个或多个成员添加到集合中
SAVE	将数据集同步保存到磁盘
SCARD key	获取集合中的成员数量
SCRIPT DEBUG YES\|SYNC\|NO	为执行的脚本设置调试模式。
SCRIPT EXISTS sha1 [sha1 ...]	检查脚本缓存中是否存在脚本。
SCRIPT FLUSH [ASYNC\|SYNC]	从脚本缓存中删除所有脚本。
SCRIPT KILL	终止当前正在执行的脚本。
SCRIPT LOAD script	将指定的 Lua 脚本加载到脚本缓存中。
SDIFF key [key ...]	减去多组
SDIFFSTORE destination key [key ...]	减去多个集合并将结果集合存储在一个键中
SELECT index	更改当前连接选择的数据库
SET key value [EX seconds\|PX milliseconds\|EXAT timestamp\|PXAT milliseconds-timestamp\|KEEPTTL] [NX\|XX] [GET]	设置一个键的字符串值
SETBIT key offset value	设置或清除存储在 key
SETEX key seconds value	设置一个键的值和过期时间
SETNX key value	设置键的值，仅当键不存在时
SETRANGE key offset value	从指定的偏移量开始覆盖键处的部分字符串
SHUTDOWN [NOSAVE\|SAVE]	将数据集同步保存到磁盘，然后关闭服务器
SINTER key [key ...]	多组相交
SINTERCARD numkeys key [key ...] [LIMIT limit]	将多个集合相交并返回结果的基数
SINTERSTORE destination key [key ...]	将多个集合相交并将结果集存储在一个键中
SISMEMBER key member	确定给定值是否是集合的成员
SMISMEMBER key member [member ...]	返回与集合的给定元素关联的成员资格
REPLICAOF host port	使服务器成为另一个实例的副本，或将其提升为主服务器。
SLOWLOG GET [count]	获取慢日志的条目
SLOWLOG LEN	获取慢日志的长度
SLOWLOG RESET	清除慢日志中的所有条目
SLOWLOG HELP	显示有关不同子命令的有用文本
SMEMBERS key	集齐所有成员
SMOVE source destination member	将成员从一组移动到另一组
SORT key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC\|DESC] [ALPHA] [STORE destination]	对列表、集合或排序集合中的元素进行排序
SORT_RO key [BY pattern] [LIMIT offset count] [GET pattern [GET pattern ...]] [ASC\|DESC] [ALPHA]	对列表、集合或有序集合中的元素进行排序。 SORT 的只读变体。
SPOP key [count]	从集合中删除并返回一个或多个随机成员
SRANDMEMBER key [count]	从一组中获取一个或多个随机成员
SREM key member [member ...]	从集合中删除一个或多个成员
LCS key1 key2 [LEN] [IDX] [MINMATCHLEN len] [WITHMATCHLEN]	求最长公共子串
STRLEN key	获取存储在键中的值的长度
SUBSCRIBE channel [channel ...]	收听发布到给定频道的消息
SUNION key [key ...]	添加多组
SUNIONSTORE destination key [key ...]	添加多个集合并将结果集存储在一个键中
SWAPDB index1 index2	交换两个Redis数据库
SYNC	用于复制的内部命令
PSYNC replicationid offset	用于复制的内部命令
TIME	返回当前服务器时间
TOUCH key [key ...]	更改键的最后访问时间。返回指定的现有键的数量。
TTL key	在几秒钟内获得一把钥匙的生存时间
TYPE key	确定存储在 key 的类型
UNSUBSCRIBE [channel [channel ...]]	停止收听发布到给定频道的消息
UNLINK key [key ...]	在另一个线程中异步删除一个键。否则它就像 DEL 一样，但非阻塞。
UNWATCH	忘记所有观看过的钥匙吧
WAIT numreplicas timeout	等待同步复制当前连接上下文中发送的所有写命令
WATCH key [key ...]	观察给定的键以确定 MULTI/EXEC 块的执行
ZADD key [NX\|XX] [GT\|LT] [CH] [INCR] score member [score member ...]	将一个或多个成员添加到排序集中，或者如果它已经存在则更新其分数
ZCARD key	获取有序集合中的成员数量
ZCOUNT key min max	用给定值内的分数计算排序集中的成员
ZDIFF numkeys key [key ...] [WITHSCORES]	减去多个排序集
ZDIFFSTORE destination numkeys key [key ...]	减去多个排序集并将结果排序集存储在一个新键中
ZINCRBY key increment member	在排序集中增加成员的分数
ZINTER numkeys key [key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM\|MIN\|MAX] [WITHSCORES]	将多个排序集相交
ZINTERCARD numkeys key [key ...] [LIMIT limit]	将多个有序集合相交并返回结果的基数
ZINTERSTORE destination numkeys key [key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM\|MIN\|MAX]	将多个排序集相交并将结果排序集存储在一个新键中
ZLEXCOUNT key min max	计算给定字典范围内排序集中的成员数量
ZPOPMAX key [count]	删除并返回排序集中得分最高的成员
ZPOPMIN key [count]	删除并返回排序集中得分最低的成员
ZMPOP numkeys key [key ...] MIN\|MAX [COUNT count]	删除并返回具有排序集中分数的成员
ZRANDMEMBER key [count [WITHSCORES]]	从有序集合中获取一个或多个随机元素
ZRANGESTORE dst src min max [BYSCORE\|BYLEX] [REV] [LIMIT offset count]	将有序集合中的一系列成员存储到另一个键中
ZRANGE key min max [BYSCORE\|BYLEX] [REV] [LIMIT offset count] [WITHSCORES]	返回有序集合中的一系列成员
ZRANGEBYLEX key min max [LIMIT offset count]	返回成员范围rs 在一个有序的集合中，按字典序排列
ZREVRANGEBYLEX key max min [LIMIT offset count]	返回排序集中的成员范围，按字典序范围，从高到低的字符串排序。
ZRANGEBYSCORE key min max [WITHSCORES] [LIMIT offset count]	按分数返回排序集中的一系列成员
ZRANK key member	确定有序集合中成员的索引
ZREM key member [member ...]	从排序集中删除一个或多个成员
ZREMRANGEBYLEX key min max	删除给定字典范围之间排序集中的所有成员
ZREMRANGEBYRANK key start stop	删除给定索引内排序集中的所有成员
ZREMRANGEBYSCORE key min max	删除给定分数内排序集中的所有成员
ZREVRANGE key start stop [WITHSCORES]	按索引返回排序集中的一系列成员，分数从高到低排序
ZREVRANGEBYSCORE key max min [WITHSCORES] [LIMIT offset count]	按分数返回排序集中的一系列成员，分数从高到低排序
ZREVRANK key member	确定一个有序集合中某个成员的索引，分数从高到低排序
ZSCORE key member	在排序集中获取与给定成员关联的分数
ZUNION numkeys key [key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM\|MIN\|MAX] [WITHSCORES]	添加多个排序集
ZMSCORE key member [member ...]	获取与排序集中的给定成员相关联的分数
ZUNIONSTORE destination numkeys key [key ...] [WEIGHTS weight [weight ...]] [AGGREGATE SUM\|MIN\|MAX]	添加多个排序集并将结果排序集存储在一个新键中
SCAN cursor [MATCH pattern] [COUNT count] [TYPE type]	增量迭代键空间
SSCAN key cursor [MATCH pattern] [COUNT count]	增量迭代 Set 元素
HSCAN key cursor [MATCH pattern] [COUNT count]	增量迭代哈希字段和关联值
ZSCAN key cursor [MATCH pattern] [COUNT count]	增量迭代已排序的集合元素和相关分数
XINFO CONSUMERS key groupname	列出消费者组中的消费者
XINFO GROUPS key	列出流的消费者组
XINFO STREAM key [FULL [COUNT count]]	获取有关流的信息
XINFO HELP	显示有关不同子命令的有用文本
XADD key [NOMKSTREAM] [MAXLEN\|MINID [=\|~] threshold [LIMIT count]] *\|ID field value [field value ...]	将新条目附加到流中
XTRIM key MAXLEN\|MINID [=\|~] threshold [LIMIT count]	将流修剪到（大约如果 '~' 被传递）特定大小
XDEL key ID [ID ...]	从流中删除指定的条目。返回实际删除的项目数，如果某些 ID 不存在，则可能与传递的 ID 数不同。
XRANGE key start end [COUNT count]	返回流中的一系列元素，其 ID 与指定的 ID 间隔相匹配
XREVRANGE key end start [COUNT count]	与 XRANGE 相比，以相反的顺序（从较大到较小的 ID）返回流中的一系列元素，其中 ID 与指定的 ID 间隔匹配
XLEN key	返回流中的条目数
XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]	返回多个流中从未见过的元素，其 ID 大于调用者为每个流报告的 ID。可以屏蔽。
XGROUP CREATE key groupname id\|$ [MKSTREAM]	创建一个消费者组。
XGROUP CREATECONSUMER key groupname consumername	在消费者组中创建消费者。
XGROUP DELCONSUMER key groupname consumername	从消费者组中删除消费者。
XGROUP DESTROY key groupname	销毁一个消费组。
XGROUP SETID key groupname id\|$	将消费者组设置为任意最后交付的 ID 值。
XGROUP HELP	显示有关不同子命令的有用文本
XREADGROUP GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] ID [ID ...]	使用消费者组从流中返回新条目，或访问给定消费者的待处理条目的历史记录。可以屏蔽。
XACK key group ID [ID ...]	将待处理消息标记为正确处理，有效地将其从消费者组的待处理条目列表中删除。该命令的返回值是成功确认的消息数，即我们在 PEL 中实际能够解析的 ID。
XCLAIM key group consumer min-idle-time ID [ID ...] [IDLE ms] [TIME ms-unix-time] [RETRYCOUNT count] [FORCE] [JUSTID]	更改（或获取）消费者组中消息的所有权，就好像消息已交付给指定的消费者一样。
XAUTOCLAIM key group consumer min-idle-time start [COUNT count] [JUSTID]	更改（或获取）消费者组中消息的所有权，就像将消息传递给指定的消费者一样。
XPENDING key group [[IDLE min-idle-time] start end count [consumer]]	从流消费者组待处理条目列表中返回信息和条目，即获取但从未确认的消息。
LATENCY DOCTOR	返回人类可读的延迟分析报告。
LATENCY GRAPH event	返回事件的延迟图。
LATENCY HISTORY event	返回事件的时间戳延迟样本。
LATENCY LATEST	返回所有事件的最新延迟样本。
LATENCY RESET [event [event ...]]	重置一个或多个事件的延迟数据。
LATENCY HELP	显示有关不同子命令的有用文本。

编辑页面

#开发手册

← 发版说明产品白皮书→