springcloud组件技术分享(推荐)

Springcloud技术分享

Spring Cloud 是一套完整的微服务解决方案，基于 Spring Boot 框架，准确的说，它不是一个框架，而是一个大的容器，它将市面上较好的微服务框架集成进来，从而简化了开发者的代码量。

Spring Cloud 是什么？

Spring Cloud 是一系列框架的有序集合，它利用 Spring Boot 的开发便利性简化了分布式系统的开发，比如服务发现、服务网关、服务路由、链路追踪等。Spring Cloud 并不重复造轮子，而是将市面上开发得比较好的模块集成进去，进行封装，从而减少了各模块的开发成本。换句话说：Spring Cloud 提供了构建分布式系统所需的“全家桶”。

Spring Cloud 现状

目前，国内使用 Spring Cloud 技术的公司并不多见，不是因为 Spring Cloud 不好，主要原因有以下几点：
Spring Cloud 中文文档较少，出现问题网上没有太多的解决方案。
国内创业型公司技术老大大多是阿里系员工，而阿里系多采用 Dubbo 来构建微服务架构。
大型公司基本都有自己的分布式解决方案，而中小型公司的架构很多用不上微服务，所以没有采用 Spring Cloud 的必要性。
但是，微服务架构是一个趋势，而 Spring Cloud 是微服务解决方案的佼佼者，这也是作者写本系列课程的意义所在。

Spring Cloud 优缺点

其主要优点有：
集大成者，Spring Cloud 包含了微服务架构的方方面面。
约定优于配置，基于注解，没有配置文件。
轻量级组件，Spring Cloud 整合的组件大多比较轻量级，且都是各自领域的佼佼者。
开发简便，Spring Cloud 对各个组件进行了大量的封装，从而简化了开发。
开发灵活，Spring Cloud 的组件都是解耦的，开发人员可以灵活按需选择组件。
接下来，我们看下它的缺点：
项目结构复杂，每一个组件或者每一个服务都需要创建一个项目。
部署门槛高，项目部署需要配合 Docker 等容器技术进行集群部署，而要想深入了解 Docker，学习成本高。
Spring Cloud 的优势是显而易见的。因此对于想研究微服务架构的同学来说，学习 Spring Cloud 是一个不错的选择。

Spring Cloud 和 Dubbo 对比

Dubbo 只是实现了服务治理，而 Spring Cloud 实现了微服务架构的方方面面，服务治理只是其中的一个方面。下面通过一张图对其进行比较：

下面我们就简单的进行springcloud的学习吧，本文章涉及springcloud的相关重要组件的使用。

1. 项目初始化配置

1. 1. 新建maven工程

使用idea创建maven项目

1. 2. 在parent项目pom中导入以下依赖


 org.springframework.boot
 spring-boot-starter-parent
 2.3.4.RELEASE


 Hoxton.SR8



 
 org.springframework.cloud
 spring-cloud-dependencies
 ${spring.cloud-version}
 pom
 import

2. Eureka

Eureka是Spring Cloud Netflix的核心组件之一，其还包括Ribbon、Hystrix、Feign这些Spring Cloud Netflix主要组件。其实除了eureka还有些比较常用的服务发现组件如Consul，Zookeeper等，目前对于springcloud支持最好的应该还是eureka。

eureka组成

Eureka Server：服务的注册中心，负责维护注册的服务列表。
Service Provider：服务提供方，作为一个Eureka Client，向Eureka Server做服务注册、续约和下线等操作，注册的主要数据包括服务名、机器ip、端口号、域名等等。
Service Consumer：服务消费方，作为一个Eureka Client，向Eureka Server获取Service Provider的注册信息，并通过远程调用与Service Provider进行通信。

2. 1. 创建子module，命名为eureka-server 2. 2. 在eureka-server中添加以下依赖


 org.springframework.boot
 spring-boot-starter-web


 org.springframework.cloud
 spring-cloud-starter-netflix-eureka-server


 org.springframework.boot
 spring-boot-starter-security

2. 3. 在application.yml中添加以下配置

server:
 port: 8900 #应用的端口号
eureka:
 client:
 service-url:
 defaultZone: http://user:123@localhost:8900/eureka #eureka服务的的注册地址
 fetch-registry: false #是否去注册中心拉取其他服务地址
 register-with-eureka: false #是否注册到eureka
