java单例网络实现runnable

Question

我正在编写一个网络单例类，它需要在线程中运行，到目前为止没有问题，但遗憾的是我无法让它工作。

网络类别:

public class Network extends Thread {    
    private static Network cachedInstance = new Network();

    private PrintWriter out;
    private BufferedReader in;

    private Network() {        
    }

    private void init() {
        try {
            Socket clientSocket = new Socket(Config.HOST_NAME, Config.HOST_PORT);
            out = new PrintWriter(clientSocket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));

            String fromServer;
            while ((fromServer = in.readLine()) != null) {
                System.out.println("Server: " + fromServer);
            }

        } catch (IOException ex) {
            Logger.getLogger(Controller.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public static Network getInstance() {
        return cachedInstance;
    }

    public void send(final String string) {
        out.println(string);
    }

    @Override
    public void run() {
        init();
    }
}

Controller 类的一部分:

public void clientTest() {
    int random = new Random().nextInt(1000);
    Network.getInstance().start();
    Network.getInstance().send(random + "");
}

我收到的错误:

Exception in thread "AWT-EventQueue-0" java.lang.NullPointerException
at network.Network.send(Network.java:52)
at controller.Controller.clientTest(Controller.java:126)

所以看起来单个网络实例没有正确实例化，理论上这是不可能的。

我的第二个问题是我是否可以避免使用这个:

Network.getInstance().start();

换句话说，我想确保只创建一个线程(网络类)，并且在类初始化时默认情况下它始终运行。以目前的方式来说还不错，但我只是觉得这样会更好。

对于想知道为什么我使用这种方法的人:基本上我只想使用 Network.send() 发送到固定服务器。该服务器当然也可以发回内容，但网络需要在某个时刻使用react并调用 Controller 的方法。

问候。

编辑:根据 react 提出的解决方案

网络.类:

public class Network implements Runnable {    
    private static final Network cachedInstance;
    static {
        Network tempInstance = null;
        try {
            tempInstance = new Network(Config.HOST_NAME, Config.HOST_PORT);
        } catch (IOException ex) {
            Logger.getLogger(Network.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            cachedInstance = tempInstance;
        }
    }

    private final Socket clientSocket;
    private final PrintWriter out;
    private final BufferedReader in;

    private Network(final String hostname, final int port) throws IOException {
        clientSocket = new Socket(hostname, port);
        out = new PrintWriter(clientSocket.getOutputStream(), true);        
        in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    }

    public static Network getInstance() {
        return cachedInstance;
    }

    @Override
    public void run() {
        try {
            String fromServer;
            while ((fromServer = in.readLine()) != null) {
                System.out.println("Server: " + fromServer);
            }
        } catch (IOException ex) {
            Logger.getLogger(Network.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public void send(final String string) {
        out.println(string);
    }

    public void close() {
        try {
            in.close();
            out.close();
            clientSocket.close();
        } catch (IOException ex) {
            Logger.getLogger(Network.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

调用代码:

public void clientTest() {
    int random = new Random().nextInt(1000);
    Network network = Network.getInstance();
    new Thread(network).start();
    network.send(random + "");
    network.close();
}

这仅用于测试，实际上连接需要保持打开状态，直到用户关闭程序。

Answer 1

当你在一个线程上调用start()时，在线程真正运行之前会经过一段时间。您在调用 run() 之前调用 send()，因此在初始化 out 之前。不要这样做。等待来自正在运行的线程的消息，然后才能安全地调用 send()。您可以在简单的 Object 上使用 wait() 和 notify() 来执行此操作。

为了避免客户端调用 start() - 当然，从 Network 的构造函数中调用 start()。