From 7a199ae21a291d45dd194d4ae110e629c4fa3d2c Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Thu, 24 Oct 2024 10:08:13 +0800 Subject: [PATCH] =?UTF-8?q?feat:(grpc):=20=E4=BF=AE=E5=A4=8DreqId=E4=B8=A2?= =?UTF-8?q?=E5=A4=B1=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../rpc/server/GrpcRequestHandlerActor.java | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcRequestHandlerActor.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcRequestHandlerActor.java index 72b6684e8..698f7be24 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcRequestHandlerActor.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcRequestHandlerActor.java @@ -77,6 +77,7 @@ public class GrpcRequestHandlerActor extends AbstractActor { String body = grpcSnailJobRequest.getBody(); Object[] objects = JsonUtil.parseObject(body, Object[].class); request.setArgs(objects); + request.setReqId(grpcSnailJobRequest.getReqId()); snailJobRpcResult = doProcess(uri, JsonUtil.toJsonString(request), headersMap); if (Objects.isNull(snailJobRpcResult)) { snailJobRpcResult = new SnailJobRpcResult(StatusEnum.NO.getStatus(), "服务端异常", null, @@ -147,19 +148,5 @@ public class GrpcRequestHandlerActor extends AbstractActor { throw new SnailJobServerException("No matching handler found. Path:[{}] method:[{}]", builder.getPathStr()); } - /** - * write response - */ - private void writeResponse(ChannelHandlerContext ctx, boolean keepAlive, String responseJson) { - FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, - Unpooled.copiedBuffer(responseJson, CharsetUtil.UTF_8)); - response.headers().set(HttpHeaderNames.CONTENT_TYPE, - HttpHeaderValues.APPLICATION_JSON); - response.headers().set(HttpHeaderNames.CONTENT_LENGTH, response.content().readableBytes()); - if (keepAlive) { - response.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE); - } - ctx.writeAndFlush(response); - } }