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

fix(sj_1.2.0-beta1): 发送客户端，对于golang的net.http 需要 host 头部

Browse Source
This commit is contained in:
dhb52 2024-07-26 00:12:20 +08:00
parent 5a583a17be
commit 30c3504e42
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/client/NettyChannel.java
View File

@ -23,12 +23,10 @@ import java.util.concurrent.TimeUnit;
*/ */
@Slf4j @Slf4j
public class NettyChannel { public class NettyChannel {
private NettyChannel() {
}
private static Bootstrap bootstrap; private static Bootstrap bootstrap;
private static ConcurrentHashMap<Pair<String, String>, Channel> CHANNEL_MAP = new ConcurrentHashMap<>(16); private static ConcurrentHashMap<Pair<String, String>, Channel> CHANNEL_MAP = new ConcurrentHashMap<>(16);
private NettyChannel() {
}
public static void setChannel(String hostId, String ip, Channel channel) { public static void setChannel(String hostId, String ip, Channel channel) {
CHANNEL_MAP.put(Pair.of(hostId, ip), channel); CHANNEL_MAP.put(Pair.of(hostId, ip), channel);
@ -70,6 +68,9 @@ public class NettyChannel {
HttpVersion.HTTP_1_1, method, url, Unpooled.wrappedBuffer(body.getBytes(StandardCharsets.UTF_8))); HttpVersion.HTTP_1_1, method, url, Unpooled.wrappedBuffer(body.getBytes(StandardCharsets.UTF_8)));
request.headers() request.headers()
// Host
.set(HttpHeaderNames.HOST, hostIp)
// Content-Type
.set(HttpHeaderNames.CONTENT_TYPE, HttpHeaderValues.APPLICATION_JSON) .set(HttpHeaderNames.CONTENT_TYPE, HttpHeaderValues.APPLICATION_JSON)
// 开启长连接 // 开启长连接
.set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE) .set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE)