rpc链接socket设置超时时间

back_recharge
duhui 2022-04-06 14:58:57 +08:00
parent ce712afeac
commit 26d5114213
1 changed files with 5 additions and 5 deletions

View File

@ -53,15 +53,15 @@ public class ThriftFactory extends BaseKeyedPooledObjectFactory<String, TTranspo
TTransport transport = null;
if (key.equals(ServiceKey.RPCCore)){
transport = new TSocket(host, port);
transport = new TSocket(host, port, 3000);
}else if (key.equals(ServiceKey.RPCMATCH)){
transport = new TSocket(host, port);
transport = new TSocket(host, port, 3000);
}else if (key.equals(ServiceKey.GM_CANCLE_SCENE)){
transport = new TSocket(host, port);
transport = new TSocket(host, port, 3000);
}else if (key.equals(ServiceKey.RPC_GLOBAL)){
transport = new TSocket(host, port);
transport = new TSocket(host, port, 3000);
}else if (key.equals(ServiceKey.RPC_WORLD)){
transport = new TSocket(host, port);
transport = new TSocket(host, port, 3000);
}
if (transport!=null){