Go语言视频零基础入门到精通

javalearner

该文章对编写客户服务器应用的java程序员有所帮助,可以解决程序在对方出现故障的时候继续稳定运行.

目前java平台已经广泛应用于各类客户/服务器系统中，在实际编程中，往往需要网络的异步处理。比如客户程序，如果客户程序运行先于服务程序，则客户程序则需要在服务程序启动后再自动连接服务程序；在客户程序运行中如果服务程序中途停止，则也需要在不停止的条件下，等待服务程序运行并重新连接。下面提供了一类异步编程的方法。

网络异步应用涉及到如下几个关键点：
客户应用启动后，检测服务应用是否存在。如果不存在，则等待服务应用启动，同时不堵塞客户应用其他任务的执行。一旦服务应用启动，客户应用应该及时的与其建立连接。

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

  
  

2. 
   
3.                         　　 该网络异步编程首先涉及到一个定时器和定时器事件。该定时器用于不断的检测网络中客户应用和服务应用是否连通，同时在服务应用出现异常时中止数据通信，返回到初始状态。网络的故障可以通过网络方法的异常处理获知。
4.                         
5. 
   
6.                         　　 定时器包含在网络通信类中，使得使用该类的应用感知不到定时器的存在，而方便的处理网络信息。
7.                         
8. 
   
9.                         该客户程序类如下结构：
10. 
    
11.                         
    
12.                         

复制代码

1. import java.io.*;
   
2. import java.net.*;
   
3. import java.awt.event.*;
   
4. public class NetComm implements ActionListener{
   
5.    
   
6.   javax.swing.Timer timer = new javax.swing.Timer(3000,this);
   
7.       
   
8.   Socket sock;
   
9.   //private EventNotifier en;
   
10.   public static int net_state = 0;
    
11.   InetAddress ServerAddr;
    
12.   int ServerPort;
    
13.    
    
14.   public NetComm(InetAddress addr, int port){
    
15.     ServerAddr = addr;
    
16.     ServerPort  = port;
    
17.   }

复制代码

2. public void NetComm_Init() {
   
3.       
   
4.     net_state = 1;
   
5.        try {
   
6.            sock = new Socket(ServerAddr, ServerPort);
   
7.        } catch (IOException e) {
   
8.            net_state = 0;
   
9.        }
   
10.        timer.start();
    
11. }
    
12.    
    
13. public void NetComm_Data(){
    
14.    try {
    
15.        OutputStream outputstream = sock.getOutputStream();
    
16.       
    
17.        BufferedWriter out = new BufferedWriter(new OutputStreamWriter(outputstream));
    
18.            
    
19.        out.write("java by ghf@china.com");
    
20.        out.flush();
    
21.        BufferedReader in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
    
22.       
    
23.        boolean more = true;
    
24.        while(more) {
    
25.            String str = in.readLine();
    
26.            if(str == null) more = false;
    
27.            else
    
28.                // 处理数据
    
29.                System.out.println(str);
    
30.        }
    
31.            
    
32.        in.close();
    
33.       } catch (IOException e) {
    
34.          NetComm_Close();
    
35.          net_state = 0;
    
36.        }
    
37.      timer.start();
    
38.    }
    
39.    
    
40.    public void NetComm_Close()
    
41.    {
    
42.        if(sock != null)
    
43.            try{
    
44.                sock.close();
    
45.                } catch ( IOException e) {
    
46.            }
    
47.    }
    
48.    
    
49.    public void actionPerformed(ActionEvent e)
    
50.    {
    
51.        if(net_state == 0)
    
52.               NetComm_Init();
    
53.        else
    
54.               NetComm_Data();
    
55.    }
    
56. }
    
57. 在以上程序中，也可以为外部应用提供一个回调函数，以便在网络异常或恢复正常时通知应用。
58. 服务应用的网络通信类类似，可以放在同一类中。
    
59. 
    
60.                         

复制代码

   
     
     
      
      

        
      

        
      
     
   

1. 
   
2.                         

复制代码

  


源码下载：http://file.javaxxz.com/2014/10/30/000003687.zip