基于XSocket框架的socket编程技巧（同步通信）

77 阅读 0 评论 51 点赞

我是靠谱客的博主无私口红，最近开发中收集的这篇文章主要介绍基于XSocket框架的socket编程技巧（同步通信），觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

最近在做socket通信编程，现总结如下，关于XSocket的大话就不再多说了，google一下一大片。

一、 Server端

Socket监听如下：

ServerHandler handler = new ServerHandler();

//创建一个服务端的对象

IServer srv = new Server(address, port, handler);

//设置当前的采用的异步模式

srv.setFlushmode(FlushMode.ASYNC);

//设置连接的超时时间和最大空闲时间

srv.setConnectionTimeoutMillis(5000);

srv.setIdleTimeoutMillis(10000);

//启动监听

srv.start();

其中如下两个方法的设置与ServerHandler的实现有关系，

srv.setConnectionTimeoutMillis(5000);

srv.setIdleTimeoutMillis(10000);

下面再看ServerHandler吧

public class ServerHandler implements IDataHandler, IConnectHandler,

IIdleTimeoutHandler, IConnectionTimeoutHandler, IDisconnectHandler

{

public boolean onConnect(INonBlockingConnection nbc) throws IOException,

BufferUnderflowException, MaxReadSizeExceededException

{

return true;

}

public boolean onDisconnect(INonBlockingConnection nbc) throws IOException

{

return true;

}

public boolean onData(INonBlockingConnection nbc) throws IOException,

BufferUnderflowException, ClosedChannelException,

MaxReadSizeExceededException

{

return true;

}

public boolean onIdleTimeout(INonBlockingConnection connection)

throws IOException

{

System.out.println("onIdleTimeout");

return false;

}

public boolean onConnectionTimeout(INonBlockingConnection connection)

throws IOException

{

System.out.println("onConnectionTimeout");

return true;

}

ServerHandler分别实现了以下接口

IDataHandler, IConnectHandler,IIdleTimeoutHandler, IConnectionTimeoutHandler, IDisconnectHandler

其中主要说一下IDataHandler、IIdleTimeoutHandler、IConnectionTimeoutHandler吧。

首先说明一下，socket连接的生命周期与server端的connectionTimeout和idleTimeout及client端有关系。

A、 IDataHandler中的事件onData事件就是处理业务逻辑的，当客户端发送一个业务请求时，会触发此事件。

B、 IIdleTimeoutHandler中的onIdleTimeout事件是在socket连接空闲超时被触发，这个超时时间就是刚刚srv.setIdleTimeoutMillis(10000)设置的值“10000”，单位毫秒。此事件返回一个bool状态，

　　（1）如果返回true，xsocket则认为这事件已经关闭了此连接，那么我们在此事件中是否去关闭连接了呢？前面说了这个连接的生命周期和与server端的connectionTimeout和idleTimeout及client端有关，如下解释，

1）、如果close();，那么就不多说了；

2）、如果没有close();，此时又和IConnectionTimeoutHandler的事件onConnectionTimeout和client有关。如果onConnectionTimeout返回false，则此事件被触发并在事件结束后，则xsocket关闭连接；如果onConnectionTimeout返回true，则此连接由client负责关闭。

　　（2）如果返回false，相当于onIdleTimeout没有做任何处理，则此时又和IConnectionTimeoutHandler的事件onConnectionTimeout有关。如果onConnectionTimeout事件返回true，则onIdleTimeout事件被触发并在事件结束后由xsocket关闭连接；如果onConnectionTimeout事件返回false，则onConnectionTimeout与onIdleTimeout任何一个事件被触发后就会由xsocket关闭连接。

C、 IConnectionTimeoutHandler中的onConnectionTimeout事件是在socket建立连接后，经过srv.setConnectionTimeoutMillis(5000)这个方法中的值时间后触发此事件，强调是指建立连接时，不是指上一次通信时间。此事件返回一个bool状态：

　　（1）如果返回true，如下解释，

与IIdleTimeoutHandler的事件onIdleTimeout和client有关。如果onIdleTimeout返回false，则在onIdleTimeout事件被触发并在事件结束后，则xsocket关闭连接；如果onIdleTimeout返回true，则此连接由client负责关闭。

　　（2）如果返回false，解释如下：

与IIdleTimeoutHandler的事件onIdleTimeout有关。如果onIdleTimeout事件返回true，则onConnectionTimeout事件被触发并在事件结束后由xsocket关闭连接；如果onIdleTimeout事件返回false，则onConnectionTimeout与onIdleTimeout任何一个事件被触发后就会由xsocket关闭连接。

终上，关于在服务器端socket连接的生命周期如下表（以下事件中都没有通过编程主动关闭连接）：

onIdleTimeout 返回值	onConnectionTimeout 返回值	何时关闭
true	true	由client端负责
false	true	idleTimeout到时
true	false	connectionTimeout到时
false	false	idleTimeout与connectionTimeout的最小值到达时

说明一下connectionTimeout和idleTimeout从何时开始计时：

connectionTimeout是从建立连接开始计时；

idleTimeout是从建立连接或最后一次触发onData事件时开始计时；

二、 Client端

1、如何创建一个同步socket连接？

　　　A、可以通过直接new 一个BlockingConnection(String hostname, int port)；

　　　B、也可通过异步连接构建，如new BlockingConnection(INonBlockingConnection delegate)

2、当然XSocket也提供了连接池，同样包括同步连接池和异步连接池。

BlockingConnectionPool pool = new BlockingConnectionPool();这样就创建了一个同步连接池，既然是池，肯定会有池的大小了，pool.setMaxActivePerServer(poolSize);这是为池设置每个server池的大小，也可以设置池的总大小，如果不设置，默认为值为Integer.MAX_VALUE。

如何从池中获取一个连接呢，如IBlockingConnection bc = pool.getBlockingConnection(host,port);有很多重载方法了。

当获取这个连接之后，我们可以通过设置如下参数进行调整优化：

设置连接超时时间

bc.setConnectionTimeoutMillis(connectTimeoutMillis);

设置连接最大空闲时间

bc.setIdleTimeoutMillis(this.idleTimeoutMillis);

是否自动刷新缓存

bc.setAutoflush(false);

这项时设置在真正要关闭连接时，client端是否要立即释放随机分配的端口，默认不会立即释放端口，需要等待1~4分钟，连接一直处于TIME_WAIT状态，如果这样设置，当关闭连接时，就会立即释放端口。

bc.setOption(IBlockingConnection.SO_LINGER , "0");

当然当连接使用完以后，需要调用bc.close();放回连接池中，如果close失败，那就要调用pool.destroy(bc)真正的关闭连接了。

仍需要解释下这里的connectTimeoutMillis与idleTimeoutMillis了，