org.tio.client

Class TioClient

java.lang.Object

org.tio.client.TioClient

public class TioClient
extends Object

Author:

tanyaowu 2017年4月1日 上午9:29:58

Constructor Summary

Constructors

Constructor and Description
TioClient(ClientTioConfig clientTioConfig)

Method Summary

Modifier and Type	Method and Description
void	asynConnect(Node serverNode)
void	asynConnect(Node serverNode, Integer timeout)
void	asynConnect(Node serverNode, String bindIp, Integer bindPort, Integer timeout)
ClientChannelContext	connect(Node serverNode)
ClientChannelContext	connect(Node serverNode, Integer timeout)
ClientChannelContext	connect(Node serverNode, String bindIp, Integer bindPort, ClientChannelContext initClientChannelContext, Integer timeout)
ClientChannelContext	connect(Node serverNode, String bindIp, Integer bindPort, Integer timeout)
AsynchronousChannelGroup	getChannelGroup()
ClientTioConfig	getClientTioConfig()
void	reconnect(ClientChannelContext channelContext, Integer timeout)
void	setClientTioConfig(ClientTioConfig clientTioConfig)
boolean	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TioClient

public TioClient(ClientTioConfig clientTioConfig)
          throws IOException

Parameters:

serverIp - 可以为空

serverPort -

aioDecoder -

aioEncoder -

aioHandler -

Throws:

IOException

Method Detail

asynConnect

public void asynConnect(Node serverNode)
                 throws Exception

Parameters:

serverNode -

Throws:

Exception

asynConnect

public void asynConnect(Node serverNode,
                        Integer timeout)
                 throws Exception

Parameters:

serverNode -

timeout -

Throws:

Exception

asynConnect

public void asynConnect(Node serverNode,
                        String bindIp,
                        Integer bindPort,
                        Integer timeout)
                 throws Exception

Parameters:

serverNode -

bindIp -

bindPort -

timeout -

Throws:

Exception

connect

public ClientChannelContext connect(Node serverNode)
                             throws Exception

Parameters:

serverNode -

Returns:

Throws:

Exception

connect

public ClientChannelContext connect(Node serverNode,
                                    Integer timeout)
                             throws Exception

Parameters:

serverNode -

timeout -

Returns:

Throws:

Exception

connect

public ClientChannelContext connect(Node serverNode,
                                    String bindIp,
                                    Integer bindPort,
                                    ClientChannelContext initClientChannelContext,
                                    Integer timeout)
                             throws Exception

Parameters:

serverNode -

bindIp -

bindPort -

initClientChannelContext -

timeout - 超时时间，单位秒

Returns:

Throws:

Exception

connect

public ClientChannelContext connect(Node serverNode,
                                    String bindIp,
                                    Integer bindPort,
                                    Integer timeout)
                             throws Exception

Parameters:

serverNode -

bindIp -

bindPort -

timeout - 超时时间，单位秒

Returns:

Throws:

Exception

getChannelGroup

public AsynchronousChannelGroup getChannelGroup()

Returns:

the channelGroup

getClientTioConfig

public ClientTioConfig getClientTioConfig()

Returns:

the clientTioConfig

reconnect

public void reconnect(ClientChannelContext channelContext,
                      Integer timeout)
               throws Exception

Parameters:

channelContext -

timeout - 单位秒

Throws:

Exception

setClientTioConfig

public void setClientTioConfig(ClientTioConfig clientTioConfig)

Parameters:

clientTioConfig - the clientTioConfig to set

stop

public boolean stop()

Returns: