服务端
public void run() {
try {
System.out.println(socket.toString());
socket.setKeepAlive(true);
socket.setSoTimeout(5 * 1000);
InputStream in= socket.getInputStream();
PrintWriter out=new PrintWriter(socket.getOutputStream());
//BufferedReader wt = new BufferedReader(new InputStreamReader(System.in));
while (true) {
String strXML = "";
byte[] temp = new byte[1024];
int length = 0;
while((length = in.read(temp)) != -1){
strXML += new String(temp,0,length);
}
if("1".equals(strXML)){
out.print((char)1);
System.out.println("接受心跳包并回复");
break;
}
if("".equals(strXML))
continue;
System.out.println("客户端发来:"+strXML.toString());
// MethodHandler mh = new MethodHandler(ReadXML.readXML(strXML.toString()));
// String resultXML = mh.getResultXML();
// System.out.println("返回:"+resultXML.toString());
//
//
// if(!"".equals(resultXML)){
// out.print(resultXML);
out.flush();
out.close();
// }
}
socket.close();
System.out.println("socket stop.....");
} catch (Exception e) {
e.printStackTrace();
}
}
客户端