文档章节

java获取redis的日志信息和动态监控信息

Zero零_度
 Zero零_度
发布于 2017/05/05 14:18
字数 1785
阅读 34
收藏 0

效果展示

实时监控

实时监控

redis环境信息和日志列表

redis环境信息和日志列表

Redis配置

在windows下安装的redis,在安装目录找到redis.windows.conf文件,修改以下字段(按实际情况设置):

 

1

2

3

 

slowlog-log-slower-than 100

slowlog-max-len 1000000

slowlog-log-slower-than:是配置需要日志记录的命令执行时间,单位是微秒,也就是说配置为100,会记录命令执行时间为0.1ms以上的记录。如果设置为0,就会记录所有执行过的命令。

slowlog-max-len:是配置日志记录的条数,因为这个日志也是存储在内存中的,所以不需要担心记录日志会影响性能,但是会消耗一定内存。

完成对这些信息的获取主要还是利用redis的一些命令,如果是win系统下安装的redis,在安装目录运行redis-cli.exe这个文件,输入info,再回车,就可以看到输出很多字段的参数,部分具体参数对应的意思如下:

  • server : 一般 Redis 服务器信息,包含以下域:
  • redis_version : Redis 服务器版本
  • redis_git_sha1 : Git SHA1
  • redis_git_dirty : Git dirty flag
  • os : Redis 服务器的宿主操作系统
  • arch_bits : 架构(32 或 64 位)
  • multiplexing_api : Redis 所使用的事件处理机制
  • gcc_version : 编译 Redis 时所使用的 GCC 版本
  • process_id : 服务器进程的 PID
  • run_id : Redis 服务器的随机标识符(用于 Sentinel 和集群)
  • tcp_port : TCP/IP 监听端口
  • uptime_in_seconds : 自 Redis 服务器启动以来,经过的秒数
  • uptime_in_days : 自 Redis 服务器启动以来,经过的天数
  • lru_clock : 以分钟为单位进行自增的时钟,用于 LRU 管理
  • clients : 已连接客户端信息,包含以下域:
  • connected_clients : 已连接客户端的数量(不包括通过从属服务器连接的客户端)
  • client_longest_output_list : 当前连接的客户端当中,最长的输出列表
  • client_longest_input_buf : 当前连接的客户端当中,最大输入缓存
  • blocked_clients : 正在等待阻塞命令(BLPOP、BRPOP、BRPOPLPUSH)的客户端的数量
  • memory : 内存信息,包含以下域:
  • used_memory : 由 Redis 分配器分配的内存总量,以字节(byte)为单位
  • used_memory_human : 以人类可读的格式返回 Redis 分配的内存总量
  • used_memory_rss : 从操作系统的角度,返回 Redis 已分配的内存总量(俗称常驻集大小)。这个值和 top 、 ps 等命令的输出一致。
  • used_memory_peak : Redis 的内存消耗峰值(以字节为单位)
  • used_memory_peak_human : 以人类可读的格式返回 Redis 的内存消耗峰值
  • used_memory_lua : Lua 引擎所使用的内存大小(以字节为单位)
  • mem_fragmentation_ratio : used_memory_rss 和 used_memory 之间的比率
  • mem_allocator : 在编译时指定的, Redis 所使用的内存分配器。可以是 libc 、 jemalloc 或者 tcmalloc 。
    在理想情况下, used_memory_rss 的值应该只比 used_memory 稍微高一点儿。
    当 rss > used ,且两者的值相差较大时,表示存在(内部或外部的)内存碎片。
    内存碎片的比率可以通过 mem_fragmentation_ratio 的值看出。
    当 used > rss 时,表示 Redis 的部分内存被操作系统换出到交换空间了,在这种情况下,操作可能会产生明显的延迟。
    当 Redis 释放内存时,分配器可能会,也可能不会,将内存返还给操作系统。
    如果 Redis 释放了内存,却没有将内存返还给操作系统,那么 used_memory 的值可能和操作系统显示的 Redis 内存占用并不一致。
    查看 used_memory_peak 的值可以验证这种情况是否发生。
  • persistence : RDB 和 AOF 的相关信息
  • stats : 一般统计信息
  • replication : 主/从复制信息
  • cpu : CPU 计算量统计信息
  • commandstats : Redis 命令统计信息
  • cluster : Redis 集群信息
  • keyspace : 数据库相关的统计信息

java部分代码实现

上面是命令窗的方式,使用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

69

70

71

72

73

74

75

 

@Component

public class RedisUtil {

@Autowired

JedisPool jedisPool;

// 获取redis 服务器信息

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();

}

}

// 获取日志条数

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();

}

}

// 获取占用内存大小

public Long dbSize() {

Jedis jedis = null;

try {

jedis = jedisPool.getResource();

// TODO 配置redis服务信息

Client client = jedis.getClient();

client.dbSize();

return client.getIntegerReply();

} finally {

// 返还到连接池

jedis.close();

}

}

}

