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 91aebb992e
commit 8c1854f75c
2 changed files with 9 additions and 0 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;