Java web怎样实现异步编程

在实际编程中，往往需要网络的异步处理。比如客户程序，如果客户程序运行先于服务程序，则客户程序则需要在服务程序启动后再自动连接服务程序;在客户程序运行中如果服务程序中途停止，则也需要在不停止的条件下，等待服务程序运行并重新连接。下面提供了一类异步编程的方法。

网络异步应用涉及到如下几个关键点：

客户应用启动后，检测服务应用是否存在。如果不存在，则等待服务应用启动，同时不堵塞客户应用其他任务的执行。一旦服务应用启动，客户应用应该及时的与其建立连接。

客户应用和服务应用在数据通信中，服务应用异常退出后，客户应用应可以检测到服务应用的退出。同时客户应用自动清除该通信链路，回到初始状态，等待服务应用重新启动。

该网络异步编程首先涉及到一个定时器和定时器事件。该定时器用于不断的检测网络中客户应用和服务应用是否连通，同时在服务应用出现异常时中止数据通信，返回到初始状态。网络的故障可以通过网络方法的异常处理获知。

定时器包含在网络通信类中，使得使用该类的应用感知不到定时器的存在，而方便的处理网络信息。

该客户程序类如下结构：

publicclassNetComm
implementsActionListener
{
javax.swing.Timertimer=newjavax.swing.Timer(3000,this);
Socketsock;
privateEventNotifieren;
publicstaticintnet_state=0;
InetAddressServerAddr;
intServerPort;
publicNetComm(InetAddressaddr,intport){
ServerAddr=addr;
ServerPort=port;
}
publicvoidNetComm_Init(){
net_state=1;
try{
sock=newSocket(ServerAddr,ServerPort);
}catch(IOExceptione){
net_state=0;
}
timer.start();
}
publicvoidNetComm_Data()
{
try{
OutputStreamoutputstream=sock.getOutputStream();
BufferedWriterout=newBufferedWriter
(newOutputStreamWriter(outputstream));
out.write("javabypiky2004@126.com");
out.flush();
BufferedReaderin=newBufferedReader
(newInputStreamReader(sock.getInputStream()));
booleanmore=true;
while(more){
Stringstr=in.readLine();
if(str==null)more=false;
else
//处理数据
System.out.println(str);
}
in.close();
}catch(IOExceptione){
NetComm_Close();
net_state=0;
}
timer.start();
}
publicvoidNetComm_Close()
{
if(sock!=null)
try{
sock.close();
}catch(IOExceptione){
}
}
publicvoidactionPerformed(ActionEvente)
{
if(net_state==0)
NetComm_Init();
else
NetComm_Data();
}
}

在上面的程序中，也可以为外部应用提供一个回调函数，以便在网络异常或恢复正常时通知应用。服务应用的网络通信类类似，可以放在同一类中。

有用  |  无用 取消

猜你喜欢