3

我想在 Netty 客户端/服务器上应用压缩/解压缩我在客户端和服务器中使用以下代码进行管道：

@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
    8192, Delimiters.lineDelimiter()));

pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("encoder", new StringEncoder());
pipeline.addLast("gzipdeflater", ZlibCodecFactory.newZlibEncoder(ZlibWrapper.GZIP));
pipeline.addLast("gzipinflater", ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP));

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

和服务器为：

@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
    8192, Delimiters.lineDelimiter()));
pipeline.addLast("decoder", new StringDecoder());
pipeline.addLast("encoder", new StringEncoder());
pipeline.addLast("gzipdeflater", ZlibCodecFactory.newZlibEncoder(ZlibWrapper.GZIP));
pipeline.addLast("gzipinflater", ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP));
//GlibDecoder
//pipeline.addLast("decoder", new ZlibDecoder());
//pipeline.addLast("encoder", new StringEncoder());
// and then business logic.
pipeline.addLast("handler", new NettyServerHandler());        
}

我在客户端启动连接时收到以下错误

警告：无法初始化通道。关闭：[id: 0x3553bb5c] java.lang.NoClassDefFoundError: com/jcraft/jzlib/Inflater at io.netty.handler.codec.compression.JZlibDecoder.(JZlibDecoder.java:28) at io.netty.handler.codec.compression .ZlibCodecFactory.newZlibDecoder(ZlibCodecFactory.java:86) 在 testChat.NettyClientInitializer.initChannel(NettyClientInitializer.java:36) 在 testChat.NettyClientInitializer.initChannel(NettyClientInitializer.java:21) 在 io.netty.channel.ChannelInitializer.channelRegistered(ChannelInitializer. java:70) 在 io.netty.channel.DefaultChannelHandlerContext.fireChannelRegistered(DefaultChannelHandlerContext.java:174) 在 io.netty.channel 的 io.netty.channel.DefaultChannelHandlerContext.invokeChannelRegistered(DefaultChannelHandlerContext.java:188)。

线程“主”java.nio.channels.ClosedChannelException 中的异常

客户端/服务器在没有压缩的情况下工作正常我尝试将压缩/解压缩放在字符串编码之前，但我得到了同样的错误？请问有什么帮助吗？

4

2 回答 2

3

您需要在 pom.xml 中添加以下依赖项：

  <dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jzlib</artifactId>
      <version>1.1.2</version>
  </dependency>

这是因为 netty 将所有依赖项声明为可选。

于 2013-08-03T20:57:15.277 回答
0

感谢您在多次试验后发表评论，我为我的问题找到了正确的解决方案： - 在 netbeans 中，我将 jzlib-1.1.2.jar 添加到我的项目中。- 管道的正确顺序为以下代码：

pipeline.addLast("deflater", ZlibCodecFactory.newZlibEncoder(ZlibWrapper.GZIP));
pipeline.addLast("inflater", ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP));

pipeline.addLast("framer", new DelimiterBasedFrameDecoder(
        8192, Delimiters.lineDelimiter()));


pipeline.addLast("decoder", new MyStringDecoder());
pipeline.addLast("encoder", new MyStringEncoder());

在客户端和服务器中

于 2013-08-04T18:44:46.140 回答