Spring Cloud 微服务项目实现总架构一

 Spring Cloud 服务是一种分布式服务，包括配置管理，服务发现，断路器，智能路由，微代理，控制总线，一次性令牌，全局锁，主节点选举， 分布式session, 集群状态等公共组件。

一  注册机， Spring Cloud使用erureka server。服务在启动的时候，会将自己要发布的服务注册到服务注册中心；运行时，如果需要调用其他微服务的接口，那么就要先到注册中心获取服务提供者的地址，拿到地址后，通过微服务容器内部的简单负载均衡期进行路由用。

pom.xml配置如下：

<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>
<parent>
<groupId>com.rgzx</groupId>
<artifactId>rgzx-platform-parent</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<artifactId>rg-register-server</artifactId>

<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

2 注解@EnableEurekaServer加在springboot工程的启动类上

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@EnableEurekaServer
@SpringBootApplication
public class RegisterServerApplication {

public static void main(String[] args) {
SpringApplication.run(RegisterServerApplication.class, args);
}
}

3 配置注册机监控

#注册机监控 http://localhost:8090/
spring.application.name = registerServer
server.port = 8090
eureka.client.serviceUrl.defaultZone=http://localhost:8090/eureka
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false

二 接口API ，主要实现数据池配置，日志跟踪，数据库配置等接口开发相关，主要配置如下

1 注解服务类

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.web.bind.annotation.RestController;

import com.sun.glass.ui.Application;
@EnableEurekaClient
@SpringBootApplication
@RestController
@MapperScan("org.com.xx.mapper") // 告诉Mapper所在的包名
public class MobileServerApplication {

public static void main(String[] args) {
SpringApplication.run(MobileServerApplication.class, args);
}
//②
protected SpringApplicationBuilder configure(SpringApplicationBuilder application){
return application.sources(Application.class);
}
}

2 服务接口配置

eureka.client.serviceUrl.defaultZone=http://localhost:8090/eureka
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true

3 pom.xml配置 

三 负载均衡服务，实现负载均衡，熔断，服务接口状态管理，主要使用feign.hystrix实现

1 hystrix配置

#http://localhost:8091/actuator/hystrix.stream
#http://localhost:8091/hystrix

eureka.client.serviceUrl.defaultZone=http://localhost:8090/eureka
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true

feign.hystrix.enabled=true

management.endpoints.web.exposure.include=*

feign.hystrix.httpclient.enabled=true
feign.hystrix.httpclient.max-connections=200
feign.hystrix.okhttp.enabled=false
feign.hystrix.httpclient.max-connections-per-route=50

feign.hystrix.threadpool.default.coreSize=60
feign.hystrix.threadpool.default.maximumSize=5000

2 注解服务

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.openfeign.EnableFeignClients;
import com.sun.glass.ui.Application;

@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients
@EnableCircuitBreaker
@EnableHystrixDashboard
public class ProxyServerApplication {

public static void main(String[] args) {
SpringApplication.run(ProxyServerApplication.class, args);
}
//②
protected SpringApplicationBuilder configure(SpringApplicationBuilder application){
return application.sources(Application.class);
}

}

3 pom.xml 引用相关主要jar

<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
</dependency>

四  注册机服务监控

1application.properties

#http://localhost:8092
server.port=8092
spring.application.name= monitoradminserver
eureka.instance.preferIpAddress=true
eureka.instance.health-check-url-path: /actuator/health
eureka.client.service-url.defaultZone=http://localhost:8090/eureka/
eureka.client.registryFetchIntervalSeconds = 5
management.endpoints.web.exposure.include:"*"
management.endpoint.health.show-details: ALWAYS
management.endpoints.web.base-path=/
spring.boot.admin.client.url=http://localhost:8092
spring.profiles.active=prod

info.app.name="@project.name@"
info.app.description="@project.description@"
info.app.version="@project.version@"
info.spring-boot-version="@project.parent.version@"
info.version=@project.version@

spring.endpoints.health.sensitive= true
spring.endpoints.cors.allowed-methods=HEAD,GET,POST

spring.endpoints.shutdown.enabled=true

spring.endpoints.shutdown.sensitive=false

2 注解类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.web.authentication.SavedRequestAwareAuthenticationSuccessHandler;

import de.codecentric.boot.admin.server.config.AdminServerProperties;
import de.codecentric.boot.admin.server.config.EnableAdminServer;

@Configuration
@EnableAutoConfiguration
@EnableAdminServer
@SpringBootApplication
public class MonitorAdminServerApplication {

public static void main(String[] args) {
SpringApplication.run(MonitorAdminServerApplication.class, args);
}
@Profile("insecure")
@Configuration
public static class SecurityPermitAllConfig extends WebSecurityConfigurerAdapter {
@Override
protected void configure(HttpSecurity http) throws Exception {
http.authorizeRequests().anyRequest().permitAll()//
.and().csrf().disable();
}
}

@Profile("secure")
@Configuration
public static class SecuritySecureConfig extends WebSecurityConfigurerAdapter {
private final String adminContextPath;

public SecuritySecureConfig(AdminServerProperties adminServerProperties) {
this.adminContextPath = adminServerProperties.getContextPath();
}

protected void configure(HttpSecurity http) throws Exception {
// @formatter:off
SavedRequestAwareAuthenticationSuccessHandler successHandler = new SavedRequestAwareAuthenticationSuccessHandler();
successHandler.setTargetUrlParameter("redirectTo");

http.authorizeRequests()
.antMatchers(adminContextPath + "/assets/**").permitAll()
.antMatchers(adminContextPath + "/login").permitAll()
.anyRequest().authenticated()
.and()
.formLogin().loginPage(adminContextPath + "/login").successHandler(successHandler).and()
.logout().logoutUrl(adminContextPath + "/logout").and()
.httpBasic().and()
.csrf().disable();
// @formatter:on
}
}

}

五 链路跟踪，跟踪api的调用情况，使用Zipkin组件，要使用com.alibaba.druid.pool.DruidDataSource数据链接池，注意有个数据库

1 application.properties

#http://localhost:8093/
server.port=8093
spring.application.name = 
management.metrics.web.server.auto-time-requests=false

#zipkin.storage.type=mysql
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/zipkindb?useUnicode=true&characterEncoding=UTF-8&useSSL=true
spring.datasource.username=
spring.datasource.password=
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

sleuth.enabled=false

2 注解

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

import zipkin.server.EnableZipkinServer;
import zipkin2.storage.mysql.v1.MySQLStorage;

@SpringBootApplication
@EnableZipkinServer
public class LinkServerApplication {

public static void main(String[] args) {
SpringApplication.run(LinkServerApplication.class, args);
}

@Bean
public MySQLStorage mySQLStorage(DataSource datasource) {
return MySQLStorage.newBuilder().datasource(datasource).executor(Runnable::run).build();
}
}

spring cloud 微服务实现了多应用分布式整套架构，从应用注册到应用状态监控，服务接口建立到数据链接监控，还包含了负载均衡实现，其中负载均衡还含有熔断机制。满足大部分运维使用。社区活跃，使用案例广泛。