做产品网站费用吗,iis 无法访问此网站,建设茶网站目的,中国兼职设计师网介绍
Consul 是一套开源的分布式服务发现和配置管理系统#xff0c;由 HashiCorp 公司用 Go 语言开发。
提供了微服务系统中的服务治理、配置中心、控制总线等功能。这些功能中的每一个都可以根据需要单独使用#xff0c;也可以一起使用以构建全方位的服务网格#xff0c;…介绍
Consul 是一套开源的分布式服务发现和配置管理系统由 HashiCorp 公司用 Go 语言开发。
提供了微服务系统中的服务治理、配置中心、控制总线等功能。这些功能中的每一个都可以根据需要单独使用也可以一起使用以构建全方位的服务网格总之Consul提供了一种完整的服务网格解决方案。它具有很多优点。包括 基于 raft 协议比较简洁 支持健康检查, 同时支持 HTTP 和 DNS 协议 支持跨数据中心的 WAN 集群 提供图形界面 跨平台支持 Linux、Mac、Windows
简言之Consul的作用是服务发现和配置管理
Consul的作用
服务发现提供HTTP和DNS两种发现方式。健康检测支持多种方式HTTP、TCP、Docker、Shell脚本定制化监控kv存储Key、Value的存储方式多数据中心Consul支持多数据中心可视化Web界面
服务注册与发现
步骤
pom文件中引入consul服务注册与发现的依赖
!--SpringCloud consul discovery --dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-consul-discovery/artifactIdexclusionsexclusiongroupIdcommons-logging/groupIdartifactIdcommons-logging/artifactId/exclusion/exclusions/dependencyyaml文件中做好consul的相关配置例
spring:application:name: cloud-consumer-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}在启动类上加上EnableDiscoveryClient在RestTemplateConfig配置类中创建RestTemplate组件的方法上加上负载均衡支持的注解
Configuration
public class RestTemplateConfig
{BeanLoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}
}在要引用服务的地址的时候就可以将原来的 ip地址:端口号 改为对应的服务名
public static final String PaymentSrv_URL http://cloud-payment-service;分布式配置
微服务意味着要将单体应用中的业务拆分成一个个子服务每个服务的粒度相对较小因此系统中会出现大量的服务。由于每个服。务都需要必要的配置信息才能运行所以一套集中式的、动态的配置管理设施是必不可少的。
服务配置
配置通用全局配置信息直接注册进Consul服务器从Consul获取配置信息
pom中加入依赖
!--SpringCloud consul config--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-consul-config/artifactId
/dependency
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-bootstrap/artifactId
/dependency关于bootstrap.yaml文件 applicaiton.yml是用户级的资源配置项 bootstrap.yml是系统级的优先级更加高 Spring Cloud会创建一个“Bootstrap Context”作为Spring应用的Application Context的父上下文。初始化的时候Bootstrap Context负责从外部源加载配置属性并解析配置。这两个上下文共享一个从外部获取的Environment。 Bootstrap属性有高优先级默认情况下它们不会被本地配置覆盖。 Bootstrap context和Application Context有着不同的约定所以新增了一个bootstrap.yml文件保证Bootstrap Context和Application Context配置的分离。 application.yml文件改为bootstrap.yml这是很关键的或者两者共存一般推荐两者共存。 因为bootstrap.yml是比application.yml先加载的。bootstrap.yml优先级高于application.yml
例
spring:application:name: cloud-payment-service####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:service-name: ${spring.application.name}config:profile-separator: - # default value is ,we update -format: YAML接着在consul中配置好kv配置信息要读取配置信息也是和读取普通配置文件中的信息一样使用Value注解获取。
kv信息的配置格式为config/服务名-运行环境/data最终的配置信息在data中配置可以使用yaml的格式。
及时动态刷新
在consul中的配置信息修改后立即访问时候不会生效要等待一会才会刷新。
解决步骤 添加RefreshScope注解到主启动类上 修改watch的wait-time不建议 spring:application:name: cloud-payment-service####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:service-name: ${spring.application.name}config:profile-separator: - # default value is ,we update -format: YAMLwatch:wait-time: 1LoadBanlancer负载均衡调用
LB负载均衡(Load Balance)
简单的说就是将用户的请求平摊的分配到多个服务上从而达到系统的HA高可用常见的负载均衡有软件NginxLVS硬件 F5等。
spring-cloud-starter-loadbalancer组件是什么
Spring Cloud LoadBalancer是由SpringCloud官方提供的一个开源的、简单易用的客户端负载均衡器它包含在SpringCloud-commons中用它来替换了以前的Ribbon组件。相比较于RibbonSpringCloud LoadBalancer不仅能够支持RestTemplate还支持WebClientWeClient是Spring Web Flux中提供的功能可以实现响应式异步请求
在负责转发请求的rest服务客户端做负载均衡。导入以下依赖并在RestTemplateConfig的组件配置中加上LoadBalanced注解 !--loadbalancer--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-loadbalancer/artifactId
/dependency原理
LoadBalance在工作时分为两步
第一步先选择ConsulServer从服务端查询服务列表默认轮询调用谁都可以正常执行。第二步按照指定的负载均衡策略从server取到的服务注册中由客户端自己选择一个地址所以LoadBalancer是一个客户端的负载均衡器
负载均衡轮询算法rest接口第几次请求数 % 服务器集群总数量 实际调用服务器位置下标 每次服务重启动后rest接口计数从1开始。
默认是两种算法除了轮询算法还有一种是随机算法。如果要使用随机算法RestTemplateConfig配置如下
Configuration
LoadBalancerClient(//下面的value值大小写一定要和consul里面的名字一样必须一样value cloud-payment-service,configuration RestTemplateConfig.class)
public class RestTemplateConfig
{BeanLoadBalanced //使用LoadBalanced注解赋予RestTemplate负载均衡的能力public RestTemplate restTemplate(){return new RestTemplate();}BeanReactorLoadBalancerServiceInstance randomLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {String name environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return new RandomLoadBalancer(loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), name);}
}一般还是建议使用默认的轮询算法。
OpenFeign服务接口调用
openFeign是一个声明式的服务客户端。也支持并包含了loadBalanced。
官方介绍文 它使编写web服务客户端变得更容易。使用Feign创建一个接口并对其进行注释。它具有可插入的注释支持包括Feign注释和JAX-RS注释。Feign还支持可插拔编码器和解码器。Spring Cloud添加了对Spring MVC注释的支持以及对使用Spring Web中默认使用的HttpMessageConverter的支持。Spring Cloud集成了Eureka、Spring Cloud CircuitBreaker以及Spring Cloud LoadBalancer以便在使用Feign时提供负载平衡的http客户端。 由于对服务依赖的调用可能不止一处往往一个接口会被多处调用所以通常都会针对每一个微服务自行封装一些客户端类来包装这些依赖服务的调用。所以OpenFeign在此基础上做了进一步封装帮助我们定义和实现依赖服务接口的定义。
可以在使用OpenFeign式提供http客户端的负载均衡也可以集成阿里巴巴的Sentinel来提供熔断降级等功能。通过OpenFeign只需要服务绑定接口且以声明式的方法优雅而简单的实现了服务调用
使用步骤
建好服务客户端模块后引入依赖
!--openfeign--
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-openfeign/artifactId
/dependencyyaml文件
server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}主启动类上加上consul的支持注册服务的注解和启用feign客户端的注解
SpringBootApplication
EnableDiscoveryClient //该注解用于向使用consul为注册中心时注册服务
EnableFeignClients//启用feign客户端,定义服务绑定接口以声明式的方法优雅而简单的实现服务调用
public class MainOpenFeign80 {public static void main(String[] args) {SpringApplication.run(MainOpenFeign80.class,args);}
}在通用模块commons中引入依赖如上后新建服务接口PayFeignApi在接口上配置FeignClient注解并定义好抽象方法抽象方法的定义要对应的服务的controller类中的controller方法。相应的mapping注解也要对应好。
FeignClient(cloud-payment-service)
public interface PayFeignApi {PostMapping(value /pay/add)public ResultDataString addPay(RequestBody Pay pay);DeleteMapping(pay/del/{id})public ResultDataInteger deletePay(PathVariable(id) Integer id);PutMapping(/pay/update)public ResultDataString updatePay(RequestBody PayDTO payDto);GetMapping(/pay/get/{id})public ResultDataPay getById(PathVariable(id) Integer id);GetMapping(/pay/getAll)public ResultDataListPay getAll();
}在服务客户端的controller中调用payFeignApi
RestController
public class OrderController {Resourceprivate PayFeignApi payFeignApi;PostMapping(/feign/pay/add)public ResultData addOrder(RequestBody Pay pay){ResultDataString resultData payFeignApi.addPay(pay);return resultData;}GetMapping(/feign/pay/get/{id})public ResultData getPayInfo(PathVariable(id) Integer id){System.out.println(-------支付微服务远程调用按照id查询订单支付流水信息);ResultData resultData payFeignApi.getById(id);return resultData;}
}OpenFeign高级特性
超时控制
在SpringCloud微服务架构中大部分公司都是利用OpenFeign进行服务间的调用如果服务要进行比较繁杂的业务计算那后台很有可能会出现Read Timeout这个异常因此定制化配置超时时间就非常有必要了。
openFeign默认等待六十秒超时后会报错。
关于超时控制的配置项
connectTimeOut连接超时时间readTimeOut请求处理超时时间
配置分为两种
全局配置
直接在application.yaml文件中进行配置
server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}openfeign:client:config:default:#连接超时时间connectTimeout: 3000#读取超时时间readTimeout: 3000指定配置
就是config的下一级属性的属性名改为要指定的服务的服务名default的同级
server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}openfeign:client:config:default:#连接超时时间connectTimeout: 3000#读取超时时间readTimeout: 3000cloud-provider-payment:#连接超时时间connectTimeout: 5000#读取超时时间readTimeout: 5000服务的超时配置先看指定的再看全局的。
重试机制
重试是指当请求失败后会重新再次发送该请求。在OpenFeign中默认是关闭重试的如果要开启重试在配置类FeignConfig中设置
Configuration
public class FeignConfig {Beanpublic Retryer myRetryer(){//return Retryer.NEVER_RETRY; //Feign默认配置是不走重试策略的//最大请求次数为3(12)初始间隔时间为100ms重试间最大间隔时间为1sreturn new Retryer.Default(100,1,3);}
}HttpClient
OpenFeign中http client如果不做特殊配置默认使用jdk自带的HttpURLConnection发送HTTP请求由于默认HttpURLConnection没有连接池、性能和效率低如果采用默认性能上欠佳。
建议使用阿帕奇的httpclient5。
步骤 pom引入依赖 !-- httpclient5--
dependencygroupIdorg.apache.httpcomponents.client5/groupIdartifactIdhttpclient5/artifactIdversion5.3/version
/dependency
!-- feign-hc5--
dependencygroupIdio.github.openfeign/groupIdartifactIdfeign-hc5/artifactIdversion13.1/version
/dependency开启httpclient5的配置application.yaml文件 server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}openfeign:client:config:default:connect-timeout: 3000read-timeout: 3000cloud-provider-payment:#连接超时时间connectTimeout: 5000#读取超时时间readTimeout: 5000# 配置httpclient5httpclient:hc5:enabled: true请求响应压缩
Spring Cloud OpenFeign支持对请求和响应进行GZIP压缩以减少通信过程中的性能损耗。还可以对请求压缩做一些更细致的设置比如指定压缩的请求数据类型并设置了请求压缩的大小下限。
application.yaml配置文件
server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}openfeign:client:config:default:connect-timeout: 3000read-timeout: 3000cloud-provider-payment:#连接超时时间connectTimeout: 5000#读取超时时间readTimeout: 5000httpclient:hc5:enabled: truecompression:request:enabled: truemin-request-size: 2048 #最小触发压缩的大小单位 字节mime-types: text/xml,application/xml,application/json #触发压缩数据类型response:enabled: true日志打印
Feign提供了日志打印功能可以通过配置来调整日志级别从而了解feign中http请求的细节也就是对Feign接口的调用情况进行监控和输出。
日志级别
NONE默认的不显示任何日志
BASIC仅记录请求方法、URL、响应状态码及执行时间
HEADERS除了 BASIC 中定义的信息之外还有请求和响应的头信息
FULL除了 HEADERS 中定义的信息之外还有请求和响应的正文及元数据。
配置方式
在FeignConfig中配置
Configuration
public class FeignConfig {Beanpublic Retryer myRetryer(){//return Retryer.NEVER_RETRY; //Feign默认配置是不走重试策略的//最大请求次数为3(12)初始间隔时间为100ms重试间最大间隔时间为1sreturn new Retryer.Default(100,1,3);}//配置日志级别BeanLogger.Level feignLoggerLevel() {return Logger.Level.FULL;}
}在yaml文件中配置配置公式是logging.level 含有FeignClient注解的完整带包名的接口名debug例如
server:port: 80spring:application:name: cloud-consumer-openfeign-order####Spring Cloud Consul for Service Discoverycloud:consul:host: localhostport: 8500discovery:prefer-ip-address: true #优先使用服务ip进行注册service-name: ${spring.application.name}openfeign:client:config:default:connect-timeout: 3000read-timeout: 3000cloud-provider-payment:#连接超时时间connectTimeout: 5000#读取超时时间readTimeout: 5000httpclient:hc5:enabled: truecompression:request:enabled: truemin-request-size: 2048 #最小触发压缩的大小mime-types: text/xml,application/xml,application/json #触发压缩数据类型response:enabled: true
#日志配置
logging:level:com:ergou:cloud:apis:PayFeignApi: debug
