ops / monitor-service · Commits

Go to a project

Authored by simba
Commit 460ace25f47fcda4b52315e3db98eeb19c401427 1 parent 59555316

update

Inline Side-by-side
Showing 4 changed files with 53 additions and 108 deletions
... ... @@ -7,7 +7,7 @@ import java.util.HashMap;
import java.util.Map;
public class RedisInfo {
public class RedisInfoUtil {
public static Map<String,Object> getRedisInfo(String host,int port){
Jedis client = new Jedis(host, port);
... ...
package com.monitor.middleware.redis.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.model.MObjectInfo;
import com.model.RedisInfo;
import com.monitor.common.util.HttpRestClient;
import com.monitor.common.util.RedisInfo;
import com.monitor.common.util.RedisInfoUtil;
import com.monitor.middleware.redis.service.IRedisMonitorService;
import com.monitor.mysql.mapper.RedisMonitorMapper;
import com.monitor.mysql.mapper.MObjectInfoMapper;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
... ... @@ -21,26 +24,30 @@ public class RedisMonitorServiceImpl implements IRedisMonitorService {
Logger log = LoggerFactory.getLogger(RedisMonitorServiceImpl.class);
@Autowired
RedisMonitorMapper redisMonitorMapper;
HttpRestClient httpRestClient;
@Autowired
HttpRestClient httpRestClient;
MObjectInfoMapper mObjectInfoMapper;
@Override
public void redisMonitor() {
/**********************************************************************
*1、处理twemproxy
***********************************************************************/
List<com.model.RedisInfo> proxyList=redisMonitorMapper.selectRedisMonitorByLevel(1);
if(CollectionUtils.isEmpty(proxyList)){
List<RedisInfo> redisInfoList=new ArrayList<RedisInfo>();
redisInfoList.add(new RedisInfo("AWS","AWS",0,null));
redisInfoList.add(new RedisInfo("Qcloud","Qcloud",0,null));
RedisInfo redisInfo=null;
List<MObjectInfo> mlist= mObjectInfoMapper.getMoInfosByAlias("com_twemproxy");
if(CollectionUtils.isEmpty(mlist)){
return;
}
StringBuffer paramMonitor=null;
//遍历twemproxy
Map<String,List<String>> tMap=new HashMap<String,List<String>>();
List<String> ipList=null;
for(com.model.RedisInfo obj:proxyList){
for(MObjectInfo obj:mlist){
paramMonitor=new StringBuffer();
//JSONObject response=httpRestClient.defaultPost(obj.getHostIp()+obj.getParamMonitor(), null, JSONObject.class);
JSONObject response=httpRestClient.defaultPost("http://192.168.102.222:22222", null, JSONObject.class);
... ... @@ -62,10 +69,20 @@ public class RedisMonitorServiceImpl implements IRedisMonitorService {
ipList.add(key);
}
}
tMap.put(obj.getHostIp(),ipList);
tMap.put(obj.getMoHostIp(),ipList);
}
obj.setParamMonitor(paramMonitor.toString());
redisMonitorMapper.updateByPrimaryKey(obj);
redisInfo = new RedisInfo();
if(StringUtils.isNotBlank(obj.getMoName()) && obj.getMoName().contains("aws")){
redisInfo.setNodeFrom("AWS");
}else if(obj.getMoName().contains("qq")){
redisInfo.setNodeFrom("Qcloud");
}
redisInfo.setNodeTo(obj.getMoHostIp());
redisInfo.setLevel(1);
redisInfo.setParamMonitor(paramMonitor.toString());
redisInfoList.add(redisInfo);
//obj.setParamMonitor(paramMonitor.toString());
//redisMonitorMapper.updateByPrimaryKey(obj);
}
/**********************************************************************
... ... @@ -74,7 +91,7 @@ public class RedisMonitorServiceImpl implements IRedisMonitorService {
if(tMap.size()==0){
return;
}
Map<String,Object> rMap=new HashMap<String,Object>();
for (Map.Entry<String, List<String>> entry : tMap.entrySet()) {
String key = entry.getKey().toString();
List<String> rlist = entry.getValue();
... ... @@ -83,12 +100,21 @@ public class RedisMonitorServiceImpl implements IRedisMonitorService {
String[] ipConfig=ipStr.split(":");
Map<String,Object> result=null;
if(ipConfig.length==2){
result=RedisInfo.getRedisInfo(ipConfig[0],Integer.valueOf(ipConfig[1]));
rMap.put(ipConfig[0],result);
result= RedisInfoUtil.getRedisInfo(ipConfig[0], Integer.valueOf(ipConfig[1]));
paramMonitor=new StringBuffer();
if(null==result){
paramMonitor.append("状态：宕机;");
}else{
String role=(String)result.get("role");
paramMonitor.append("角色："+role+";");
paramMonitor.append("用量："+result.get("used_memory_rss")+";");
paramMonitor.append("内存碎片比率：" + result.get("mem_fragmentation_ratio") + ";");
// paramMonitor.append("："+isSlave+";");
}
redisInfoList.add(new RedisInfo(key,ipStr,3,paramMonitor.toString()));
}
}
}
}
}
}
... ...
... ... @@ -19,7 +19,7 @@ public class ZookeeperMonitorTask {
IZkMonitorService zkMonitorService;
//@Scheduled(fixedRate=20000)
@Scheduled(cron="0 */15 * * * ?")
@Scheduled(cron="0 0/15 * * * ? *")
public void zookeeperMonitor() {
zkMonitorService.zookeeperMonitor();
}
... ...
package com.model;
import lombok.Data;
@Data
public class RedisInfo {
private String id;
private String alias;
private String hostIp;
private String port;
private int port;
private int level;
private String nodeFrom;
private String nodeTo;
... ... @@ -15,100 +18,16 @@ public class RedisInfo {
private String createTime;
private String updateTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getAlias() {
return alias;
}
public void setAlias(String alias) {
this.alias = alias;
}
public String getHostIp() {
return hostIp;
}
public void setHostIp(String hostIp) {
this.hostIp = hostIp;
}
public String getPort() {
return port;
}
public void setPort(String port) {
this.port = port;
}
public int getLevel() {
return level;
}
public void setLevel(int level) {
this.level = level;
}
public String getNodeFrom() {
return nodeFrom;
public RedisInfo() {
super();
}
public void setNodeFrom(String nodeFrom) {
public RedisInfo(String nodeFrom,String nodeTo,int level,String paramMonitor) {
super();
this.nodeFrom = nodeFrom;
}
public String getNodeTo() {
return nodeTo;
}
public void setNodeTo(String nodeTo) {
this.nodeTo = nodeTo;
}
public String getParamMonitor() {
return paramMonitor;
}
public void setParamMonitor(String paramMonitor) {
this.paramMonitor = paramMonitor;
}
public int getState() {
return state;
}
public void setState(int state) {
this.state = state;
}
public int getCloudType() {
return cloudType;
}
public void setCloudType(int cloudType) {
this.cloudType = cloudType;
}
public String getCreateTime() {
return createTime;
}
public void setCreateTime(String createTime) {
this.createTime = createTime;
}
public String getUpdateTime() {
return updateTime;
}
public void setUpdateTime(String updateTime) {
this.updateTime = updateTime;
this.level = level;
this.paramMonitor=paramMonitor;
}
}
... ...