SCTP 在 Java 中的一对多

Question

我正在使用Java使用Java和SCTP协议创建一对多连接。

我已经启动并运行了 SctpMultiChannel，我可以接收消息，但是需要做一些特殊的事情来向所有连接发送消息吗？

The error message:
java.net.SocketException: Invalid argument
    at sun.nio.ch.SctpChannelImpl.send0(Native Method)
    at sun.nio.ch.SctpMultiChannelImpl.send0(SctpMultiChannelImpl.java:976)
    at sun.nio.ch.SctpMultiChannelImpl.sendFromNativeBuffer(SctpMultiChannelImpl.java:888)
    at sun.nio.ch.SctpMultiChannelImpl.send(SctpMultiChannelImpl.java:847)
    at sun.nio.ch.SctpMultiChannelImpl.send(SctpMultiChannelImpl.java:824)
    at org.test.MultiServer.run(MultiServer.java:56)

和完整的代码：

SocketAddress serverSocketAddress = new InetSocketAddress(SOCKET_PORT);
    SctpMultiChannel smc;
    try {
      Logger.info("Start");
      smc = SctpMultiChannel.open().bind(serverSocketAddress);
      ByteBuffer buf = ByteBuffer.allocateDirect(160);
      Charset charset = Charset.forName("ISO-8859-1");
      CharsetDecoder decoder = charset.newDecoder();
      AssociationHandler assocHandler = new AssociationHandler();
      MessageInfo messageInfo;
      while ((messageInfo = smc.receive(buf, System.out, assocHandler)) != null) {
        Logger.debug(messageInfo.toString());
        buf.flip();
        Logger.debug(decoder.decode(buf).toString());
        Logger.info(smc.associations().size() + "");
        ByteBuffer buf1 = ByteBuffer.allocateDirect(60);
        CharBuffer cbuf1 = CharBuffer.allocate(60);
        charset = Charset.forName("ISO-8859-1");
        CharsetEncoder encoder = charset.newEncoder();
        cbuf1.put("foo").flip();
        encoder.encode(cbuf1, buf1, true);
        buf1.flip();
        for (Association ass : smc.associations()) {
          MessageInfo mi = MessageInfo.createOutgoing(ass, null, 1);
          smc.send(buf, mi);
        }
        cbuf1.clear();
        buf1.clear();
        buf1.flip();
      }
      smc.close();
    } catch (IOException e) {
      Logger.error("Server error");
      e.printStackTrace();
    }

这就是我到目前为止所做的，我的客户端发送一条消息，然后等待接收新消息。我的目标是采用一种非阻塞方法，以便我可以在同一通道上发送和接收消息，而不是使用接收查询进行阻塞。

有人在这方面有任何经验吗？

最好亨利

Answer 1

从错误中我可以说消息信息不正确。尝试只发送一条消息而不循环。静态设置地址。

此外，在 SctpMultiChannel 的情况下，第一次发送会建立连接 - 由于关联未建立，您如何能够循环关联？这是整个代码吗？