1.实现HealthIndicator这个接口
package org.springframework.boot.actuate.health;
public interface HealthIndicator {
Health health();
}
2.AbstractHealthIndicator这个抽象类实现HealthIndicator接口
package org.springframework.boot.actuate.health;
import org.springframework.boot.actuate.health.Health.Builder;
public abstract class AbstractHealthIndicator implements HealthIndicator {
@Override
public final Health health() {
Health.Builder builder = new Health.Builder();
try {
doHealthCheck(builder);
}
catch (Exception ex) {
builder.down(ex);
}
return builder.build();
}
protected abstract void doHealthCheck(Health.Builder builder) throws Exception;
}
3.我们只需要继承这个抽象类，就可以实现业务监控！
代码如下：
import com.alibaba.fastjson.JSON;
import com.yum.ec3.message.bean.BrandExchangeConfigBean;
import com.yum.ec3.misc.client.MiscClient;
import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.actuate.health.AbstractHealthIndicator;
import org.springframework.boot.actuate.health.Health;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
@Component
public class MessageListenerHealthIndicator extends AbstractHealthIndicator {
private static final Logger logger = LoggerFactory.getLogger(MessageListenerHealthIndicator.class);
//过滤的key配置
@Value(“${properties.application.line}.${properties.application.brand}.${message.webapp}.${message.messageRuntimeConfigKey}”)
private String messageRuntimeConfigKey;
@Autowired
private MiscClient client;
@Override
protected void doHealthCheck(Health.Builder builder) throws Exception {
builder.withDetail(“messageRuntimeConfigMap”, getResult());
builder.up();
}
/**
* 获取生效的配置
* @return
*/
public Map<String, Object> getResult() {
Map<String, Object> result = new HashMap<>();
try {
Map<String, Object> messageRuntimeConfigMap = client.getParameterValue(messageRuntimeConfigKey);
Set<String> keySet = messageRuntimeConfigMap.keySet();
if (CollectionUtils.isNotEmpty(keySet)) {
for (Iterator<String> iterator = keySet.iterator(); iterator.hasNext(); ) {
BrandExchangeConfigBean brandExchangeConfigBean = JSON.parseObject(JSON.toJSONString(messageRuntimeConfigMap.get(iterator.next())), BrandExchangeConfigBean.class);
if (!brandExchangeConfigBean.getSkip()) {
iterator.remove();
}
}
for(String keyTemp:keySet ){
Map<String, Object> temp = new HashMap<>();
temp.put(“skip”,true);
result.put(keyTemp,temp) ;
}
}
} catch (Exception e) {
logger.error(“misc.client|getParameterValue方法异常”, e);
}
return result;
}
}
public static byte[] readStream(InputStream inStream) throws Exception {