xyz.noark.network.rpc

类 RpcConnector

java.lang.Object

xyz.noark.network.rpc.RpcConnector

public class RpcConnector
extends java.lang.Object

RPC连接

从以下版本开始:

3.4.7

作者:

小流氓[176543888@qq.com]

构造器概要

构造器

构造器和说明
RpcConnector(io.netty.bootstrap.Bootstrap bootstrap, xyz.noark.core.network.PacketCodec packetCodec, java.net.SocketAddress address)

方法概要

限定符和类型	方法和说明
void	connect()
RpcStub	getRpcStub(java.lang.Integer reqId)
RpcClientSession	getSession()
boolean	isActiveOrTryConnect() 判定当前链接是否可用，如果不可用就进行重连，失败计次加一
boolean	isConnected()
<T> T	syncCall(java.io.Serializable opcode, java.lang.Object req, java.lang.Class<T> ackClass)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

RpcConnector

public RpcConnector(io.netty.bootstrap.Bootstrap bootstrap,
                    xyz.noark.core.network.PacketCodec packetCodec,
                    java.net.SocketAddress address)

方法详细资料

getRpcStub

public RpcStub getRpcStub(java.lang.Integer reqId)

syncCall

public <T> T syncCall(java.io.Serializable opcode,
                      java.lang.Object req,
                      java.lang.Class<T> ackClass)

connect

public void connect()

isConnected

public boolean isConnected()

getSession

public RpcClientSession getSession()

isActiveOrTryConnect

public boolean isActiveOrTryConnect()

判定当前链接是否可用，如果不可用就进行重连，失败计次加一

返回:

返回连接可用了则返回true