修改經過Spring Gateway的表單中的Json數據

来源:https://www.cnblogs.com/hqdong123/archive/2023/09/16/17707284.html
-Advertisement-
Play Games

背景 使用Spring Cloud Gateway作為網關時有時候一個請求是既包含excel又包含json的表單數據,出於各種層面考慮網關需要獲取並更新其中的json數據 依賴 Spring Boot版本:2.7.15 Hutool: 5.8.21 Java: 11 實現邏輯 實現分為2個部分 使用 ...


背景

使用Spring Cloud Gateway作為網關時有時候一個請求是既包含excel又包含json的表單數據,出於各種層面考慮網關需要獲取並更新其中的json數據

依賴

  • Spring Boot版本:2.7.15
  • Hutool: 5.8.21
  • Java: 11

實現邏輯

實現分為2個部分

  1. 使用上文提到的ModifyRequestBodyGatewayFilterFactory類來修改請求體,這樣最後就不用我們手動包裝
  2. 核心service通過將表單轉為String,然後根據其中的boundary進行分割,提取修改json報文部分後再進行組裝

註意:示例代碼的核心service處理的表單內容只是2個,Json數據的key指定為json,另一個excel文件流

自定義filter

@Component
@Slf4j
public class RequestModifyFilter implements GlobalFilter, Ordered {
    @Autowired
    private ModifyRequestBodyGatewayFilterFactory modifyRequestBodyFilter;
    @Autowired
    private JsonRequestBodyRewriteService jsonRequestBodyRewriteService;
    @Autowired
    private FormDataRequestBodyRewriteService formDataRequestBodyRewriteService;

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        MediaType mediaType = exchange.getRequest().getHeaders().getContentType();
        if (MediaType.APPLICATION_JSON.isCompatibleWith(mediaType)) {
            // 純json報文處理邏輯
            return modifyRequestBodyFilter
                    .apply(
                            new ModifyRequestBodyGatewayFilterFactory.Config()
                                    .setRewriteFunction(byte[].class, byte[].class, jsonRequestBodyRewriteService))
                    .filter(exchange, chain);
        } else if (MediaType.MULTIPART_FORM_DATA.isCompatibleWith(mediaType)) {
            // form表單數據處理
            return modifyRequestBodyFilter
                    .apply(
                            new ModifyRequestBodyGatewayFilterFactory.Config()
                                    .setRewriteFunction(byte[].class, byte[].class, formDataRequestBodyRewriteService))
                    .filter(exchange, chain);
        } else {
            return filter(exchange, chain);
        }

    }

    @Override
    public int getOrder() {
        return OrderConstant.REQUEST_MODIFY_FILTER.getOrder();
    }
}

核心service

@Service
@Slf4j
public class FormDataRequestBodyRewriteService implements RewriteFunction<byte[], byte[]> {
    private final String BOUNDARY_PREFIX_IN_CONTENT_TYPE = "----WebKitFormBoundary";
    private final String BOUNDARY_PREFIX_IN_FORM_DATA = "------WebKitFormBoundary";
    private final String BOUNDARY_SUFFIX = "--\r\n";

