Java服务器套接字程序在一天后停止监听 [英] Java server socket program after one day it stops listening

问题描述

我有一台服务器，并且该机器运行服务器套接字代码. 我已经使用线程池来维护线程. 问题是，当我启动服务器套接字时，它的监听很好. 但是第二天，我看到控制台在某种程度上暂停了，没有监听任何TCP数据包. 没有生成异常. 在Java服务器上侦听数据包有任何限制吗? 我该如何解决这个问题?

I have a server and that machine i run the server socket code. I have used thread pool to maintain the thread. The problem is, when i start the server socket it's listening fine. But the next day i see the console that is paused at some level and no listening at any TCP packets. There is no exception generated. Is there any limit of listening packets on server in java? How can i resolve this problem?

服务器类

public final class Server {

    private final ServerSocket serverSocket;
    private final ExecutorService pool;



    public Server(int port, int poolSize)
            throws IOException {
        serverSocket = new ServerSocket(port);
        pool = Executors.newFixedThreadPool(poolSize);


        System.out.println("Server running...");
        runServerEngine();
    }

    public void runServerEngine() { // run the service
        try {
            while (true) {
                System.out.println("user come ");
                pool.execute(new Handler(serverSocket.accept()));
            }
        } catch (IOException ex) {
            System.out.println("Error " + ex);


            //pool.shutdown();
        }
    }

    public static void main(String[] args) throws IOException {
        Server server = new Server(1256, 20);//port number and pooling size
    }
}

处理程序类

class Handler implements Runnable {

    private Socket socket = null;
    //private static Location location = new Location();


    Handler(Socket socket) {
        this.socket = socket;

    }

    private Handler() {
    }
    String recievedPacket = null;

    @Override
    public void run() {
        // read and service request on socket
        try {
            BufferedReader in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));

            while ((recievedPacket = in.readLine()) != null) {
                //recievedPacket = in.readLine();
                System.out.println("Recieved packate " + recievedPacket);

                if (recievedPacket != null) {
                    try {
                        System.out.println("Saving function " + recievedPacket);


                    } catch (Exception ex) {
                         System.out.println(ex);
                    }

                }

            }

        } catch (IOException ex) {
           System.out.println(ex);
        }
    }
}

推荐答案

尝试在Handler的finally块中关闭in和socket，以确保您的系统没有资源不足.

Try closing the in and socket in finally block of Handler to make sure your system is not out of resources.

@Override
public void run() {
    // read and service request on socket
    BufferedReader in = null;
    try {
        in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));

        while ((recievedPacket = in.readLine()) != null) {
            //recievedPacket = in.readLine();
            System.out.println("Recieved packate " + recievedPacket);

            if (recievedPacket != null) {
                try {
                    System.out.println("Saving function " + recievedPacket);


                } catch (Exception ex) {
                     System.out.println(ex);
                }

            }

        }

    } catch (IOException ex) {
       System.out.println(ex);
    } finally {
        if (in != null) {
            try {
                in.close();
            } catch (IOException ex) {
                // No-OP
            }

        }

        if (socket != null) {
            try {
                scoket.close();
            } catch (IOException ex) {
                // No-OP
            }
        }
    }
}

如果您使用的是Java 7+，则可能需要查看尝试使用资源.

If you are Java 7+ you may want to have a look on try with resources.

这篇关于Java服务器套接字程序在一天后停止监听的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！