Netty（4.0.4）版本压缩/解压缩字符串消息错误

Question

我想在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 Excepthtml" target="_blank">ion {
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在io.netty.handler.codec.compression.JZlibDecoder.（JZlibDecoder.java:28）在io.netty.handler.codec.compression.ZlibCodecFactory.newZlibDecoder（ZlibCodecFactory.java:86）在testchat。NettyClientInitializer.init频道（NettyClientInitializer.java:36）。NettyClientInitializer.init频道（NettyClientInitializer.java:21）在io.netty.channel.频道nitializer.channel注册（频道nitializer.java:70）在io.netty.channel.DefaultChannelHandlerContext.invoke频道注册（DefaultChannelHandlerContext.java:188）在io.netty.channel.DefaultChannelHandlerContext.fire渠道注册（DefaultChannelHandlerContext.java:174）在io.netty.channel.DefaultChannelPipeline. fire渠道注册（DefaultChannelPipeline. java： 730）在io. netty. channel。AbstractChannel在io. netty. Channel注册0（AbstractChannel. java： 426）。AbstractChannel$AbstractUn安全访问100美元（AbstractChannel. java： 367）在io. netty. Channel。AbstractChannel$AbstractUn安全1美元. run（AbstractChannel. java： 403）at io. netty. util. con电流。SingleThreadEventExecutor. runAll任务（SingleThreadEventExecutor. java： 353）位于io. netty. Channel. nio。NioEventLoop. run（NioEventLoop. java： 366）at io. netty. util. con当前。在java. lang上运行（SingleThreadEventExecutor. java： 101）。线程. run（Thread. java： 722）引起：java. lang.ClassNotFoundExcema： com. jcraft. jzlib.在java. net充气。在java. net上运行（URLClassLoader. java： 366）。运行（URLClassLoader. java： 355）在java. security。在java. net的AccessController. doPrivileged（本机方法）。在java. lang的URLClassLoader. findClass（URLClassLoader. java： 354）。ClassLoader. loadClass（ClassLoader. java： 423）at sun. misc.在java. lang启动$AppClassLoader. loadClass（Launcher. java： 308）。ClassLoader. loadClass（ClassLoader. java： 356）...15 more

线程“main”java中出现异常。尼奥。频道。ClosedChannel异常

客户端/服务器在没有压缩的情况下工作得很好。我尝试在字符串编码之前进行压缩/解压缩，但我得到了相同的错误？需要帮忙吗？

Answer 1

感谢您在多次试验后的评论，我找到了正确的问题解决方案，如：-在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()); 

在客户端和服务器中

Answer 2

您需要在pom中添加以下依赖项。xml:

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

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