基于XSocket框架的socket编程技巧（设置连接的超时时间和最大空闲时间）

忘是亡心i 2022-04-14 04:38 169阅读 0赞

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

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

一、 Server端

Socket监听如下：

<table> 
 <tbody> 
 <tr> 
 <td> ServerHandler handler = new ServerHandler(); //创建一个服务端的对象 IServer srv = new Server(address, port, handler); //设置当前的采用的异步模式 srv.setFlushmode(FlushMode.ASYNC); //设置连接的超时时间和最大空闲时间 srv.setConnectionTimeoutMillis(5000); srv.setIdleTimeoutMillis(10000); //启动监听 srv.start(); </td> 
 </tr> 
 </tbody> 
</table>

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

srv.setConnectionTimeoutMillis(5000);

srv.setIdleTimeoutMillis(10000);

下面再看ServerHandler吧

<table> 
 <tbody> 
 <tr> 
 <td> publicclass ServerHandler implements IDataHandler, IConnectHandler, IIdleTimeoutHandler, IConnectionTimeoutHandler, IDisconnectHandler { publicboolean onConnect(INonBlockingConnection nbc) throws IOException, BufferUnderflowException, MaxReadSizeExceededException { returntrue; } publicboolean onDisconnect(INonBlockingConnection nbc) throws IOException { returntrue; } publicboolean onData(INonBlockingConnection nbc) throws IOException, BufferUnderflowException, ClosedChannelException, MaxReadSizeExceededException { returntrue; } publicboolean onIdleTimeout(INonBlockingConnection connection) throws IOException { System.out.println("onIdleTimeout"); returnfalse; } publicboolean onConnectionTimeout(INonBlockingConnection connection) throws IOException { System.out.println("onConnectionTimeout"); returntrue; } </td> 
 </tr> 
 </tbody> 
</table>

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连接的生命周期如下表（以下事件中都没有通过编程主动关闭连接）：

<table> 
 <tbody> 
 <tr> 
 <td> onIdleTimeout 返回值 </td> 
 <td> onConnectionTimeout 返回值 </td> 
 <td> 何时关闭 </td> 
 </tr> 
 <tr> 
 <td> true </td> 
 <td> true </td> 
 <td> 由client端负责 </td> 
 </tr> 
 <tr> 
 <td> false </td> 
 <td> true </td> 
 <td> idleTimeout到时 </td> 
 </tr> 
 <tr> 
 <td> true </td> 
 <td> false </td> 
 <td> connectionTimeout到时 </td> 
 </tr> 
 <tr> 
 <td> false </td> 
 <td> false </td> 
 <td> idleTimeout与connectionTimeout的最小值到达时 </td> 
 </tr> 
 </tbody> 
</table>

说明一下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了，