SpringCloud分散式微服務搭建（二）

来源:https://www.cnblogs.com/linjiaqin/archive/2019/04/26/10776395.html
-Advertisement-
Play Games

這個例子主要是將zuul和eureka結合起來使用，zuul作為反向代理，同時起到負載均衡的作用，同時網關後面的消費者也作為服務提供者,同時提供負載均衡。 ...


這個例子主要是將zuul和eureka結合起來使用，zuul作為反向代理，同時起到負載均衡的作用，同時網關後面的消費者也作為服務提供者,同時提供負載均衡。

一.API網關（摘自百度）

API網關是一個伺服器，是系統的唯一入口。從面向對象設計的角度看，它與外觀模式類似。API網關封裝了系統內部架構，為每個客戶端提供一個定製的API。它可能還具有其它職責，如身份驗證、監控、負載均衡、緩存、請求分片與管理、靜態響應處理。
API網關方式的核心要點是，所有的客戶端和消費端都通過統一的網關接入微服務，在網關層處理所有的非業務功能。通常，網關也是提供REST/HTTP的訪問API。服務端通過API-GW註冊和管理服務。

二. 整體架構

 

    （1）http://localhost:40000/provider/hello?name=ljq3經過zuul網關之後，由於zuul對路徑映射

zuul.routes.api-a.path=/provider/**
zuul.routes.api-a.serviceId=ribbon-consumer
（2）把provider映射到ribbon-cunsumer這個服務上，zuul利用負載均衡的方式選一個服務地址，然後將路徑替換，得到
http://localhost:40001/hello?name=ljq3
（3）ribbon-consummer再利用ribbon負載均衡選擇一個provider，但是因為我在代碼中只把地址傳遞，而沒有傳遞參數，所以得到的url是
http://localhost:20003/

（4）github地址：https://github.com/linjiaqin/scdemo

三. zuul代碼結構

這裡把zuul的服務作為一個服務提供者去註冊到eureka中，要使用這個註解表名是一個服務提供者@EnableEurekaClient

1.引導類

package com.ljq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
import org.springframework.context.annotation.Bean;

@EnableZuulProxy
@SpringBootApplication
@EnableEurekaClient
//把zuul作為服務提供者到eureka註冊
public class GatewayApplication {

   private static final Logger LOGGER = LoggerFactory.getLogger(GatewayApplication.class);
   GatewayApplication(){
      LOGGER.info("app init");
   }
   public static void main(String[] args) {
      LOGGER.info("app start");
      SpringApplication.run(GatewayApplication.class, args);
   }

}

2.配置文件

這裡把的路徑匹配規則是當訪問的符合provider這個路徑時，自動映射到serviceId上，去eureka找到serviceID的所有可用地址，負載均衡選取一個後替換成這個地址

spring.application.name=gateway-service-zuul
server.port=40000
eureka.client.serviceUrl.defaultZone=http://mu01:8761/eureka,http://cu01:8762/eureka,http://cu02:8763/eureka
zuul.routes.api-a.path=/provider/**
zuul.routes.api-a.serviceId=eureka-client-service-provider

3. beanconfig

package com.ljq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Service;

@Service
public class MyBaenConfig {
    private static final Logger LOGGER = LoggerFactory.getLogger(MyBaenConfig.class);
    MyBaenConfig(){
        LOGGER.info("service init");
    }
    @Bean
    public MyFilter myFilter() {
        LOGGER.info("bean init");
        return new MyFilter();
    }
}

 

4. zuul的核心filter類，用來過濾請求

package com.ljq;


import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.servlet.http.HttpServletRequest;

public class MyFilter extends ZuulFilter {

    private final Logger LOGGER = LoggerFactory.getLogger(MyFilter.class);

    MyFilter(){
        LOGGER.info("filter init");
    }
    @Override
    public String filterType() {
        return "pre"; // 可以在請求被路由之前調用
    }

    @Override
    public int filterOrder() {
        return 0; // filter執行順序，通過數字指定 ,優先順序為0，數字越大，優先順序越低
    }

    @Override
    public boolean shouldFilter() {
        return true;// 是否執行該過濾器，此處為true，說明需要過濾
    }

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();

        LOGGER.info("--->>> MyFilter {},{}", request.getMethod(), request.getRequestURL().toString());

        String token = request.getParameter("name");// 獲取請求的參數

        if (StringUtils.isNotBlank(token)) {
            ctx.setSendZuulResponse(true); //對請求進行路由
            ctx.setResponseStatusCode(200);
            ctx.set("isSuccess", true);
            return null;
        } else {
            ctx.setSendZuulResponse(false); //不對其進行路由
            ctx.setResponseStatusCode(400);
            ctx.setResponseBody("parameter name is empty");
            ctx.set("isSuccess", false);
            return null;
        }
    }

}

 

5.mvn spring-boot:run起來之後，就可以看到網關服務在eureka上註冊了

curl http://localhost:40000/provider  可以看到負載均衡的效果

 

6.網關的預設路由規則

但是如果後端服務多達十幾個的時候，每一個都這樣配置也挺麻煩的，spring cloud zuul已經幫我們做了預設配置。

預設情況下，Zuul會代理所有註冊到Eureka Server的微服務，

並且Zuul的路由規則如下：http://ZUUL_HOST:ZUUL_PORT/微服務在Eureka上的serviceId/**會被轉發到serviceId對應的微服務。

 

二 .Ribbon Consumer

這裡的consummer不僅是服務消費者去後面拿取provider的內容，同時也作為一個服務提供者對外提供服務

1.引導類

@SpringBootApplication
@EnableDiscoveryClient
@EnableEurekaClient
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

}

2.beanconfig類

package com.ljq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ljqConfig {
    private static final Logger logger = LoggerFactory.getLogger(ljqConfig.class);
    ljqConfig(){
        logger.info("config init");
    }
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        logger.info("restTemplate function");
        return new RestTemplate();
    }
}

3.controller

package com.ljq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.servlet.http.HttpServletRequest;

@RestController
public class ljqController {
    private static final Logger logger = LoggerFactory.getLogger(ljqController.class);
    ljqController(){
        logger.info("controller init");
    }
    @Autowired
    private RestTemplate restTemplate;

    //這裡不寫eureka的註冊中心，而是寫服務提供者的應用名
    @GetMapping(value = "/hello")
    public String hello(HttpServletRequest request){
        logger.info("hello function");
        logger.info(request.getPathInfo());
        logger.info("--->>> consumer contorller {},{}", request.getMethod(), request.getRequestURL().toString());

        String token = request.getParameter("name");// 獲取請求的參數
        logger.info(token);

        return restTemplate.getForEntity("http://eureka-client-service-provider/", String.class).getBody();
    }
}

配置與上篇文章一致

spring.application.name=ribbon-consumer
server.port=30001
eureka.client.serviceUrl.defaultZone=http://mu01:8761/eureka,http://cu01:8762/eureka,http://cu02:8763/eureka

 

 springboot的執行順序

註解

三. provider

代碼與上篇文章基本一直

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;

@RestController
public class ljqController {
    private final Logger logger = LoggerFactory.getLogger(ljqController.class);
    @Value("${server.port}")
    String port;

    @RequestMapping("/")
    public String home(HttpServletRequest request){
        logger.info(request.getPathInfo());
        logger.info("--->>> consumer contorller {},{}", request.getMethod(), request.getRequestURL().toString());

        String token = request.getParameter("name");// 獲取請求的參數
        logger.info(token);
        return "Hello world, port is:" + port;
    }
}

 

一鍵啟動腳本

#首先開啟eureka，上篇文章中我們把eureka放在集群上，並單獨寫了一個腳本了，這裡不在贅述
#然後開啟zuul
cd /home/linjiaqin/log_stream_platform/source/scdemo/gateway;
nohup mvn spring-boot:run > /dev/null 2>&1  &
#開兩個ribbon-consumer
cd /home/linjiaqin/log_stream_platform/source/scdemo/consumer
nohup mvn spring-boot:run -Dserver.port=30001 > /dev/null 2>&1  &
nohup mvn spring-boot:run -Dserver.port=30002 > /dev/null 2>&1  &
#開啟三個provider
cd /home/linjiaqin/log_stream_platform/source/scdemo/provider
nohup mvn spring-boot:run -Dserver.port=20001 > /dev/null 2>&1  &
nohup mvn spring-boot:run -Dserver.port=20002 > /dev/null 2>&1  &
nohup mvn spring-boot:run -Dserver.port=20003 > /dev/null 2>&1  &

　　

測試結果

linjiaqin@linjiaqin-computer:~$ curl http://localhost:40000/provider/hello?name=ljq2
Hello world, port is:20003
linjiaqin@linjiaqin-computer:~$ curl http://localhost:40000/provider/hello?name=ljq3
Hello world, port is:20003
linjiaqin@linjiaqin-computer:~$ curl http://localhost:40000/provider/hello?name=ljq4
Hello world, port is:20003
linjiaqin@linjiaqin-computer:~$ curl http://localhost:40000/provider/hello?name=ljq5
Hello world, port is:20002
linjiaqin@linjiaqin-computer:~$ curl http://localhost:40000/provider/hello?name=ljq6
Hello world, port is:20002

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 小試小程式雲開發
    微信小程式剛出沒多久時，曾經上手寫過demo，但開發體驗比較差，所以一直沒怎麼關註。不過自從諸多適配方案出爐，以及雲端的開通，覺得還是有必要上手體驗一番的，於是為我的技術博客也寫了個小程式版。 原生開發我是不想再試了，那就選一種適配方案，目前比較知名的有基於vue的 mpvue ， umi app ...
  • 【原】js數組對象去重最簡單的方法
    簡單的數組去重是比較簡單的，方法也特別多，如給下麵的數組去重： 最常用的可以用for迴圈套for迴圈，再用splice刪除重覆的數組： 然而數組的子集為對象時，一般不使用多個for迴圈來去重，如下麵的數組對象： 通過觀察，我們可以發現該數組中的第1、3、4項其實是一樣的，最初在谷歌找了幾個方法最終都 ...
  • 分頁按鈕樣式
    裡層div絕對定位，因為不知道具體按鈕數量,所以整個寬度是自適應的，用絕對進行居中，外層div相對定位，控制上下距離，適用於不用頁面不同高度需求，只用一次就絕對定位硬寫。。。。 ...
  • jQuery通過ajax請求php遍歷json數組到table中的代碼
    html代碼（test.html），js在html底部 具體代碼如下所示： php代碼 （test.php） ...
  • JS截取數字
    Math是javascript的一個內部對象，該對象的方法主要是一些數學計算方法floor：下退 Math.floor(12.9999) = 12ceil：上進 Math.ceil(12.1) = 13;round: 四捨五入 Math.round(12.5) = 13 Math.round(12. ...
  • vue px 轉rem
    來自：https://www.cnblogs.com/wangqiao170/p/8652505.html 侵 刪 每一個認真生活的人，都值得被認真對待 來自：https://www.cnblogs.com/wangqiao170/p/8652505.html 侵 刪 每一個認真生活的人，都值得被認 ...
  • 設計模式 | 抽象工廠模式（abstract factory）
    定義： 定義： 提供一個創建一系列相關或相互依賴對象的介面，而無需指定他們具體的類。 結構：（書中圖，侵刪） 這個圖相對來說有一點點複雜，其實就是在工廠方法模式的基礎上做了一些擴展，工廠方法模式只用於生成一種產品（把上圖ProductB相關的都去掉就是了），而抽象工廠模式可用於生產多種產品。 加上例 ...
  • 適配器模式(Adapter Pattern)
    適配器模式簡述： 定義：將一個類的介面轉化成客戶希望的另一個介面，適配器模式讓那些介面不相容的類可以一起工作。別名(包裝器[Wrapper]模式) 它屬於創建型模式的成員，何為創建型模式：就是關註如何將現有類或對象組織在一起形成更大的結構。由於系統中存在類和對象，所以存在兩種結構型模式：類結構型模式 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類