SpringCloud(一)_健康自检

2019-06-24 12:03:58 阅读：289 来源： 互联网

标签：SpringCloud 数据库 springframework health org import 健康自检 cloud

目的：监测Eureka客户端和服务器是否正常

需要依赖的jar： pom.xml

红色部分： springboot的actuator主要用于系统监控

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>org.crazyit.cloud</groupId>
	<artifactId>health-handler-provider</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	
	<dependencyManagement>
		<dependencies>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Dalston.SR1</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>

	<dependencies>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-config</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-eureka</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-actuator</artifactId>
			<version>1.5.3.RELEASE</version>
		</dependency>
	</dependencies>
	
</project>

application.yml文件

配置 healthcheck之后，就会调用实现HealthCheckHandler的类，比如MyHealthCheckHandler

spring:
  application:
    name: health-handler-provider
eureka:
  instance:
    hostname: localhost
  client:
    healthcheck: 
      enabled: true
    instanceInfoReplicationIntervalSeconds: 10
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

MyHealthCheckHandler模拟数据库是否可用的监测

return InstanceStatus.UP就会被Eureka服务器端监测到该client是down的状态

package org.crazyit.cloud;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.actuate.health.Status;
import org.springframework.stereotype.Component;

import com.netflix.appinfo.HealthCheckHandler;
import com.netflix.appinfo.InstanceInfo.InstanceStatus;

/**
 * 健康检查处理器
 * @author 杨恩雄
 *
 */
@Component
public class MyHealthCheckHandler implements HealthCheckHandler {

	@Autowired
	private MyHealthIndicator indicator;

	public InstanceStatus getStatus(InstanceStatus currentStatus) {
		Status s = indicator.health().getStatus();
		if(s.equals(Status.UP)) {
			System.out.println("数据库正常连接");
			return InstanceStatus.UP;
		} else {
			System.out.println("数据库无法连接");
			return InstanceStatus.DOWN;
		}
	}
}

　　MyHealthIndicator监测数据数据库状态，是否可用

package org.crazyit.cloud;

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.Status;
import org.springframework.boot.actuate.health.Health.Builder;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.stereotype.Component;

/**
 * 鍋ュ悍鎸囩ず鍣�
 * @author 鏉ㄦ仼闆�
 *
 */
@Component
public class MyHealthIndicator implements HealthIndicator {

	public Health health() {
		if(HealthController.canVisitDb) {		
			// 鎴愬姛杩炴帴鏁版嵁搴擄紝杩斿洖UP
			return new Health.Builder(Status.UP).build();
		} else {
			// 杩炴帴鏁版嵁搴撳け璐ワ紝杩斿洖 out of service
			return new Health.Builder(Status.DOWN).build();
		}
	}
}

　　HealthController修改数据库状态，输入http://localhost:8080/db/true即可开启数据库，而http://localhost:8080/db/false是关闭数据库

package org.crazyit.cloud;

import javax.servlet.http.HttpServletRequest;

import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HealthController {

	// 标识当前数据库是否可以访问
	static Boolean canVisitDb = false;
	
	@RequestMapping(value = "/db/{canVisitDb}", method = RequestMethod.GET)
	@ResponseBody
	public String setConnectState(@PathVariable("canVisitDb") Boolean canVisitDb) {
		this.canVisitDb = canVisitDb;
		return "当前数据库是否正常: " + this.canVisitDb;
	}
}

处理流程

1. 执行main方法，启动server

2. 自动读取application.yml文件,看到有配置healthcheck的状态为true，找实现HealthCheckHandler接口的类和重写的方法getStatus

3. MyHealthCheckHandler实现了HealthCheckHandler这个接口，通过MyHealthIndicator去查看数据库状态

4. MyHealthIndicator获取到数据库状态

5. HealthController专门为测试改变数据库状态而存在的

6.application.yml文件配置了instanceInfoReplicationIntervalSeconds: 10，所以每隔10s，就会访问实现HealthCheckHandler接口的类和重写的方法getStatus。

标签：SpringCloud,数据库,springframework,health,org,import,健康,自检,cloud
来源： https://www.cnblogs.com/zhougongjin/p/11076287.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

SpringCloud(一)_健康自检