SpringCloud Eureka

我会带着你远行 2024-04-18 11:48 120阅读 0赞

SpringCloud Eureka

欢迎关注微信公众号： 程序员小圈圈
原文首发于： www.zhangruibin.com
本文出自于： RebornChang的博客
转载请标明出处^_^

公众号回复:sp2，即可获取本节代码哦~~

在前文基础上新建模块springclouddemo-04-consumer-product-8002

  1. <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"
  2.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <parent>
  5.         <artifactId>springcloud-demo-01</artifactId>
  6.         <groupId>com.zrb.springcloud</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     <modelVersion>4.0.0</modelVersion>
  11.     <artifactId>springclouddemo-04-consumer-product-8002</artifactId>
  13.     <dependencies>
  14.         <dependency>
  15.             <groupId>com.zrb.springcloud</groupId>
  16.             <artifactId>springcloud-02-api</artifactId>
  17.             <version>${project.version}</version>
  18.         </dependency>
  19.         <dependency>
  20.             <groupId>org.springframework.boot</groupId>
  21.             <artifactId>spring-boot-starter-web</artifactId>
  22.         </dependency>
  23.     </dependencies>
  24. </project>

新建后项目目录如下图所示：

format_png

新建目录及文件

新建application.yml 文件，声明模块访问端口为8002.

  1. server:
  2.  port: 8002

在ConfigBean.java里面，配置RestTemplate.
这里我们使用spring提供的web组件进行接口的请求，来访问8001项目获取商品信息。

ConfigBean.java

  1. package com.zhrb.springcloud.config;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.client.RestTemplate;
  7. /**
  8.  * @ClassName ConfigBean
  9.  * @Description TODO
  10.   * @Author zhrb
  11.  * @Date 2019/9/4 11:56
  12.  * @Version
  13.   */ @Configuration public class ConfigBean {
  14.     // 向容器中添加 RestTemplate 组件,直接通过此组件可调用 REST 接口
  15.   @Bean
  16.   public RestTemplate getRestTemplate() {
  17.         return new RestTemplate();
  18.     }
  19. }

ProductControllerConsumer.java

  1. package com.zhrb.springcloud.controller;
  3. import com.zhrb.springcloud.entity.Product;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.web.bind.annotation.*;
  6. import org.springframework.web.client.RestTemplate;
  8. import java.util.List;
  10. /**
  11.  * @ClassName ProductControllerConsumer
  12.  * @Description TODO
  13.   * @Author zhrb
  14.  * @Date 2019/9/4 11:57
  15.  * @Version
  16.   */ 
  17.   @RestController
  18.    @RequestMapping(value = "/consumer/product")
  19. public class ProductControllerConsumer {
  21.     private static final String REST_URL_PREFIX = "http://127.0.0.1:8001";
  23.     @Autowired
  24.   private RestTemplate restTemplate;
  26.     @PostMapping(value = "/add")
  27.     public boolean add(Product product) {
  28.         return restTemplate.postForObject(REST_URL_PREFIX + "/product/add",
  29.                 product, Boolean.class);
  30.     }
  32.     @GetMapping(value = "/{id}")
  33.     public Product get(@PathVariable("id") Long id) {
  34.         return restTemplate.getForObject(REST_URL_PREFIX + "/product/" + id,
  35.                 Product.class);
  36.     }
  38.     @GetMapping(value = "/list")
  39.     public List<Product> list() {
  40.         return restTemplate.getForObject(REST_URL_PREFIX + "/product/list",
  41.                 List.class);
  42.     }
  43. }

启动类：
SpringCloudProductConsumer_8002.java

  1. package com.zhrb.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  8. /**
  9.  * @ClassName SpringCloudProductConsumer_8002
  10.  * @Description TODO
  11.   * @Author zhrb
  12.  * @Date 2019/9/4 11:59
  13.  * @Version
  14.   */ @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
  15. public class SpringCloudProductConsumer_8002 {
  16.     public static void main(String[] args) {
  17.         SpringApplication.run(SpringCloudProductConsumer_8002.class, args);
  18.     }
  19. }

