四、TCP 客户端类

4. 客户端类

org.voovan.network.aio.AioSocket

org.voovan.network.nio.NioSocket

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

  1. public *ioSocket(String host, int port, int readTimeout) throws IOException
  • 构造一个TCP客户端类，默认不会出发空闲事件。
  • host: 服务发布地址。
  • port: 服务发布端口。
  • readTimeout: 读取超时时间。
  1. public *ioSocket(String host,int port,int readTimeout, int idleInterval) throws IOException
  • 构造一个TCP客户端类。
  • host: 服务发布地址。
  • port: 服务发布端口。
  • readTimeout: 读取超时时间。
  • idleInterval: 空闲事件触发时间, 单位: 秒。
  1. public * socketChannel()
  • 获取 SocketChannel 对象, "*"代表返回值类型。
  • 返回值: 获取当前 java 异步通信类,Aio 通信返回AsynchronousSocketChannel,Nio 通信返回SocketChannel。
  1. public int getBufferSize()
  • 获取缓冲区大小。
  • 返回值: 缓冲区大小。
  1. public void setBufferSize(int bufferSize)
  • 设置缓冲区大小, 默认大小 1024byte。
  • bufferSize: 缓冲区大小。
  1. public AioSession getSession()
  • 获取 Session 会话对象。
  • readTimeout: 读取超时时间。
  1. public boolean isConnect()
  • 判断当前 Socket 连接是否处于连接状态。
  • 返回值: true:处于连接状态,false:连接处于断开状态。
  1. public <T> void setOption(SocketOption<T> name, T value) throws IOException {
  • 设置当前 socket 的参数, 具体请参考java.net.SocketOption1类
  • 返回值: 设置的参数。
  1. public Object synchronouRead() throws ReadMessageException
  • 同步读取消息。
  • 返回值: 读取出的对象。
  1. public void synchronouSend(Object obj) throws SendMessageException
  • 同步发送消息。
  • obj: 要发送的对象。
  1. public boolean Close()
  • 关闭当前 Socket 连接。
  • 返回值: true:连接成功关闭,false:连接关闭失败。
  1. public void start() throws Exception
  • 启动当前服务连接,时当前处于服务可用状态,会阻赛当前连接。
  1. public void syncStart() throws IOException
  • 同步启动方法
  • 启动当前服务连接,使当前处于服务可用状态, 不会阻赛当前线程。