Spring Cloud-Eureka 服务注册与发现

ゝ一世哀愁。 2022-05-25 12:06 155阅读 0赞

### 文章目录 ###

*  Spring Cloud-Eureka 服务注册与发现
 *   *   *   *  1.Eureka
             *   *  1.1 什么是Eureka
                 *  1.2 Eureka-server
                 *   *  pom.xml
                     *  application.yml
                     *  EurekaApp.java
                     *  application.yml
             *  2.服务提供者 provider-user
             *   *  pom.xml
                 *  application.yml
                 *  UserController.java
                 *  UserApp.java
             *  3.服务消费者
             *   *  application.yml
                 *  OrderController.java

# Spring Cloud-Eureka 服务注册与发现 #

>  在前面讲到，微服务的架构涉及到服务提供者和消费者，利用RPC去建立连接，那么一个公共的注册中心是不可或缺的。在这里，我们需要用的的组件上Spring Cloud Netflix的Eureka ,eureka是一个服务注册和发现模块。  
> [Spring Cloud官网][Spring Cloud]  
> [Spring Cloud文档][Spring Cloud 1]  
> [Spring Cloud中文文档][Spring Cloud 2]

#### 1.Eureka ####

##### 1.1 什么是Eureka #####

>  官方的介绍在这里Eureka wiki。Eureka是Netflix开源的一个RESTful服务，主要用于服务的注册发现。  
>  Eureka由两个组件组成：Eureka服务器和Eureka客户端。;Eureka服务器用作服务注册服务器。Eureka客户端是一个java客户端，用来简化与服务器的交互、作为轮询负载均衡器，并提供服务的故障切换支持。Netflix在其生产环境中使用的是另外的客户端，它提供基于流量、资源利用率以及出错状态的加权负载均衡。  
>  集群方案逻辑架构图如下：  
> ![这里写图片描述][70]  
>  上面的体系结构描述了Netflix如何部署Eureka，这是通常运行的方式。每个区域一个Eureka集群区域，负责该区域内的服务实例。每个区域至少有一台Eureka服务器来处理区域故障。  
>  服务注册Eureka，然后发送心跳每30秒更新一次租约。如果客户端无法续租几次，则会在大约90秒内将其从服务器注册表中取出。注册信息和更新被复制到群集中的所有Eureka节点。来自任何区域的客户端可以查找注册表信息（每30秒发生一次）以找到他们的服务（可能位于任何区域）并进行远程调用。  
>  通过了解之后，我觉得Eureka有以下几点吸引我的地方：
> 
> 1.  开源：可以了解实现原理，有必要还能修改源码。
> 2.  可靠：经过Netflix多年的生产环境考验，使用应该比较靠谱省心
> 3.  功能齐全：不但提供了完整的注册发现服务，还有Ribbon等配合使用的服务。
> 4.  基于Java：对于Java程序员来说，使用起来更加有底。
> 5.  spring cloud：可以使用Spring Cloud,与Eureka进行了很好的集成，使用起来非常方便。

##### 1.2 Eureka-server #####

>  搭建一个eureka-server服务，可以延续上一篇博客中，构建一个子项目eureka-server

###### pom.xml ######

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka-server</artifactId>
                <version>1.4.3.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-security</artifactId>
            </dependency>

###### application.yml ######

###### EurekaApp.java ######

package com.ithzk.spring.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /** * Hello world! * */
    @SpringBootApplication
    @EnableEurekaServer//将当前项目标记为eureka server
    
    public class EurekaApp
    { 
        public static void main( String[] args )
        { 
            SpringApplication.run(EurekaApp.class);
        }
    }

>  这样就搭建好了一个eureka服务，访问http://localhost:10000/ ，此时需要输入一个用户名和密码，用户名默认user，密码在启动项目时自动生成  
> ![这里写图片描述][70 1]  
>  进入到这个界面说明搭建成功  
> ![这里写图片描述][70 2]  
>  修改配置文件，可以达到免密登录

###### application.yml ######

server:
      port: 10000
    # 由于当前eureka是单机，所以需要做一些配置
    eureka:
      instance:
        hostname: localhost
      client:
        register-with-eureka: false
        fetch-registry: false
        server-url:
          defaultZone: http://user:user@${ eureka.instance.hostname}:${ server.port}/eureka/
    security:
      basic:
        enabled: true # 开启安全配置 需要密码 若不需要则设为false 注意该参数必须放在application.yml中而不能放在bootstrap.yml
      user:
        name: user
        password: user # 在配置用户和密码后 可以修改地址的访问风格为curl风格

#### 2.服务提供者 provider-user ####

>  改装之前简单样例中的项目注册eureka

##### pom.xml #####

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        <version>1.4.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

##### application.yml #####

server:
      port: 7900 #程序启动后的端口，也就是tomcat的端口，可自定义
    spring:
     application:
       name: provider-user
    eureka:
      client:
        service-url:
          defaultZone:  http://user:user@localhost:10000/eureka/

##### UserController.java #####

##### UserApp.java #####

package com.ithzk.spring.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    /** * Hello world! * */
    @SpringBootApplication
    @EnableEurekaClient//eureka 客户端
    public class UserApp { 
    
        public static void main(String[] args )
        { 
            SpringApplication.run(UserApp.class);
        }
    }

>  此时启动UserApp，在eureka服务中可以查看到服务者上线  
> ![这里写图片描述][70 3]  
>  ps:在构建过程中遇到过一次问题导致无法启动 java.lang.NoSuchMethodError:  
>  java.util.concurrent.ConcurrentHashMap.keySet()Ljava/util/concurrent：这是由于JDK版本问题造成，部分方法从JDK8开始支持，所以需要将项目变为JDK8的环境  
> ![这里写图片描述][70 4]

#### 3.服务消费者 ####

>  同样改装之前简单样例消费者项目,pom.xml与以上提供者一致,App启动类同理加上@EnableEurekaClient注解

##### application.yml #####

server:
      port: 8900
    spring:
      application:
        name: consumer-order
    user:
      url: http://localhost:7900/user/
    eureka:
      client:
        service-url:
          defaultZone:  http://user:user@localhost:10000/eureka/

##### OrderController.java #####

package com.ithzk.spring.cloud.controller;
    
    import com.ithzk.spring.cloud.entity.User;
    import com.netflix.appinfo.InstanceInfo;
    import com.netflix.discovery.EurekaClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    /** * @author hzk * @date 2018/5/13 */
    @RestController
    public class OrderController { 
    
        //spring 提供用于访问rest接口的模板对象
        @Autowired
        private RestTemplate restTemplate;
    
        @Autowired
        private EurekaClient eurekaClient;
    
        @Value("${user.url}")
        private String url;
    
        @GetMapping("/order/{id}")
        public User getOrder(@PathVariable Integer id){ 
            //访问提供者 获取数据 通过rest访问获取的json数据转换为的User对象
            //PROVIDER-USER 为eureka中提供者注册服务名称
            InstanceInfo instanceInfo = eurekaClient.getNextServerFromEureka("PROVIDER-USER", false);
            //获取接口项目地址
            String homePageUrl = instanceInfo.getHomePageUrl();
    
            User user = restTemplate.getForObject(homePageUrl + "/user/" +id, User.class);
            return user;
        }
    }

>  这样就简单搭建好了eureka-server、服务提供者和服务消费者，此时eureka注册中心有两个服务注册成功  
> ![这里写图片描述][70 5]  
>  通过调用http://localhost:8900/order/xx 可以达到同样的效果、到此基本的使用就大功告成

[Spring Cloud]: http://projects.spring.io/spring-cloud/
[Spring Cloud 1]: http://projects.spring.io/spring-cloud/spring-cloud.html#_the_bootstrap_application_context
[Spring Cloud 2]: https://springcloud.cc/spring-cloud-dalston.html
[70]: /images/20220525/c3b13239e9ae4470989df89e73a3e986.png
[70 1]: /images/20220525/b17fe92b54f040fd8ec7c786da35c8f1.png
[70 2]: /images/20220525/59555f39abb944bf90106aadaa1b1e23.png
[70 3]: /images/20220525/616e4f5be22d4647a4813f360eedf4fc.png
[70 4]: /images/20220525/b21f7e1294c7476f8ebe5add550dd778.png
[70 5]: /images/20220525/1d36b611bf844c478a44b59c1b312b96.png