小编ope*_*ter的帖子

我在我的开源项目中使用Apache MINA.但是,我遇到了一个性能障碍,它无法处理从移动设备上传到服务器的大型有效负载.我出现内存不足错误.我从未使用Netty,并希望将MINA与Netty交换.

我对Netty团队的问题是,Netty如何在大量传入的有效载荷下运行.在我的性能测试中,我使用1000个并发设备生成负载,每个设备发送1MB大小的有效负载.它倾向于在5分钟内生成1GIG的上传数据.这种负荷往往会破坏MINA.

Netty可以支持这种负载吗？非常感谢您对此的意见.

顺便说一句:我确实使用JProfiler对应用程序进行了分析.它确实指出MINA堆栈是罪魁祸首.我甚至完全断开了我的服务器端堆栈并将其留在了消耗数据并返回数据的普通MINA服务器上.在这种模式下,即使我的后端没有真正的处理,它在大约15到20分钟内开始耗尽内存

我正在为我的项目制作Netty原型.我试图在Netty上实现一个简单的面向文本/字符串的协议.在我的管道中,我使用以下内容:

public class TextProtocolPipelineFactory implements ChannelPipelineFactory
{
@Override
public ChannelPipeline getPipeline() throws Exception 
{
    // Create a default pipeline implementation.
    ChannelPipeline pipeline = pipeline();

    // Add the text line codec combination first,
    pipeline.addLast("framer", new DelimiterBasedFrameDecoder(2000000, Delimiters.lineDelimiter()));
    pipeline.addLast("decoder", new StringDecoder());
    pipeline.addLast("encoder", new StringEncoder());

    // and then business logic.
    pipeline.addLast("handler", new TextProtocolHandler());

    return pipeline;
}
}

我在管道中有DelimiterBasedFrameDecoder,String Decoder和String Encoder.

由于此设置,我的传入消息被拆分为多个字符串.这导致我的处理程序的"messageReceived"方法的多次调用.这可以.但是,这需要我在内存中累积这些消息,并在收到消息的最后一个字符串数据包时重新构造消息.

我的问题是,什么是"积累字符串"然后"将它们重新构造成最终消息"的最有效的内存方式.到目前为止我有3个选项.他们是:

• 使用StringBuilder积累和toString来构造.(这给出了最差的内存性能.事实上,对于具有大量并发用户的大型有效负载,这会产生不可接受的性能)

• 通过ByteArrayOutputStream累积到ByteArray中,然后使用字节数组构造(这提供了比选项1更好的性能,但它仍然占用了相当多的内存)

• 累积到Dymamic Channel Buffer并使用toString(charset)来构造.我还没有介绍过这种设置,但我很好奇这与上述两个选项相比如何.有没有人使用动态通道缓冲区解决了这个问题？

我是Netty的新手,我可能在架构上做错了.非常感谢您的意见.

在此先感谢Sohil

添加我的自定义FrameDecoder实现供Norman审查

public final class TextProtocolFrameDecoder extends FrameDecoder 
{
public static ChannelBuffer messageDelimiter() 
{
      return …