【Spring Cloud】分布式必学springcloud（二）——注册中心Eureka

川长思鸟来 2022-05-27 12:46 280阅读 0赞

一、前言

  1.   在上一篇博客中，小编简单的向大家介绍了springcloud的一些概念，大家可能对那些还是不太的了解，不过没有问题，盲人摸象嘛，慢慢的摸，你会了解的越来越多的。所以不用担心。在下面的博客，小编依次介绍，依次实现。
  3.   在这篇博客中，小编介绍一下注册中心——Eureka。

二、注册中心Eureka

  1.   想必做过Dubbo的老铁们一定使用过Zookeeper吧。这里的zookeeper就起到了一个注册中心的作用。Dubbo架构中分成了提供者和消费者，提供者需要把自己的服务注册到注册中心，消费者订阅注册中心，注册中心有提供者后，会通知消费者。ZK起到了一个服务协调的作用。
  3.   在springcloud中，自己提供了一个注册中心——Eureka。
  5.   Eureka是一个基于REST(Representational State Transfer)的服务，主要用于AWS cloud， 提供服务定位(locating services)、负载均衡(load balancing)、故障转移(failover of middle-tier servers)。我们把它叫做Eureka Server. Eureka也提供了基于Java的客户端组件，Eureka Client,内置的负载均衡器可以实现基本的round-robin负载均衡能力。在Netflix，一个基于Eureka的更复杂的负载均衡器针对多种因素(如流量、资源利用率、错误状态等)提供加权负载均衡，以实现高可用(superior resiliency).

三、服务注册中心

