Java尝试使用资源未知资源计数

Question

我需要打开N个多播套接字（其中N来自参数列表的大小）。然后，我将向循环中的N个套接字中的每个套接字发送相同的数据，最后关闭每个套接字。我的问题是，如何使用try with resources块来实现这一点？以下是我将如何使用单个资源来实现这一点：

final int port = ...;
try (final MulticastSocket socket = new MulticastSocket(port)) {
    // Do a bunch of sends of small packet data over a long period of time
    ...
}

我能想到的使用多个端口执行此操作的唯一方法如下：

final List<Integer> ports = ...;
final List<MulticastSocket> sockets = new ArrayList<>(ports.size());
try {
    for (final Integer port : ports) {
        sockets.add(new MulticastSocket(port));
    }

    // Do a bunch of sends of small packet data over a long period of time
    ...
} finally {
    for (final MulticastSocket socket : sockets) {
        try {
            socket.close();
        } catch (final Throwable t) {
            // Eat the exception
        }
    }
}

有没有一种更简洁的方法来实现这一点，或者我提出的解决方案是否尽可能好？

Answer 1

匿名用户

使用ArrayList存储多播套接字实例有什么意义？

你说过：

然后，我将向循环中的N个套接字中的每个套接字发送相同的数据，最后关闭每个套接字。

因此，您可以在循环中创建它们，并为每次迭代发送相同的处理。
要做到这一点，您应该稍微改变一下您的设计。
MulticastSocket的处理任务可以由一个功能接口执行，该接口也允许指定要使用的端口。

例如：

@FunctionalInterface
public interface SocketProcessor {
    void process(MulticastSocket multicastSocket) ;
}

您可以有一个方法，将此函数接口作为参数来应用处理：

public static void processSocket(SocketProcessor socketProcessor, Integer port) throws IOException {
  try (final MulticastSocket socket = new MulticastSocket(port)) {
    socketProcessor.process(socket);
  }
}

最后，通过客户端代码，您可以创建一个带有lambda的socketProcessor实例：

SocketProcessor socketProcessor = (MulticastSocket socket) -> {
    socket.send(...);
    socket.send(...);
};

然后，您可以在端口上循环，以便使用合适的端口和刚刚创建的SocketProcator实例调用过程Socket：

for (final Integer port : ports) {
    try {
      processSocket(socketProcessor, port);
    } catch (IOException e) {
      // do processing
    }
}

这个解决方案不一定要更短（而不是更长），但它确实更清晰
两个主要问题是分开的：

>

定义具体任务的SocketProcessor。

Answer 2

你所做的几乎和它得到的一样好。

您可以创建一个AutoCloseable通用多闭包，其中包含一个List

try( MultiCloser<MulticastSocket> multiCloser = 
         new MultiCloser<>( ports.size(), i -> new MulticastSocket( ports.get( i ) ) )
{
    for( MulticastSocket socket : multiCloser.getItems() )
    {
        do something with the socket
    }
}

...但这可能是一种过度杀戮。

Answer 3

以递归的方式进行，以保证使用资源进行尝试：

void foo(List<Integer> ports, List<Socket> sockets) {
  if (sockets.size() == ports.size()) {
    // Do something with your sockets.
  } else {
    try (Socket s = new MulticastSocket(ports.get(sockets.size())) {
      sockets.add(s);
      foo(ports, sockets);
      // You could call sockets.remove(sockets.size()-1) here.
      // Not convinced whether it's worth it.
    }
  }
}