服務器沒有收到消息

即時通訊正在嘗試學習netty，只是沒有任何工作...）：不知何故，服務器不接收任何來自客戶端的消息，我不知道爲什麼。請記住，我從來沒有在netty中構建一個工作應用程序，所以我絕對沒有經驗。如果有人能幫助我，我會很高興。林張貼了很多代碼，並很抱歉，但我不知道如何使這個問題更小。服務器沒有收到消息

所以，這是我的代碼：

new Server().run(); 
    Client client = new Client(); 
    client.run(); 

    while(true){ 
     System.out.println("sending message to server..."); 
     client.sendMessage(new PacketPing(System.currentTimeMillis())); 
     Thread.sleep(1000); 
    }

這是我的客戶：

private Channel channel; 
@Override public void run() { 
    ChannelFuture future = new Bootstrap(). 
      group(new NioEventLoopGroup()). 
      channel(NioSocketChannel.class). 
      handler(new ChannelInitializer<SocketChannel>() { 
       @Override protected void initChannel(SocketChannel ch) throws Exception { 
        ch.pipeline().addLast(
          new ObjectEncoder(), 
          new ObjectDecoder(ClassResolvers.cacheDisabled(null)), 
          new ChannelInboundHandlerAdapter() { 
           @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { 
            System.out.println("client received message!"); 
           } 
          }); 
       } 
      }).connect("localhost", 40401); 
    try { 
     future.get(); 
    } catch (InterruptedException | ExecutionException e) { 
     e.printStackTrace(); 
    } 
    this.channel = future.channel(); 
} 
public void sendMessage(Object msg) { 
    channel.writeAndFlush(msg); 
}

這是我的服務器：

@Override public void run() { 
    new ServerBootstrap(). 
      group(new NioEventLoopGroup(1), new NioEventLoopGroup()). 
      channel(NioServerSocketChannel.class). 
      handler(new LoggingHandler(LogLevel.INFO)). 
      childHandler(new ChannelInitializer<SocketChannel>() { 
       @Override protected void initChannel(SocketChannel ch) throws Exception { 
        ch.pipeline().addLast(
          new ObjectEncoder(), 
          new ObjectDecoder(ClassResolvers.cacheDisabled(null)), 
          new ChannelInboundHandlerAdapter() { 
           @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { 
            System.out.println("server received a message!"); 
           } 
          }); 
       } 
      }).bind(40401); 
}

我想我錯過了一些基本認識我不知道從哪裏開始調試。的代碼非常簡單，所以它應該很容易爲大家熟悉的網狀回答這個（！@everybody 感謝

控制檯：

Nov 18, 2016 7:47:58 PM io.netty.handler.logging.LoggingHandler channelRegistered 
INFORMATION: [id: 0x52b5b879] REGISTERED 
Nov 18, 2016 7:47:58 PM io.netty.handler.logging.LoggingHandler bind 
INFORMATION: [id: 0x52b5b879] BIND: 0.0.0.0/0.0.0.0:40401 
Nov 18, 2016 7:47:58 PM io.netty.handler.logging.LoggingHandler channelActive 
INFORMATION: [id: 0x52b5b879, L:/0:0:0:0:0:0:0:0:40401] ACTIVE 
Nov 18, 2016 7:47:58 PM io.netty.handler.logging.LoggingHandler channelRead 
INFORMATION: [id: 0x52b5b879, L:/0:0:0:0:0:0:0:0:40401] RECEIVED: [id: 0xdda43b4c, L:/127.0.0.1:40401 - R:/127.0.0.1:56421] 
sending message to server... 
sending message to server... 
sending message to server... 
sending message to server... 
sending message to server... 
sending message to server...

來源

2016-11-18 NyxMC

從'writeAndFlush'獲得的通道未來是否表示成功？ – Ferrybig

不，它返回false ...但爲什麼？ – NyxMC

檢查原因，調用'.cause（）。printStackTrace（）'（on通道未來）將其打印到控制檯 – Ferrybig

修正了缺陷，感謝Ferrybig我的包只是不可序列化

來源

2017-03-01 22:08:00 NyxMC

服務器沒有收到消息

回答

相關問題