了解 Java NIO Socket Channel 中 NullPointerException 的原因

Question

我使用 java nio 组合了一个简单的 echo 类型服务器应用程序。虽然它能够写入数据，但它总是抛出以下异常。谁能解释为什么会发生这种情况？我的代码如下。在创建包含 run 方法的线程之前，我确保 key.isAcceptable() 为 true。

线程“pool-1-thread-2”中出现异常 java.lang.NullPointerException

ExecutorService pool = Executors.newFixedPool(5);
...
try {
    pool.execute(                                           
        new Thread() {
            @Override public void run() {
                ServerSocketChannel ssc = (ServerSocketChannel) key.channel();
                SocketChannel sc = null;
                try {
                    sc = ssc.accept();
                    String response = "Server thread (" + Thread.currentThread().getId() + ") Current time: " + new Date();
                    ByteBuffer bytes = encoder.encode(CharBuffer.wrap(response));
                    sc.write(bytes);
                } catch (java.io.IOException e) {
                    System.out.println("Exception: " + e.getMessage());                                                                              
                } finally {
                    try {
                        if (sc.isOpen()) sc.close(); // This is the line causing the exception to be thrown. If the check is changed to (sc != null) no exceptions are thrown.
                    } catch (java.io.IOException e) {
                        System.out.println("Exception: " + e.getMessage());
                    }
                }
            }
        }
    );
} catch (java.lang.Exception e) {
    System.out.println("Interrupted!");
}               

线程“pool-1-thread-2”中出现异常 60java.lang.NullPointerException

 在 EchoServer$1.run(EchoServer.java:61)
    在 java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec

utor.java:886) 在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:908) 在 java.lang.Thread.run(Thread.java:619)

Answer 1

我猜测 ssc.accept 返回的 SocketChannel 为 null，这又意味着 ServerSocketChannel 处于非阻塞模式并且没有挂起的连接。

Answer 2

ServerSocketChannel 的 Javadoc 说：

If this channel is in non-blocking mode then this method will immediately 
return null if there are no pending connections. Otherwise it will block 
indefinitely until a new connection is available or an I/O error occurs.

您确定 ssc.accept() 不会因为这个原因返回 null 吗？

Answer 3

正如@IainM和@QuantumMechanic所建议的，您没有检查“sc”是否为空。如果 NPE 出现在 sc.close() 中，“sc”为 null，我会说您有一个 NPE 调用 sc.write()，而在 finally{} 块中调用 sc.close() 则有另一个 NPE。

您也没有检查 write() 的结果，因此您可能只写了部分消息，或者实际上什么也没写。您还对 sc.isOpen() 进行了完全毫无意义的测试。这段代码中要么为 null，要么为 open，没有其他可能。

我不知道当它不读取任何输入时，如何将其称为回显服务器。

这不是使用 NIO 的方式。整个想法是您不需要额外的线程。你的整个设计有严重的问题。

你打印“Interrupted!”也是在欺骗自己。 任何异常，并通过不打印其消息或堆栈跟踪来隐藏实际异常。这也不是使用异常的方法。