com.alipay.remoting.connection

Class AbstractConnectionFactory

java.lang.Object

com.alipay.remoting.connection.AbstractConnectionFactory

All Implemented Interfaces:

ConnectionFactory

Direct Known Subclasses:

DefaultConnectionFactory

public abstract class AbstractConnectionFactory
extends Object
implements ConnectionFactory

ConnectionFactory to create connection.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.Bootstrap	bootstrap

Constructor Summary

Constructors

Constructor and Description
AbstractConnectionFactory(Codec codec, io.netty.channel.ChannelHandler heartbeatHandler, io.netty.channel.ChannelHandler handler, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
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.Channel	doCreateConnection(String targetIP, int targetPort, int connectTimeout)
void	init(ConnectionEventHandler connectionEventHandler) Initialize the factory.

Methods inherited from class java.lang.Object

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

Field Detail

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

Constructor Detail

AbstractConnectionFactory

public AbstractConnectionFactory(Codec codec,
                                 io.netty.channel.ChannelHandler heartbeatHandler,
                                 io.netty.channel.ChannelHandler handler,
                                 Configuration configuration)

Method Detail

init

public void init(ConnectionEventHandler connectionEventHandler)

Description copied from interface: ConnectionFactory

Initialize the factory.

Specified by:

init in interface ConnectionFactory

createConnection

public Connection createConnection(Url url)
                            throws Exception

Description copied from interface: ConnectionFactory

Create a connection use #BoltUrl

Specified by:

createConnection in interface ConnectionFactory

Parameters:

url - target url

Returns:

connection

Throws:

Exception

createConnection

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

Description copied from interface: ConnectionFactory

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

Specified by:

createConnection in interface ConnectionFactory

Parameters:

targetIP - target ip

targetPort - target port

connectTimeout - connect timeout in millisecond

Returns:

connection

Throws:

Exception

createConnection

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

Description copied from interface: ConnectionFactory

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

Specified by:

createConnection in interface ConnectionFactory

Parameters:

targetIP - target ip

targetPort - target port

version - protocol version

connectTimeout - connect timeout in millisecond

Returns:

connection

Throws:

Exception

doCreateConnection

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

Throws:

Exception