Spring Cloud 之 Eureka集群整合Zuul、Feign

素颜马尾好姑娘i 2021-09-23 00:44 405阅读 0赞

微信搜索：“二十同学” 公众号，欢迎关注一条不一样的成长之路

简介
Eureka是Spring Cloud Netflix微服务套件中的一部分，提供了服务治理的功能。Eureka集群中的节点基于REST服务进行通信，如使用HttpClient与RestTemplate，Spring Cloud 套件中的Feign模块提供了更为简洁的服务访问。
Zuul是一个网关，能够将集群的服务隐藏到网关后面，统一对外提供服务，功能上类似Nginx（部分类似），提升了集群的安全性。

集群结构 

  1.     本示例共4个项目，分别为eureka-server、service-provider、service-invoker和zuul-server。其中，eureka-server为服务注册中心，端口号为8761；service-provider为服务提供者，端口号为9100；service-invoker为服务调用者，端口号为9000；zuul-server为网关，端口号为8080。

1、构建Eureka服务器
创建名为eureka-server的maven项目，或者使用eclipse（idea）的Springboot生成器创建Springboot项目。pom.xml文件如下： 

  1. <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>1.5.16.RELEASE</version>
  5.         <relativePath />
  6.     </parent>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  11.         <java.version>1.8</java.version>
  12.         <spring-cloud.version>Edgware.SR4</spring-cloud.version>
  13.     </properties>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-eureka-server</artifactId>
  19.         </dependency>
  21.     </dependencies>
  23.     <dependencyManagement>
  24.         <dependencies>
  25.             <dependency>
  26.                 <groupId>org.springframework.cloud</groupId>
  27.                 <artifactId>spring-cloud-dependencies</artifactId>
  28.                 <version>${spring-cloud.version}</version>
  29.                 <type>pom</type>
  30.                 <scope>import</scope>
  31.             </dependency>
  32.         </dependencies>
  33.     </dependencyManagement>
  35.     <build>
  36.         <plugins>
  37.             <plugin>
  38.                 <groupId>org.springframework.boot</groupId>
  39.                 <artifactId>spring-boot-maven-plugin</artifactId>
  40.             </plugin>
  41.         </plugins>
  42.     </build>

接下来，编写一个Springboot的启动类，并加上@EnableEurekaServer即可将此项目声明为Eureka服务器。启动类如下所示：

  1. @SpringBootApplication
  2. @EnableEurekaServer
  3. public class EurekaServer {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(EurekaServer.class, args);
  7.     }
  8. }

最后修改application.properties文件。

  1. server.port: 8761
  2. # 是否向Eureka服务器注册
  3. eureka.client.register-with-eureka: false
  4. # 是否抓取注册信息
  5. eureka.client.fetch-registry: false

因为本例只有一台eureka服务器（可以是多台），所以register-with-eureka和fetch-registry这两项为false

2、编写服务提供者
创建名为service-provider的maven项目。pom.xml文件如下： 

  1. <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>1.5.16.RELEASE</version>
  5.         <relativePath/>
  6.     </parent>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  11.         <java.version>1.8</java.version>
  12.         <spring-cloud.version>Edgware.SR4</spring-cloud.version>
  13.     </properties>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-config</artifactId>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-eureka</artifactId>
  23.         </dependency>
  25.     </dependencies>
  27.     <dependencyManagement>
  28.         <dependencies>
  29.             <dependency>
  30.                 <groupId>org.springframework.cloud</groupId>
  31.                 <artifactId>spring-cloud-dependencies</artifactId>
  32.                 <version>${spring-cloud.version}</version>
  33.                 <type>pom</type>
  34.                 <scope>import</scope>
  35.             </dependency>
  36.         </dependencies>
  37.     </dependencyManagement>
  39.     <build>
  40.         <plugins>
  41.             <plugin>
  42.                 <groupId>org.springframework.boot</groupId>
  43.                 <artifactId>spring-boot-maven-plugin</artifactId>
  44.             </plugin>
  45.         </plugins>
  46.     </build>

编写一个Controller，提供REST服务。代码如下：

  1. @RestController
  2. public class ProviderController {
  4.     @RequestMapping("/hello/{name}")
  5.     public String hello(@PathVariable("name") String name) {
  6.         return "Hello," + name;
  7.     }
  8. }

编写Springboot启动器，需要加上@EnableEurekaClient注解声明该项目为eureka的客户端。代码如下：

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. public class ProviderApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(ProviderApplication.class, args);
  7.     }
  8. }

最后修改application.properties文件。

  1. server.port=9100
  2. spring.application.name=servcie-provider
  3. #主机名
  4. eureka.instance.hostname= localhost
  5. #eureka服务器地址
  6. eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka

3、编写服务调用者（使用Feign）
创建名为service-invoker的maven项目。pom.xml文件如下： 

  1. <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>1.5.16.RELEASE</version>
  5.         <relativePath />
  6.     </parent>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  11.         <java.version>1.8</java.version>
  12.         <spring-cloud.version>Edgware.SR4</spring-cloud.version>
  13.     </properties>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-config</artifactId>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-eureka</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-ribbon</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.cloud</groupId>
  30.             <artifactId>spring-cloud-starter-feign</artifactId>
  31.         </dependency>
  33.     </dependencies>
  35.     <dependencyManagement>
  36.         <dependencies>
  37.             <dependency>
  38.                 <groupId>org.springframework.cloud</groupId>
  39.                 <artifactId>spring-cloud-dependencies</artifactId>
  40.                 <version>${spring-cloud.version}</version>
  41.                 <type>pom</type>
  42.                 <scope>import</scope>
  43.             </dependency>
  44.         </dependencies>
  45.     </dependencyManagement>
  47.     <build>
  48.         <plugins>
  49.             <plugin>
  50.                 <groupId>org.springframework.boot</groupId>
  51.                 <artifactId>spring-boot-maven-plugin</artifactId>
  52.             </plugin>
  53.         </plugins>
  54.     </build>

首先编写一个HelloService接口，Feign使用该接口完成请求。@FeignClient注解中的值表示调用服务名为service-provider的节点,@RequestMapping注解声明了调用该节点的哪个路由。

  1. @FeignClient("service-provider")
  2. public interface HelloService {
  4.     @RequestMapping("/hello/{name}")
  5.     String hello(@PathVariable("name") String name);
  6. }

编写一个Controller，对外提供服务，使用HelloService接口（代理对象）完成服务调用。

  1. @RestController
  2. @Configuration
  3. public class InvokerController {
  5.     @Autowired
  6.     private HelloService helloService;
  8.     @RequestMapping("/invoker-hello/{name}")
  9.     public String hello(@PathVariable String name) {
  10.         return helloService.hello(name);
  11.     }
  12. }

编写Springboot启动器，需要加上@EnableDiscoveryClient注解声明有能力发现eureka中的服务，加上@EnableFeignClients打开Feign开关。启动器代码如下：

  1. @SpringBootApplication
  2. @EnableDiscoveryClient
  3. @EnableFeignClients
  4. public class InvokerApplication {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(InvokerApplication.class, args);
  8.     }
  9. }

最后修改application.properties文件。

  1. server.port=9000
  2. spring.application.name=server-invoker
  3. #主机名
  4. eureka.instance.hostname= localhost
  5. #eureka服务器地址
  6. eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka

4、构建Zuul网关服务器
创建名为zuul-server的maven项目。pom.xml文件如下： 

  1. <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>1.5.16.RELEASE</version>
  5.         <relativePath/>
  6.     </parent>
  8.     <properties>
  9.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  10.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  11.         <java.version>1.8</java.version>
  12.         <spring-cloud.version>Edgware.SR4</spring-cloud.version>
  13.     </properties>
  15.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-config</artifactId>
  19.         </dependency>
  20.         <dependency>
  21.             <groupId>org.springframework.cloud</groupId>
  22.             <artifactId>spring-cloud-starter-eureka</artifactId>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.cloud</groupId>
  26.             <artifactId>spring-cloud-starter-zuul</artifactId>
  27.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-test</artifactId>
  32.             <scope>test</scope>
  33.         </dependency>
  34.     </dependencies>
  36.     <dependencyManagement>
  37.         <dependencies>
  38.             <dependency>
  39.                 <groupId>org.springframework.cloud</groupId>
  40.                 <artifactId>spring-cloud-dependencies</artifactId>
  41.                 <version>${spring-cloud.version}</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>

编写一个Springboot的启动类，并加上@EnableZuulProxy即可将此项目声明为zuul服务器。启动类如下所示：

  1. @SpringBootApplication
  2. @EnableZuulProxy
  3. public class ZuulGatewayApplication {
  5.     public static void main(String[] args) {
  6.         SpringApplication.run(ZuulGatewayApplication.class, args);
  7.     }
  8. }

接下来，最关键的一步是配置zuul服务的application.properties文件，zuul的请求转发在此配置。

  1. server.port=8080
  2. spring.application.name=zuul-server
  4. eureka.instance.hostname: localhost
  5. eureka.client.serviceUrl.defaultZone: http://localhost:8761/eureka
  7. zuul.routes.sale.path=/test/**
  8. zuul.routes.sale.service-id=server-invoker

这个配置的含义为将所有/test/**的请求转发到服务名为service-invoker的节点进行处理。

测试
启动服务器eureka-server项目
启动服务提供者service-provider项目
启动服务调用者service-invoker项目
启动服务调用者zuul-server项目
访问eureka提供的、含有集群节点信息的web页面，http://localhost:8761/

访问zuul网关，http://localhost:8080/test/invoker-hello/kangkang
接口返回内容为：hello,kangkang,得到预期结果。
在生产环境中，集群中的其他节点都没有暴露在公网环境下，只有zuul网关有公网IP，用户通过网关访问集群中的服务。

发表评论

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

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

相关阅读