com.alipay.remoting.rpc

类 RpcConnectionFactory

java.lang.Object

com.alipay.remoting.rpc.RpcConnectionFactory

所有已实现的接口:

ConnectionFactory

public class RpcConnectionFactory
extends Object
implements ConnectionFactory

Rpc connection factory, create rpc connections. And generate user triggered event.

构造器概要

构造器

构造器和说明
RpcConnectionFactory()

方法概要

方法

限定符和类型	方法和说明
Connection	createConnection(String targetIP, int targetPort, byte version, int connectTimeout) Create a connection according to the IP and port.
Connection	createConnection(String targetIP, int targetPort, int connectTimeout) Create a connection according to the IP and port.
Connection	createConnection(Url url) Create a connection use #BoltUrl
protected io.netty.channel.ChannelFuture	doCreateConnection(String targetIP, int targetPort, int connectTimeout)
void	init(ConnectionEventHandler connectionEventHandler) Initialize the factory.
void	registerUserProcessor(UserProcessor<?> processor) Register User processor

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

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

构造器详细资料

RpcConnectionFactory

public RpcConnectionFactory()

方法详细资料

init

public void init(ConnectionEventHandler connectionEventHandler)

从接口复制的说明: ConnectionFactory

Initialize the factory.

指定者:

init 在接口中 ConnectionFactory

另请参阅:

ConnectionFactory.init(ConnectionEventHandler)

createConnection

public Connection createConnection(Url url)
                            throws Exception

从接口复制的说明: ConnectionFactory

Create a connection use #BoltUrl

指定者:

createConnection 在接口中 ConnectionFactory

返回:

抛出:

Exception

另请参阅:

ConnectionFactory.createConnection(com.alipay.remoting.Url)

createConnection

public Connection createConnection(String targetIP,
                          int targetPort,
                          int connectTimeout)
                            throws Exception

从接口复制的说明: ConnectionFactory

Create a connection according to the IP and port. Note: The default protocol is RpcProtocol.

指定者:

createConnection 在接口中 ConnectionFactory

返回:

抛出:

Exception

另请参阅:

ConnectionFactory.createConnection(java.lang.String, int, int)

createConnection

public Connection createConnection(String targetIP,
                          int targetPort,
                          byte version,
                          int connectTimeout)
                            throws Exception

从接口复制的说明: ConnectionFactory

Create a connection according to the IP and port. Note: The default protocol is RpcProtocolV2, and you can specify the version

指定者:

createConnection 在接口中 ConnectionFactory

返回:

抛出:

Exception

另请参阅:

ConnectionFactory.createConnection(String, int, byte, int)

doCreateConnection

protected io.netty.channel.ChannelFuture doCreateConnection(String targetIP,
                                                int targetPort,
                                                int connectTimeout)
                                                     throws Exception

参数:

targetIP -

targetPort -

connectTimeout -

返回:

抛出:

Exception

registerUserProcessor

public void registerUserProcessor(UserProcessor<?> processor)

从接口复制的说明: ConnectionFactory

Register User processor

指定者:

registerUserProcessor 在接口中 ConnectionFactory

另请参阅:

ConnectionFactory.registerUserProcessor(com.alipay.remoting.rpc.protocol.UserProcessor)