这里有一个小知识点，我们可以看到，8002项目所用注解，和8001项目不一样，注解后面多了一些东西，这是为什么呢？如果不加上那些会有什么错吗？看下面。

根据springboot官方文档解释，@SpringBootApplication是一个复合注解。

简单的说就是：@SpringBootApplication相当于@Configuration,@EnableAutoConfiguration,@ComponentScan。

1、@Configuration的注解类标识这个类可以使用Spring IoC容器作为bean定义的来源。@Bean注解告诉Spring，一个带有@Bean的注解方法将返回一个对象，该对象应该被注册为在Spring应用程序上下文中的bean。

2、@EnableAutoConfiguration：能够自动配置spring的上下文，试图猜测和配置你想要的bean类，通常会自动根据你的类路径和你的bean定义自动配置。

3、@ComponentScan：会自动扫描指定包下的全部标有@Component的类，并注册成bean，当然包括@Component下的子注解@Service,@Repository,@Controller。

所以，在启动类上使用@SpringBootApplication时，会自动根据启动类路径进行扫描，执行了@ComponentScan，因此，在没有配置mapper时，一定要使用@DataSourceAutoConfiguration排除默认扫描配置。否则启动报错。

启动8002验证

先启动8001，再启动8002.
访问地址：localhost:8002/consumer/product/list
效果如下图所示：
format_png 1
新建完上面的那些项目之后，就迎来了我们接触springcloud的第一个组件，eureka。

Eureka

Eureka介绍

Spring Cloud Eureka 是对Netflix公司的Eureka的二次封装，它实现了服务治理的功能，Spring Cloud Eureka 提供 Eureka Server 服务端与 Eureka Client 客户端 ，服务端即是Eureka服务注册中心，客户端完成微服务向Eureka服务的注册与发现。

客户端同时也具备一个内置的使用轮询(round-robin)负载算法的负载均衡器。在微服务启动后，将会向
Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心
跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）。

  1. Eureka Server 是服务端，负责管理各个微服务注册和发现。
  2. 在微服务上添加 Eureka Client 代码，就会访问到 Eureka Server 将此微服务注册在Eureka Server中，从而
    使服务消费方能够找到。
  3. 微服务（服务消费者）需要调用另一个微服务（服务提供者）时，从 Eureka Server 中获取服务调用地址，
    进行远程调用。

来看一下服务于注册Eureka架构图

format_png 2

看完了上面，是不是很像dubboo+zookeeper的服务注册与发现？
那么我们现在再新建一个类似dubbo-admin的模块，来进行页面视图的Eureka服务控制台。

Eureka 服务中心

新建模块springclouddemo-05-eureka-9000

新建后只需要新建两个文件：
1.application.yml

  1. server:
  2.  port: 9000 # 服务端口   eureka:
  3.  instance: hostname: eureka-server # eureka服务端的实例名称
  4.   client:
  5.  registerWithEureka: false # 服务注册，false表示不将自已注册到Eureka服务中
  6.   fetchRegistry: false # 服务发现，false表示自己不从Eureka服务中获取注册信息
  7.   serviceUrl: # Eureka客户端与Eureka服务端的交互地址，集群版配置对方的地址，单机版配置自己（如果不配置则默认本机8761端口）
  8.   defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

关于yml文件，一定一定要注意缩进问题，否则会编译报错！

2.启动类EurekaServer_9000

  1. package com.zhrb.springcloud;
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  7. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RequestParam;
  10. import org.springframework.web.bind.annotation.RestController;
  12. /**
  13.  * @ClassName EurekaServer_9000
  14.  * @Description TODO
  15.   * @Author Administrator
  16.  * @Date 2019/9/5 9:02
  17.  * @Version
  18.   */ 
  19.   @RestController @EnableEurekaServer @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
  20. public class EurekaServer_9000 {
  21.     public static void main(String[] args) {
  22.         SpringApplication.run(EurekaServer_9000.class, args);
  23.     }
  24.     @Value("${server.port}")
  25.     String port;
  26.     @RequestMapping("/hi")
  27.     public String home(@RequestParam String name) {
  28.         return "hi "+name+",i am from port:" +port+"this is my first test eureka";
  29.     }
  30.     @RequestMapping("/shishi")
  31.     public Object getNumber(){
  32.         String s = "";
  33.         for (int i=1;i<=9;i++){
  34.             for (int j = 1;j<=i;j++){
  35.                 s+=i+"*"+j+"="+(i*j)+"\t";
  36.                 System.out.print(i+"*"+j+"="+(i*j)+"\t");
  37.             }
  38.             System.out.print("\n");
  39.         }
  40.         return s;
  41.     }
  42. }

