1

我在 Netty 上实现为 SIP 服务器，使用 Netty 3.x 一切正常。但是，由于定义明确的线程模型，我决定升级到 Netty 4，但事情发生了很大变化，我迷失了。我最初的问题（我得到了大部分工作，但对我来说还不太有意义）是关于MessageToByteEncoder我为什么要给ctx.writeAndFlush自己打电话。

引导程序：

private void createTCPListeningPoint() {
    this.serverBootstrap = new ServerBootstrap();

    this.serverBootstrap.group(this.bossGroup, this.workerGroup)
            .channel(NioServerSocketChannel.class)
            .childHandler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(final SocketChannel ch) throws Exception {
                    final ChannelPipeline pipeline = ch.pipeline();
                    pipeline.addLast("decoder", new SipFrameDecoder(Protocol.TCP));
                    pipeline.addLast("encoder", new SipMessageEncoder());
                    pipeline.addLast("handler", NettyNetworkStack.this.sipHandler);
                }
            });
    // .option(ChannelOption.SO_BACKLOG, 128)
    // .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000)
    // .childOption(ChannelOption.SO_KEEPALIVE, true)
    // .childOption(ChannelOption.TCP_NODELAY, true);
}

（绑定操作稍后进行，此处未显示）

由于传入管道正在工作（解码器和处理程序正在被调用），唯一有趣的部分是SipMessageEncoder，它非常简单，它的代码在下面找到。另请注意，我一直在尝试各种选项，但正如怀疑的那样，我还没有找到任何改变这种行为的组合。

编码器：

public final class SipMessageEncoder extends MessageToByteEncoder<SipMessage> {

@Override
protected void encode(final ChannelHandlerContext ctx, final SipMessage msg, final ByteBuf out) throws Exception {
    final Buffer b = msg.toBuffer();
    for (int i = 0; i < b.getReadableBytes(); ++i) {
        out.writeByte(b.getByte(i));
    }
    out.writeByte(SipParser.CR);
    out.writeByte(SipParser.LF);
    // ctx.writeAndFlush(out);
}

}

SipMessageand SipParseretc 取自我的另一个开源项目 pkts.io，但与这个问题并不真正相关。只知道SipMessage.toBuffer()本质上只是吐出一个原始byte[]内容，然后我将其转移到ByteBuffNetty 传入的内容中。

除非我这样做，否则上面的代码不起作用ctx.writeAndFlush(out)。然而，我认为，就像在 Netty 3 中一样，这个稍微高级一点的编码器的目的是为了保护我免受这些细节的影响。逐步调试ByteBuf写入ctx但未刷新的代码，我猜这是它没有出现在套接字上的原因。所以，我的问题很简单：

  • 为什么ctx.writeAndFlush我在使用SipMessageEncoder. Factorial 示例中没有这样做，NumberEncoder并且通过 HTTP 编解码器查看我也看不到它这样做，所以很明显我错过了一些明显的东西。
  • 此外，ByteBuf正在写入上下文但从不刷新，所以什么时候会？我试图通过单个 TCP 连接（使用 sipp）推送大量流量，看看这是否最终会强制刷新，但不，什么都没有出现。

顺便说一句，我还尝试使用MessageToMessageEncoder并通过上下文分配 ByteBuf 并将其添加到List相同的结果中。

顺便说一句——我使用的是 Netty 4.0.10.Final

谢谢，

/乔纳斯

4

1 回答 1

1

向通道写入消息时，您是否在其他地方调用了 flush() ？

“..你必须非常小心，不要忘记在写完之后调用 ctx.flush()。或者，你可以使用快捷方法 writeAndFlush()”

实际上，您不需要在 SipMessageEncoder 中调用 write()，因为消息将由父 MessageToByteEncode 写入。如果之前没有完成，您只需要调用 flush() 即可。

于 2013-10-14T05:41:32.450 回答