Fizz企業級微服務API網關進階系列教程-服務編排處理列表數據(上)-展開與合併

来源:https://www.cnblogs.com/ZHONG-J/archive/2022/05/19/16287462.html
-Advertisement-
Play Games

​ 概述 服務編排是Fizz網關提供的一個強大的功能，能夠基於現有的業務微服務通過線上配置的方式快速的生成一個聚合介面，減少中間層膠水代碼以及降低編碼投入。在服務編排中支持使用函數，本進階教程中我們分三篇文章（上篇：列表展開&合併、中篇：列表提取&關聯、下篇：列表欄位重命名&欄位移除）來介紹數據列表 ...


​

概述

服務編排是Fizz網關提供的一個強大的功能，能夠基於現有的業務微服務通過線上配置的方式快速的生成一個聚合介面，減少中間層膠水代碼以及降低編碼投入。在服務編排中支持使用函數，本進階教程中我們分三篇文章（上篇：列表展開&合併、中篇：列表提取&關聯、下篇：列表欄位重命名&欄位移除）來介紹數據列表類函數的使用。

本文為服務編排處理列表數據系列的上篇。

函數

函數是服務編排提供的一個強大又便捷的功能，通過將一些常用的邏輯封裝成函數，在服務編排中使用函數對服務編排過程的數據進行處理，從而簡化我們的配置又能實現複雜的功能。

函數分類

版本要求：v2.3或以上版本

函數以fn.開頭，如fn.date.timestamp(), date為類別， 網關內置了以下幾大類函數

  • 公共類 fn.common
  • 日期類 fn.date
  • 字元串類 fn.string
  • 編解碼類 fn.codec
  • 數學類 fn.math
  • 數據列表類 fn.list

引用值

在函數里支持使用引用值，如：

