本文节选自《疯狂Spring Cloud微服务架构实战》

Spring Cloud教学视频：https://my.oschina.net/JavaLaw/blog/1552993

Spring Cloud电子书：https://my.oschina.net/JavaLaw/blog/1570383

Spring Cloud集群使用Zuul

        在前面小节的例子中，Zuul将请求转发到一个Web项目进行处理，如果实际处理请求的不是一个Web项目，而是整个微服务集群，那么Zuul将成为整个集群的网关。在加入Zuul前，Spring Cloud集群的结构请见图7-3。

图7-3 原来的Spring Cloud集群结构

        为微服务集群加入Zuul网关后，结构如图7-4所示。

图7-4 加入Zuul后集群结构

        在深入学习Zuul前，先按图7-4的搭建本章的测试项目。

集群搭建

        假设当前需要实现一个书本销售业务，在销售模块中需要调用书本模块的服务，用来查找书本，本小节案例以此为基础，建立以下项目：

• zuul-eureka-server：Eureka服务器，应用端口为8761，读者可以到以下目录取得源代码：codes\07\03\zuul-eureka-server。
• zuul-book-service：书本模块，属于服务提供者，提供“/book/{bookId}”服务，用于查找图书，最后返回Book的JSON字符串，应用端口为9000，代码目录codes\07\03\zuul-book-service。
• zuul-sale-service：销售模块，属于服务调用者，对外发布销售服务“/sale-book/{bookId}”，该服务中会调用zuul-book-service来查找Book，应用端口为9100，代码目录codes\07\03\zuul-sale-service。

        书本模块“zuul-book-service”发布的服务，仅返回一个简单的Book对象，控制器代码如下：

    @RequestMapping(value = "/book/{bookId}", method = RequestMethod.GET,              produces = MediaType.APPLICATION_JSON_VALUE)     public Book findBook(@PathVariable Integer bookId) {         Book book = new Book();         book.setId(bookId);         book.setName("Workflow讲义");         book.setAuthor("杨恩雄");         return book;     } 

        销售模块“zuul-sale-service”发布的服务，相关代码如下：

@FeignClient("zuul-book-service") // 声明调用书本服务 public interface BookService {      /**      * 调用书本服务的接口，获取一个Book实例      */     @RequestMapping(method = RequestMethod.GET, value = "/book/{bookId}")     Book getBook(@PathVariable("bookId") Integer bookId); }  @RestController public class SaleController {      @Autowired     private BookService bookService;      @RequestMapping(value = "/sale-book/{bookId}", method = RequestMethod.GET)    public String saleBook(@PathVariable Integer bookId) {         // 调用book服务查找         Book book = bookService.getBook(bookId);         // 控制台输入，模拟进行销售         System.out.println("销售模块处理销售，要销售的图书id: " + book.getId() + ", 书名："                 + book.getName());         // 销售成功         return "SUCCESS";     } } 

        销售模块的服务，使用Feign来调用书本模块的服务来获取Book实例，然后在控制台中输出信息，在实际应用中，销售的过程会更为复杂，例如有可能涉及支付等内容，本例为了简单起见，仅作简单的输出。接下来，创建网关项目。

路由到集群服务

        在前一小节的基础上，新建一个名称为“zuul-gateway”的Maven项目（代码目录codes\07\03\zuul-gateway），在pom.xml中加入以下依赖：

        <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-config</artifactId>         </dependency>         <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-eureka</artifactId>         </dependency>         <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-zuul</artifactId>         </dependency>         <dependency>             <groupId>org.apache.httpcomponents</groupId>             <artifactId>httpclient</artifactId>             <version>4.5.3</version>         </dependency> 

        新建应用类，如代码清单7-3所示。

        代码清单7-3：

        codes\07\03\zuul-gateway\src\main\java\org\crazyit\cloud\GatewayApplication.java

@EnableZuulProxy @SpringBootApplication public class GatewayApplication {      public static void main(String[] args) {         new SpringApplicationBuilder(GatewayApplication.class).properties(                 "server.port=8080").run(args);     } } 

        应用类跟前面的例子一致，使用@EnableZuulProxy注解，但是，由于网关项目需要加入到集群中，因此要修改配置文件，让其注册到Eureka服务器中。本例的配置文件如代码清单7-4。

        代码清单7-4：codes\07\03\zuul-gateway\src\main\resources\application.yml

spring:   application:     name: zuul-gateway eureka:   instance:     hostname: localhost   client:     serviceUrl:       defaultZone: http://localhost:8761/eureka/ zuul:    routes:     sale:       path: /sale/**       serviceId: zuul-sale-service 

        使用eureka的配置，将自己注册到8761的Eureka中。在配置Zuul时，声明所有的“/sale/**”请求，将会被转发到Id为“zuul-sale-service”的服务进行处理。

        一般情况下，配置了serviceId后，在处理请求的“routing”阶段，将会使用一个名称为RibbonRoutingFilter的过滤器，该过滤器会调用Ribbon的API来实现负载均衡，默认情况下调用HttpClient来调用集群服务。

        按照以下顺序启动集群：

• 启动zuul-eureka-server（Eureka服务器）。
• 启动zuul-book-service（服务提供者）。
• 启动zuul-sale-service（服务调用者）。
• 启动zuul-gateway（集群网关）。

        在浏览器中访问：http://localhost:8080/sale/sale-book/1，返回“SUCCESS”字符串，在销售模块的控制台，可以看到输出如下：

销售模块处理销售，要销售的图书id: 1, 书名：Workflow讲义

        根据输出可知，销售模块、书本模块均被调用。本例涉及了4个项目，图7-5展示了本例的结构，可帮助读者理解本例。

图7-5 本例的结构

Zuul Http客户端

        我们知道，Ribbon用来实现负载均衡，Ribbon在选取了合适的服务器后，再调用REST客户端API来调用集群服务。在默认情况下，将使用HttpClient的API来调用集群服务。除了HttpClient外，还可以使用OkHttpClient，以及com.netflix.niws.client.http.RestClient，RestClient目前已经不推荐使用，如果想启用OkHttpClient，可以添加以下配置：ribbon.okhttp.enabled=true。除了该配置外，还要在pom.xml中加入OkHttpClient的依赖：

        <dependency>             <groupId>com.squareup.okhttp3</groupId>             <artifactId>okhttp</artifactId>         </dependency> 

        注意：本小节的案例，也会在本章后面章节中使用。

本文节选自《疯狂Spring Cloud微服务架构实战》

Spring Cloud教学视频：https://my.oschina.net/JavaLaw/blog/1552993

Spring Cloud电子书：https://my.oschina.net/JavaLaw/blog/1570383

本书代码共享地址：https://gitee.com/yangenxiong/SpringCloud