3.1 建立Maven项目

  1.   小编使用springboot的快速生产项目的网站 [http://start.spring.io/][http_start.spring.io]，来生产项目：

这里写图片描述

  1.   导入idea：

这里写图片描述

3.2 导入Eureka依赖和springcloud依赖

  1.   在maven的pom文件中，添加Eureka依赖：`spring-cloud-starter-eureka-server`
  3. <?xml version="1.0" encoding="UTF-8"?>
  4. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  6. <groupId>com.forezp</groupId>
  7.     <artifactId>eurekaserver</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>jar</packaging>
  10. <name>eurekaserver</name>
  11.     <description>Demo project for Spring Boot</description>
  12. <parent>
  13.         <groupId>org.springframework.boot</groupId>
  14.         <artifactId>spring-boot-starter-parent</artifactId>
  15.         <version>1.5.2.RELEASE</version>
  16.         <relativePath/> <!-- lookup parent from repository -->
  17.     </parent>
  18. <properties>
  19.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  20.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  21.         <java.version>1.8</java.version>
  22.         <spring-cloud.version>Edgware.SR2</spring-cloud.version>
  23.     </properties>
  24. <dependencies>
  25.         <!--eureka server -->
  26.         <dependency>
  27.             <groupId>org.springframework.cloud</groupId>
  28.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  29.         </dependency>
  30. <!-- spring boot test-->
  31.         <dependency>
  32.             <groupId>org.springframework.boot</groupId>
  33.             <artifactId>spring-boot-starter-test</artifactId>
  34.             <scope>test</scope>
  35.         </dependency>
  36.     </dependencies>
  37. <dependencyManagement>
  38.         <dependencies>
  39.             <dependency>
  40.                 <groupId>org.springframework.cloud</groupId>
  41.                 <artifactId>spring-cloud-dependencies</artifactId>
  42.                 <version>${spring-cloud.version}</version>
  43.                 <type>pom</type>
  44.                 <scope>import</scope>
  45.             </dependency>
  46.         </dependencies>
  47.     </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>
  56. <repositories>
  57.         <repository>
  58.             <id>spring-milestones</id>
  59.             <name>Spring Milestones</name>
  60.             <url>https://repo.spring.io/milestone</url>
  61.             <snapshots>
  62.                 <enabled>false</enabled>
  63.             </snapshots>
  64.         </repository>
  65.     </repositories>
  66. </project>
  68.   添加完成的时候，如果要建立父子pom，需要把`${spring-cloud.version}`提取出来。这样子pom中跟springcloud相关的就不用设置版本号了。

3.3 代码编写

  1.   springboot有一个application的启动类，我们这里就修改这个启动类：添加`@EnableEurekaServer`。通过这个注解，启动一个服务注册中心提供给其他应用进行对话。
  3. package com.wl.eureka;
  5. import org.springframework.boot.SpringApplication;
  6. import org.springframework.boot.autoconfigure.SpringBootApplication;
  7. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
  10. @SpringBootApplication
  11. @EnableEurekaServer
  12. public class EurekaApplication {
  14.     public static void main(String[] args) {
  15.         SpringApplication.run(EurekaApplication.class, args);
  16.     }
  17. }

3.4 修改配置文件

  1.   在默认情况下，注册中心会将自己作为客户端来尝试注册自己，所以我们需要禁用它的客户端注册行为。需要在application.properties文件或application.yml中添加配置。
  3.   注意：生成的maven项目默认是application.properties，没有application.yml，对比一下，官方很多的demo中使用的是application.yml，另外application.yml天然的形成了树结构。代码写的也少。
  5. server:
  6.   port: 8761
  8. eureka:
  9.   instance:
  10.     hostname: localhost
  11.   client:
  12.     registerWithEureka: false
  13.     fetchRegistry: false
  14.     serviceUrl:
  15.       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
  17.   代码说明：
  • eureka.client.registerWithEureka：false ，由于应用为注册中心， 来表明自己是一个eureka server. 不会把自己注册到自己上。
  • eureka.client.fetchRegistry：由于注册中心的职责是维护服务实例，不需要去检索服务，所以也设置为false

3.5 运行

  1.   运行后，输入`http://localhost:8761/`，打开注册中心监控页面：

这里写图片描述

3.6 Eureka配置用户名密码登录

  1.   pom文件中添加：
  3. <dependency>
  4.             <groupId>org.springframework.boot</groupId>
  5.             <artifactId>spring-boot-starter-security</artifactId>
  6.         </dependency>
  8.   修改配置文件：
  10. server:
  11.   port: 8761
  13. security:
  14.   basic:
  15.     enabled: true
  16.   user:
  17.     name: admin
  18.     password: admin
  20. eureka:
  21.   instance:
  22.     hostname: localhost
  23.   client:
  24.     registerWithEureka: false
  25.     fetchRegistry: false
  26.     serviceUrl:
  27.       defaultZone: http://${security.user.name}:${security.user.password}@${eureka.instance.hostname}:${server.port}/eureka/
  29.   再次登录的时候，会出现输入账户和密码的弹窗：

这里写图片描述

四、服务提供者

  1.   建立如下的结构：

这里写图片描述

  1.   当client向server注册时，它会提供一些元数据，例如主机和端口，URL，主页等。Eureka server 从每个client实例接收心跳消息。 如果心跳超时，则通常将该实例从注册server中删除。  
  2.   创建过程同server类似,创建完pom.xml如下：
  4. <?xml version="1.0" encoding="UTF-8"?>
  5. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  6.     <modelVersion>4.0.0</modelVersion>
  8.     <groupId>com.wl</groupId>
  9.     <artifactId>client</artifactId>
  10.     <version>0.0.1-SNAPSHOT</version>
  11.     <packaging>jar</packaging>
  13.     <name>client</name>
  14.     <description>Demo project for Spring Boot</description>
  17.     <parent>
  18.         <groupId>com.wl</groupId>
  19.         <artifactId>scf</artifactId>
  20.         <version>0.0.1-SNAPSHOT</version>
  21. </parent>
  23.     <dependencies>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-eureka</artifactId>
  27.         </dependency>
  29.     </dependencies>
  31. </project>
  33.   创建controller：
  35. package com.wl.client.controller;
  37. import org.springframework.web.bind.annotation.GetMapping;
  38. import org.springframework.web.bind.annotation.RequestParam;
  39. import org.springframework.web.bind.annotation.RestController;
  41. /** * Created by Ares on 2018/4/11. */
  42. @RestController
  43. public class User { 
  45.     @GetMapping("/user/findById")
  46.     public String findById(@RequestParam("id")String id){
  47.         return "这个是springcloud的客户端"+id;
  48.     }
  51. }
  53.   配置启动类：
  55. package com.wl.client;
  57. import org.springframework.boot.SpringApplication;
  58. import org.springframework.boot.autoconfigure.SpringBootApplication;
  59. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  61. @SpringBootApplication
  62. @EnableEurekaClient
  63. public class ClientApplication {
  65.     public static void main(String[] args) {
  66.         SpringApplication.run(ClientApplication.class, args);
  67.     }
  68. }
  70.   类中@EnableEurekaClient或@EnableDiscoveryClient注解，激活EurekaDiscoveryClient实现，自动化配置，创建DiscoveryClient接口针对Eureka客户端的EnableDiscoveryClient实例。
  72.   修改配置文件：
  74. server:
  75.   port: 9001
  76. eureka:
  77.   client:
  78.     serviceUrl:
  79.       defaultZone: http://${security.user.name}:${security.user.password}@localhost:8761/eureka/
  80. spring:
  81.   application:
  82.     name: client1
  83. security:
  84.   basic:
  85.     enabled: true
  86.   user:
  87.     name: admin
  88.     password: admin
  90.   在配置文件中，使用spring.application.name配置服务名，如命名为client1；通过eureka.serviceUrl.defaultZone指定服务注册中心的地址，这里小编指定的是之前建立的注册中心地址。
  92.   依次启动注册中心`http://localhost:8761/`和提供者

这里写图片描述

  1.   我们可以通过访问 `http://localhost:9001//user/findById?id=1`来访问提供者：

这里写图片描述

五、小结

  1.   Eureka服务注册发现，容错管理、失效剔除、自我保护、安全验证。功能真是很强大，使用也非常好用，多多用吧。

发表评论

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

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

相关阅读