com.alipay.remoting

接口 ConnectionFactory

所有已知实现类:

RpcConnectionFactory

public interface ConnectionFactory

Factory that creates connections.

方法概要

方法

限定符和类型	方法和说明
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
void	init(ConnectionEventHandler connectionEventHandler) Initialize the factory.
void	registerUserProcessor(UserProcessor<?> processor) Register User processor

方法详细资料

init

void init(ConnectionEventHandler connectionEventHandler)

Initialize the factory.

createConnection

Connection createConnection(Url url)
                            throws Exception

Create a connection use #BoltUrl

参数:

url -

返回:

抛出:

Exception

createConnection

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

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

参数:

targetIP -

targetPort -

connectTimeout -

返回:

抛出:

Exception

createConnection

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

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

参数:

targetIP -

targetPort -

version -

connectTimeout -

返回:

抛出:

Exception

registerUserProcessor

void registerUserProcessor(UserProcessor<?> processor)

Register User processor

参数:

processor -