2

我有一个小型服务器设置，我正在尝试使用基于事件的连接套接字，以便在每个传入连接上调用处理程序。它适用于第一个连接，但在第一个连接之后不接受任何新连接。

为简单起见，我只是关闭客户端连接。另外，是的，第一次连接后服务器仍在运行，它不会终止。

这是代码：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.AsynchronousChannelGroup;
import java.nio.channels.AsynchronousServerSocketChannel;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;


public class ServerTest
{
static CompletionHandler<AsynchronousSocketChannel, Object> handler =
        new CompletionHandler<AsynchronousSocketChannel, Object>() {
        @Override
        public void completed(AsynchronousSocketChannel result, Object attachment) {
            System.out.println(attachment + " completed with " + result + " bytes written");
            try {
                result.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        @Override
        public void failed(Throwable e, Object attachment) {
            System.err.println(attachment + " failed with:");
            e.printStackTrace();
        }
    };

public static void main(String[] args) throws Exception
{
    AsynchronousChannelGroup group = AsynchronousChannelGroup.withThreadPool(Executors.newSingleThreadExecutor());
    System.out.println("STARTING");
    AsynchronousServerSocketChannel ssc =
        AsynchronousServerSocketChannel.open(group).bind(new InetSocketAddress("localhost", 9999));

    System.out.println("BOUND");
    ssc.accept(ssc, handler);

    group.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);

}
}
4

1 回答 1

0

公共抽象无效接受（附件，CompletionHandler 处理程序）

此方法启动异步操作以接受与此通道的套接字建立的连接。handler 参数是一个完成处理程序，在接受连接（或操作失败）时调用。传递给完成处理程序的结果是新连接的 AsynchronousSocketChannel。

在这里阅读更多

这意味着它初始化一个异步线程来接受传入的连接。这也意味着它将获取第一个连接并将其转发到异步线程，然后等待更多连接。要允许更多客户端连接，您还必须在覆盖的已完成函数内调用接受方法。

这是一个例子，

server.accept(null, new CompletionHandler<AsynchronousSocketChannel,Void>() {
@Override
public void completed(AsynchronousSocketChannel chan, Void attachment) {
    System.out.println("Incoming connection...");
    server.accept(null, this); //add this

    //...

需要注意的是，对于每个客户端，都会产生一个新的 AsynchronousSocketChannel 结果。话虽如此，如果您要打印出“chan”，则会产生不同的对象。

不同的客户对象

于 2018-03-12T04:00:02.657 回答