服务治理：Spring Cloud Eureka
一、服务治理
服务治理是微服务架构中最为核心和基础的模块，它主要用来实现各个微服务实例的自动化注册与发现。
1.服务注册：
在服务治理框架中，通常会构建一个注册中心，每个服务单元向注册中心登记自己提供的服务，将主机与端口号、
版本号、通信协议等一些附件信息告知注册中心，注册中心按服务名称分类组织服务清单，例如：
2.服务发现：
调用方需要向服务注册中心咨询服务，并获取所有服务的实例清单，以实现对具体服务实例的访问。
二、Netflexi Euraka
Spring Cloud Euraka使用Netflexi Euraka来实现服务的注册与发现，它既包含了
服务端的组件也包含了客户端的组件。
Euraka 服务端：即服务注册中心。
Euraka 客户端：主要处理服务的注册与发现。Euraka客户端向注册中心注册自身提供的服务并
周期性地发送心跳来更新它的服务租约。同时，他能从服务端查询当前注册的服务信息并把它们
缓存到本地并周期性地更新服务状态。
三、搭建服务注册中心
pom.xml中引入必要依赖：
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
</dependencies> <dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Brixton.SR5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
启用服务注册中心：
//启动一个服务注册中心，提供给其他应用进行对话。
//在默认设置下，该服务注册中心也会将自己作为客户端尝试注册它自己
@EnableEurekaServer
@SpringBootApplication
public class TangcloudApplication {
public static void main(String[] args) {
SpringApplication.run(TangcloudApplication.class, args);
}
}
禁用默认的客户端注册行为：
#设置服务注册中心端口
server.port=
eureka.instance.hostname=localhost
#不向注册中心注册自己
eureka.client.register-with-eureka=false
#注册中心不需要去检索服务
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eurka/
四、注册服务提供者
pom.xml:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
</dependencies> <dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Brixton.SR5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
controller:
@RestController
public class HelloController {
@Autowired
private DiscoveryClient client;
@RequestMapping(value = "/hello", method = RequestMethod.GET)
public String index() {
ServiceInstance serviceInstance = client.getLocalServiceInstance();
System.out.println("/hello, host: " + serviceInstance.getHost() + ", service_id: " +
serviceInstance.getServiceId());
return "Hello World!";
}
}
@EnableDiscoveryClient //激活DiscoveryClient实现
@SpringBootApplication
public class Service1Application { public static void main(String[] args) {
SpringApplication.run(Service1Application.class, args);
} }
application.properties文件：
server.port=
spring.application.name=hello-service
eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
五、高可用注册中心
Euraka高可用实际上就是将自己作为服务向其他服务注册中心注册自己，这样就可以
形成一组互相注册的服务注册中心，以实现服务清单的互相同步，达到高可用效果。
构建一个服务注册中心集群：
1）创建application-peer1.properties,作为peer1服务中心的配置：
pring.application.name=eureka-server
server.port=1111 eureka.instance.hostname=peer1
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true
eureka.client.service-url.defaultZone=http://peer2:1112/eureka/
2）建application-peer1.properties,作为peer1服务中心的配置：
spring.application.name=eureka-server
server.port=1112 eureka.instance.hostname=peer2
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true
eureka.client.service-url.defaultZone=http://peer1:1111/eureka/
3）服务提供方的配置：
eureka.client.service-url.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka/
六、服务的发现与消费
下面构建一个服务消费者，它可以发现服务及消费服务。其中服务的发现任务由Eureka的客户端完成。
Ribbon是一个基于HTTP和TCP的客户端负载均衡器，它在Eureka发现服务的基础上，实现了一套对服务
的选择策略。
首先，创建一个Spring Boot工程，并在之前hello-service的pom.xml基础上新增：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
启动类：
@SpringBootApplication
@EnableDiscoveryClient //让该应用注册为Eureka客户端，获得服务发现的能力
public class ConsumerApplication {
@Bean
@LoadBalanced //开启客户端负载均衡
RestTemplate restTemplate() {
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}
application.properties
server.port=9671
spring.application.name=ribbon-consumer
eureka.client.service-url.defaultZone=http://localhost:1111/eureka/
controller:
@RestController
public class ConsumerController {
@Autowired
RestTemplate restTemplate; //通过它来调用service-hello服务的/hello接口
@RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)
public String helloConsumer() {
return restTemplate.getForEntity("http://hello-service/hello",
String.class).getBody();
}
}