服务端任务调度报超时异常,网络是没问题的

Viewed 21

在linux服务器上部署snail-job服务端,本地windows10电脑启动客户端,客户端能注册到服务端,但是服务端定时任务调度报超时异常。
在服务器上执行 telnet 本地电脑ip 1789 是能连上的。
本地电脑启动服务端请求本地客户端是正常的。
Linux系统:CentOS 7
snail-job版本:1.6.0
服务端错误日志:

2025-08-02 15:10:18.313 [JOB_ACTOR_SYSTEM-pekko.actor.job-task-executor-call-client-dispatcher-42] ERROR com.aizuda.snailjob.server.job.task.support.executor.job.RequestClientActor - Task ID:[6] Task scheduling failed. <|>{"namespaceId":"m28x9sYY1NYL6d61Dudi-fEFYsQLrCXY","groupName":"sz0001-tk-data-sync","timestamp":1754118598310,"logType":"JOB","jobId":1,"taskBatchId":18,"taskId":6}<|>
java.util.concurrent.TimeoutException: Waited 20 seconds (plus 124079 nanoseconds delay) for io.grpc.stub.ClientCalls$GrpcFuture@8befca6[status=PENDING, info=[GrpcFuture{clientCall=PendingCall{realCall=ClientCallImpl{method=MethodDescriptor{fullMethodName=UnaryRequest/unaryRequest, type=UNARY, idempotent=false, safe=false, sampledToLocalTracing=false, requestMarshaller=io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller@54cb19d4, responseMarshaller=io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller@4793ed52}}}}]]
        at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:534)
        at com.aizuda.snailjob.server.common.rpc.client.grpc.GrpcClientInvokeHandlerV2.lambda$requestRemote$3(GrpcClientInvokeHandlerV2.java:133)
        at com.github.rholder.retry.AttemptTimeLimiters$NoAttemptTimeLimit.call(AttemptTimeLimiters.java:78)
        at com.github.rholder.retry.Retryer.call(Retryer.java:160)
        at com.aizuda.snailjob.server.common.rpc.client.grpc.GrpcClientInvokeHandlerV2.requestRemote(GrpcClientInvokeHandlerV2.java:111)
        at com.aizuda.snailjob.server.common.rpc.client.grpc.GrpcClientInvokeHandlerV2.invoke(GrpcClientInvokeHandlerV2.java:90)
        at com.aizuda.snailjob.server.common.rpc.client.grpc.GrpcClientInvokeHandlerV2.invoke(GrpcClientInvokeHandlerV2.java:49)
        at jdk.proxy3/jdk.proxy3.$Proxy195.dispatch(Unknown Source)
        at com.aizuda.snailjob.server.job.task.support.executor.job.RequestClientActor.doExecute(RequestClientActor.java:102)
        at com.aizuda.snailjob.server.job.task.support.executor.job.RequestClientActor.lambda$createReceive$0(RequestClientActor.java:65)
        at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
        at org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
        at scala.PartialFunction.applyOrElse(PartialFunction.scala:214)
        at scala.PartialFunction.applyOrElse$(PartialFunction.scala:213)
        at org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
        at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:269)
        at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
        at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
        at org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
        at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
        at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
        at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
        at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
        at java.base/java.lang.Thread.run(Thread.java:1583)
2 Answers

服务端为默认配置

snail-job:
retry-pull-page-size: 1000
job-pull-page-size: 1000
server-port: 17888
log-storage: 7
rpc-type: grpc

客户端配置

snail-job:
enabled: true
server:
host: 10.250.9.85
port: 17888
namespace: "m28x9sYY1NYL6d61Dudi-fEFYsQLrCXY"
group: "sz0001-tk-data-sync"
token: "SJ_LZ8egjDdRiRdUxA64KFBeYx81RbeGb04"
host: 10.10.0.4
port: 1789
rpc-type: grpc