в netty мы можем только записывать и получать данные меньше 1024 байт: как мы можем писать или получать больше?

Попробуйте использовать TruncatedChannelBuffer или BigEndianHeapChannelBuffer вместо буфера каналов в ClientHandler. Я думаю, что это сработает ... или, если это не сработает, пожалуйста, опубликуйте трассировку стека сгенерированного исключения. Я попробовал это в своем коде, и это сработало. Надеюсь, это поможет вам.

public void messageReceived(ChannelHandlerContext channelHandlerContext,MessageEvent messageEvent) throws Exception {

    Object messageObject = messageEvent.getMessage();

    // if size of message < 1024 then TruncatedChannelBuffer is returned.

    if (messageObject instanceof TruncatedChannelBuffer) {

        try {

            TruncatedChannelBuffer truncatedChannelBuffer = (TruncatedChannelBuffer) messageObject;

            byte[] byteArray = new byte[truncatedChannelBuffer.readableBytes()];

            truncatedChannelBuffer.readBytes(byteArray);

            System.out.print(" Message = "+new String(byteArray));

            truncatedChannelBuffer.clear();

        } catch (Exception e) {

            System.out.println("Exception in MessageReceived...");

            e.printStackTrace();


        }
    }
    // if size of message > 1024 then BigEndianHeapChannelBuffer is returned.

    if (messageObject instanceof BigEndianHeapChannelBuffer) {

        try {

            BigEndianHeapChannelBuffer bigEndianHeapChannelBuffer = (BigEndianHeapChannelBuffer) messageObject;

            byte[] byteArray  = new byte[bigEndianHeapChannelBuffer.readableBytes()];

            bigEndianHeapChannelBuffer.readBytes(byteArray);

            System.out.print(" Message = "+new String(byteArray));

            bigEndianHeapChannelBuffer.clear();


        } catch (Exception e) {

            System.out.println("Exception in MessageReceived...");

            e.printStackTrace();

        }
    }

}       

Прежде всего, для клиента параметр начальной загрузки не должен начинаться с «дочернего»:

bootstrap.setOption("tcpNoDelay", true);
bootstrap.setOption("keepAlive", true);

Также вы не используете один и тот же порт на клиенте и сервере!!

Во-вторых, у вас нет «закрытой» стратегии: когда ваш клиент должен знать, что его работа выполнена? Как предотвратить преждевременное завершение темы? Вы должны сделать это

ОБРАБОТЧИК СЕРВЕРА

public class ServerHandler extends SimpleChannelHandler{

    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e){
        byte[] resp=data.getBytes();//data is a String greater than 1024bytes;
        ChannelBuffer buffer=ChannelBuffers.buffer(resp.length);
        buffer.writerBytes(resp);
        e.getChannel().write(buffer);
        buffer.clear();
        e.getChannel.close();
    }
}

ЗАГРУЗКА КЛИЕНТА

public class Client{
    public static void main(String[] args){
        ChannelFactory channelFactory=new NioClientSocketChannelFactory(
            Executors.newCachedThreadPool(),
            Executors.newCachedThreadPool());
        ClientBootstrap bootstrap=new ClientBootstrap(channelFactory);
        bootstrap.getPipeline().addLast("handler", new PhoneClientHandler());

        bootstrap.setOption("child.tcpNoDelay", true);
        bootstrap.setOption("child.keepAlive", true);

        // Start the connection attempt.
        ChannelFuture future = bootstrap.connect(new InetSocketAddress("127.0.0.1",8181));

        // Wait until the connection is closed or the connection attempt fails.
        future.getChannel().getCloseFuture().awaitUninterruptibly();

        // Shut down thread pools to exit.
        bootstrap.releaseExternalResources();
    }
}

Наконец, вам нужно лучше понять, что вы делаете, прочитав множество примеров. Их можно найти внутри пакета org.jboss.netty.example в основном пакете загрузки.

У меня была такая же проблема, попробуйте использовать Oio, а не Nio! (просто измените «nio» на «oio» и «Nio» на «Oio».

http://lists.jboss.org/pipermail/netty-users/2009-June/000891.html

RenaudBlue@ делает хорошие выводы. Кроме того, я предлагаю переключиться на Netty4, который делает все ByteBuf динамическими и упрощает управление чтением/записью по частям. См. "Перенос клиента".

Например,

private void sendNumbers() {
  // Do not send more than 4096 numbers.
  boolean finished = false;
  MessageBuf<Object> out = ctx.nextOutboundMessageBuffer();
  while (out.size() < 4096) {
      if (i <= count) {
          out.add(Integer.valueOf(i));
          i ++;
      } else {
          finished = true;
          break;
      }
  }

  ChannelFuture f = ctx.flush();
  if (!finished) {
      f.addListener(numberSender);
  }
}

private final ChannelFutureListener numberSender = new ChannelFutureListener() {
  @Override
  public void operationComplete(ChannelFuture future) throws Exception {
      if (future.isSuccess()) {
          sendNumbers();
      }
  }
};

Netty4 также имеет безопасность типов для конфигурации параметров канала, что предотвратило бы ошибку "child.tcpNoDelay".

Но большим преимуществом Netty4 является четко определенная модель потоков, которая делает Netty намного проще в использовании.

Вам необходимо настроить FixedRecvByteBufAllocator из SocketChannel в childHandler() следующим образом:

bootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel ch) throws Exception {
                ch.config().setRecvByteBufAllocator(new FixedRecvByteBufAllocator(2 * 1024));
                ChannelPipeline pipeline = ch.pipeline();
                pipeline.addLast("idleStateHandler", new IdleStateHandler(0, 0, 5));
                pipeline.addLast(new StringEncoder());
                pipeline.addLast(new StringDecoder());
                ...
            }
        });