下面介绍的这个类实现了伪异步socket通讯。

基本思想就是在现有socket类的基础上进行封装当socket连接建立成功后立即创建一个socket数据接收线程专门负责阻塞式的socket读取(read)而当前线程负责数据的发送(send)。

另外定义了一个接口包括了socket的各种事件的回调。

我们要实现这个接口在接口实现类中创建异步socket对象并且传递接口类到异步socket对象中目的是有socket事件的时候回调我们的方法。

SocketExHandler.java

6.当有客户端SOCKET要建立连接时会触发OnAccept事件

public

Socket(host,port);InitNotify();}

public

Socket(host,port,localAddr,localPort

);InitNotify();}

thisSocket.setSoLinger(on,val);

public

BufferedInputStream(getInputStream());

}catch(IOException

Thread(this,SocketEx_NoitfyThread);

if(seh

if(getInputStream().read(buf,0,1)

0)//试读一个字节

if(!DoReceive(getInputStream().available()))

return

seh.OnReceive(this,buf,nStart);

return

biStream.read(buf,nStart,nCurrReadCount);

if(len

seh.OnReceive(this,buf,lennStart);

nStart

s(SocketEx)ClientPool.elementAt(i);

if(s

ClientPool.removeAllElements();

public

Thread(this,ServerSocketEx_NoitfyThread);

/**

com.borland.jb.util.Diagnostic;

/**

//Diagnostic.out.println(TIMER:

startTimereventId);

//Diagnostic.out.println(TIMER:

stopTimereventId);

//Diagnostic.out.println(TIMER:

Tick);

//Diagnostic.out.println(TIMER:

Suspend);

//Diagnostic.out.println(TIMER:

Suggested

//Diagnostic.out.println(TIMER:

Caught

//Diagnostic.out.println(TIMER:

Resume);

//Diagnostic.out.println(TIMER:

purged);

//Diagnostic.out.println(TIMER:

Scanning

//Diagnostic.out.println(TIMER:

Adding

//Diagnostic.out.println(TIMER:

fire);

DemoAppSocket(DemoAppSocketHandler

issh,boolean

TimerCtl.startTimer(this,eventId,30*1000,true);

//这个方法一般不需要直接调用

TimerCtl.stopTimer(this,eventId);

if(this.isServer)

PrintWriter(currSocketEx.getOutputStream(),true);

Sender.flush();

TimerCtl.stopTimer(this,eventId);

return

TimerCtl.stopTimer(this,eventId);

return

ret[0]strS.substring(nSecondPos1);

return

FromAreastrCmd[1].substring(0,6);

String

ToAreastrCmd[1].substring(6,12);

String

ChannNostrCmd[1].substring(12,15);

String

MainFunstrCmd[1].substring(15,18);

String

SubFunstrCmd[1].substring(18,21);

String

strCmd[1].substring(22,strCmd[1].length()-1);

Vector

ParamList.add(Param.substring(nLastPos));

System.out.println(Param.substring(nLastPos));

break;

Param.substring(nLastPos,nPos);

nLastPos

DoProcessCmd(socket,FromArea,ToArea,ChannNo,MainFun,SubFun,ParamList);

}while(true);

issh.OnProcessCmd(socket,FromArea,ToArea,ChannNo,MainFun,

SubFun,

issh.OnAccept(socket,ClientSocket);

public

TimerCtl.startTimer(this,eventId,30*1000,true);

if(issh

通过这种方式可以高效地使用socket通讯在异步socket版本没有发布以前不失是一种解决问题的方法。

:)