【发布时间】:2017-05-09 13:23:01
【问题描述】:
我有一个经典的服务器多客户端程序。服务器监听 ServerSocket 并为每个传入的套接字构建一个新的 Runnable 类并在 ExecuteService 中执行它。
在 Runnable 类的 run 方法中,我打开 try-with-resources 块,在 try 中我有一个 while 循环,它从 inputstream 读取并写入 outputstream,直到它收到来自客户端的 FIN 命令。一切正常,客户端成功断开连接。运行到达 finally 块并打印一些用于测试的东西,但它没有退出 try 块,因此它没有退出 run 方法,我被困在 run 的某个地方,可能是输入流的 read 方法。
如果有人感兴趣,我可以发布代码。
如何强制关闭 finally 中的所有内容并退出 run 方法?
代码:
服务器.java:
public static void main(String[] args) {
playersReady = new ArrayList<Integer>();
ServerSocket server = null;
try {
server = new ServerSocket(Consts.PORT);
ExecutorService service = Executors.newFixedThreadPool(characters.size());
while(playersReady.size()<characters.size()){
RequestHandler handler = new RequestHandler(server.accept());
service.execute(handler);
}
service.shutdownNow();
service.shutdown();
while(!service.isTerminated()){}
System.out.println("finished");
RequestHandler.java
public final class RequestHandler implements Runnable {
.....
public void run() {
//DataOutputStream output = null;
//DataInputStream input = null;
try (DataOutputStream output = new DataOutputStream(socket.getOutputStream());
DataInputStream input = new DataInputStream(socket.getInputStream())){
// socket.setSoTimeout(500);
handleReady(input.readUTF().split(" "), output);
while (/*!shutdown && !socket.isClosed() && */socket.isConnected()) {
System.out.println("check before read " + character.getId());
String request = input.readUTF();
System.out.println("check after read " + character.getId());
System.out.println("-----------------------------------" + request);
if (shutdown) {
socket.shutdownInput();
socket.getOutputStream().flush();
socket.shutdownOutput();
break;
}
String[] requestParser = request.split(" ");
if (requestParser[1].equals("DMG")) {
// handle damage request
handleDamage(requestParser, output);
} else if (requestParser[1].equals("BND")) {
// handle bandage request
handleBandage(requestParser, output);
} else if (requestParser[1].equals("FIN")) {
// handle finish request
handleFin();
if (!socket.isClosed())
socket.shutdownInput();
if (!socket.isClosed()) {
socket.getOutputStream().flush();
socket.shutdownOutput();
}
shutdown = true;
break;
} else {
break;
}
}
} catch (SocketTimeoutException e) {
System.out.println(e.getMessage());
} catch (IOException e) {
e.printStackTrace();
shutdown = true;
break;
} catch (Throwable e) {
e.printStackTrace();
} finally {
try {
System.out.println("finished");
if (!socket.isClosed())
socket.shutdownInput();
if (!socket.isClosed()) {
socket.getOutputStream().flush();
socket.shutdownOutput();
socket.close();
}
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
System.out.println("Done run");
}
....
finally 中的System.out.println("finished") 被打印出来,
但是run方法末尾的System.out.println("Done run")没有!!
为什么?
它卡在 run 方法中,我认为是在 readUTF 调用中,但我关闭了所有资源!
【问题讨论】:
-
你试过调试你的程序吗?您的“我认为在 readUTF 调用中”有点含糊。
-
我试过了,没什么特别的,它通过了run方法,上到java的Runnable类并停止,但线程继续运行
标签: java sockets try-with-resources