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核心技術》 官方套話:能夠分析類能力的程式成為反射。 又通過網上搜索有這句話:反射指程式可以訪問、檢測和修改它本身狀態或行為的一種能力。 反射是用來乾什麼的呢? “明明我自己能直接new一個對象,為什麼它要繞一個圈子,先拿到Class對象,再調用Class對象的方法來創建對象呢, ...
  • #包機制 包就是裝代碼的文件夾。 為了更好地組織類,JAVA提供了包機制,用於區別類名的組織空間。 ##package 包語句的句法格式為: 一般利用公司功能變數名稱倒置作為包名。 ##import 為了使用某個包的成員,需要在JAVA程式中明確導入該包。使用import語句可以完成此功能。 import必 ...
  • 轉自:https://www.evanlin.com/maglev/ 2016 年 6 月 2 日 前言(為什麼想讀這一篇論文) 這一篇論文吸引我註意的原因是,Consistent Hashing本來的特性就是作為分散式緩存之用。谷歌將他們的負載均衡器(代號:Maglev)發佈他的實作方式,裡面將一 ...
  • 文章已收錄至https://lichong.work,轉載請註明原文鏈接。 ps:歡迎關註公眾號“Fun肆編程”或添加我的私人微信交流經驗🤝 一.Nginx安裝配置及常用命令 1.環境搭建 首先在linux系統下安裝gcc編譯環境,執行: yum install gcc-c++ -y 確保當前系統 ...
  • 來源:blog.csdn.net/qq_15371293/article/details/117090780 項目場景: ClickHouse 操作基於 Mybatis-puls源碼擴展開發。解決ClickHouse的修改和刪除 SQL操作與Mysql不相同。 基於 Mybatis-puls: up ...
  • 個人學習筆記總結。Basic Types、Strings、Arrays, Slices, and Maps、Control Statements、Declarations & Types、Formatted & File I/O、 Functions, Parameters、Defer、Closur... ...
  • #一、概述 ##1.1、Ribbon Spring Cloud Ribbon是基於Netflix Ribbon實現的一套客戶端負載均衡的工具。簡單的說,Ribbon是Netflix發佈的開源項目,主要功能是提供客戶端的軟體負載均衡演算法和服務調用。Spring Cloud Ribbon雖然只是一個工具 ...
  • ##基本介紹 ###1.變數 定義:可以變化的量 ###2.變數聲明 Java是一種強制類型語言,每一個變數必須聲明類型 ###3.變數名,變數類型和作用域 Java變數是程式中最基本的存儲單元,其要素包括變數名,變數類型和作用域 type varName [=value] [{,varName[= ...
一周排行
    -Advertisement-
    Play Games
  • 一:背景 準備開個系列來聊一下 PerfView 這款工具,熟悉我的朋友都知道我喜歡用 WinDbg,這東西雖然很牛,但也不是萬能的,也有一些場景他解決不了或者很難解決,這時候藉助一些其他的工具來輔助,是一個很不錯的主意。 很多朋友喜歡在項目中以記錄日誌的方式來監控項目的流轉情況,其實 CoreCL ...
  • 本來閑來無事,準備看看Dapper擴展的源碼學習學習其中的編程思想,同時整理一下自己代碼的單元測試,為以後的進一步改進打下基礎。 突然就發現問題了,源碼也不看了,開始改代碼,改了好久。 測試Dapper.LiteSql數據批量插入的時候,耗時20秒,感覺不正常,於是我測試了非Dapper版的Lite ...
  • 需求如下,在DEV框架項目中,需要在表格中增加一列顯示圖片,並且能編輯該列圖片,然後進行保存等操作,最終效果如下 這裡使用的是PictureEdit控制項來實現,打開DEV GridControl設計器,在ColumnEdit選擇PictureEdit: 綁定圖片代碼如下: DataTable dtO ...
  • 前兩天微軟偷偷更新了Visual Studio 2022 正式版版本 17.3 發佈,發佈摘要: MAUI 工作負荷 GA 生成 MAUI/Blazor CSS 熱重載支持 現在,你將能夠使用我們的新增功能在 Visual Studio 中使用每個更新試用一系列新功能。 選擇每個功能以瞭解有關特定功 ...
  • 航天和軍工領域的數字化轉型和建設正在積極推進,在與航天二院、航天三院、航天六院、航天九院、無線電廠、兵工廠等單位交流的過程中,用戶更聚焦試驗和生產過程中的痛點,迫切需要解決軟體平臺統一監測和控制設備及軟體與設備協同的問題。 ...
  • .NET 項目預設情況下 日誌是使用的 ILogger 介面,預設提供一下四種日誌記錄程式: 控制台 調試 EventSource EventLog 這四種記錄程式都是預設包含在 .NET 運行時庫中。關於這四種記錄程式的詳細介紹可以直接查看微軟的官方文檔 https://docs.microsof ...
  • 一:背景 上一篇我們聊到瞭如何去找 熱點函數,這一篇我們來看下當你的程式出現了 非托管記憶體泄漏 時如何去尋找可疑的代碼源頭,其實思路很簡單,就是在 HeapAlloc 或者 VirtualAlloc 時做 Hook 攔截,記錄它的調用棧以及分配的記憶體量, PerfView 會將這個 分配量 做成一個 ...
  • 背景 在 CI/CD 流程當中,測試是 CI 中很重要的部分。跟開發人員關係最大的就是單元測試,單元測試編寫完成之後,我們可以使用 IDE 或者 dot cover 等工具獲得單元測試對於業務代碼的覆蓋率。不過我們需要一個獨立的 CLI 工具,這樣我們才能夠在 Jenkins 的 CI 流程集成。 ...
  • 一、應用場景 大家在使用Mybatis進行開發的時候,經常會遇到一種情況:按照月份month將數據放在不同的表裡面,查詢數據的時候需要跟不同的月份month去查詢不同的表。 但是我們都知道,Mybatis是ORM持久層框架,即:實體關係映射,實體Object與資料庫表之間是存在一一對應的映射關係。比 ...
  • 我國目前並未出台專門針對網路爬蟲技術的法律規範,但在司法實踐中,相關判決已屢見不鮮,K 哥特設了“K哥爬蟲普法”專欄,本欄目通過對真實案例的分析,旨在提高廣大爬蟲工程師的法律意識,知曉如何合法合規利用爬蟲技術,警鐘長鳴,做一個守法、護法、有原則的技術人員。 案情介紹 深圳市快鴿互聯網科技有限公司 2 ...