然后就是最重要的pom文件：

  1. <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"
  2.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <parent>
  5.         <artifactId>springcloud-demo-01</artifactId>
  6.         <groupId>com.zrb.springcloud</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     <modelVersion>4.0.0</modelVersion>
  11.     <artifactId>springclouddemo-05-eureka-9000</artifactId>
  12.     <dependencies>
  13.         <dependency>
  14.             <groupId>org.springframework.cloud</groupId>
  15.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  16.             <version>1.3.5.RELEASE</version>
  17.         </dependency>
  19.         <dependency>
  20.             <groupId>org.springframework.boot</groupId>
  21.             <artifactId>spring-boot-starter-test</artifactId>
  22.             <scope>test</scope>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-autoconfigure</artifactId>
  27.         </dependency>
  28.         <!--热部署-->
  29.   <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-devtools</artifactId>
  32.             <optional>true</optional>
  33.         </dependency>
  34.     </dependencies>
  36.     <dependencyManagement>
  37.         <dependencies>
  38.             <dependency>
  39.                 <groupId>org.springframework.cloud</groupId>
  40.                 <artifactId>spring-cloud-dependencies</artifactId>
  41.                 <version>Finchley.SR2</version>
  42.                 <type>pom</type>
  43.                 <scope>import</scope>
  44.             </dependency>
  45.         </dependencies>
  46.     </dependencyManagement>
  48.     <build>
  49.         <plugins>
  50.             <plugin>
  51.                 <groupId>org.springframework.boot</groupId>
  52.                 <artifactId>spring-boot-maven-plugin</artifactId>
  53.             </plugin>
  54.         </plugins>
  55.     </build>
  57.     <repositories>
  58.         <repository>
  59.             <id>spring-milestones</id>
  60.             <name>Spring Milestones</name>
  61.             <url>https://repo.spring.io/milestone</url>
  62.             <snapshots>
  63.                 <enabled>false</enabled>
  64.             </snapshots>
  65.         </repository>
  66.     </repositories>
  68. </project>

然后启动项目后截图如下：
![Image 1][]
可以看到，此时是没有项目向注册中心注册的。
接下来改造8001，8002向注册中心注册。

改造8001，8002

改造两个项目，让两个项目向注册中心注册：
format_png 3

8001

