This is an automated email from the ASF dual-hosted git repository.
Aias00 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 75a23bbd31 fix(netty): support configurable httpRequestDecoder
properties (#6378)
75a23bbd31 is described below
commit 75a23bbd31c2af02102cdd9d85f685244c22dad5
Author: hqbhonker <[email protected]>
AuthorDate: Thu Jun 11 10:46:30 2026 +0800
fix(netty): support configurable httpRequestDecoder properties (#6378)
Add HTTP request decoder configuration support including:
- maxInitialLineLength (default 4096)
- maxHeaderSize (default 8192)
- maxChunkSize (default 8192)
Users can now configure these properties via application.yml:
shenyu.netty.http.httpDecoder.maxInitialLineLength=8192
This resolves the issue where HTTP requests with URLs exceeding
4096 bytes are rejected by the gateway.
Closes #5856
Co-authored-by: ColinMark <[email protected]>
Co-authored-by: aias00 <[email protected]>
---
.../src/main/resources/application.yml | 4 +
.../shenyu/common/config/NettyHttpProperties.java | 98 ++++++++++++++++++++++
.../netty/ShenyuNettyWebServerConfiguration.java | 10 +++
.../ShenyuNettyWebServerConfigurationTest.java | 35 ++++++++
4 files changed, 147 insertions(+)
diff --git a/shenyu-bootstrap/src/main/resources/application.yml
b/shenyu-bootstrap/src/main/resources/application.yml
index 397f7c8f55..9272726f69 100644
--- a/shenyu-bootstrap/src/main/resources/application.yml
+++ b/shenyu-bootstrap/src/main/resources/application.yml
@@ -139,6 +139,10 @@ shenyu:
# - domain: 'example.com'
# keyCertChainFile:
'/Users/zhukunshuai/Desktop/cert/example.com+1.pem'
# keyFile: '/Users/zhukunshuai/Desktop/cert/example.com+1-key.pem'
+ httpDecoder:
+ maxInitialLineLength: 4096
+ maxHeaderSize: 8192
+ maxChunkSize: 8192
# httpclient:
# strategy: netty # webClient
# connectTimeout: 45000
diff --git
a/shenyu-common/src/main/java/org/apache/shenyu/common/config/NettyHttpProperties.java
b/shenyu-common/src/main/java/org/apache/shenyu/common/config/NettyHttpProperties.java
index 82c89495fa..6e029374dd 100644
---
a/shenyu-common/src/main/java/org/apache/shenyu/common/config/NettyHttpProperties.java
+++
b/shenyu-common/src/main/java/org/apache/shenyu/common/config/NettyHttpProperties.java
@@ -40,6 +40,8 @@ public class NettyHttpProperties {
private SniProperties sni = new SniProperties();
+ private HttpDecoderProperties httpDecoder = new HttpDecoderProperties();
+
/**
* get webServerFactoryEnabled.
*
@@ -167,6 +169,24 @@ public class NettyHttpProperties {
this.accessLog = accessLog;
}
+ /**
+ * get httpDecoder properties.
+ *
+ * @return httpDecoder properties
+ */
+ public HttpDecoderProperties getHttpDecoder() {
+ return httpDecoder;
+ }
+
+ /**
+ * set httpDecoder properties.
+ *
+ * @param httpDecoder http decoder properties
+ */
+ public void setHttpDecoder(final HttpDecoderProperties httpDecoder) {
+ this.httpDecoder = httpDecoder;
+ }
+
public static class ServerSocketChannelProperties extends
NettyChannelProperties {
private Integer soBacklog = 128;
@@ -292,6 +312,84 @@ public class NettyHttpProperties {
}
}
+ /**
+ * Properties for HTTP request decoder configuration.
+ */
+ public static class HttpDecoderProperties {
+
+ /**
+ * The maximum length of the initial line (e.g. "GET / HTTP/1.1").
+ * Default is 4096.
+ */
+ private int maxInitialLineLength = 4096;
+
+ /**
+ * The maximum size of all headers.
+ * Default is 8192.
+ */
+ private int maxHeaderSize = 8192;
+
+ /**
+ * The maximum size of the content of each chunk.
+ * Default is 8192.
+ */
+ private int maxChunkSize = 8192;
+
+ /**
+ * get maxInitialLineLength.
+ *
+ * @return maxInitialLineLength
+ */
+ public int getMaxInitialLineLength() {
+ return maxInitialLineLength;
+ }
+
+ /**
+ * set maxInitialLineLength.
+ *
+ * @param maxInitialLineLength max initial line length
+ */
+ public void setMaxInitialLineLength(final int maxInitialLineLength) {
+ this.maxInitialLineLength = maxInitialLineLength;
+ }
+
+ /**
+ * get maxHeaderSize.
+ *
+ * @return maxHeaderSize
+ */
+ public int getMaxHeaderSize() {
+ return maxHeaderSize;
+ }
+
+ /**
+ * set maxHeaderSize.
+ *
+ * @param maxHeaderSize max header size
+ */
+ public void setMaxHeaderSize(final int maxHeaderSize) {
+ this.maxHeaderSize = maxHeaderSize;
+ }
+
+ /**
+ * get maxChunkSize.
+ *
+ * @return maxChunkSize
+ */
+ public int getMaxChunkSize() {
+ return maxChunkSize;
+ }
+
+ /**
+ * set maxChunkSize.
+ *
+ * @param maxChunkSize max chunk size
+ */
+ public void setMaxChunkSize(final int maxChunkSize) {
+ this.maxChunkSize = maxChunkSize;
+ }
+ }
+
public static class SniProperties {
private Boolean enabled = false;
diff --git
a/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/main/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfiguration.java
b/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/main/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfiguration.java
index 775ddb40c1..f8063b4a98 100644
---
a/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/main/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfiguration.java
+++
b/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/main/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfiguration.java
@@ -156,6 +156,16 @@ public class ShenyuNettyWebServerConfiguration {
return sniProcessor.apply(httpServer)
.runOn(LoopResources.create("shenyu-netty",
nettyHttpProperties.getSelectCount(), nettyHttpProperties.getWorkerCount(),
true))
.accessLog(nettyHttpProperties.getAccessLog())
+ // configure http request decoder
+ .httpRequestDecoder(spec -> {
+ NettyHttpProperties.HttpDecoderProperties decoder =
nettyHttpProperties.getHttpDecoder();
+ if (Objects.nonNull(decoder)) {
+
spec.maxInitialLineLength(decoder.getMaxInitialLineLength());
+ spec.maxHeaderSize(decoder.getMaxHeaderSize());
+ spec.maxChunkSize(decoder.getMaxChunkSize());
+ }
+ return spec;
+ })
// server socket channel parameters
.option(ChannelOption.SO_BACKLOG,
nettyHttpProperties.getServerSocketChannel().getSoBacklog())
.option(ChannelOption.SO_REUSEADDR,
nettyHttpProperties.getServerSocketChannel().isSoReuseAddr())
diff --git
a/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/test/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfigurationTest.java
b/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/test/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfigurationTest.java
index 39fd875748..dffde11104 100644
---
a/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/test/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfigurationTest.java
+++
b/shenyu-spring-boot-starter/shenyu-spring-boot-starter-gateway/src/test/java/org/apache/shenyu/springboot/starter/netty/ShenyuNettyWebServerConfigurationTest.java
@@ -97,4 +97,39 @@ public class ShenyuNettyWebServerConfigurationTest {
assertThat(properties.getSocketChannel().getSingleEventExecutorPerGroup(),
is(false));
});
}
+
+ @Test
+ public void testHttpDecoderProperties() {
+ applicationContextRunner
+ .withPropertyValues(
+ "shenyu.netty.http.web-server-factory-enabled=false",
+ "shenyu.netty.http.httpDecoder.maxInitialLineLength=8192",
+ "shenyu.netty.http.httpDecoder.maxHeaderSize=16384",
+ "shenyu.netty.http.httpDecoder.maxChunkSize=16384"
+ )
+ .run(context -> {
+ NettyHttpProperties properties =
context.getBean("nettyTcpProperties", NettyHttpProperties.class);
+ assertNotNull(properties);
+ assertNotNull(properties.getHttpDecoder());
+
assertThat(properties.getHttpDecoder().getMaxInitialLineLength(), is(8192));
+ assertThat(properties.getHttpDecoder().getMaxHeaderSize(),
is(16384));
+ assertThat(properties.getHttpDecoder().getMaxChunkSize(),
is(16384));
+ });
+ }
+
+ @Test
+ public void testHttpDecoderDefaultProperties() {
+ applicationContextRunner
+ .withPropertyValues(
+ "shenyu.netty.http.web-server-factory-enabled=false"
+ )
+ .run(context -> {
+ NettyHttpProperties properties =
context.getBean("nettyTcpProperties", NettyHttpProperties.class);
+ assertNotNull(properties);
+ assertNotNull(properties.getHttpDecoder());
+
assertThat(properties.getHttpDecoder().getMaxInitialLineLength(), is(4096));
+ assertThat(properties.getHttpDecoder().getMaxHeaderSize(),
is(8192));
+ assertThat(properties.getHttpDecoder().getMaxChunkSize(),
is(8192));
+ });
+ }
}
