|
@@ -57,6 +57,9 @@ public class ExecutionServer {
|
|
|
|
|
|
|
|
System.out.println("等待客户机的连接");
|
|
System.out.println("等待客户机的连接");
|
|
|
client = server.accept();
|
|
client = server.accept();
|
|
|
|
|
+
|
|
|
|
|
+ reader = new BufferedReader(new InputStreamReader(client.getInputStream(), "GB2312"));
|
|
|
|
|
+ writer = new BufferedWriter(new OutputStreamWriter(client.getOutputStream(), "GB2312"));
|
|
|
System.out.println("连接成功");
|
|
System.out.println("连接成功");
|
|
|
} catch (IOException e) {
|
|
} catch (IOException e) {
|
|
|
e.printStackTrace();
|
|
e.printStackTrace();
|
|
@@ -64,8 +67,6 @@ public class ExecutionServer {
|
|
|
}
|
|
}
|
|
|
public String ExecutionData(String msg) {
|
|
public String ExecutionData(String msg) {
|
|
|
try {
|
|
try {
|
|
|
- reader = new BufferedReader(new InputStreamReader(client.getInputStream(), "GB2312"));
|
|
|
|
|
- writer = new BufferedWriter(new OutputStreamWriter(client.getOutputStream(), "GB2312"));
|
|
|
|
|
System.out.println("测试完成!");
|
|
System.out.println("测试完成!");
|
|
|
String returnMsgReplace = "";
|
|
String returnMsgReplace = "";
|
|
|
System.out.println("第1路闭合,发送指令:"+msg);
|
|
System.out.println("第1路闭合,发送指令:"+msg);
|
|
@@ -101,13 +102,6 @@ public class ExecutionServer {
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
log.info(e.toString());
|
|
log.info(e.toString());
|
|
|
throw new RuntimeException("指令执行失败");
|
|
throw new RuntimeException("指令执行失败");
|
|
|
- }finally {
|
|
|
|
|
- try {
|
|
|
|
|
- if (reader != null) reader.close();
|
|
|
|
|
- if (writer != null) writer.close();
|
|
|
|
|
- } catch (IOException e) {
|
|
|
|
|
- e.printStackTrace();
|
|
|
|
|
- }
|
|
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|