spring:
 application:
 name: eureka-server #应用名称 还可以用eureka.instance.hostname = eureka-server
 security: #配置自定义Auth账号密码
 user:
 name: user

2. 4. 在启动类上架注解

@SpringBootApplication
@EnableEurekaServer

在启动类中加入以下方法,防止spring的Auth拦截eureka请求

@EnableWebSecurity
 static class WebSecurityConfig extends WebSecurityConfigurerAdapter {
 @Override
 protected void configure(HttpSecurity http) throws Exception {
 http.csrf().ignoringAntMatchers("/eureka
 @GetMapping(value = "/user/{id}")
 public User getUserNotHystrix(@PathVariable Long id){
 //获取数据
 return userFeignNotHystrixClient.getUserNotHystrix(id);
 }
}

7. 4. 两个FeignClient

一个加了configuration一个没有，加了可以通过注解重写feignBuilder方法单独控制，默认是返回HystrixFeignBuilder

@FeignClient(name = "provider-user", fallback = HystrixClientFallback.class)
public interface UserFeignClient {
 @RequestMapping (value = "/user/{id}", method = RequestMethod.GET)
 User getUser(@PathVariable Long id);
}

@Component
public class HystrixClientFallback implements UserFeignClient{
 @Override
 public User getUser(Long id) {
 System.out.println(Thread.currentThread().getId());
 User user = new User();
 user.setId(1L);
 return user;
 }
}

@FeignClient(name = "provider-user1",configuration = ConfigurationNotHystrix.class,fallback = HystrixClientNotHystrixFallback.class)
public interface UserFeignNotHystrixClient {
 @RequestMapping (value = "/user/{id}", method = RequestMethod.GET)
 User getUserNotHystrix(@PathVariable Long id);
}

@Component
public class HystrixClientNotHystrixFallback implements UserFeignNotHystrixClient{
 @Override
 public User getUserNotHystrix(Long id) {
 System.out.println(Thread.currentThread().getId());
 User user = new User();
 user.setId(1L);
 return user;
 }
}

7. 5. 配置类

@Configuration
public class ConfigurationNotHystrix {

 @Bean
 @Scope("prototype")
 public Feign.Builder feignBuilder(){
 return Feign.builder();
 }
}

7. 6. 获取异常信息代码

@FeignClient(name = "hello", fallbackFactory = HystrixClientFallbackFactory.class)
protected interface HystrixClient {
 @RequestMapping(method = RequestMethod.GET, value = "/hello")
 Hello iFailSometimes();
}

@Component
static class HystrixClientFallbackFactory implements FallbackFactory {
 @Override
 public HystrixClient create(Throwable cause) {
 return new HystrixClient() {
  @Override
  public Hello iFailSometimes() {
  return new Hello("fallback; reason was: " + cause.getMessage());
  }
 };
 }
}

8. Zuul

Zuul是Spring Cloud全家桶中的微服务API网关。

所有从设备或网站来的请求都会经过Zuul到达后端的Netflix应用程序。作为一个边界性质的应用程序，Zuul提供了动态路由、监控、弹性负载和安全功能。Zuul底层利用各种filter实现如下功能：

认证和安全识别每个需要认证的资源，拒绝不符合要求的请求。
性能监测在服务边界追踪并统计数据，提供精确的生产视图。
动态路由根据需要将请求动态路由到后端集群。
压力测试逐渐增加对集群的流量以了解其性能。
负载卸载预先为每种类型的请求分配容量，当请求超过容量时自动丢弃。
静态资源处理直接在边界返回某些响应。

8. 1. 编写一个Zuul网关

@SpringBootApplication
@EnableZuulProxy
@EnableEurekaClient
public class GatewayZuulApp
{
 public static void main( String[] args )
 {
 SpringApplication.run(GatewayZuulApp.class,args);
 }
 @Bean
 public PreZuulFilter preZuulFilter(){
 return new PreZuulFilter();
 }
}

application.yml 配置

zuul:
 ignoredServices: '*' #剔除的链接，*代表所有
 routes:
 lyh-provider-user: /myusers
 @Override
 public String getRoute() {
 return "lyh-provider-user";
 }

 
 @Override
 public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
 if (cause instanceof HystrixTimeoutException) {
  return response(HttpStatus.GATEWAY_TIMEOUT);
 } else {
  return response(HttpStatus.INTERNAL_SERVER_ERROR);
 }
 }
 private ClientHttpResponse response(final HttpStatus status) {
 return new ClientHttpResponse() {
  @Override
  public HttpStatus getStatusCode() throws IOException {
  //当fallback时返回给调用者的状态码
  return status;
  }

  @Override
  public int getRawStatusCode() throws IOException {
  return status.value();
  }

  @Override
  public String getStatusText() throws IOException {
  //状态码的文本形式
  return status.getReasonPhrase();
  }

  @Override
  public void close() {
  }

  @Override
  public InputStream getBody() throws IOException {
  //响应体
  return new ByteArrayInputStream("fallback".getBytes());
  }

  @Override
  public HttpHeaders getHeaders() {
  //设定headers
  HttpHeaders headers = new HttpHeaders();
  headers.setContentType(MediaType.APPLICATION_JSON);
  return headers;
  }
 };
 }
}

