xsocket使用指南【官方文档翻译】

连接的超时事件可以被用户处理。通过实现

I IdleTimeoutHandler

和

IConnecti onTimeoutHandler

，对应的

onconnec tionTimeout

和

onIdleTimeout

方法

会被调用。如果这些方法返回

true< /p>

，表明这些事件已经被处理，连接就不会被想

Socket

关闭。如果返回

false

，

xSocket

则会关闭这些连接。

连接的空闲超时时间可以针对每一个连接调用

setConnectionti meoutsec()

和

setIdletimeoutSec ()

方法设定，同样的也调用这些方法来重设。例如超时在一个超

时回调方法中设定并且返回

true

，

那么这个超时事件就会表现的像从来没有发生

过。

服务端的默认超时行为可以通过服务器端的超时设置函数修改。

// the handler

class Handler implements IDataHandler, IIdleTimeoutHandler,

IConnectionTimeoutHandler {

publicbooleanonConnectionTimeout(INonBl ockingConnectionnbc) throws

IOException {

(

();

return true;

// prevent, that xSocket also closes the connection

}

pu blicbooleanonIdleTimeout(INonBlockingConnectionnbc ) throws IOException

{

(

eTimeoutMillis(30 * 1000); // resets the timeout counter

return true;

// prevent, that xSocket closes the connection

}

publicbooleanonData(INonBlo ckingConnectionnbc) throws IOException {

//...

return true;

}

}

// and the server

IServer server = new Server(8090, new Handler());

eTimeoutMillis(30 * 1000);

// set the default idle timeout for

server-side connections

();

11

、回调方法的同步

onConnect

和

onData

这样的回调方法会根据连接同步处理，也就是说对伊同

一个连接，如果

onConnect

不执行完成，那么用户也不会调用

< br>onData

。

class Handler implements IConnectHandler, IDataHandler {

publicbooleanonConnect(INon BlockingConnectionnbc) throws IOException {

(

//...

// DO NOT DO THIS!

// this causes that onData() will never be called because executing of

// callback methods is synchronized based on the connection

while (true) {

try {

(1000);

} catch (InterruptedException ignore) {

}

(

}

// You could define a TimerTask and run it within a Timer (thread)

// to implement the

return true;

}

pu blicbooleanonData(INonBlockingConnectionnbc) throws IOException {

String msg = ringByDelimiter(

//...

return true;

}

}

12

、定义连接作用域的

默认的

Handler

作用域是实例作用域（全局）

。也就是同一个

H andler

可以用

于每一个新进入的连接。

< br>一个

Handler

通过实现

I ConnectionScoped

接口来转变成

连接作用域的 。这个接口需要一个可以被用来为新连接创建专门

Handler

实例的

clone

方法。为了避免副作用，

< br>clone

方法需要实现成深度拷贝。

classSmtpHandler implements IDataHandler, IConnectionScoped {

privateinthandledMessages = 0;

privateSessionDatasessionData = new SessionData();

publicboolea nonData(INonBlockingConnectionnbc) throws IOException {

//...

return true;

}

// deep clone: all attributes beside primitives, immutable or

// global manager/service references have also to be cloned

public Object clone() throws CloneNotSupportedException {

SmtpHandler copy = (SmtpHandler) ();

nData = (SessionData) ();

return copy;

}

}

通过声明

Handler

为连接作用域，

在支持深度拷贝的情况下，

Handler

的变量

自动变成连接指 定的。

同时除了这种显式的往连接发送数据的方法之外，

隐式的

方法也是支持的。

13

、绑定会话相关的数据到连接

< /p>

一个可选的向连接分发会话数据的方法是直接附加数据。一般而言，这是推

荐的方法。一个连接支持附件特定连接的会话数据通过

setAttachme nt(object)

，

getAttachment()

方法。

classSmtpHandler implements IConnectHandler, IDataHandler {

publicbooleanonConnect(INonBlockingConnection nbc) throws IOException {

achment(new SessionData());

return true;

}

publicbooleanonData(INonBlo ckingConnectionnbc) throws IOException {

SessionDatasessionData = (SessionData) achment();

//...

return true;

}

}

14

、运行时替换

Handler < /p>

xSocket

支持在运行时替换

Han dler

，这可以在服务器端为所有新进入的连接

应用新的

Handler

。如果连接已经建立，可以调用

setHandler

方法来替换当前连

接的

Handler

。

classServerHandlerA implements IDataHandler {

publicbooleanonData(INon BlockingConnectionnbc) throws IOException {

String cmd = ringByDelimiter(

if ((

dler(new ServerHandlerB());

} else {

(

}

return true;

}

}

在服务器端

Handler

赋给了

server

，

这个

Handler

会赋值给每一个新进入的连

接，可以通过调用

setHandler

方法来替换。

classServerSideHandler implements IDataHandler {

@Resource

private Server server;

publicbooleanonData(INonBlockingConnection connection) throws IOException

{

String cmd = ringByDelimiter(

if ((

dler(new ServerHandlerB());

(

(

} else {

(

}

return true;

}

}

15

、示例：简单的基于长度的

Han dler

为了应用基于长度的通信方法，

连接的

mark-support

可以使用，

这种情况下，

客户端首先写一个空的长度属性，

在写完内容数据之后，

写指针会移回到长度属

性域来覆盖长度属性域。

IBlockingConnectionbc = new BlockingConnection(host, port);

oflush(false); // mark support requires deactivated autoflush!