    @Override
    public Publisher<byte[]> apply(ServerWebExchange exchange, byte[] body) {
        String finalResultString = "";

        // 將表單轉為字元串格式從而根據boundary分割表單數據。註意這裡不能用預設編碼
        String request = StrUtil.str(body, StandardCharsets.ISO_8859_1);

        // 獲取boundary的隨機字元信息
        String contentType = exchange.getRequest().getHeaders().getContentType().toString();
        String randomStr = contentType.substring(contentType.indexOf(BOUNDARY_PREFIX_IN_CONTENT_TYPE) + BOUNDARY_PREFIX_IN_CONTENT_TYPE.length());

        // 這裡和前端約定json數據的表單key為json
        String keyPart = "^\r\nContent-Disposition: form-data; name=\"json\"";
        Pattern r = Pattern.compile(keyPart);

        // 根據表單內分割線進行分割。並通過關鍵段落keyPart來找到目標json數據
        String[] split = request.split(BOUNDARY_PREFIX_IN_FORM_DATA + randomStr);
        for (int x = 0; x < split.length - 1; x++) {
            Matcher m = r.matcher(split[x]);
            if (m.find()) {
                // 找到了json報文部分數據
                String originalJsonString = split[x];

                // 找到 JSON 數據的起始和結束位置
                int startIndex = originalJsonString.indexOf("{\"");
                int endIndex = originalJsonString.indexOf("\"}") + 2;
                // 提取 JSON 數據
                String jsonData = originalJsonString.substring(startIndex, endIndex);
                log.info("原始報文為:{}", jsonData);

                JSONObject jsonObject = JSONUtil.parseObj(jsonData);
                jsonObject.set("empId", "2345");
                jsonObject.set("department", "Engineering");
                String modifiedString = originalJsonString.substring(0, startIndex) + jsonObject + originalJsonString.substring(endIndex);
                log.info("修改後報文為:{}", modifiedString);

                // 重新組裝split數組
                finalResultString = finalResultString + modifiedString + BOUNDARY_PREFIX_IN_FORM_DATA + randomStr;
            } else {
                // 重組表單數據
                finalResultString = finalResultString + split[x] + BOUNDARY_PREFIX_IN_FORM_DATA + randomStr;
            }
        }

        // 補上最後一截數據
        finalResultString = finalResultString + BOUNDARY_SUFFIX;

        return Mono.just(finalResultString.getBytes(StandardCharsets.ISO_8859_1));
    }
}

相關代碼

https://github.com/eastcukt/demo-gatway

其他

核心service獲取表單中的json數據邏輯挺複雜,根本原因是沒有合適的方法進行對象轉換,如果有像使用@RequestPart(value = "json")註解一樣方便的方法將會非常方便也不用自己截取,各位大佬有更方便的方法感謝分享一下

參考

https://blog.csdn.net/qq_36966137/article/details/128536391


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

