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 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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類