gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

1. netty client修改http协议增加Host请求头

Browse Source
This commit is contained in:
likepeng 2023-11-20 23:11:01 +08:00 committed by byteblogs168
parent 331839f512
commit f3718624a0
3 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
easy-retry-client/easy-retry-client-common/src/main/java/com/aizuda/easy/retry/client/common/netty/NettyChannel.java
View File

@ -71,6 +71,13 @@ public class NettyChannel {
ServerProperties serverProperties = SpringContext.CONTEXT.getBean(ServerProperties.class); ServerProperties serverProperties = SpringContext.CONTEXT.getBean(ServerProperties.class);
EasyRetryProperties easyRetryProperties = SpringContext.CONTEXT.getBean(EasyRetryProperties.class); EasyRetryProperties easyRetryProperties = SpringContext.CONTEXT.getBean(EasyRetryProperties.class);
// server配置不能为空
EasyRetryProperties.ServerConfig serverConfig = easyRetryProperties.getServer();
if (Objects.isNull(serverConfig)) {
LogUtils.error(log, "easy retry server config is null");
return;
}
Integer port = easyRetryProperties.getPort(); Integer port = easyRetryProperties.getPort();
// 获取客户端指定的端口 // 获取客户端指定的端口
if (Objects.isNull(port)) { if (Objects.isNull(port)) {
@ -95,6 +102,7 @@ public class NettyChannel {
.set(HeadersEnum.CONTEXT_PATH.getKey(), Optional.ofNullable(serverProperties.getServlet().getContextPath()).orElse("/")) .set(HeadersEnum.CONTEXT_PATH.getKey(), Optional.ofNullable(serverProperties.getServlet().getContextPath()).orElse("/"))
.set(HeadersEnum.HOST_PORT.getKey(), port) .set(HeadersEnum.HOST_PORT.getKey(), port)
.set(HeadersEnum.VERSION.getKey(), GroupVersionCache.getVersion()) .set(HeadersEnum.VERSION.getKey(), GroupVersionCache.getVersion())
.set(HeadersEnum.HOST.getKey(), serverConfig.getHost())
; ;
//发送数据 //发送数据

1
easy-retry-common/easy-retry-common-core/src/main/java/com/aizuda/easy/retry/common/core/enums/HeadersEnum.java
View File

@ -16,6 +16,7 @@ public enum HeadersEnum {
CONTEXT_PATH("context-path"), CONTEXT_PATH("context-path"),
REQUEST_ID("request-id"), REQUEST_ID("request-id"),
VERSION("version"), VERSION("version"),
HOST("Host"),
; ;
private final String key; private final String key;

2
pom.xml
View File

@ -21,7 +21,7 @@
<java.version>1.8</java.version> <java.version>1.8</java.version>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target> <maven.compiler.target>1.8</maven.compiler.target>
<revision>2.4.0</revision> <revision>2.5.0-SNAPSHOT</revision>
<dingding-talk.version>1.0.0</dingding-talk.version> <dingding-talk.version>1.0.0</dingding-talk.version>
<netty-all.version>4.1.94.Final</netty-all.version> <netty-all.version>4.1.94.Final</netty-all.version>
<hutool-all.version>5.8.19</hutool-all.version> <hutool-all.version>5.8.19</hutool-all.version>