您的位置:首页 > 其它

令人郁闷的socket重联问题

2008-11-12 16:09 260 查看
最近弄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;
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: