springcloud 之组件 eureka 使用（一）

阳光穿透心脏的1/2处 2022-11-28 00:43 139阅读 0赞

从今天开始我们讲解 springcloud 专题，前部分我们讲解各组件的使用，后部分讲解各组件的原理及源码。此篇我们分析eureka的使用流程。

首先我们知道eureka 是微服务的注册中心，分为服务端和客户端，服务端通常有一个或多个eureka 服务，客户端一般为多个不同或相同功能的微服务。下面我们用idea工具演示一下服务端和客户端的配置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmd5dW56aGFvMDA3_size_16_color_FFFFFF_t_70][]

1、先创建一个springboot 项目 ，一种方式如下图：

右键总目录名

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70][]

点击Module,然后依次操作，然后继续点击next

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1][]

进入下一步，填好项目相关信息，然后点击next

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2][]

进入Maven 配置环境

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 3][]

继续下一步，可以根据需求修改一些信息

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 4][]

2、，新建后在pom 文件中加一下几个重要依赖，包含一些依赖版本信息 如下：

<parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>2.2.2.RELEASE</version>
      <relativePath/>
    </parent>

<properties>
      <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
      <maven.compiler.source>1.7</maven.compiler.source>
      <maven.compiler.target>1.7</maven.compiler.target>
      <spring-cloud.version>Hoxton.SR1</spring-cloud.version>
    </properties>

<dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>

<dependencyManagement>
      <dependencies>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-dependencies</artifactId>
          <version>${spring-cloud.version}</version>
          <type>pom</type>
          <scope>import</scope>
        </dependency>
      </dependencies>
    </dependencyManagement>

3、创建springboot 启动类：

package com.navinfo.nandao;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /** springboot启动注解*/
    @SpringBootApplication
    /** eureka 服务端启动注解 */
    @EnableEurekaServer
    public class EurekaApplication {
        public static void main(String[] args) {
            SpringApplication.run(EurekaApplication.class, args);
        }
    }

4、在resources 中创建配置文件 application.properties  简单配置内容如下：

#该eureka 服务端的端口号
    server.port=8763
    #该eureka 服务端的ip地址
    eureka.instance.hostname=localhost
    
    #是否注册eureka
    eureka.client.register-with-eureka=false
    
    #是否从eureka中拉取信息
    eureka.client.fetch-registry=false
    
    #暴露eureka 服务地址
    eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/
    
    #自我保护模式，当出现出现网络分区、eureka在短时间内丢失过多客户端时，会进入自我保护模式，
    # 即一个服务长时间没有发送心跳，eureka也不会将其删除，默认为true
    eureka.server.enable-self-preservation=true
    
    #eureka server清理无效节点的时间间隔，默认60000毫秒，即60秒
    eureka.server.eviction-interval-timer-in-ms=60

5、然后启动服务：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 5][]

6、成功后访问 [http://localhost:8763/][http_localhost_8763]   显示如下：目前还没有客户端注册，所以eureka客户端列表为空

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 6][]

7、现在我们创建eureka 客户端,客户端创建端创建类似，几处不同的地方我这里详解一下：

pom 配置不同：

<dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

<plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
        <configuration>
          <mainClass>com.navinfo.nandao.OrderApplication</mainClass>
        </configuration>
      </plugin>
    </plugins>

启动类不同：

package com.navinfo.nandao;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    /** eureka 客户端 注解配置，重点 */
    @EnableEurekaClient
    public class OrderApplication {
        public static void main(String[] args) {
            SpringApplication.run(OrderApplication.class,args);
        }
    }

配置文件不同：

#微服务项目名称
    spring.application.name=nandao-order
    #微服务项目端口号
    server.port=8084
    #此客户端连接的eureka 服务端地址
    eureka.client.service-url.defaultZone=http\://localhost\:8763/eureka/

8、大概三处不同，配置后 启动该微服务，启动后刷新  [http://localhost:8763/][http_localhost_8763]  显示：有一个微服务客户端注册来了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 7][]

9、添加多个窗口，启动多个微服务比如8085、8086，启动后刷新  [http://localhost:8763/][http_localhost_8763]  显示

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 9][]

打包以及启动服务的步骤：

a、![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 10][]

b、![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 11][]

c、输入打包命令：mvn package -Dmaven.test.skip=true    回车，打好后的包在target目录

d、运行打好包，cd target/  输入启动命令  java -jar 包名 --server.port=8085  回车，第二个微服务就启动了......................

10、eureka 注册中心作用 已经解析完，在创建一个微服务进行接口调用，同理，简单流程如下：

package com.navinfo.nandao;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class NandaoWebApplication {
    
        @Bean
        @LoadBalanced  //接口调用时起到负载均衡作用
        RestTemplate restTemplate(){
          return new  RestTemplate();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(NandaoWebApplication.class,args);
        }
    }

conroller 控制层

package com.navinfo.nandao.controller;
    
    
    import com.navinfo.nandao.service.UserService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/user")
    public class UserController {
    
        @Autowired
        private UserService userService;
    
        @RequestMapping("/queryUser")
        public String queryUser() {
            return userService.queryContents();
        }
    }

server 接口实现层：

package com.navinfo.nandao.service;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Scope;
    import org.springframework.context.annotation.ScopedProxyMode;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
    import java.util.concurrent.atomic.AtomicInteger;
    @Slf4j
    @Service
    @Scope(proxyMode = ScopedProxyMode.INTERFACES)
    public class UserServiceImpl implements UserService {
    
        private AtomicInteger s = new AtomicInteger();
        private AtomicInteger f = new AtomicInteger();
    
        public static String SERVIER_NAME = "nandao-order";
    
        @Autowired
        private RestTemplate restTemplate;
    
        @Override
        public String queryContents() {
            s.incrementAndGet();
            String results = restTemplate.getForObject("http://"
                    + SERVIER_NAME + "/queryUser", String.class);
            return results;
        }
    }

另外一个客户端代码如下：

package com.navinfo.nandao.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @Slf4j
    @RestController
    public class UserController {
    
        @RequestMapping("/queryUser")
        public String queryUser() {
            log.info("========micro-order===queryUser");
            return "========micro-order===queryUser";
        }
    }

该微服务有多客户端 8084、8085、8086，其他接口过来时通过负载均衡算法随机选择一个服务。小伙伴可以自己模拟一下，印象会更深刻。下一篇我们 继续深入讲解eureka 使用和原理，敬请期待！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmd5dW56aGFvMDA3_size_16_color_FFFFFF_t_70]: /images/20221124/eb5fcb6c0276496185c9fe47ef401dde.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70]: /images/20221124/5d9afa4fd0164f46afbedfa20ae518c8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1]: /images/20221124/d68d33ba618d4898bfad38c2d02178b6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2]: /images/20221124/f53cc1c6e009443abd1b9026586be37c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 3]: /images/20221124/cb2d10d1a78e475c9d0e5cdc1084d208.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 4]: /images/20221124/da68f653eced488ca420c8482b2439ae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 5]: /images/20221124/1a852d4f042c4a47bc996bf7733318dc.png
[http_localhost_8763]: http://localhost:8763/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 6]: /images/20221124/3371e24eadad4200b46373ae0fc44974.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 7]: /images/20221124/3e00e694e5db473dae85e10ff7735932.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 8]: /images/20221124/03ab55a75cf34228b4de4447d4ca24a5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 9]: /images/20221124/23a6d39c26834909a068d788b02ea570.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 10]: /images/20221124/680d989d2319426a8f232657e30c91cc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 11]: /images/20221124/52883c80cd19449a9eb5396976bbfb52.png