Spring Cloud微服务笔记（三）服务治理：Spring Cloud Eureka快速入门

服务治理：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=1111
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=9669
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();
    }
}