改造后的pom如下：

  1. <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"
  2.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <parent>
  5.         <artifactId>springcloud-demo-01</artifactId>
  6.         <groupId>com.zrb.springcloud</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     <modelVersion>4.0.0</modelVersion>
  10.     <properties>
  11.         <swagger.version>2.6.1</swagger.version>
  12.         <swagger.ui.version>2.6.1</swagger.ui.version>
  13.     </properties>
  14.     <artifactId>springcloud-demo-03-provider-product-8001</artifactId>
  15.     <dependencies>
  16.         <!--springboot web启动器-->
  17.   <dependency>
  18.             <groupId>org.springframework.boot</groupId>
  19.             <artifactId>spring-boot-starter-web</artifactId>
  20.         </dependency>
  21.         <!-- mybatis 启动器-->
  22.   <dependency>
  23.             <groupId>org.mybatis.spring.boot</groupId>
  24.             <artifactId>mybatis-spring-boot-starter</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-test</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>junit</groupId>
  32.             <artifactId>junit</artifactId>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>mysql</groupId>
  36.             <artifactId>mysql-connector-java</artifactId>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>com.alibaba</groupId>
  40.             <artifactId>druid</artifactId>
  41.         </dependency>
  43.         <dependency>
  44.             <groupId>com.zrb.springcloud</groupId>
  45.             <artifactId>springcloud-02-api</artifactId>
  46.             <version>${project.version}</version>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>org.springframework.cloud</groupId>
  50.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  51.             <version>1.3.5.RELEASE</version>
  52.         </dependency>
  53.         <dependency>
  54.             <groupId>org.springframework.cloud</groupId>
  55.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  56.         </dependency>
  57.         <!--druid数据源-->
  58.   <dependency>
  59.             <groupId>com.alibaba</groupId>
  60.             <artifactId>druid</artifactId>
  61.             <version>${druid.version}</version>
  62.         </dependency>
  63.         <dependency>
  64.             <groupId>mysql</groupId>
  65.             <artifactId>mysql-connector-java</artifactId>
  66.             <version>${mysql-connector-java.version}</version>
  67.         </dependency>
  68.         <dependency>
  69.             <groupId>org.mybatis</groupId>
  70.             <artifactId>mybatis-spring</artifactId>
  71.             <version>2.0.0</version>
  72.         </dependency>
  73.         <!--导入 mybatis 启动器-->
  74.   <dependency>
  75.             <groupId>org.mybatis.spring.boot</groupId>
  76.             <artifactId>mybatis-spring-boot-starter</artifactId>
  77.             <version>${mybatis-spring-boot-starter.version}</version>
  78.         </dependency>
  79.         <!--lombok bean 生成辅助框架-->
  80.   <dependency>
  81.             <groupId>org.projectlombok</groupId>
  82.             <artifactId>lombok</artifactId>
  83.             <version>${lombok.version}</version>
  84.         </dependency>
  85.         <!--swagger 前后端分离调试用-->
  86.   <dependency>
  87.             <groupId>io.springfox</groupId>
  88.             <artifactId>springfox-swagger2</artifactId>
  89.             <version>${swagger.version}</version>
  90.         </dependency>
  91.         <dependency>
  92.             <groupId>io.springfox</groupId>
  93.             <artifactId>springfox-swagger-ui</artifactId>
  94.             <version>${swagger.ui.version}</version>
  95.         </dependency>
  96.     </dependencies>
  97.     <dependencyManagement>
  98.         <dependencies>
  99.             <dependency>
  100.                 <groupId>org.springframework.cloud</groupId>
  101.                 <artifactId>spring-cloud-dependencies</artifactId>
  102.                 <version>Finchley.SR2</version>
  103.                 <type>pom</type>
  104.                 <scope>import</scope>
  105.             </dependency>
  106.         </dependencies>
  107.     </dependencyManagement>
  109.     <build>
  110.         <plugins>
  111.             <plugin>
  112.                 <groupId>org.springframework.boot</groupId>
  113.                 <artifactId>spring-boot-maven-plugin</artifactId>
  114.             </plugin>
  115.         </plugins>
  116.     </build>
  118.     <repositories>
  119.         <repository>
  120.             <id>spring-milestones</id>
  121.             <name>Spring Milestones</name>
  122.             <url>https://repo.spring.io/milestone</url>
  123.             <snapshots>
  124.                 <enabled>false</enabled>
  125.             </snapshots>
  126.         </repository>
  127.     </repositories>
  129. </project>

application.yml如下：

  1. server:
  2.  port: 8001
  4. mybatis:
  5.  config-location: classpath:mybatis/mybatis.cfg.xml # mybatis配置文件所在路径
  6.   type-aliases-package: com.zhrb.springcloud.entity # 所有Entity别名类所在包
  7.   mapper-locations: classpath:mybatis/mapper/**/*.xml # mapper映射文件   spring:
  8.  application: name: springcloud-product #这个很重要，这在以后的服务与服务之间相互调用一般都是根据这个name    datasource:
  9.  type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型
  10.   driver-class-name: com.mysql.cj.jdbc.Driver # mysql驱动包
  11.   url: jdbc:mysql://104.225.147.76:3306/springcloud_db01?serverTimezone=GMT%2B8 # 数据库名称
  12.   username: root
  13.     password: Zhrb1992!
  14.     dbcp2:
  15.  min-idle: 5 # 数据库连接池的最小维持连接数
  16.   initial-size: 5 # 初始化连接数
  17.   max-total: 5 # 最大连接数
  18.   max-wait-millis: 150 # 等待连接获取的最大超时时间 eureka:
  19.  client: serviceUrl: defaultZone: http://localhost:9000/eureka/

