spring cloud构建互联网分布式微服务云平台-服务注册与发现

冷不防 2022-03-18 13:54 226阅读 0赞

Spring Cloud Eureka是Spring Cloud Netflix项目下的服务治理模块。而Spring Cloud Netflix项目是Spring Cloud的子项目之一，主要内容是对Netflix公司一系列开源产品的包装，它为Spring Boot应用提供了自配置的Netflix OSS整合。通过一些简单的注解，开发者就可以快速的在应用中配置一下常用模块并构建庞大的分布式系统。它主要提供的模块包括：服务发现（Eureka），断路器（Hystrix），智能路由（Zuul），客户端负载均衡（Ribbon）等。愿意了解源码的朋友直接求求交流分享技术 一七九一七四三三八零

服务注册中心 ：eureka-server

新建一个springboot项目：eureka-server，其pom.xml配置如下

<properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
        <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>Dalston.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

想要实现一个服务注册中心的功能非常简单，只需要在项目的启动类EurekaServerApplication上使用@EnableEurekaServer注解即可

@EnableEurekaServer
    @SpringBootApplication
    public class EurekaServerApplication{
     
        public static void main(String[] args) {
            new SpringApplicationBuilder(EurekaServerApplication.class)
                        .web(true).run(args);
        }
    }

默认情况下，该服务注册中心也会将自己作为客户端来尝试注册它自己，所以我们需要禁用它的客户端注册行为，只需要在application.properties配置文件中增加如下信息：

spring.application.name=eureka-server
    server.port=1001
    eureka.instance.hostname=localhost
    eureka.client.register-with-eureka=false
    eureka.client.fetch-registry=false

启动EurekaServerApplication，访问 http:/ /localhost:9001/ 可以看到Eureka的页面。

服务提供方 ：eureka-client

每一个实例注册之后需要向注册中心发送心跳，当client向server注册时，它会提供一些元数据，例如主机和端口，URL，主页等。Eureka server 从每个client实例接收心跳消息。 如果心跳超时，则通常将该实例从注册server中删除。

新建一个springboot项目：eureka-client，其pom.xml配置如下：

<properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
        </dependencies>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

想要实现一个服务提供方也很简单，只要在项目的启动类EurekaClientApplication上使用@EnableEurekaClient注解即可

@EnableEurekaClient
    @SpringBootApplication
    public class EurekaClientApplication {
     
         public static void main(String[] args) {
                new SpringApplicationBuilder(
                        EurekaClientApplication.class)
                    .web(true).run(args);
            }
    }

在application.properties中进行如下配置

spring.application.name=eureka-client
    server.port=9002
    eureka.client.serviceUrl.defaultZone=http://localhost:9001/eureka/

启动EurekaClientApplication类

刷新 http:/ /localhost:9001/， 可以看到咱们的服务提供方已经注册到了服务注册中心

新建一个DiscoveryController 使用discoveryClient.getServices()获取已经注册的服务名，使用@value将配置文件中的信息赋值到ip

@RestController
    public class DiscoveryController {
        
        @Autowired
        private DiscoveryClient discoveryClient;
        @Value("${server.port}")
        private String ip;
        
        @GetMapping("/client")
        public String client() {
            String services = "Services: " + discoveryClient.getServices()+" ip :"+ip;
            
            System.out.println(services);
            return services;
        }
    }

访问：http:/ /localhost:9002/client

最后说明一下@EnableEurekaClient 与@EnableDiscoveryClient这两个注解

首先这个两个注解都可以实现服务发现的功能，在spring cloud中discovery service有许多种实现（eureka、consul、 zookeeper等等）

@EnableEurekaClient基于spring-cloud-netflix。服务采用eureka作为注册中心，使用场景较为单一。

@EnableDiscoveryClient基于spring-cloud-commons。服务采用其他注册中心。