本文共 7503 字,大约阅读时间需要 25 分钟。
在前后端分离架构中,服务层被拆分成了很多的微服务,微服务的信息如何管理?Spring Cloud中提供服务注册中心来管理微服务信息。
为什么 要用注册中心? 1、微服务数量众多,要进行远程调用就需要知道服务端的ip地址和端口,注册中心帮助我们管理这些服务的ip和端口。 2、微服务会实时上报自己的状态,注册中心统一管理这些微服务的状态,将存在问题的服务踢出服务列表,客户端获取到可用的服务进行调用。Spring Cloud Eureka 是对Netflix公司的Eureka的二次封装,它实现了服务治理的功能,Spring Cloud Eureka提供服务端与客户端,服务端即是Eureka服务注册中心,客户端完成微服务向Eureka服务的注册与发现。服务端和客户端均采用Java语言编写。下图显示了Eureka Server与Eureka Client的关系:
1、创建xc-govern-center工程:
包结构:com.xuecheng.govern.center 2、添加依赖 在父工程添加:(有了则不用重复添加)org.springframework.cloud spring-cloud-dependencies Finchley.SR1 pom import
在Eureka Server工程添加:
org.springframework.cloud spring-cloud-starter-netflix-eureka-server
3、启动类
@EnableEurekaServer//标识这是一个Eureka服务@SpringBootApplicationpublic class GovernCenterApplication { public static void main(String[] args) { SpringApplication.run(GovernCenterApplication.class, args); }}
4、从其它服务拷贝application.yml和logback-spring.xml。
application.yml的配置内容如下:server: port: ${ PORT:50101} #服务端口spring: application: name: xc-govern-center #指定服务名eureka: client: registerWithEureka: true #服务注册,是否将自己注册到Eureka服务中 fetchRegistry: true #服务发现,是否从Eureka中获取注册信息 serviceUrl: #Eureka客户端与Eureka服务端的交互地址,高可用状态配置对方的地址,单机状态配置自己(如果不配置则默认本机8761端口) defaultZone: http://localhost:50101/eureka/ server: enable‐self‐preservation: false #是否开启自我保护模式 eviction‐interval‐timer‐in‐ms: 60000 #服务注册表清理间隔(单位毫秒,默认是60*1000)
5、启动Eureka Server
启动Eureka Server,浏览50101端口。Eureka Server 高可用环境需要部署两个Eureka server,它们互相向对方注册。如果在本机启动两个Eureka需要注意两个Eureka Server的端口要设置不一样,这里我们部署一个Eureka Server工程,将端口可配置,制作两个Eureka Server启动脚本,启动不同的端口,如下图:
配置如下:
1、端口可配置server: port: ${ PORT:50101} #服务端口
2、Eureka服务端的交互地址可配置
eureka: client: registerWithEureka: true #服务注册,是否将自己注册到Eureka服务中 fetchRegistry: true #服务发现,是否从Eureka中获取注册信息 serviceUrl: #Eureka客户端与Eureka服务端的交互地址,高可用状态配置对方的地址,单机状态配置自己(如果不配置则默认本机8761端口) defaultZone: ${ EUREKA_SERVER:http://eureka02:50102/eureka/}
3、配置hostname
Eureka 组成高可用,两个Eureka互相向对方注册,这里需要通过域名或主机名访问,这里我们设置两个Eureka服 务的主机名分别为 eureka01、eureka02。 完整的eureka配置如下:server: port: ${ PORT:50101} #服务端口spring: application: name: xc-govern-center #指定服务名eureka: client: registerWithEureka: true #服务注册,是否将自己注册到Eureka服务中 fetchRegistry: true #服务发现,是否从Eureka中获取注册信息 serviceUrl: #Eureka客户端与Eureka服务端的交互地址,高可用状态配置对方的地址,单机状态配置自己(如果不配置则默认本机8761端口) defaultZone: ${ EUREKA_SERVER:http://eureka02:50102/eureka/} server: enable‐self‐preservation: false #是否开启自我保护模式 eviction‐interval‐timer‐in‐ms: 60000 #服务注册表清理间隔(单位毫秒,默认是60*1000) instance: hostname: ${ EUREKA_DOMAIN:eureka01}
4、在IDEA中制作启动脚本
启动1下边实现cms向Eureka Server注册。
org.springframework.cloud spring-cloud-starter-netflix-eureka-client
eureka: client: registerWithEureka: true #服务注册开关 fetchRegistry: true #服务发现开关 serviceUrl: #Eureka客户端与Eureka服务端进行交互的地址,多个中间用逗号分隔 defaultZone: ${ EUREKA_SERVER:http://localhost:50101/eureka/,http://localhost:50102/eureka/} instance: prefer‐ip‐address: true #将自己的ip地址注册到Eureka服务中 ip‐address: ${ IP_ADDRESS:127.0.0.1} instance‐id: ${ spring.application.name}:${ server.port} #指定实例id
在启动类上添加注解
在启动类上添加注解 @EnableDiscoveryClient ,表示它是一个Eureka的客户端刷新Eureka Server查看注册情况
在前后端分离架构中,服务层被拆分成了很多的微服务,服务与服务之间难免发生交互,比如:课程发布需要调用CMS服务生成课程静态化页面,本节研究微服务远程调用所使用的技术。
Ribbon是Netflix公司开源的一个负载均衡的项目(https://github.com/Netflix/ribbon),它是一个基于HTTP、TCP的客户端负载均衡器。
1、什么是负载均衡? 负载均衡是微服务架构中必须使用的技术,通过负载均衡来实现系统的高可用、集群扩容等功能。负载均衡可通过硬件设备及软件来实现,硬件比如:F5、Array等,软件比如:LVS、Nginx等。2、什么是客户端负载均衡?
上图是服务端负载均衡,客户端负载均衡与服务端负载均衡的区别在于客户端要维护一份服务列表,Ribbon从Eureka Server获取服务列表,Ribbon根据负载均衡算法直接请求到具体的微服务,中间省去了负载均衡服务。 如下图是Ribbon负载均衡的流程图:Spring Cloud引入Ribbon配合 restTemplate 实现客户端负载均衡。Java中远程调用的技术有很多,如:webservice、socket、rmi、Apache HttpClient、OkHttp等,互联网项目使用基于http的客户端较多,本项目使
用OkHttp。1、在客户端添加Ribbon依赖:
com.netflix.feign feign-okhttp
2、配置Ribbon参数
ribbon: MaxAutoRetries: 2 #最大重试次数,当Eureka中可以找到服务,但是服务连不上时将会重试 MaxAutoRetriesNextServer: 3 #切换实例的重试次数 OkToRetryOnAllOperations: false #对所有操作请求都进行重试,如果是get则可以,如果是post,put等操作,没有实现幂等的情况下是很危险的,所以设置为false ConnectTimeout: 5000 #请求连接的超时时间 ReadTimeout: 6000 #请求处理的超时时间
3、负载均衡测试
1)启动两个cms服务,注意端口要不一致 启动完成观察Eureka Server的服务列表 2)定义RestTemplate,使用@LoadBalanced注解 在课程管理服务的启动类中定义RestTemplate@Bean @LoadBalanced public RestTemplate restTemplate() { return new RestTemplate(new OkHttp3ClientHttpRequestFactory()); }
3)测试代码
在课程管理服务工程创建单元测试代码,远程调用cms的查询页面接口:@Test public void testRibbon() { //服务id String serviceId = "XC-SERVICE-MANAGE-CMS"; for (int i = 0; i < 10; i++) { //通过服务id调用 ResponseEntityforEntity = restTemplate.getForEntity("http://" + serviceId + "/cms/page/get/5a754adf6abb500ad05688d9", CmsPage.class); CmsPage cmsPage = forEntity.getBody(); System.out.println(cmsPage); } }
4)负载均衡测试
添加@LoadBalanced注解后,restTemplate会走LoadBalancerInterceptor拦截器,此拦截器中会通过RibbonLoadBalancerClient查询服务地址,可以在此类打断点观察每次调用的服务地址和端口,两个cms服务会轮 流被调用。Feign是Netflix公司开源的轻量级rest客户端,使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。
1、在客户端添加依赖
在课程管理服务添加下边的依赖:org.springframework.cloud spring-cloud-starter-openfeign com.netflix.feign feign-okhttp
2、定义FeignClient接口
参考Swagger文档定义FeignClient,注意接口的Url、请求参数类型、返回值类型与Swagger接口一致。 在课程管理服务中创建client包,定义查询cms页面的客户端该用接口.@FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)public interface CmsPageClient { @GetMapping("/cms/page/get/{id}") CmsPage findById(@PathVariable("id") String id);}
3、启动类添加@EnableFeignClients注解
4、测试
@RunWith(SpringRunner.class)@SpringBootTestpublic class FeignTest { @Autowired CmsPageClient cmsPageClient; @Test public void testFeign() { //通过服务id调用cms的查询页面接口 CmsPage cmsPage = cmsPageClient.findById("5a754adf6abb500ad05688d9"); System.out.println(cmsPage); }}
Feign工作原理如下:
1、 启动类添加@EnableFeignClients注解,Spring会扫描标记了@FeignClient注解的接口,并生成此接口的代理对象 2、 @FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)即指定了cms的服务名称,Feign会从注册中心获取cms服务列表,并通过负载均衡算法进行服务调用。 3、在接口方法 中使用注解@GetMapping("/cms/page/get/{id}"),指定调用的url,Feign将根据url进行远程调用.SpringCloud对Feign进行了增强兼容了SpringMVC的注解 ,我们在使用SpringMVC的注解时需要注意:
1、feignClient接口 有参数在参数必须加@PathVariable(“XXX”)和@RequestParam(“XXX”) 2、feignClient返回值为复杂对象时其类型必须有无参构造函数。转载地址:http://tvhwz.baihongyu.com/