客户端通信
客户端通信
每个
127.0.0.1:6390> client list
id=2 addr=127.0.0.1:53184 fd=8 name= age=33 idle=24 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=0 obl=0 oll=0 omem=0 events=r cmd=client
id=3 addr=127.0.0.1:53190 fd=7 name= age=2 idle=0 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=32768 obl=0 oll=0 omem=0 events=r cmd=client
以上为两个客户端,每个包含
id:客户端唯一标识, 每新创建一个连接就自增1;redis重启后重置1。
addr: 客户端源ip:port;用于分析异常的客户端,定位是由哪个服务器哪个进程引起的;如id=2的客户端 netstat -anp | grep 53184
fd: socket的文件描述符;数值同lsof的FD字段相同
name: 客户端的名字,默认不会设置,一般用处不大。可手动执行[clientsetname](http://redis.io/commands/client-setname)
age: 客户端存活的秒数
idle: 空闲的秒数;用于回收客户端和分析大量连接时有用
flages:客户端类型的标志, 共13种,常用的几种:N(普通客户端),M(master),S(slave),O(执行monitor)
db:客户端当前使用的database序号
sub/psub: 快订阅的频道/模式数
multi:当前事务中已执行命令个数
qbuf: query buffer的字节数 重要
qbuf-free: query buffer的剩余字节数
obl:定长Output buffer的使用字节数
oll:可变大小output buffer的对象个数
omem:可变大小output buffer的内存使用字节数 重要
events: 文件描述符事作件(r/w)
cmd:客户端最近一次执行的命令,不包含参数
Buffer
Query Buffer
每个
server.h#163
/* Protocol and IO related defines */
#define PROTO_MAX_QUERYBUF_LEN (1024*1024*1024) /* 1GB max query buffer. */
用
127.0.0.1:6390> client list
id=169 qbuf=128679888 qbuf-free=425984 obl=0 oll=0 omem=0 events=r cmd=NULL
id=171 qbuf=128679888 qbuf-free=425984 obl=0 oll=0 omem=0 events=r cmd=NULL
id=218 qbuf=128679888 qbuf-free=425984 obl=0 oll=0 omem=0 events=r cmd=NULL
id=151 qbuf=128696272 qbuf-free=425984 obl=0 oll=0 omem=0 events=r cmd=NULL
Query Buffer 过载
模拟
127.0.0.1:6390> info memory
# Memory
used_memory:46979129016
used_memory_human:43.75G
used_memory_rss:49898303488
used_memory_rss_human:46.47G
used_memory_peak:54796105584
used_memory_peak_human:51.03G
total_system_memory:134911881216
total_system_memory_human:125.65G
maxmemory:4294967296
maxmemory_human:4.00G
maxmemory_policy:allkeys-random
mem_fragmentation_ratio:1.06
mem_allocator:jemalloc-4.0.3
## 当client断开后,rss会马上释放内存给OS
127.0.0.1:6390> set a b
(error) OOM command not allowed when used memory > 'maxmemory'.
我们在程序中要避免
- 禁用大
KEY ,尽量保证key 小于1KB; 虽redis 支持512MB 大小string 。 - 监控
redis 内存使用,如果忽高忽低,极有可能query buffer 引起 - 核心
Redis 集群定期收集client list 并分析qbuf 的使用量 - 建议官方提供
query buffer size 的设置参数,以保证过载保护
Output Buffer
客户端输出缓存区:执行命令所返回的结果会保存到
- 静态定长
16KB 的缓存区;主要快速存储返回比较小的结果;如简单的get 等 - 动态大小缓冲区;存储返回较大的结果,如大的集合类型
:set/list/hash 因为静态的buffer ,一般无性能和风险影响,这里简单介绍。
#define PROTO_REPLY_CHUNK_BYTES (16*1024) /* 16k output buffer */
/* With multiplexing we need to take per-client state.
* Clients are taken in a linked list. */
typedef struct client {
uint64_t id; /* Client incremental unique ID. */
redisDb *db; /* Pointer to currently SELECTed DB. */
robj *name; /* As set by CLIENT SETNAME. */
sds querybuf; /* Buffer we use to accumulate client queries. */
list *reply; /* List of reply objects to send to the client. */
/* Response buffer */
int bufpos;
char buf[PROTO_REPLY_CHUNK_BYTES];
} client;
我们常说的
client-output-buffer-limit normal 10mb 5mb 60
client-output-buffer-limit slave 256mb 64mb 60
client-output-buffer-limit pubsub 32mb 8mb 60
normal: 普通的客户端slave: 从库复制,连接到主库的客户端pubsub: 发布/ 订阅客户端
设置的
569:M 18 Jun 21:12:57.775 # Client id=972 addr=127.0.0.1:57934 fd=107 name= age=2 idle=0
flags=O db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=0 obl=0 oll=366 omem=10492208 events=rw cmd=monitor
scheduled to be closed ASAP for overcoming of output buffer limits.
要查看
id=972 addr=127.0.0.1:57934 idle=0 flags=O db=0 qbuf=0 qbuf-free=0 obl=0 oll=366 omem=10492208 events=rw cmd=monitor
另外
- 对于
normal 限制尽量小,可避免程序过度使用output buffer. - 监控
redis used_memory 如果抖动严重,极有可能 - 增加
slave 的limit 限制,避免slave 同步线程被杀,导致无限循环同步数据;且slave 线程和挂载的slave 个数相同,理论只有几个 - 禁止生产环境使用
monitor 命令,在高QPS 环境下,monitor 很快会产生output query 使用