From f25977a21857f0a7af0f4c47b50ff5e624c93cf4 Mon Sep 17 00:00:00 2001 From: dhb52 Date: Fri, 26 Jul 2024 00:12:20 +0800 Subject: [PATCH] =?UTF-8?q?fix(sj=5F1.2.0-beta1):=20=E5=8F=91=E9=80=81?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=EF=BC=8C=E5=AF=B9=E4=BA=8Egolang?= =?UTF-8?q?=E7=9A=84net.http=20=E9=9C=80=E8=A6=81=20host=20=E5=A4=B4?= =?UTF-8?q?=E9=83=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/common/rpc/client/NettyChannel.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/client/NettyChannel.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/client/NettyChannel.java index a9829d2ef..b30773da0 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/client/NettyChannel.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/client/NettyChannel.java @@ -23,12 +23,10 @@ import java.util.concurrent.TimeUnit; */ @Slf4j public class NettyChannel { - private NettyChannel() { - } - private static Bootstrap bootstrap; private static ConcurrentHashMap, Channel> CHANNEL_MAP = new ConcurrentHashMap<>(16); - + private NettyChannel() { + } public static void setChannel(String hostId, String ip, Channel channel) { CHANNEL_MAP.put(Pair.of(hostId, ip), channel); @@ -70,10 +68,13 @@ public class NettyChannel { HttpVersion.HTTP_1_1, method, url, Unpooled.wrappedBuffer(body.getBytes(StandardCharsets.UTF_8))); request.headers() + // Host + .set(HttpHeaderNames.HOST, hostIp) + // Content-Type .set(HttpHeaderNames.CONTENT_TYPE, HttpHeaderValues.APPLICATION_JSON) - //开启长连接 + // 开启长连接 .set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE) - //设置传递请求内容的长度 + // 设置传递请求内容的长度 .set(HttpHeaderNames.CONTENT_LENGTH, request.content().readableBytes()) ; request.headers().setAll(requestHeaders);