四、TCP 客户端类

4. 客户端类

org.voovan.network.aio.AioSocket

org.voovan.network.nio.NioSocket

同时支持同步和异步处理。

public *ioSocket(String host, int port, int readTimeout) throws IOException

• 构造一个TCP客户端类，默认不会出发空闲事件。
• host: 服务发布地址。
• port: 服务发布端口。
• readTimeout: 读取超时时间。

public *ioSocket(String host,int port,int readTimeout, int idleInterval) throws IOException

• 构造一个TCP客户端类。
• host: 服务发布地址。
• port: 服务发布端口。
• readTimeout: 读取超时时间。
• idleInterval: 空闲事件触发时间, 单位: 秒。

public * socketChannel()

• 获取 SocketChannel 对象, "*"代表返回值类型。
• 返回值: 获取当前 java 异步通信类,Aio 通信返回AsynchronousSocketChannel,Nio 通信返回SocketChannel。

public int getBufferSize()

• 获取缓冲区大小。
• 返回值: 缓冲区大小。

public void setBufferSize(int bufferSize)

• 设置缓冲区大小, 默认大小 1024byte。
• bufferSize: 缓冲区大小。

public AioSession getSession()

• 获取 Session 会话对象。
• readTimeout: 读取超时时间。

public boolean isConnect()

• 判断当前 Socket 连接是否处于连接状态。
• 返回值: true:处于连接状态,false:连接处于断开状态。

public <T> void setOption(SocketOption<T> name, T value) throws IOException {

• 设置当前 socket 的参数, 具体请参考java.net.SocketOption1类
• 返回值: 设置的参数。

public Object synchronouRead() throws ReadMessageException

• 同步读取消息。
• 返回值: 读取出的对象。

public void synchronouSend(Object obj) throws SendMessageException

• 同步发送消息。
• obj: 要发送的对象。

public boolean Close()

• 关闭当前 Socket 连接。
• 返回值: true:连接成功关闭,false:连接关闭失败。

public void start() throws Exception

• 启动当前服务连接,时当前处于服务可用状态,会阻赛当前连接。

public void syncStart() throws IOException

• 同步启动方法
• 启动当前服务连接,使当前处于服务可用状态, 不会阻赛当前线程。