spring cloud使用zuul實現反向代理和負載均衡

本文轉載自查看原文 2017-08-23 20:24 62117

首先，這篇文章參考的是http://blog.didispace.com/springcloud5/這位大牛的博客。本人是通過這篇博客來學習zuul的，現在寫的博客只是個人在學習時個人的一些感受和理解。

談到spring cloud，就要提及到其核心組件：zuul組件，這個組件其實功能很多，比如反向代理，負載均衡還有權限控制等功能，這篇博客主要寫的是zuul的反向代理和負載均衡。

首先是進行eureka的實現，代碼如下：

首先是pom.xml，添加依賴：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka-server</artifactId>
            <version>1.3.2.RELEASE</version>
        </dependency>

然后是application:

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@EnableEurekaServer
@SpringBootApplication
public class EurekaApplication {

    public static void main(String[] args) {
        new SpringApplicationBuilder(EurekaApplication.class).web(true).run(args);
    }
}

接着是配置文件：

server.port=1111
#eureka.instance.hostname=localhost

eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://localhost:${server.port}/eureka/

創建好eureka后,則是實現zuul：

首先是添加pom.xml文件的依賴：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zuul</artifactId>
            <version>1.3.4.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.3.2.RELEASE</version>
        </dependency>

然后是具體的實現，也非常簡單：

@EnableZuulProxy
@SpringCloudApplication
public class ZuulApplication {

    public static void main(String[] args) {
        new SpringApplicationBuilder(ZuulApplication.class).web(true).run(args);
    }

}

接下來是配置文件：

spring.application.name=api-gateway
server.port=5555

# routes to serviceId 這里邊是通過serviceid來綁定地址，當在路徑后添加/api-a/   則是訪問service-A對應的服務。
zuul.routes.api-a.path=/api-a/**
zuul.routes.api-a.serviceId=service-A

zuul.routes.api-b.path=/api-b/**
zuul.routes.api-b.serviceId=service-B

# routes to url  這里是綁定具體的ip地址
zuul.routes.api-a-url.path=/api-a-url/**
zuul.routes.api-a-url.url=http://localhost:2222/

eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/

那么，其實在配置完這個配置文件后，其實zuul已經實現了反向代理和負載均衡的兩個功能了，可能有人這時候就納悶了，這里不是只是反向代理了嗎？怎么實現負載均衡呢？其實zuul實現負載均衡很簡單，使用serviceId進行綁定后，如果有多個相同的serviceid，則會進行輪詢的方式進行訪問。這個在下文會有具體的結果截圖。

現在需要開啟建立兩個服務，具體的操作為實現a+b的操作,第一個為Service-A。

pom.xml中添加：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
            <version>1.3.2.RELEASE</version>
        </dependency>

然后是配置文件：

spring.application.name=service-A

server.port=2224

eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/

然后是一個客戶端和一個controller:

package com.example;

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@EnableDiscoveryClient
@SpringBootApplication
public class ControllerApplicationA {

    public static void main(String[] args) {
        new SpringApplicationBuilder(ControllerApplicationA.class).web(true).run(args);
    }
}

package com.example.web;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.*;

@RestController
public class ComputeController {

    @Autowired
    private DiscoveryClient client;

    @RequestMapping(value = "/add/{a}/{b}",method = RequestMethod.GET)
    public String add(@PathVariable Integer a,@PathVariable Integer b)
    {
        System.out.println("host:"+client.getLocalServiceInstance().getHost()+"   -----port:"+client.getLocalServiceInstance().getPort());
        return a+b+" ------      host:"+client.getLocalServiceInstance().getHost()+"   -----port:"+client.getLocalServiceInstance().getPort();
    }

}