1、需求

我們都知道專案中的服務是越來越多的，如果沒有一個統一的閘道器來做分發，那麼就會將複雜度帶到客戶端，所以我們必須搭建閘道器。

2、實現步驟

1、建立一個專案langjitianya-gateway

2、準備好pom.xml檔案

3、準備好配置檔案

4、準備好啟動類

5、run 起來

6、訪問驗證

3、具體實現

1、專案結構簡圖

2、pom配置檔案

<groupId>com.niepengfei.langjitianya</groupId>
    <artifactId>langjitianya-gateway</artifactId>
    <version>1.0-SNAPSHOT</version>

    <name>langjitianya-gateway</name>
    <description>浪跡天涯商城閘道器</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.12.RELEASE</version>
        <relativePath/>
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Edgware.SR3</spring-cloud.version>
    </properties>

    <dependencies>
        <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.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-web</artifactId>
        </dependency>
    </dependencies>


    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
 

3、配置檔案application.properties

#服務埠
server.port=5555

#服務名稱
spring.application.name=langjitianya-gateway

## 註冊中心eurka地址
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

#給閘道器地址加上版本號
zuul.prefix=/v1

# 商品服務閘道器
zuul.routes.item-service.path=/itemservice/api/**
zuul.routes.item-service.serviceId=langjitianya-itemservice
 

4、啟動類

5、run

6、測試, 訪問：http://localhost:5555/v1/itemservice/api/item/list.json?page=1&rows=2

4、服務降級處理

1、服務降級處理類

具體原始碼參考如下：

package com.niepengfei.langjitianya.gateway.fallback.itemservice;

import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.stereotype.Component;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;

/**
 * @author Jack
 */
@Component
public class ItemServiceFallbackProvider implements FallbackProvider {

    /**
     *  只對langjitianya-itemservice做降級處理, 如果需要對所有的服務都加降級處理
     *  只需要將字串變成“*”
     * @return
     */
    @Override
    public String getRoute() {
        return "langjitianya-itemservice";
    }

    @Override
    public ClientHttpResponse fallbackResponse(Throwable cause) {
        return this.fallbackResponse();
    }

    @Override
    public ClientHttpResponse fallbackResponse() {

        return new ClientHttpResponse(){
            @Override
            public HttpStatus getStatusCode() throws IOException {
                return HttpStatus.OK;
            }

            @Override
            public int getRawStatusCode() throws IOException {
                return HttpStatus.OK.value();
            }

            @Override
            public String getStatusText() throws IOException {
                return "OK";
            }

            @Override
            public void close() {

            }

            @Override
            public InputStream getBody() throws IOException {
                return new ByteArrayInputStream("error".getBytes());
            }

            @Override
            public HttpHeaders getHeaders() {
                HttpHeaders httpHeaders = new HttpHeaders();
                httpHeaders.setContentType(MediaType.APPLICATION_JSON);
                return httpHeaders;
            }
        };
    }
}
 

2、服務降級測試

第一步：首先停掉langjitianya-itemservice服務。

第二步：訪問 http://localhost:5555/v1/itemservice/api/item/list.json?page=1&rows=2

5、程式碼託管