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

javalearner

1. java客户端使用TCP/IP协议连接服务器,服务器有数据(可用数据,非交互信令)即发送给客户端.
   
2. 客户端在一定时间内没有收到数据,在无法判断是服务器无数据或是网络连接不可达时,重新连接.
   
3. 设置socket的keepAlive 超时时间 和 捕获连接异常 作为判断条件.
   
4. connPbx(){
   
5. try{
   
6.   if(s != null)
   
7.      s.close();
   
8.   s= new Socket(IP,PORT);//连接pbx服务器
   
9.   if(s  == null){
   
10.      connPbx();
    
11.   }
    
12.    if(s.isConnected()) {
    
13.      s.setKeepAlive(true);
    
14.      s.setSoTimeout(60000*3);
    
15.   
    
16.      foStream = new FileWriter(fileTxt,true);//保存数据到文件末尾，而不是覆盖文件
    
17.      BufferedWriter bfout = new BufferedWriter(foStream);
    
18.      bf= new BufferedReader(new InputStreamReader(s.getInputStream()));
    
19.      out = new PrintWriter(bfout);
    
20.      String huadan = null;
    
21.      while( (huadan = bf.readLine()) != null)
    
22.       {
    
23.        out.write(huadan+"
    
24. ");//写入文件
    
25.        out.flush();   
    
26.      }  
    
27.     }  
    
28.   }catch(Exception Te){
    
29.     // 超时、网络异常 重连
    
30.     try {
    
31.       if(out != null)
    
32.         out.close();
    
33.      if(s    != null)
    
34.         s.close();
    
35.      connPbx();
    
36.     } catch (IOException e) {
    
37.      e.printStackTrace();
    
38.     }
    
39.    
    
40.   }
    
41. }
    
43. 
    
44.                      

复制代码