Java Socket 的应用程序随机停止

Question

服务器

public void run () {

 Socket serversocket = new ServerSocket(port);
 while(true) {
   new Thread(new ServerThread(serverSocket.accept())).start();
 }
}
//serverSocket.close(); etc

服务器线程

public void run() {
 BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

 String input;

 while(true) {
   input = in.readLine();
   new Thread(new RequestThread(clientSocket, input)).start();
 }
}
//close sockets etc in.close() clientSocket.close();

请求线程

public void run() { 
 //input was passed from constructor
 String output = new SomeProtocol(input);

 if(output == null)
  break;
 //true for auto flush
 PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
 out.println(output);
}//closing out seems to also close the socket, so opted to not to close it, maybe this is the one giving me trouble?

监控

public class ServerMonitor implements Runnable{
    private ServerThread server;
    private LoggingClass log = LoggingClass .getInstance();
    private int heartbeat = 0;

    public ServerMonitor(ServerThread server) {
        this.server = server;
    }

    public boolean checkFile() {
        File file = new File("cmd//in//shutdown.txt");
        return file.exists();
    }

    public void run() {

        log.logToFile("Server monitor running");

        while (true) {
            incHeartbeat();
            if (checkFile()) {
                log.logToFile("Shutting down server");
                break;
            }
            writeStatus();
            this.delay(5000);
        }

        log.logToFile("Server monitor stopped");
    }

    public void delay(long delay) {
        try {
            wait(delay);
        } catch (InterruptedException e) {
            log.logToFile("Monitor sleep error");
            e.printStackTrace();
        }
    }

    public void writeStatus() {
        try {
            BufferedWriter out = new BufferedWriter(new FileWriter(
                    "sys//status//status.txt"));
            out.write("Start date:" + log.getStartDate());
            out.newLine();
            out.write("Current date:" + log.getTimestamp("yyyy-MMM-dd k:mm:ss"));
            out.newLine();
            out.write("Heartbeat:" + getHeartbeat());
            out.newLine();
            out.write("Cimd in:" + log.getCimdIn());
            out.newLine();
            out.write("Cimd out:" + log.getCimdOut());
            out.newLine();
            out.write("Keep alive:" + log.getCimdKeepAlive());
            out.newLine();
            out.write("HTTP in:" + log.getNumHTTPIn());
            out.newLine();
            out.write("HTTP out:" + log.getNumHTTPOut());
            out.newLine();
            out.close();

        } catch (Exception e) {
            log.logToFile("Write status error");
            e.printStackTrace();
        }
    }

    public int getHeartbeat() {
        return heartbeat;
    }

    public synchronized void incHeartbeat() {
        heartbeat++;
    }
}

这是我的应用程序的粗略骨架。我遇到了麻烦，因为有时它只是停止而没有任何错误。我怀疑这可能是因为插座，但我不太确定，所以你们中的任何人有什么想法吗？谢谢。

---

添加了我的监控服务器线程的类

>How do I know that it doesn't work

心跳不再增加

Answer 1

您可能内存/线程不足

你是否碰巧有一些像这样的高级异常处理：

public static void main( String ... args ) {
    try {
        // lots of code ... 
    } catch( Exception e ) {}
}

如果是这样，您至少必须记录您忽略的错误。

这正是我想到的，因为我手头没有你的源代码。

Answer 2

您能否更好地定义“停止工作”？它是否停止接受连接？它会崩溃吗？它是否在处理过程中停止做某事？等等？

有一点猜测是，当套接字关闭时，我不确定读者会发生什么。我期望发生的是，尝试使用关闭的套接字调用 read 行会导致异常，这将停止该线程，和/或可能终止整个应用程序。这会产生堆栈跟踪和其他问题。

基本上，除了 Oscar 所说的 main 中的异常日志；你会想要登录任何 run() 方法。 main 中的 try/catch 只会捕获主线程抛出的异常；不是那些在其他线程中抛出的。

Answer 3

很难从您发布的伪代码中看出，但如果应用程序挂起（而不是彻底崩溃），我最好的猜测是 ServerThread 中的 in.readLine() 正在阻塞。如果应用程序刚刚关闭，我会查看套接字闭包，并可能在 BufferedReader 中检查 isReady()。

一般性评论：您在这里生成的线程可能比您需要的多。看起来从客户端套接字读取和写入它是串行发生的。如果是这种情况，ServerThread Runnable（我假设它是 Runnable，因为您将其传递给 Thread 的构造函数）不一定需要生成 RequestThread。

public class ServerRunnable implements Runnable {
    ...

    public void run() {
        BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

         String input;

         while(true)
         {
           input = in.readLine();
           if(input == null)
           {
               //this means the underlying socket closed
               //log something here or return or whatever
           }

           String output = new SomeProtocol(input);

           if(output == null)
            break;
           //true for auto flush
           PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
           out.println(output);
         }
    }
    ...
}