day05-SpringCloud Eureka-服务注册与发现02
SpringCloud Eureka-服务注册与发现02
3.搭建EurekaServer集群-实现负载均衡&故障容错
3.1为什么需要集群EurekaServer？
- 微服务RPC远程服务调用最核心的是高可用
- 如果注册中心只有1个，如果出现故障，会导致整个服务环境不可用
- 解决办法就是搭建Eureka注册中心集群，实现负载均衡和故障容错（构成集群的几个主机之间的提供的服务是相同的）
3.2搭建EurekaServer集群
3.2.1搭建第二个注册中心
搭建 e-commerce-eureka-server-9002 微服务模块，作为第二个 EurekaServer -注册中心。
搭建的具体步骤和 e-commerce-eureka-server-9001 一样，见上篇2.2
（1）创建Module，在pom.xml加入相关依赖（略）
（2）创建配置文件application.yml
server:
port: 9002
#配置Eureka-server
eureka:
instance:
hostname: eureka9002.com #服务实例名
client: #如果Eureka是一个集群，那么相互两个EurekaServer之间也可以当做对方为客户端
#配置是否向注册中心注册自己
register-with-eureka: false
#表示自己就是注册中心，作用是维护注册的服务实例，不需要去检索服务
fetch-registry: false
service-url:
#当前的注册中心 需要注册到 Eureka9001 注册中心
defaultZone: http://eureka9001.com:9001/eureka/
（3）创建主启动类
package com.li.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
/**
* @author 李
* @version 1.0
*/
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication9002 {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication9002.class,args);
}
}
3.2.2修改第一个注册中心
（1）修改 e-commerce-eureka-server-9001 的 application.yml 文件
server:
port: 9001
#配置Eureka-server
eureka:
instance:
hostname: eureka9001.com #服务实例名
client: #如果Eureka是一个集群，那么相互两个EurekaServer之间也可以当做对方为客户端
#配置是否向注册中心注册自己
register-with-eureka: false
#表示自己就是注册中心，作用是维护注册的服务实例，不需要去检索服务
fetch-registry: false
service-url: #设置于 Eureka server 的交互模块，查询服务和注册服务都需要依赖这个地址
#EurekaServer之间相互注册
defaultZone: http://eureka9002.com:9002/eureka/
（2）将e-commerce-eureka-server-9001的主启动类的名称修改为 EurekaApplication9001
3.2.3修改host文件
因为是在一台电脑上模拟的集群，为了浏览器输入类似eureka9002.com:9002/eureka/的地址，可以直接访问到，这里修改host文件，对上述指定域名进行本机的ip映射。
文件位置：C:\Windows\System32\drivers\etc\hosts
3.2.4完成测试
分别启动两个注册中心，在浏览器中访问上图配置的地址：
3.3.5将其他微服务注册到EurekaServer集群
（1）将member-service-provider-10000注册到 EurekaServer 集群
部分配置：
eureka:
service-url:
#将本微服务注册到多个EurekaServer，使用逗号间隔
defaultZone: http://eureka9001.com:9001/eureka,http://eureka9002.com:9002/eureka
（2）将member-service-consumer-80注册到 EurekaServer 集群：同上，修改位置相同（略）。
（3）启动这些微服务，可以看到在所有EurekaServer的监控页面中都注册了上述微服务：
3.3搭建会员中心服务提供方集群
同样的，为了高可用性，我们不仅在EurekaServer中要使用集群，在服务提供方也要使用集群（构成集群的几个主机之间的提供的服务是相同的）。
3.3.1搭建第二个服务提供方
所以参考 member-service-provider-10000 的代码来创建 member-service-provider-10002 ，以下简称为10000 和 10002
（1）创建Module-member-service-provider-10002
（2）可以将磁盘下10000子模块的main目录复制替换10002的main目录
（3）然后在10002的pom.xml中导入和10000的pom.xml相同的依赖
（4）最后修改10002的端口和当前应用的名称，并修改10002的主程序名称。
（5）测试
3.3.2注意事项和细节
因为member-service-provider-10000和member-service-provider-10002是作为一个集群对外提供服务的，因为我们需要将两个微服务的spring.application.name进行统一，这样消费方可以通过统一的别名进行负载均衡调用。
spring:
application:
name: member-service-provider #同一将服务提供方的应用名设置为member-service-provider
设置后，重新启动服务启动方，在EurekaServer中可以看到注册列表中只有一个服务提供名，但是它包含了两个远程调用的接口：
3.4配置服务消费端使用会员中心服务集群
配置服务消费端 member-service-consumer-80，让它可以使用会员中心服务集群。
（1）修改MemberConsumerController.java
package com.li.springcloud.controller;
import ...
/**
* @author 李
* @version 1.0
*/
@RestController
@Slf4j
public class MemberConsumerController {
@Resource
private RestTemplate restTemplate;
/**
* 1.MEMBER-SERVICE-PROVIDER 是服务提供方[集群]注册到EurekaServer的别名
* 2.也是服务提供方[集群]对方暴露的名称
* 3.这里MEMBER-SERVICE-PROVIDER 目前有两个可以获取的区域：
* member-service-provider-10000、member-service-provider-10002
*/
public static final String MEMBER_SERVICE_PROVIDER_URL =
"http://MEMBER-SERVICE-PROVIDER";//改为提供服务模块的别名
//添加对象到数据库表中
@PostMapping("/member/consumer/save")
public Result<Member> save(Member member) {
return restTemplate.postForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/save",
member,
Result.class);
}
//根据id调用服务接口，返回member对象信息
@GetMapping("/member/consumer/get/{id}")
public Result<Member> getMemberById(@PathVariable("id") Integer id) {
return restTemplate.getForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/get/" + id,
Result.class);
}
}
（2）修改 CustomInitBean.java
需要增加注解 @LoadBalanced，赋予 RestTemplate负载均衡能力，即选择 MEMBER-SERVICE-PROVIDER 某一个服务访问，默认是轮询算法
package com.li.springcloud.config;
import ...
/**
* @author 李
* @version 1.0
* 注入RestTemplate Bean
*/
@Configuration
public class CustomInitBean {
@Bean
@LoadBalanced //赋予RestTemplate负载均衡的能力，默认是使用轮询算法来访问远程调用接口
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}
（3）依次启动EurekaServer集群、服务提供方集群、服务消费方
为了区分，可以在服务提供方的Controller中打印当前的服务提供方的名称
-
先用浏览器直接访问服务提供方集群的接口，目的是测试服务提供方是否正常工作：
注意这里访问的分别是不同的服务提供方的接口
-
在用浏览器访问服务消费方的接口，测试服务消费方是否正常工作：
可以看到浏览器访问同一个地址（即只有一个服务消费方模块），但是底层调用的服务提供方是不一样的（轮询访问）
第一次访问：
第二次访问：
交替访问member服务说明：
- 注解 @LoadBalanced底层是Ribbon支持算法
- Ribbon和Eureka整合后，服务消费方可以直接调用服务，而不用再关心服务提供方的地址和端口号
- 该服务还有负载功能
3.5通过DiscoveryClient获取EurekaServer服务注册信息
无论是服务消费方还是服务提供方，它们都是EurekaClient。如果希望获取到EurekaServer的服务注册信息，可以使用DiscoveryClient。
这里以服务消费方为例，获取EurekaServer的服务注册信息：
（1）修改 MemberConsumerController.java
package com.li.springcloud.controller;
import ...
/**
* @author 李
* @version 1.0
*/
@RestController
@Slf4j
public class MemberConsumerController {
@Resource
private RestTemplate restTemplate;
//装配一个DiscoveryClient，
//注意用的包是 import org.springframework.cloud.client.discovery.DiscoveryClient;
@Resource
private DiscoveryClient discoveryClient;
@GetMapping("/member/consumer/discovery")
public Object discovery() {
List<String> services = discoveryClient.getServices();
for (String service : services) {
log.info("服务名={}", service);
//通过服务名来获取服务名对应的实例
List<ServiceInstance> instances = discoveryClient.getInstances(service);
for (ServiceInstance instance : instances) {
log.info("id={},host={},port={},uri={}",
instance.getServiceId(), instance.getHost(),
instance.getPort(), instance.getUri());
}
}
return discoveryClient;
}
//其他方法略..
}
（2）修改启动类，添加注解启用服务发现
（3）重启服务消费模块，浏览器访问 http://localhost/member/consumer/discovery，后台输出如下：