本文对编写客户服务器应用的java程序员有所帮助可以解决程序在对方出现故障的时候继续稳定运行
目前java平台已经广泛应用于各类客户/服务器系统中在实际编程中往往需要网络的异步处理比如客户程序如果客户程序运行先于服务程序则客户程序则需要在服务程序启动后再自动连接服务程序在客户程序运行中如果服务程序中途停止则也需要在不停止的条件下等待服务程序运行并重新连接下面提供了一类异步编程的方法
网络异步应用涉及到如下几个关键点
◇客户应用启动后检测服务应用是否存在如果不存在则等待服务应用启动同时不堵塞客户应用其他任务的执行一旦服务应用启动客户应用应该及时的与其建立连接
◇客户应用和服务应用在数据通信中服务应用异常退出后客户应用应可以检测到服务应用的退出同时客户应用自动清除该通信链路回到初始状态等待服务应用重新启动
该网络异步编程首先涉及到一个定时器和定时器事件该定时器用于不断的检测网络中客户应用和服务应用是否连通同时在服务应用出现异常时中止数据通信返回到初始状态网络的故障可以通过网络方法的异常处理获知
定时器包含在网络通信类中使得使用该类的应用感知不到定时器的存在而方便的处理网络信息
客户程序类如下结构
public class NetComm
implements ActionListener
{
javaxswingTimer timer = new javaxswingTimer(this);
Socket sock;
private EventNotifier en;
public static int net_state = ;
InetAddress ServerAddr;
int ServerPort;
public NetComm(InetAddress addr int port){
ServerAddr = addr;
ServerPort = port;
}
public void NetComm_Init() {
net_state = ;
try {
sock = new Socket(ServerAddr ServerPort);
} catch (IOException e) {
net_state = ;
}
timerstart();
}
public void NetComm_Data()
{
try {
OutputStream outputstream = sockgetOutputStream();
BufferedWriter out = new BufferedWriter
(new OutputStreamWriter(outputstream));
outwrite(java by ghf@chinacom);
outflush();
BufferedReader in = new BufferedReader
(new InputStreamReader(sockgetInputStream()));
boolean more = true;
while(more) {
String str = inreadLine();
if(str == null) more = false;
else
// 处理数据
Systemoutprintln(str);
}
inclose();
} catch (IOException e) {
NetComm_Close();
net_state = ;
}
timerstart();
}
public void NetComm_Close()
{
if(sock != null)
try{
sockclose();
} catch ( IOException e) {
}
}
public void actionPerformed(ActionEvent e)
{
if(net_state == )
NetComm_Init();
else
NetComm_Data();
}
}
在以上程序中也可以为外部应用提供一个回调函数以便在网络异常或恢复正常时通知应用服务应用的网络通信类类似可以放在同一类中
作者简介
郭洪锋从事UNIX系统上的分布式应用系统开发已有四年分布式应用系统开发经验Email:ghf_email@chinacom