然后在启动类上增加@EnableEurekaClient 即可。

改造8002

pom

  1. <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"
  2.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <parent>
  5.         <artifactId>springcloud-demo-01</artifactId>
  6.         <groupId>com.zrb.springcloud</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     <modelVersion>4.0.0</modelVersion>
  10.     <artifactId>springclouddemo-04-consumer-product-8002</artifactId>
  12.     <properties>
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  14.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  15.         <java.version>1.8</java.version>
  16.         <spring-cloud.version>Dalston.SR4</spring-cloud.version>
  17.     </properties>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>com.zrb.springcloud</groupId>
  22.             <artifactId>springcloud-02-api</artifactId>
  23.             <version>${project.version}</version>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>org.springframework.cloud</groupId>
  27.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  28.             <version>1.3.5.RELEASE</version>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.cloud</groupId>
  32.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-starter-test</artifactId>
  37.             <scope>test</scope>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-autoconfigure</artifactId>
  42.         </dependency>
  43.         <!--热部署-->
  44.   <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-devtools</artifactId>
  47.             <optional>true</optional>
  48.         </dependency>
  49.     </dependencies>
  51.     <dependencyManagement>
  52.         <dependencies>
  53.             <dependency>
  54.                 <groupId>org.springframework.cloud</groupId>
  55.                 <artifactId>spring-cloud-dependencies</artifactId>
  56.                 <version>Finchley.SR2</version>
  57.                 <type>pom</type>
  58.                 <scope>import</scope>
  59.             </dependency>
  60.         </dependencies>
  61.     </dependencyManagement>
  63.     <build>
  64.         <plugins>
  65.             <plugin>
  66.                 <groupId>org.springframework.boot</groupId>
  67.                 <artifactId>spring-boot-maven-plugin</artifactId>
  68.             </plugin>
  69.         </plugins>
  70.     </build>
  72.     <repositories>
  73.         <repository>
  74.             <id>spring-milestones</id>
  75.             <name>Spring Milestones</name>
  76.             <url>https://repo.spring.io/milestone</url>
  77.             <snapshots>
  78.                 <enabled>false</enabled>
  79.             </snapshots>
  80.         </repository>
  81.     </repositories>
  83. </project>

application.yml

  1. server:
  2.  port: 8002
  4. eureka:
  5.  client: serviceUrl: defaultZone: http://localhost:9000/eureka/
  6. spring:
  7.  application: name: consumer-product

然后在启动类上增加@EnableEurekaClient 即可。

注意，后面的spring-boot-maven-plugin，以及pring-cloud-dependencies是必须的，否则在client找不到指定的版本。

启动项目验证

注意项目的启动顺序，先启动服务中心，再启动其他服务注册。
即：9000->8001->8002
format_png 4
启动后可以看到两个项目都注册到了服务中心。

这里有一点，当我其中一个项目宕机时，注册中心依然能看到这个服务，这不太好啊，那怎么办呢？别急，后续的springcloud组件中有关于这点的处理，那就是服务的熔断机制。

亲，博主的微信公众号
‘程序员小圈圈’开始持续更新了哟~~
识别二维码或者直接搜索名字 ‘程序员小圈圈’ 即可关注本公众号哟~~
不只是有技术哟~~
还有很多的学习娱乐资源免费下载哦~~
还可以学下教育知识以及消遣娱乐哟~~
求关注哟~~ format_png 5’

[Image 1]:

发表评论

表情：
评论列表 （有 0 条评论，120人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringCloud：Eureka

    目录 一、eureka的作用 二、搭建Eureka服务端 三、添加客户端 四、服务发现 -------------------- 提供者与消费者 服务提供者：一次

    Dear 丶Dear 丶/ 0 赞/ 126 阅读