8. 3. Zuul 的Filter

8. 3. 1. Zuul中的Filter

Zuul是围绕一系列Filter展开的，这些Filter在整个HTTP请求过程中执行一连串的操作。

Zuul Filter有以下几个特征：

Type：用以表示路由过程中的阶段（内置包含PRE、ROUTING、POST和ERROR）
Execution Order：表示相同Type的Filter的执行顺序
Criteria：执行条件
Action：执行体
Zuul提供了动态读取、编译和执行Filter的框架。各个Filter间没有直接联系，但是都通过RequestContext共享一些状态数据。

尽管Zuul支持任何基于JVM的语言，但是过滤器目前是用Groovy编写的。每个过滤器的源代码被写入到Zuul服务器上的一组指定的目录中，这些目录将被定期轮询检查是否更新。Zuul会读取已更新的过滤器，动态编译到正在运行的服务器中，并后续请求中调用。

8. 3. 2. Filter Types

以下提供四种标准的Filter类型及其在请求生命周期中所处的位置：

PRE Filter：在请求路由到目标之前执行。一般用于请求认证、负载均衡和日志记录。
ROUTING Filter：处理目标请求。这里使用Apache HttpClient或Netflix Ribbon构造对目标的HTTP请求。
POST Filter：在目标请求返回后执行。一般会在此步骤添加响应头、收集统计和性能数据等。
ERROR Filter：整个流程某块出错时执行。
除了上述默认的四种Filter类型外，Zuul还允许自定义Filter类型并显示执行。例如，我们定义一个STATIC类型的Filter，它直接在Zuul中生成一个响应，而非将请求在转发到目标。

8. 3. 3. Zuul请求生命周期

一图胜千言，下面通过官方的一张图来了解Zuul请求的生命周期。

8. 3. 4. 自定义一个filter

需要继承ZuulFilter类

public class PreZuulFilter extends ZuulFilter {
 @Override
 public String filterType() {
 return "pre";
 }

 @Override
 public int filterOrder() {
 return 5;
 }

 @Override
 public boolean shouldFilter() {
 return true;
 }

 @Override
 public Object run() throws ZuulException {
 String requestURI = RequestContext.getCurrentContext().getRequest().getRequestURI();
 System.out.println(requestURI);
 return requestURI;
 }
}

将自定义的filter通过@Bean注入

@Bean
 public PreZuulFilter preZuulFilter(){
 return new PreZuulFilter();
 }

filter配置

zuul:
 PreZuulFilter: #过滤器类名
 pre: #过滤类型
 disable: false

8. 3. 5. zuul上传下载

zuul一样可以正常的上传下载，要注意的是他使用的是默认大小配置，想要上传大文件需要在访问的地址前加/zuul/服务地址，同时需要配置超时时间

#当上传大文件是在serviceid前加zuul/ 如：zuul/servcieid/*,且需要配置ribbon的超时时间和hystrix的超时时间，防止报错后走hystrix的退回代码
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 60000
ribbon:
 ConnectTimeout: 3000
 ReadTimeout: 60000

9. springCloud的Config

9. 1. 什么是spring cloud config

