看代码,不明白的追问
// 无穷循环,用于自动重新连接网关
while (true) {
// 捕获sleep异常
try {
// 捕获socket异常
try {
// 创建socket连接
socketGateway = new Socket("127.0.0.1", 8888);
// 创建输入输出对象
inStream = new DataInputStream(socketGateway.getInputStream());
outStream = new DataOutputStream(socketGateway.getOutputStream());
byte buf[] = new byte[1]; // 数据缓冲区
int intLen; // 读缓冲区返回的长度
// 无穷循环,用于读缓冲区数据
while (true) {
// 捕获读缓冲区异常
try {
intLen = inStream.read(buf, 0, 1);
// 可读长度-1则断开连接
if (intLen == -1) {
break;
}
// 处理buf
}
// 连接断开
catch (EOFException e) {
break;
}
// 接收数据超时
catch (SocketTimeoutException e) {
break;
}
// 超过数据包末尾
catch (IOException e) {
break;
}
}
} catch (Exception e) {
// 处理socket错误
}
// 休眠1秒后重连
sleep(1000);
} catch (Exception e) {
// 处理sleep错误
}
}
有两种办法:
客户端主动连,按某一时间间隔尝试与服务端连接;
服务端通知,服务端(非正常关闭)重启后向所有记录的连接客户端发重连请求。
--代码现在没时间写,你自己试着写下吧!
--希望能帮到你!!