-Advertisement-
Play Games
更多相關文章
  • 數據類型的介紹: 數據類型(data_type)是指系統中所允許的數據的類型。資料庫中的每個列都應有適當的數據類型,用於限制或允許該列中存儲的數據。例如,列中存儲的為數字,則相應的數據類型應該為數值類型。 如果使用錯誤的數據類型可能會嚴重影響應用程式的功能和性能,所以在設計表時,應該特別重視數據列所 ...
  • 上文說到,資料庫的安裝和連接,接下來將給大家講解MySQL資料庫的基本語法及數據的類型 1.基本語法 (1).查看當前所有資料庫 : show databases; (2).創建資料庫 create database 資料庫名; 例如: create database gzy; (3).如果不確定數 ...
  • 1.MySQL是什麼? MySQL是一個關係型資料庫管理系統,由瑞典MySQL AB 公司開發,屬於 Oracle 旗下產品。它是最流行的關係型資料庫管理系統之一,在 WEB 應用方面,MySQL是最好的 RDBMS (Relational Database Management System,關係 ...
  • 以下是一些 Pinia 的其他高階功能: storeToRefs():響應式解構倉庫,保證解構出來的數據是響應式的數據。 狀態持久化:Pinia 並沒有內置的狀態持久化功能,但你可以使用第三方庫或自定義插件來實現狀態的持久化。例如,你可以使用 localStorage 或 sessionStorag ...
  • 這裡給大家分享我在網上總結出來的一些知識,希望對大家有所幫助 今天,我們要實現一個很常見並且簡單的功能:將手機號中間的幾位數變成**** 這個功能其實很常見,比如我們微信的賬號安全裡面顯示的手機號、掘金的賬號設置裡面顯示的手機號、支付寶裡面的證件號碼、各大銀行的App卡號.....還有很多有關係到我 ...
  • Discuz論壇管理中心預設有窄屏和寬屏的選擇,窄屏預設是960px寬度,很多論壇為了頁面美觀,基本都是1200px的寬度,如何修改DZ論壇首頁窄屏寬度大小的呢?今天飛飛和你們分享。 ...
  • 《Programming Abstractions In C》學習第57天,開始第4章“Introduction to Recursion”的學習,p161-p165,總結如下。 一、技術總結 1.recursion vs stepwise refinement 答:p164, The strate ...
  • Python語法可以直接在命令行中編寫並執行: >>> print("Hello, World!") Hello, World! 或者,可以在伺服器上創建一個帶有.py文件擴展名的Python文件,併在命令行中運行它: C:\Users\Your Name>python myfile.py Pyth ...
一周排行
    -Advertisement-
    Play Games
  • 下麵是一個標準的IDistributedCache用例: public class SomeService(IDistributedCache cache) { public async Task<SomeInformation> GetSomeInformationAsync (string na ...
  • 這個庫提供了在啟動期間實例化已註冊的單例,而不是在首次使用它時實例化。 單例通常在首次使用時創建,這可能會導致響應傳入請求的延遲高於平時。在註冊時創建實例有助於防止第一次Request請求的SLA 以往我們要在註冊的時候實例單例可能會這樣寫: //註冊: services.AddSingleton< ...
  • 最近公司的很多項目都要改單點登錄了,不過大部分都還沒敲定,目前立刻要做的就只有一個比較老的項目 先改一個試試手,主要目標就是最短最快實現功能 首先因為要保留原登錄方式,所以頁面上的改動就是在原來登錄頁面下加一個SSO登錄入口 用超鏈接寫的入口,頁面改造後如下圖: 其中超鏈接的 href="Staff ...
  • Like運算符很好用,特別是它所提供的其中*、?這兩種通配符,在Windows文件系統和各類項目中運用非常廣泛。 但Like運算符僅在VB中支持,在C#中,如何實現呢? 以下是關於LikeString的四種實現方式,其中第四種為Regex正則表達式實現,且在.NET Standard 2.0及以上平... ...
  • 一:背景 1. 講故事 前些天有位朋友找到我,說他們的程式記憶體會偶發性暴漲,自己分析了下是非托管記憶體問題,讓我幫忙看下怎麼回事?哈哈,看到這個dump我還是非常有興趣的,居然還有這種游戲幣自助機類型的程式,下次去大玩家看看他們出幣的機器後端是不是C#寫的?由於dump是linux上的程式,剛好win ...
  • 前言 大家好,我是老馬。很高興遇到你。 我們為 java 開發者實現了 java 版本的 nginx https://github.com/houbb/nginx4j 如果你想知道 servlet 如何處理的,可以參考我的另一個項目: 手寫從零實現簡易版 tomcat minicat 手寫 ngin ...
  • 上一次的介紹,主要圍繞如何統一去捕獲異常,以及為每一種異常添加自己的Mapper實現,並且我們知道,當在ExceptionMapper中返回非200的Response,不支持application/json的響應類型,而是寫死的text/plain類型。 Filter為二方包異常手動捕獲 參考:ht ...
  • 大家好,我是R哥。 今天分享一個爽飛了的面試輔導 case: 這個杭州兄弟空窗期 1 個月+,面試了 6 家公司 0 Offer,不知道問題出在哪,難道是杭州的 IT 崩盤了麽? 報名面試輔導後,經過一個多月的輔導打磨,現在成功入職某上市公司,漲薪 30%+,955 工作制,不咋加班,還不捲。 其他 ...
  • 引入依賴 <!--Freemarker wls--> <dependency> <groupId>org.freemarker</groupId> <artifactId>freemarker</artifactId> <version>2.3.30</version> </dependency> ...
  • 你應如何運行程式 互動式命令模式 開始一個互動式會話 一般是在操作系統命令行下輸入python,且不帶任何參數 系統路徑 如果沒有設置系統的PATH環境變數來包括Python的安裝路徑,可能需要機器上Python可執行文件的完整路徑來代替python 運行的位置:代碼位置 不要輸入的內容:提示符和註 ...