[fix] fix data buffer leak (#5988)

Aias00 · 847850277 · web-flow · commit 9529642022c0 · 2025-05-26T14:59:53.000+08:00
* [fix] fix data buffer leak

* [fix] fix data buffer leak

---------

Co-authored-by: zhengpeng &lt;847850277@qq.com&gt;
diff --git a/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java b/shenyu-plugin/shenyu-plugin-base/src/main/java/org/apache/shenyu/plugin/base/support/ResponseDecorator.java
@@ -52,9 +52,10 @@ public Mono<Void> writeWith(@NonNull final Publisher<? extends DataBuffer> body)
         return dataBufferMono.flatMap(dataBuffer -> {
             byte[] bytes = new byte[dataBuffer.readableByteCount()];
             dataBuffer.read(bytes);
+            DataBufferUtils.release(dataBuffer);
             String bodyString = new String(bytes, StandardCharsets.UTF_8);
             final String convertStr = convert.apply(bodyString);
-            return WebFluxResultUtils.result(this.exchange, convertStr);
+            return WebFluxResultUtils.result(this.exchange, convertStr).doFinally(signalType -> DataBufferUtils.release(dataBuffer));
         });
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -52,9 +52,10 @@ public Mono<Void> writeWith(@NonNull final Publisher<? extends DataBuffer> body)`
`52`	`52`	`return dataBufferMono.flatMap(dataBuffer -> {`
`53`	`53`	`byte[] bytes = new byte[dataBuffer.readableByteCount()];`
`54`	`54`	`dataBuffer.read(bytes);`
	`55`	`+ DataBufferUtils.release(dataBuffer);`
`55`	`56`	`String bodyString = new String(bytes, StandardCharsets.UTF_8);`
`56`	`57`	`final String convertStr = convert.apply(bodyString);`
`57`		`- return WebFluxResultUtils.result(this.exchange, convertStr);`
	`58`	`+ return WebFluxResultUtils.result(this.exchange, convertStr).doFinally(signalType -> DataBufferUtils.release(dataBuffer));`
`58`	`59`	`});`
`59`	`60`	`}`
`60`	`61`	`}`