这样输出的都是和控制台一样的字符串,所以还需要sevice来对数据进行封装:

 

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

 

@Service

public class RedisService {

@Autowired

RedisUtil redisUtil;

public List<RedisInfoDetail> getRedisInfo() {

//获取redis服务器信息

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;

}

//获取日志总数

public Long getLogLen() {

return redisUtil.getLogsLen();

}

//清空日志

public String logEmpty() {

return redisUtil.logEmpty();

}

//获取当前数据库中key的数量

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;

}

//获取当前redis使用内存大小情况

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));

}

}

上面我只是贴了部分核心代码,想具体去了解的可以去下载我的项目跑一下。

由于这个没有什么难度,只是就只是贴了些代码。后续也会一直更新,一步步将这个系统完善起来。

·······················································································································································

个人博客:http://z77z.oschina.io/

此项目下载地址:https://git.oschina.net/z77z/springboot_mybatisplus

·······················································································································································

最后更新时间:2017年4月4日 19:26 
如要转载请注明出处:http://z77z.oschina.io/2017/04/04/java获取redis的日志信息和动态监控信息/

本文转载自:http://z77z.oschina.io/2017/04/04/java%E8%8E%B7%E5%8F%96redis%E7%9A%84%E6%97%A5%E5%BF%97%E4%BF%A1%E6

Zero零_度
粉丝 69
博文 1267
码字总数 263854
作品 0
程序员
私信 提问
Java发送邮件必带超时时间配置

前言 只有光头才能变强。 文本已收录至我的GitHub仓库,欢迎Star:https://github.com/ZhongFuCheng3y/3y 在线上遇到了一个发送邮件的问题,记录一下。 一、先说背景 某一天,小王跟我反馈:...

Java3y
09/06
28
0
Angel Redis监控工具

公司的项目中用到目前比较流行的缓存Redis,每天查看这些redis的运行信息,与是工作之余 和好友 @Fe-Fe 突发奇想准备写一个简单的redis监控工具来减轻日常的工作,工作之余开发,一个多月的时...

旺旺_c
2013/10/15
4.3K
129
Spring Cloud 2.x系列之springcloud如何使用spring-cache

学了springcloud如何操作数据库进行增删改查,又学了springcloud如何操作reids把数据存储到redis。今天结合数据库操作和reids操作,来看看如何使用SpringCache。SpringCache提供了基于注解的...

技术小能手
2018/09/29
0
0
MyBatis源码窥探:MyBatis整体架构解析

Mybatis的使用这里就不介绍了,不知道怎么使用的朋友可以点击 http://www.mybatis.org/mybatis-3/zh/index.html 这里面的教程很详细,包括xml的配置、映射、动态sql都有介绍,可以学习和使用...

java邵先生
01/15
0
0
Java 8新特性探究(九)跟OOM:Permgen说再见吧

很多开发者都在其系统中见过“java.lang.OutOfMemoryError: PermGen space”这一问题。这往往是由类加载器相关的内存泄漏以及新类加载器的创建导致的,通常出现于代码热部署时。相对于正式产...

GreenDay
2014/04/09
274
0

没有更多内容

加载失败,请刷新页面

加载更多

java快递电子面单打印接口对接demo

之前的后天管理系统的电子面单打印使用的是灵通打单。 使用相对比较麻烦,需要到处Excel之后再导入,麻烦。 快递鸟有电子面单api,后台系统直接对接很是方便,不过也遇到了好些问题。 不难是...

程序的小猿
28分钟前
3
0
fasjtjson文档

https://github.com/alibaba/fastjson/wiki/JSONField

jirak
28分钟前
3
0
Mybatis中插入多条记录

Oracle数据库 实现方法 <insert id="saveWithdrawLog"> INSERT ALL INTO OSM_TRADE_DETAIL(SID,MBR_ID,USR_ID,TRADE_MONEY,TRADE_TYPE,TRADE_TIME,TRADE_WAY,PAY_ID) VALUES(#{si......

豫华商
28分钟前
3
0
Flink on YARN(下):常见问题与排查思路

作者:杨弢(搏远) Flink 支持 Standalone 独立部署和 YARN、Kubernetes、Mesos 等集群部署模式,其中 YARN 集群部署模式在国内的应用越来越广泛。Flink 社区将推出 Flink on YARN 应用解读...

开源中国小二
30分钟前
3
0
技术沙龙|京东云端到端多媒体关键技术揭秘

编者按:从带来更高编码效率、更好的用户体验的京享高清,到直播架构与网络演进优化,从而为用户带来更流畅的观看体验,以及运维系统的异常自动修复和高弹性的多媒体存储架构,一层一层展示出...

京东云技术新知
30分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部