在分布式系统中，spring cloud config 提供一个服务端和客户端去提供可扩展的配置服务。我们可用用配置服务中心区集中的管理所有的服务的各种环境配置文件。配置服务中心采用Git的方式存储配置文件，因此我们很容易部署修改，有助于对环境配置进行版本管理。

Spring Cloud Config就是云端存储配置信息的,它具有中心化,版本控制,支持动态更新,平台独立,语言独立等特性。其特点是：

a.提供服务端和客户端支持(spring cloud config server和spring cloud config client)
b.集中式管理分布式环境下的应用配置
c.基于Spring环境，无缝与Spring应用集成
d.可用于任何语言开发的程序
e.默认实现基于git仓库，可以进行版本管理

spring cloud config包括两部分：

spring cloud config server 作为配置中心的服务端
拉取配置时更新git仓库副本，保证是最新结果
支持数据结构丰富，yml, json, properties 等
配合 eureke 可实现服务发现，配合 cloud bus 可实现配置推送更新
配置存储基于 git 仓库，可进行版本管理
简单可靠，有丰富的配套方案 Spring Cloud Config Client 客户端

Spring Boot项目不需要改动任何代码，加入一个启动配置文件指明使用ConfigServer上哪个配置文件即可

9. 2. 简单的使用

服务端配置使用

首先需要添加相关依赖


 org.springframework.cloud
 spring-cloud-config-server


 org.springframework.cloud
 spring-cloud-starter-netflix-eureka-client

启动类

@SpringBootApplication
@EnableEurekaClient
@EnableConfigServer
public class SpringCloudConfigApp
{
 public static void main( String[] args )
 {
 SpringApplication.run(SpringCloudConfigApp.class,args);
 }
}

本地方式配合Eureka配置

spring:
 application:
 name: config-server
 cloud:
 config:
 name: config-server
 server:
 native:
  search-locations: classpath:/config
 bootstrap: true
 #配置git方式
 #git:
  #uri: #配置git仓库地址
  #username: #访问git仓库的用户名
  #password: #访问git仓库的用户密码
  #search-paths: #配置仓库路径
 #label: master #git使用，默认master
 profiles:
 active: native #开启本地配置
server:
 port: 8080
eureka:
 client:
 service-url:
 defaultZone: http://user:123@localhost:8761/eureka

在resources下创建文件夹config，在config下创建文件

lyh-provider-user-dev.yml
内容为：
profile: lyh-provider-user-dev

lyh-provider-user-pro.yml
内容为：
profile: lyh-provider-user-pro

客户端配置

添加依赖


 org.springframework.boot
 spring-boot-starter-web


 org.springframework.cloud
 spring-cloud-starter-config


 org.springframework.cloud
 spring-cloud-starter-netflix-eureka-client


 org.springframework.cloud
 spring-cloud-starter-bus-amqp


 org.springframework.boot
 spring-boot-starter-actuator

server:
 port: 7900 #程序启动入口
spring:
 application:
 name: lyh-provider-user #应用名称
 cloud:
 config:
 profile: dev
 discovery: #使用eureka的发现寻找config-server的服务
 enabled: true
 service-id: config-server
 name: lyh-provider-user
 #uri: http://localhost:8080 这里可以是git地址
#trace信息 配置
 bus:
 trace:
 enabled: true
#配合rabbitmq实现自动刷新参数
 rabbitmq: #配置rabbitmq实现自动刷新
 host: localhost
 port: 5672
 username: guest
 password: guest
eureka:
 client:
 service-url:
 defaultZone: http://user:123@localhost:8761/eureka
#健康监控配置
management:
 endpoint:
 health:
 show-details: always #是否健康监控显示细节
 refresh:
 enabled: true
 endpoints:
 web:
 exposure:
 include: "*" #放开所有地址，跳过安全拦截
 base-path: /

客户端测试代码，@RefreshScope注解实现参数的刷新

@RestController
@RefreshScope
public class UserController {
 @Value("${profile}")
 private String profile;
 @GetMapping (value = "/profile")
 public String getProfile(){
 return this.profile;
 }
}

访问后我们就能拿到config服务的profile配置上数据

到此这篇关于springcloud组件技术分享的文章就介绍到这了,更多相关springcloud组件内容请搜索考高分网以前的文章或继续浏览下面的相关文章希望大家以后多多支持考高分网！

springcloud组件技术分享(推荐)

Java相关栏目本月热门文章