Java中的SCTP一对多答案

【问题标题】：SCTP one-to-many in JavaJava中的SCTP一对多
【发布时间】：2012-08-06 08:03:29
【问题描述】：

我正在使用 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();
    }

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

有人有这方面的经验吗？

最好，亨里克

【问题讨论】：

添加问题中的错误。

标签： java sctp

【解决方案1】：

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

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

【讨论】：