Netty

[acmi]

Тогда да. Дешифруем и разделяем.

[shocked]

Подскажите что не так делаю. Ниже работающий правильно вариант, но без Lenght decodera.
[src=java]
@Override
public ChannelPipeline getPipeline() throws Exception {

final ChannelPipeline pipeline = Channels.pipeline();

pipeline.addLast("decoder", new PacketFrameDecoder());

pipeline.addLast("encoder", new PacketFrameEncoder());

pipeline.addLast("executor", getExecutorHandler());

pipeline.addLast("handler", new ClientChannelHandler()); //Client logic

return pipeline;
}
[/src]
Если его добавить , то не один не отрабатывает, только коннект происходит.
[src=java]
public class LengthDecoder extends LengthFieldBasedFrameDecoder {

private static final Logger log = LoggerFactory.getLogger(LengthDecoder.class.getSimpleName());

public LengthDecoder() {
super(Short.MAX_VALUE, 0, 2);
}

@Override
protected Object decode(ChannelHandlerContext ctx, Channel channel, ChannelBuffer buffer) throws Exception {
log.info("Lengh Based Decoder, decode()");

log.info(NetUtils.getHexDump(buffer.array()));

return super.decode(ctx, channel, buffer); //To change body of overridden methods use File | Settings | File Templates.
}
}
[/src] Добавлял после первого декодера.

[acmi]

В декодерах проверь, что они возвращяют. Если null, то нужно разобраться почему.

[shocked]

У них метод decode() даже не вызывается , если добавить этот LenghtDecoder

[acmi]

А сам LenghtDecoder не null возвращает?

[shocked]

Не вызывается вообще, и не возвращает ничего ) В pipeline важен же порядок, в каком добавлять ? Если там один pipeline.addLast("decoder", new PacketFrameDecoder());, то все хорошо работает, если после него еще один pipeline.addLast("Lenghtdecoder", new LengthDecoder());, то ни один из них не вызывается
На русском статей кроме хабра нету больше информации по netty ?

[acmi]

У меня все обработчики в таком же порядке, и все работает. Могу лишь посоветовать попробовать поменять местами или начать добавлять с минимума.
Единственная проблема с LengthFieldBasedFrameDecoder`ом у меня была из-за того, что я не указал в Bootstrap`e, что нужно создавать буферы с порядком байт little endian.

[shocked]

ChannelBuffer обработанный должен идти дальше по обработчикам в порядке, который указан так ?

[acmi]

Так) Только не обязательно ChannelBuffer, сигнатура метода protected Object decode(... Можете что угодно передавать, главное чтобы дальше этот объект правильно обработали.

[shocked]

А как в Bootstrape сделать littleEndian ?, а то я в декодере возвращаю
[src=java]return ChannelBuffers.wrappedBuffer(ByteOrder.LITTLE_ENDIAN, allData);[/src]