效果展示如下所示：
實時監(jiān)控
redis配置
在windows下安裝的redis，在安裝目錄找到redis.windows.conf文件，修改以下字段（按實際情況設(shè)置）：
java" id="highlighter_870092">
|
1
2
|
slowlog-log-slower-than 100slowlog-max-len 1000000 |
slowlog-log-slower-than：是配置需要日志記錄的命令執(zhí)行時間，單位是微秒，也就是說配置為100，會記錄命令執(zhí)行時間為0.1ms以上的記錄。如果設(shè)置為0，就會記錄所有執(zhí)行過的命令。
slowlog-max-len：是配置日志記錄的條數(shù)，因為這個日志也是存儲在內(nèi)存中的，所以不需要擔(dān)心記錄日志會影響性能，但是會消耗一定內(nèi)存。
完成對這些信息的獲取主要還是利用redis的一些命令，如果是win系統(tǒng)下安裝的redis，在安裝目錄運行redis-cli.exe這個文件，輸入info，再回車，就可以看到輸出很多字段的參數(shù)
部分具體參數(shù)對應(yīng)的意思如下：
- server : 一般 redis 服務(wù)器信息，包含以下域：
- redis_version : redis 服務(wù)器版本
- redis_git_sha1 : git sha1
- redis_git_dirty : git dirty flag
- os : redis 服務(wù)器的宿主操作系統(tǒng)
- arch_bits : 架構(gòu)（32 或 64 位）
- multiplexing_api : redis 所使用的事件處理機制
- gcc_version : 編譯 redis 時所使用的 gcc 版本
- process_id : 服務(wù)器進程的 pid
- run_id : redis 服務(wù)器的隨機標(biāo)識符（用于 sentinel 和集群）
- tcp_port : tcp/ip 監(jiān)聽端口
- uptime_in_seconds : 自 redis 服務(wù)器啟動以來，經(jīng)過的秒數(shù)
- uptime_in_days : 自 redis 服務(wù)器啟動以來，經(jīng)過的天數(shù)
- lru_clock : 以分鐘為單位進行自增的時鐘，用于 lru 管理
- clients : 已連接客戶端信息，包含以下域：
- connected_clients : 已連接客戶端的數(shù)量（不包括通過從屬服務(wù)器連接的客戶端）
- client_longest_output_list : 當(dāng)前連接的客戶端當(dāng)中，最長的輸出列表
- client_longest_input_buf : 當(dāng)前連接的客戶端當(dāng)中，最大輸入緩存
- blocked_clients : 正在等待阻塞命令（blpop、brpop、brpoplpush）的客戶端的數(shù)量
- memory : 內(nèi)存信息，包含以下域：
- used_memory : 由 redis 分配器分配的內(nèi)存總量，以字節(jié)（byte）為單位
- used_memory_human : 以人類可讀的格式返回 redis 分配的內(nèi)存總量
- used_memory_rss : 從操作系統(tǒng)的角度，返回 redis 已分配的內(nèi)存總量（俗稱常駐集大小）。這個值和 top 、 ps 等命令的輸出一致。
- used_memory_peak : redis 的內(nèi)存消耗峰值（以字節(jié)為單位）
- used_memory_peak_human : 以人類可讀的格式返回 redis 的內(nèi)存消耗峰值
- used_memory_lua : lua 引擎所使用的內(nèi)存大小（以字節(jié)為單位）
- mem_fragmentation_ratio : used_memory_rss 和 used_memory 之間的比率
-
mem_allocator : 在編譯時指定的， redis 所使用的內(nèi)存分配器。可以是 libc 、 jemalloc 或者 tcmalloc 。
在理想情況下， used_memory_rss 的值應(yīng)該只比 used_memory 稍微高一點兒。
當(dāng) rss > used ，且兩者的值相差較大時，表示存在（內(nèi)部或外部的）內(nèi)存碎片。
內(nèi)存碎片的比率可以通過 mem_fragmentation_ratio 的值看出。
當(dāng) used > rss 時，表示 redis 的部分內(nèi)存被操作系統(tǒng)換出到交換空間了，在這種情況下，操作可能會產(chǎn)生明顯的延遲。當(dāng) redis 釋放內(nèi)存時，分配器可能會，也可能不會，將內(nèi)存返還給操作系統(tǒng)。
如果 redis 釋放了內(nèi)存，卻沒有將內(nèi)存返還給操作系統(tǒng)，那么 used_memory 的值可能和操作系統(tǒng)顯示的 redis 內(nèi)存占用并不一致。
查看 used_memory_peak 的值可以驗證這種情況是否發(fā)生。 - persistence : rdb 和 aof 的相關(guān)信息
- stats : 一般統(tǒng)計信息
- replication : 主/從復(fù)制信息
- cpu : cpu 計算量統(tǒng)計信息
- commandstats : redis 命令統(tǒng)計信息
- cluster : redis 集群信息
- keyspace : 數(shù)據(jù)庫相關(guān)的統(tǒng)計信息
java部分代碼實現(xiàn)
上面是命令窗的方式，使用java的話，我們就是借助jedis這個框架來幫我們完成：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
@componentpublic class redisutil { @autowired jedispool jedispool; // 獲取redis 服務(wù)器信息 public string getredisinfo() { jedis jedis = null; try { jedis = jedispool.getresource(); client client = jedis.getclient(); client.info(); string info = client.getbulkreply(); return info; } finally { // 返還到連接池 jedis.close(); } } // 獲取日志列表 public list<slowlog> getlogs(long entries) { jedis jedis = null; try { jedis = jedispool.getresource(); list<slowlog> loglist = jedis.slowlogget(entries); return loglist; } finally { // 返還到連接池 jedis.close(); } } // 獲取日志條數(shù) public long getlogslen() { jedis jedis = null; try { jedis = jedispool.getresource(); long loglen = jedis.slowloglen(); return loglen; } finally { // 返還到連接池 jedis.close(); } } // 清空日志 public string logempty() { jedis jedis = null; try { jedis = jedispool.getresource(); return jedis.slowlogreset(); } finally { // 返還到連接池 jedis.close(); } } // 獲取占用內(nèi)存大小 public long dbsize() { jedis jedis = null; try { jedis = jedispool.getresource(); // todo 配置redis服務(wù)信息 client client = jedis.getclient(); client.dbsize(); return client.getintegerreply(); } finally { // 返還到連接池 jedis.close(); } }} |
這樣輸出的都是和控制臺一樣的字符串，所以還需要sevice來對數(shù)據(jù)進行封裝：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
@servicepublic class redisservice { @autowired redisutil redisutil; public list<redisinfodetail> getredisinfo() { //獲取redis服務(wù)器信息 string info = redisutil.getredisinfo(); list<redisinfodetail> ridlist = new arraylist<redisinfodetail>(); string[] strs = info.split("\n"); redisinfodetail rif = null; if (strs != null && strs.length > 0) { for (int i = 0; i < strs.length; i++) { rif = new redisinfodetail(); string s = strs[i]; string[] str = s.split(":"); if (str != null && str.length > 1) { string key = str[0]; string value = str[1]; rif.setkey(key); rif.setvalue(value); ridlist.add(rif); } } } return ridlist; } //獲取redis日志列表 public list<operate> getlogs(long entries) { list<slowlog> list = redisutil.getlogs(entries); list<operate> oplist = null; operate op = null; boolean flag = false; if (list != null && list.size() > 0) { oplist = new linkedlist<operate>(); for (slowlog sl : list) { string args = json.tojsonstring(sl.getargs()); if (args.equals("[\"ping\"]") || args.equals("[\"slowlog\",\"get\"]") || args.equals("[\"dbsize\"]") || args.equals("[\"info\"]")) { continue; } op = new operate(); flag = true; op.setid(sl.getid()); op.setexecutetime(getdatestr(sl.gettimestamp() * 1000)); op.setusedtime(sl.getexecutiontime()/1000.0 + "ms"); op.setargs(args); oplist.add(op); } } if (flag) return oplist; else return null; } //獲取日志總數(shù) public long getloglen() { return redisutil.getlogslen(); } //清空日志 public string logempty() { return redisutil.logempty(); } //獲取當(dāng)前數(shù)據(jù)庫中key的數(shù)量 public map<string,object> getkeyssize() { long dbsize = redisutil.dbsize(); map<string,object> map = new hashmap<string, object>(); map.put("create_time", new date().gettime()); map.put("dbsize", dbsize); return map; } //獲取當(dāng)前redis使用內(nèi)存大小情況 public map<string,object> getmemeryinfo() { string[] strs = redisutil.getredisinfo().split("\n"); map<string, object> map = null; for (int i = 0; i < strs.length; i++) { string s = strs[i]; string[] detail = s.split(":"); if (detail[0].equals("used_memory")) { map = new hashmap<string, object>(); map.put("used_memory",detail[1].substring(0, detail[1].length() - 1)); map.put("create_time", new date().gettime()); break; } } return map; } private string getdatestr(long timestmp) { simpledateformat dateformat = new simpledateformat("yyyy-mm-dd hh:mm:ss"); return dateformat.format(new date(timestmp)); }} |
上面我只是貼了部分核心代碼，想具體去了解的可以去下載項目跑一下。
由于這個沒有什么難度，只是就只是貼了些代碼。后續(xù)也會一直更新，一步步將這個系統(tǒng)完善起來。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對服務(wù)器之家的支持。
原文鏈接：http://z77z.oschina.io/2017/04/04/java獲取redis的日志信息和動態(tài)監(jiān)控信息/