fn.string.concat({step1.result.channelCode},{step1.result.nonce}）

{step1.result.channelCode} 表示引用值, 引用step1的結果

fn.string.concat({step1.result.channelCode},{g.account.name}）

{g.account.name} 表示引用值, 引用公共資源“account.name”, 以g開頭表示引用公共資源

嵌套調用

支持多重嵌套調用，如：

fn.codec.md5(fn.date.add(fn.date.add("2021-07-09 22:44:55", "yyyy-MM-dd HH:mm:ss", 1, fn.math.addExact(999,1)), "yyyy-MM-dd HH:mm:ss", fn.math.addExact(0,1), 1000))

fn.string.toUpperCase(fn.codec.sha256(fn.string.concat({step1.result.channelCode},{step1.result.nonce},{step1.result.timestamp},{step1.result.appSecret})))

數據列表類函數

函數返回值類型用途參數說明
fn.list.expand(
List<List<Object>> data)		 List<Object> 將二維數組(列表)展開為一維數組(列表)，
如：
data=[[{a:1}],[{a:2}],[{a:3}]]
fn.list.expand(data)
返回：[{a:1},{a:2},{a:3}]		 data: 二維數組（列表）
fn.list.merge(
List<Object>... data)		 List<Object> 將多個列表合併成一個，如：
data1=[{a:1}]
data2=[{a:2}]
data3=[{a:3}]
fn.list.merge(data1,data2,data3)
返回：[{a:1},{a:2},{a:3}]		 data: 列表，可多個
fn.list.extract(
List<Map<String, Object>> data,
String... fields)		 List<Map<String, Object>> 只提取列表裡的部分欄位，如：
data=[
{a:1,b:4,c:7},
{a:2,b:5,c:8},
{a:3,b:6,c:9}
]
fn.list.extract(data, "a", "c")
返回：[
{a:1,c:7},
{a:2,c:8},
{a:3,c:9}
]		 data: 列表
fields: 【可選】欄位，可多個
fn.list.join(
List<Map<String, Object>> dest,
List<Map<String, Object>> src,
String joinField,
String... fields)		 List<Map<String, Object>> 合併2個列表欄位，可只合併指定欄位，如：
dest=[
{a:1,b:4,c:7},
{a:2,b:5,c:8},
{a:3,b:6,c:9}
]
src=[
{a:1,d:444,e:777},
{a:2,d:555,e:888}
]
fn.list.join(dest,src, "a", "d")
返回：[
{a:1,b:4,c:7,d:444},
{a:2,b:5,c:8,d:555},
{a:3,b:6,c:9}
]		 dest: 目標列表
src: 被合併的列表
joinField: 兩個列表關聯的欄位
格式：
dest列表的關聯欄位:src列表的
關聯欄位，如：userName:uname,
如果兩個列表的關聯欄位一樣可
只填一個，如：userName
fields: 【可選】被合併列表裡需合併的欄位，可多個，不填則合併所有欄位
fn.list.rename(
List<Map<String, Object>> data,
String... fieldPairs)		 List<Map<String, Object>> 重命名列表裡的部分欄位，如：
data=[
{a:1,b:4,c:7},
{a:2,b:5,c:8},
{a:3,b:6,c:9}
]
fn.list.rename(data, "a:apple", "c:cat")
返回：[
{apple:1,b:4,cat:7},
{apple:2,b:5,cat:8},
{apple:3,b:6,cat:9}
]		 data: 列表
fieldPairs: 【可選】需重命名
的欄位對，可多個。格式：
原欄位名:新欄位名，如：c:cat
fn.list.removeFields(
List<Map<String, Object>> data,
String... fields)		 List<Map<String, Object>> 刪除列表裡的部分欄位，如：
data=[
{a:1,b:4,c:7},
{a:2,b:5,c:8},
{a:3,b:6,c:9}
]
fn.list.removeFields(data, "b")
返回：[
{a:1,c:7},
{a:2,c:8},
{a:3,c:9}
]		 data: 列表
fields: 【可選】需刪除的
欄位，可多個

資料準備

Fizz網關安裝

可參考： https://www.fizzgate.com/fizz/guide/installation

底層服務介面

本文服務編排調用的底層服務介面源碼可從github(https://github.com/wehotel/fizz-examples)獲取。從github克隆最新的fizz-examples源碼，並啟動fizz-examples-rest-api服務。

aggr_fn_list_demo_backend_1

aggr_fn_list_demo_backend_2

管理後臺(菜單位置：RPC管理->服務聲明)配置服務聲明，如圖所示。

aggr_fn_list_demo_backend_3

新增編排介面

管理後臺，菜單位置：服務編輯->介面列表，點擊新增。

列表展開 fn.list.expand

本例子在編排介面中調用底層fizz-examples-rest-api服務的/fn-list/user-basic-info-list-by-roles/{roleList}介面(介面源碼：FnListController )來獲取用戶基本信息列表，並對該介面的響應數據進行列表展開以滿足我們想要的數據格式。

基礎信息

aggr_fn_list_expand_1

配置輸入

在配置輸入中可以定義介面的入參和請求頭等信息，如果不配置入參或請求頭，網關會原樣接收調用方傳過來的所有入參或請求頭，但不會對接收到的參數做任何校驗。在本例子中我們不需要入參，全留空。

配置步驟

新增1個步驟step1，然後在步驟step1里新增1個請求request1，服務選擇我們預先準備好的fizz-examples-rest-api服務，請求/fn-list/user-basic-info-list-by-roles/developer,manager介面。配置響應部分留空，網關會原樣接收介面的返回結果。

aggr_fn_list_expand_2

配置輸出

在配置輸出中我們使用step1.request1.response.body.*來引用配置步驟中請求的響應結果(相關引用值的使用方式可參考文檔：數據轉換使用文檔 )。

配置要返回給前端的響應報文，這裡配置了響應體有以下欄位：

code：引用類型，值為步驟step1中請求request1的響應的code欄位;

message：引用類型，值為步驟step1中請求request1的響應的message欄位；

data：引用類型，值為步驟step1中請求request1的響應的data欄位並用fn.list.expand函數對其進行展開。

aggr_fn_list_expand_3

測試

直接調用/fn-list/user-basic-info-list-by-roles/developer,manager介面得到的響應如圖所示。

aggr_fn_list_expand_4

測試介面得到響應如圖所示。

aggr_fn_list_expand_5

從測試介面的響應可以看出服務編排介面已完成了對/fn-list/user-basic-info-list-by-roles/developer,manager介面的請求並正確對響應的data欄位的列表進行了展開。

列表合併 fn.list.merge

本例子在編排介面中兩次調用底層fizz-examples-rest-api服務的/fn-list/user-basic-info-list-by-roles/{roleList}介面(介面源碼：FnListController )來獲取用戶基本信息列表，並對該介面的兩次調用響應數據進行列表合併以滿足我們想要的數據格式。

基礎信息

aggr_fn_list_merge_1

配置輸入

在本例子中我們不需要入參，全留空。

配置步驟

新增1個步驟step1，在步驟step1里新增1個請求request1，服務選擇fizz-examples-rest-api，請求/fn-list/user-basic-info-list-by-role/admin介面。在步驟step1里新增1個請求request2，服務選擇fizz-examples-rest-api，請求/fn-list/user-basic-info-list-by-role/manager介面。

aggr_fn_list_merge_2

aggr_fn_list_merge_3

配置輸出

配置要返回給前端的響應報文，這裡配置了響應體有以下欄位：

code：引用類型，值為步驟step1中請求request1的響應的code欄位;

message：引用類型，值為步驟step1中請求request1的響應的message欄位；

data：引用類型，值為步驟step1中請求request1的響應的data欄位與step1中請求request2的響應的data欄位並用fn.list.merge函數對其進行合併。

aggr_fn_list_merge_4

測試

直接調用/fn-list/user-basic-info-list-by-role/admin介面得到的響應如圖所示。

aggr_fn_list_merge_5

直接調用/fn-list/user-basic-info-list-by-role/manager介面得到的響應如圖所示。

aggr_fn_list_merge_6

測試介面得到響應如圖所示。

aggr_fn_list_merge_7

從測試介面的響應可以看出服務編排介面已完成了對/fn-list/user-basic-info-list-by-role/admin介面的請求和對/fn-list/user-basic-info-list-by-role/manager介面的請求並正確對兩次調用的響應的data欄位的列表進行了合併。

Fizz網關介紹

Fizz Gateway 是一個基於 Java開發的微服務聚合網關，能夠實現熱服務編排聚合、自動授權選擇、線上服務腳本編碼、線上測試、高性能路由、API審核管理、回調管理等目的，擁有強大的自定義插件系統可以自行擴展，並且提供友好的圖形化配置界面，能夠快速幫助企業進行API服務治理、減少中間層膠水代碼以及降低編碼投入、提高 API 服務的穩定性和安全性。

官網：https://www.fizzgate.com

GitHub: https://github.com/wehotel/fizz-gateway-community

碼雲：https://gitee.com/fizzgate/fizz-gateway

入門教程：https://www.fizzgate.com/fizz/guide/GettingStarted/

進階教程：https://www.fizzgate.com/fizz/guide/advanced/

作者：ZHONG.J

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

-Advertisement-
Play Games
更多相關文章
  • java面試——反射與泛型
    一、反射 《java核心技術》 官方套話：能夠分析類能力的程式成為反射。 又通過網上搜索有這句話：反射指程式可以訪問、檢測和修改它本身狀態或行為的一種能力。 反射是用來乾什麼的呢？ “明明我自己能直接new一個對象，為什麼它要繞一個圈子，先拿到Class對象，再調用Class對象的方法來創建對象呢， ...
  • 包機制
    #包機制 包就是裝代碼的文件夾。 為了更好地組織類，JAVA提供了包機制，用於區別類名的組織空間。 ##package 包語句的句法格式為： 一般利用公司功能變數名稱倒置作為包名。 ##import 為了使用某個包的成員，需要在JAVA程式中明確導入該包。使用import語句可以完成此功能。 import必 ...
  • Maglev : A Fast and Reliable Software Network Load Balancer (using Consistent Hashing)
    轉自：https://www.evanlin.com/maglev/ 2016 年 6 月 2 日 前言（為什麼想讀這一篇論文） 這一篇論文吸引我註意的原因是，Consistent Hashing本來的特性就是作為分散式緩存之用。谷歌將他們的負載均衡器（代號：Maglev）發佈他的實作方式，裡面將一 ...
  • 【工具-Nginx】從入門安裝到高可用集群搭建
    文章已收錄至https://lichong.work，轉載請註明原文鏈接。 ps：歡迎關註公眾號“Fun肆編程”或添加我的私人微信交流經驗🤝 一.Nginx安裝配置及常用命令 1.環境搭建 首先在linux系統下安裝gcc編譯環境，執行： yum install gcc-c++ -y 確保當前系統 ...
  • 八、C++STL 6大組件-你必知必會的編程利器
    來源：blog.csdn.net/qq_15371293/article/details/117090780 項目場景： ClickHouse 操作基於 Mybatis-puls源碼擴展開發。解決ClickHouse的修改和刪除 SQL操作與Mysql不相同。 基於 Mybatis-puls： up ...
  • JavaMetaweblogClient,Metaweblog的java實現-從此上傳博客實現全平臺
    個人學習筆記總結。Basic Types、Strings、Arrays, Slices, and Maps、Control Statements、Declarations & Types、Formatted & File I/O、 Functions, Parameters、Defer、Closur... ...
  • 微服務入門之Ribbon+OpenFeign
    #一、概述 ##1.1、Ribbon Spring Cloud Ribbon是基於Netflix Ribbon實現的一套客戶端負載均衡的工具。簡單的說，Ribbon是Netflix發佈的開源項目，主要功能是提供客戶端的軟體負載均衡演算法和服務調用。Spring Cloud Ribbon雖然只是一個工具 ...
  • 解決 maven 項目無法編譯的問題
    ##基本介紹 ###1.變數 定義：可以變化的量 ###2.變數聲明 Java是一種強制類型語言，每一個變數必須聲明類型 ###3.變數名，變數類型和作用域 Java變數是程式中最基本的存儲單元，其要素包括變數名，變數類型和作用域 type varName [=value] [{,varName[= ...
一周排行
    -Advertisement-
    Play Games
  • .net 6 C#中System.IO.Path類的用法
    1. 說明 /* Performs operations on System.String instances that contain file or directory path information. These operations are performed in a cross-pla ...
  • 使用WebApi+Vue3從0到1搭建《許可權管理系統》:二、搭建JWT系統鑒權
    視頻地址：【WebApi+Vue3從0到1搭建《許可權管理系統》系列視頻：搭建JWT系統鑒權-嗶哩嗶哩】 https://b23.tv/R6cOcDO qq群:801913255 一、在appsettings.json中設置鑒權屬性 /*jwt鑒權*/ "JwtSetting": { "Issuer" ...
  • 實戰指南：使用 xUnit 和 ASP.NET Core 進行集成測試【完整教程】
    引言 集成測試可在包含應用支持基礎結構（如資料庫、文件系統和網路）的級別上確保應用組件功能正常。 ASP.NET Core 通過將單元測試框架與測試 Web 主機和記憶體中測試伺服器結合使用來支持集成測試。 簡介 集成測試與單元測試相比，能夠在更廣泛的級別上評估應用的組件，確認多個組件一起工作以生成預 ...
  • .NET Emit 入門教程：第六部分：IL 指令：9：詳解 ILGenerator 指令方法：運算操作指令（指令篇結束）
    在.NET Emit編程中，我們探討了運算操作指令的重要性和應用。這些指令包括各種數學運算、位操作和比較操作，能夠在動態生成的代碼中實現對數據的處理和操作。通過這些指令，開發人員可以靈活地進行算術運算、邏輯運算和比較操作，從而實現各種複雜的演算法和邏輯......本篇之後，將進入第七部分：實戰項目 ...
  • WPF多表頭表格實現
    前言 多表頭表格是一個常見的業務需求，然而WPF中卻沒有預設實現這個功能，得益於WPF強大的控制項模板設計，我們可以通過修改控制項模板的方式自己實現它。 一、需求分析 下圖為一個典型的統計表格，統計1-12月的數據。 此時我們有一個需求，需要將月份按季度劃分，以便能夠直觀地看到季度統計數據，以下為該需求 ...
  • gRPC入門學習之旅（七）
    如何將 ASP.NET Core MVC 項目的視圖分離到另一個項目 在當下這個年代 SPA 已是主流，人們早已忘記了 MVC 以及 Razor 的故事。但是在某些場景下 SSR 還是有意想不到效果。比如某些靜態頁面，比如追求首屏載入速度的時候。最近在項目中回歸傳統效果還是不錯。 有的時候我們希望將 ...
  • System.AggregateException: 發生一個或多個錯誤.....
    System.AggregateException: 發生一個或多個錯誤。 > Microsoft.WebTools.Shared.Exceptions.WebToolsException: 生成失敗。檢查輸出視窗瞭解更多詳細信息。 內部異常堆棧跟蹤的結尾 > (內部異常 #0) Microsoft ...
  • 精通中間件測試：Asp.Net Core實戰指南，提升應用穩定性和可靠性
    引言 在上一章節我們實戰了在Asp.Net Core中的項目實戰，這一章節講解一下如何測試Asp.Net Core的中間件。 TestServer 還記得我們在集成測試中提供的TestServer嗎？ TestServer 是由 Microsoft.AspNetCore.TestHost 包提供的。 ...
  • Case表達式
    在發現結果為真的WHEN子句時,CASE表達式的真假值判斷會終止,剩餘的WHEN子句會被忽略: CASE WHEN col_1 IN ('a', 'b') THEN '第一' WHEN col_1 IN ('a') THEN '第二' ELSE '其他' END 註意: 統一各分支返回的數據類型. ...
  • 揭秘：C#語法中“_ =” 是什麼？
    在C#編程世界中，語法的精妙之處往往體現在那些看似微小卻極具影響力的符號與結構之中。其中，“_ =” 這一組合突然出現還真不知道什麼意思。本文將深入剖析“_ =” 的含義、工作原理及其在實際編程中的廣泛應用，揭示其作為C#語法奇兵的重要角色。 一、下劃線 _：神秘的棄元符號 下劃線 _ 在C#中並非 ...
所有分類