令人郁闷的socket重联问题

 最近弄socket 流程是 主项目保持一个单例客户端socket类 在执行一些操作的时候通过此客户端socket通知服务器 如下

package com.common.utils;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class UtilSocket {
	private static final UtilSocket INSTANCE = new UtilSocket();
	private final String host = "192.168.1.201";
	private final int port = 4321;
	private  BufferedReader socketReader;
	private PrintWriter socketWriter;
    private Socket client = null;
	
    private UtilSocket() {
    	connServer();
    	System.out.println("构造UtilSocket!");
	}
    
    public static UtilSocket getInstance() {
    	if(INSTANCE.client == null || INSTANCE.client.isClosed()){
    		INSTANCE.downServer();
    		INSTANCE.connServer();
    	}
		return INSTANCE;
	}
    
    //链接远程服务器
    public void connServer() {
        try {
            client = new Socket(host,port);
            socketReader = new BufferedReader(new InputStreamReader(client.getInputStream(),"UTF-8"));
            socketWriter = new PrintWriter(client.getOutputStream(),true);
        } catch(UnknownHostException e) {
            System.out.println("Error1 setting up socket connection: unknown host at "+host+":"+port);
        } catch(IOException e) {
            System.out.println("Error2 setting up socket connection: "+e);
        }
    }
    
    //断开远程服务器
    public void downServer() {
        try {
            socketWriter.close(); 
            socketReader.close();
            client.close();
        }catch(IOException e) {            
            System.out.println("Error tearing down socket connection: "+e);
        }
    }
    
    
    //向服务器通知内容
    public void putInfo(String str) {
        try {
            socketWriter.println(str);
        }
        catch(Exception e) {
            System.out.println("Error reading from file: "+str);
        }
    }

}

 

测试之后问题出现了
socket服务器不重启  主项目重启没问题  但是socket服务器重启 主项目不重启的话 发出的socket请求 socket服务器完全接收不到信息。

仔细推敲后发觉是socket服务器已经断开 而主项目这边完全不知道，如何判断远端服务器是否已经断开连接，如果断开那么需要重新连接。

首先想到socket类的方法isClosed()、isConnected()、isInputStreamShutdown()、 isOutputStreamShutdown()等，但经过试验并查看相关文档，这些方法都是本地端的状态，无法判断远端是否已经断开连接。

然后想到是否可以通过OutputStream发送一段测试数据，如果发送失败就表示远端已经断开连接，类似ping，但是这样会影响到正常的输出数据，远端无法把正常数据和测试数据分开。

最后google了一把 发现有篇文章写的问题与我遇到的一模一样 使用sendUrgentData，查看文档后得知它会往输出流发送一个字节的数据，只要对方Socket的SO_OOBINLINE属性没有打开，就会 自动舍弃这个字节，而SO_OOBINLINE属性默认情况下就是关闭的。

然后把取得实例的方法修改了一下 问题解决！ (～ o ～)~zZ

 

 

   public static UtilSocket getInstance() {
    	if(INSTANCE.client == null || INSTANCE.client.isClosed()){
    		INSTANCE.downServer();
    		INSTANCE.connServer();
    	}
    	try{
    		INSTANCE.client.sendUrgentData(0xFF);
    	}catch(Exception ex){
    		System.out.println("远程服务器断开！重联！");
    		INSTANCE.downServer();
    		INSTANCE.connServer();
    	}
		return INSTANCE;
	}
    

 

 

 

 

评论

1 楼 RyanPoy 2008-11-13  

<div class='quote_title'>pengsky2002 写道</div>
<div class='quote_div'>
<p> </p>
<pre name='code' class='java'>......
public class UtilSocket {
   
    //向服务器通知内容
    public void putInfo(String str) {
        try {
            
             // 在这里作判读，如果没有连接上，就重新连接。知道连接上。
              socketWriter.println(str);
        }
        catch(Exception e) {
            System.out.println("Error reading from file: "+str);
        }
    }

}
</pre>
<p> </p>
<p> </p>
<p> </p>
</div>
<p>我想这样子也应该是可以的。</p>
<p> </p>
<p>或者，不用长连接。直接短连接。这样子也会简单很多。</p>