AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Netty In Action中文版 - 第十章：单元测试代码

2018-03-14 1136
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

Netty In Action中文版 - 第十章：单元测试代码

本章介绍

  • 单元测试
  • EmbeddedChannel

学会了使用一个或多个ChannelHandler处理接收/发送数据消息，但是如何测试它们呢？Netty提供了2个额外的类使得测试ChannelHandler变得很容易，本章讲解如何测试Netty程序。测试使用JUnit4，如果不会用可以慢慢了解。JUnit4很简单，但是功能很强大。本章将重点讲解测试已实现的ChannelHandler和编解码器。

10.1 General

        正如前面所学的，Netty提供了一个简单的方法在ChannelPipeline上“堆叠”不同的ChannelHandler实现。所有的ChannelHandler都会参与处理事件，这个设计允许独立出可重用的小逻辑块，它只处理一个任务。这不仅使代码更清晰，也更容易测试。
        测试ChannelHandler可以通过使用“嵌入式”传输很容易的传递事件槽管道以测试你的实现。对于这个嵌入式传输，Netty提供了一个特定的Channel实现：EmbeddedChannel。但是它是如何工作的呢？EmbeddedChannel的工作非常简单，它允许写入入站或出站数据，然后检查ChannelPipeline的结束。这允许你检查消息编码/解码或触发ChannelHandler任何行为。
        编写入站和出站的却别是什么？入站数据是通过ChannelInboundHandler处理，代表从远程对等通道读取数据；出站数据是通过ChannelOutboundHandler处理，代表写入数据到远程对等通道。因此测试ChannelHandler就会选择writeInbound(...)或writeOutbound()(或者都选择)。
        EmbeddedChannel提供了下面一些方法：
  • writeInbound(Object...)，写一个消息到入站通道
  • writeOutbound(Object...)，写消息到出站通道
  • readInbound()，从EmbeddedChannel读取入站消息，可能返回null
  • readOutbound()，从EmbeddedChannel读取出站消息，可能返回null
  • finish()，标示EmbeddedChannel已结束，任何写数据都会失败

为了更清楚的了解其处理过程，看下图：

        如上图所示，使用writeOutbound(...)写消息到通道，消息在出站方法通过ChannelPipeline，之后就可以使用readOutbound()读取消息。着同样使用与入站，使用writeInbound(...)和readInbound()。处理入站和出站是相似的，它总是遍历整个ChannelPipeline直到ChannelPipeline结束，并将处理过的消息存储在EmbeddedChannel中。下面来看看如何测试你的逻辑。

10.2 测试ChannelHandler

        测试ChannelHandler最好的选择是使用EmbeddedChannel。

10.2.1 测试处理入站消息的handler

        我们来编写一个简单的ByteToMessageDecoder实现，有足够的数据可以读取时将产生固定大小的包，如果没有足够的数据可以读取，则会等待下一个数据块并再次检查是否可以产生一个完整包。下图显示了重新组装接收的字节：
        如上图所示，它可能会占用一个以上的“event”以获取足够的字节产生一个数据包，并将它传递到ChannelPipeline中的下一个ChannelHandler，看下面代码：

[java] view plain copy

  1. package netty.in.action;
  3. import java.util.List;
  5. import io.netty.buffer.ByteBuf;
  6. import io.netty.channel.ChannelHandlerContext;
  7. import io.netty.handler.codec.ByteToMessageDecoder;
  9. public class FixedLengthFrameDecoder extends ByteToMessageDecoder {
  11.     private final int frameLength;
  13.     public FixedLengthFrameDecoder(int frameLength) {
  14.         if (frameLength <= 0) {
  15.             throw new IllegalArgumentException(
  16.                     "frameLength must be a positive integer: " + frameLength);
  17.         }
  18.         this.frameLength = frameLength;
  19.     }
  21.     @Override
  22.     protected void decode(ChannelHandlerContext ctx, ByteBuf in,
  23.             List<Object> out) throws Exception {
  24.         while (in.readableBytes() >= frameLength) {
  25.             ByteBuf buf = in.readBytes(frameLength);
  26.             out.add(buf);
  27.         }
  28.     }
  30. }

解码器的实现完成了，写一个单元测试的方法是个好主意。即使代码看起来没啥问题，但是也应该进行单元测试，这样能在部署到生产之前就发现问题。现在让我们来看看如何使用EmbeddedChannel来完成测试，看下面代码：

[java] view plain copy

  1. package netty.in.action;
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.Unpooled;
  5. import io.netty.channel.embedded.EmbeddedChannel;
  7. import org.junit.Assert;
  8. import org.junit.Test;
  10. public class FixedLengthFrameDecoderTest {
  12.     @Test
  13.     public void testFramesDecoded() {
  14.         ByteBuf buf = Unpooled.buffer();
  15.         for (int i = 0; i < 9; i++) {
  16.             buf.writeByte(i);
  17.         }
  18.         ByteBuf input = buf.duplicate();
  19.         EmbeddedChannel channel = new EmbeddedChannel(
  20.                 new FixedLengthFrameDecoder(3));
  21.         // write bytes
  22.         Assert.assertTrue(channel.writeInbound(input));
  23.         Assert.assertTrue(channel.finish());
  24.         // read message
  25.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  26.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  27.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  28.         Assert.assertNull(channel.readInbound());
  29.     }
  31.     @Test
  32.     public void testFramesDecoded2() {
  33.         ByteBuf buf = Unpooled.buffer();
  34.         for (int i = 0; i < 9; i++) {
  35.             buf.writeByte(i);
  36.         }
  37.         ByteBuf input = buf.duplicate();
  38.         EmbeddedChannel channel = new EmbeddedChannel(
  39.                 new FixedLengthFrameDecoder(3));
  40.         Assert.assertFalse(channel.writeInbound(input.readBytes(2)));
  41.         Assert.assertTrue(channel.writeInbound(input.readBytes(7)));
  42.         Assert.assertTrue(channel.finish());
  43.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  44.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  45.         Assert.assertEquals(buf.readBytes(3), channel.readInbound());
  46.         Assert.assertNull(channel.readInbound());
  47.     }
  49. }

如上面代码，testFramesDecoded()方法想测试一个ByteBuf，这个ByteBuf包含9个可读字节，被解码成包含了3个可读字节的ByteBuf。你可能注意到，它写入9字节到通道是通过调用writeInbound()方法，之后再执行finish()来将EmbeddedChannel标记为已完成，最后调用readInbound()方法来获取EmbeddedChannel中的数据，直到没有可读字节。testFramesDecoded2()方法采取同样的方式，但有一个区别就是入站ByteBuf分两步写的，当调用writeInbound(input.readBytes(2))后返回false时，FixedLengthFrameDecoder值会产生输出，至少有3个字节是可读，testFramesDecoded2()测试的工作相当于testFramesDecoded()。

10.2.2 测试处理出站消息的handler

        测试处理出站消息和测试处理入站消息不太一样，例如有一个继承MessageToMessageEncoder的AbsIntegerEncoder类，它所做的事情如下：
  • 将已接收的数据flush()后将从ByteBuf读取所有整数并调用Math.abs(...)
  • 完成后将字节写入ChannelPipeline中下一个ChannelHandler的ByteBuf中

看下图处理过程：

看下面代码：

[java] view plain copy

  1. package netty.in.action;
  3. import java.util.List;
  5. import io.netty.buffer.ByteBuf;
  6. import io.netty.channel.ChannelHandlerContext;
  7. import io.netty.handler.codec.MessageToMessageEncoder;
  9. public class AbsIntegerEncoder extends MessageToMessageEncoder<ByteBuf> {
  10.     @Override
  11.     protected void encode(ChannelHandlerContext ctx, ByteBuf msg,
  12.             List<Object> out) throws Exception {
  13.         while(msg.readableBytes() >= 4){
  14.             int value = Math.abs(msg.readInt());
  15.             out.add(value);
  16.         }
  17.     }
  18. }

下面代码是测试AbsIntegerEncoder：

[java] view plain copy

  1. package netty.in.action;
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.Unpooled;
  5. import io.netty.channel.embedded.EmbeddedChannel;
  7. import org.junit.Assert;
  8. import org.junit.Test;
  10. public class AbsIntegerEncoderTest {
  12.     @Test
  13.     public void testEncoded() {
  14.         //创建一个能容纳10个int的ByteBuf
  15.         ByteBuf buf = Unpooled.buffer();
  16.         for (int i = 1; i < 10; i++) {
  17.             buf.writeInt(i * -1);
  18.         }
  19.         //创建EmbeddedChannel对象
  20.         EmbeddedChannel channel = new EmbeddedChannel(new AbsIntegerEncoder());
  21.         //将buf数据写入出站EmbeddedChannel
  22.         Assert.assertTrue(channel.writeOutbound(buf));
  23.         //标示EmbeddedChannel完成
  24.         Assert.assertTrue(channel.finish());
  25.         //读取出站数据
  26.         ByteBuf output = (ByteBuf) channel.readOutbound();
  27.         for (int i = 1; i < 10; i++) {
  28.             Assert.assertEquals(i, output.readInt());
  29.         }
  30.         Assert.assertFalse(output.isReadable());
  31.         Assert.assertNull(channel.readOutbound());
  32.     }
  34. }

10.3 测试异常处理

有时候传输的入站或出站数据不够，通常这种情况也需要处理，例如抛出一个异常。这可能是你错误的输入或处理大的资源或其他的异常导致。我们来写一个实现，如果输入字节超出限制长度就抛出TooLongFrameException，这样的功能一般用来防止资源耗尽。看下图：

        上图显示帧的大小被限制为3字节，若输入的字节超过3字节，则超过的字节被丢弃并抛出TooLongFrameException。在ChannelPipeline中的其他ChannelHandler实现可以处理TooLongFrameException或者忽略异常。处理异常在ChannelHandler.exceptionCaught()方法中完成，ChannelHandler提供了一些具体的实现，看下面代码：

[java] view plain copy

  1. package netty.in.action;
  3. import java.util.List;
  5. import io.netty.buffer.ByteBuf;
  6. import io.netty.channel.ChannelHandlerContext;
  7. import io.netty.handler.codec.ByteToMessageDecoder;
  8. import io.netty.handler.codec.TooLongFrameException;
  10. public class FrameChunkDecoder extends ByteToMessageDecoder {
  12.     // 限制大小
  13.     private final int maxFrameSize;
  15.     public FrameChunkDecoder(int maxFrameSize) {
  16.         this.maxFrameSize = maxFrameSize;
  17.     }
  19.     @Override
  20.     protected void decode(ChannelHandlerContext ctx, ByteBuf in,
  21.             List<Object> out) throws Exception {
  22.         // 获取可读字节数
  23.         int readableBytes = in.readableBytes();
  24.         // 若可读字节数大于限制值,清空字节并抛出异常
  25.         if (readableBytes > maxFrameSize) {
  26.             in.clear();
  27.             throw new TooLongFrameException();
  28.         }
  29.         // 读取ByteBuf并放到List中
  30.         ByteBuf buf = in.readBytes(readableBytes);
  31.         out.add(buf);
  32.     }
  34. }

测试FrameChunkDecoder的代码如下：

[java] view plain copy

  1. package netty.in.action;
  3. import io.netty.buffer.ByteBuf;
  4. import io.netty.buffer.Unpooled;
  5. import io.netty.channel.embedded.EmbeddedChannel;
  6. import io.netty.handler.codec.TooLongFrameException;
  8. import org.junit.Assert;
  9. import org.junit.Test;
  11. public class FrameChunkDecoderTest {
  13.     @Test
  14.     public void testFramesDecoded() {
  15.         //创建ByteBuf并填充9字节数据
  16.         ByteBuf buf = Unpooled.buffer();
  17.         for (int i = 0; i < 9; i++) {
  18.             buf.writeByte(i);
  19.         }
  20.         //复制一个ByteBuf
  21.         ByteBuf input = buf.duplicate();
  22.         //创建EmbeddedChannel
  23.         EmbeddedChannel channel = new EmbeddedChannel(new FrameChunkDecoder(3));
  24.         //读取2个字节写入入站通道
  25.         Assert.assertTrue(channel.writeInbound(input.readBytes(2)));
  26.         try {
  27.             //读取4个字节写入入站通道
  28.             channel.writeInbound(input.readBytes(4));
  29.             Assert.fail();
  30.         } catch (TooLongFrameException e) {
  32.         }
  33.         //读取3个字节写入入站通道
  34.         Assert.assertTrue(channel.writeInbound(input.readBytes(3)));
  35.         //标识完成
  36.         Assert.assertTrue(channel.finish());
  37.         //从EmbeddedChannel入去入站数据
  38.         Assert.assertEquals(buf.readBytes(2), channel.readInbound());
  39.         Assert.assertEquals(buf.skipBytes(4).readBytes(3),
  40.                 channel.readInbound());
  41.     }
  43. }

10.4 Summary

In this chapter you learned how you are be able to test your custom ChannelHandler and so make  sure  it works  like  you  expected. Using  the  shown  techniques  you  are  now  be  able  to make use of JUnit and so ultimately test your code as your are used to. Using the techniques shown in the chapter you will be able to guarantee a high quality of your code and also guard it from misbehavior..  In the next chapters we will focus on writing "real" applications on top of Netty and so show you  how  you  can make  real  use  of  it.  Even  if  the  applications  don't  contain  any  test-code remember it is quite important to do so when you will write your next-gen application.

原文地址http://www.bieryun.com/2178.html

文章标签：
测试技术
Java
存储
关键词：
测试代码
action测试
单元测试代码
中文版测试
Netty代码
幸运券发放
目录
相关文章
zzy的aly
|
3月前
|
数据采集 机器学习/深度学习 大数据
行为检测代码(一)：超详细介绍C3D架构训练+测试步骤
这篇文章详细介绍了C3D架构在行为检测领域的应用，包括训练和测试步骤，使用UCF101数据集进行演示。
zzy的aly
89 1
行为检测代码(一)：超详细介绍C3D架构训练+测试步骤
游客5fdji2pvmf8888
|
3月前
|
机器学习/深度学习 人工智能 监控
提升软件质量的关键路径：高效测试策略与实践在软件开发的宇宙中，每一行代码都如同星辰般璀璨，而将这些星辰编织成星系的过程，则依赖于严谨而高效的测试策略。本文将引领读者探索软件测试的奥秘，揭示如何通过精心设计的测试方案，不仅提升软件的性能与稳定性，还能加速产品上市的步伐，最终实现质量与效率的双重飞跃。
在软件工程的浩瀚星海中，测试不仅是发现缺陷的放大镜，更是保障软件质量的坚固防线。本文旨在探讨一种高效且创新的软件测试策略框架，它融合了传统方法的精髓与现代技术的突破，旨在为软件开发团队提供一套系统化、可执行性强的测试指引。我们将从测试规划的起点出发，沿着测试设计、执行、反馈再到持续优化的轨迹，逐步展开论述。每一步都强调实用性与前瞻性相结合，确保测试活动能够紧跟软件开发的步伐，及时适应变化，有效应对各种挑战。
游客5fdji2pvmf8888
98 4
追逐时光者
|
9天前
|
算法 Java 测试技术
使用 BenchmarkDotNet 对 .NET 代码进行性能基准测试
使用 BenchmarkDotNet 对 .NET 代码进行性能基准测试
追逐时光者
40 13
游客qeoynko2nmbgk
|
4月前
|
Web App开发 JavaScript 前端开发
添加浮动按钮点击滚动到网页底部的纯JavaScript演示代码 IE9、11，Maxthon 1.6.7，Firefox30、31，360极速浏览器7.5.3.308下测试正常
添加浮动按钮点击滚动到网页底部的纯JavaScript演示代码 IE9、11，Maxthon 1.6.7，Firefox30、31，360极速浏览器7.5.3.308下测试正常
游客qeoynko2nmbgk
51 0
土木林森
|
2月前
|
并行计算 算法 测试技术
C语言因高效灵活被广泛应用于软件开发。本文探讨了优化C语言程序性能的策略，涵盖算法优化、代码结构优化、内存管理优化、编译器优化、数据结构优化、并行计算优化及性能测试与分析七个方面
C语言因高效灵活被广泛应用于软件开发。本文探讨了优化C语言程序性能的策略，涵盖算法优化、代码结构优化、内存管理优化、编译器优化、数据结构优化、并行计算优化及性能测试与分析七个方面，旨在通过综合策略提升程序性能，满足实际需求。
土木林森
65 1
武子康
|
3月前
|
分布式计算 大数据 Spark
大数据-95 Spark 集群 SparkSQL Action与Transformation操作 详细解释与测试案例（二）
大数据-95 Spark 集群 SparkSQL Action与Transformation操作 详细解释与测试案例（二）
武子康
52 1
顾翔
|
4月前
|
SQL JavaScript 前端开发
基于Python访问Hive的pytest测试代码实现
根据《用Java、Python来开发Hive应用》一文，建立了使用Python、来开发Hive应用的方法，产生的代码如下
顾翔
85 6
基于Python访问Hive的pytest测试代码实现
yantuguiguziPGJ
|
4月前
|
Java C++
代码文件间重复性测试
本文介绍了如何使用代码相似性检测工具simian来找出代码文件中的重复行，并通过示例指令展示了如何将检测结果输出到指定的文本文件中。
yantuguiguziPGJ
71 1
游客nmbcre4jd7shs
|
4月前
|
测试技术 UED
软件测试的艺术：从代码到品质的探索之旅
在数字时代的浪潮中，软件已成为我们生活和工作不可或缺的一部分。然而，高质量的软件背后隐藏着一门鲜为人知的艺术——软件测试。本文将带你走进这门艺术的世界，从基础理论到实践应用，一起探索如何通过软件测试保障产品质量，提升用户体验，并最终实现从代码到品质的华丽转变。
游客nmbcre4jd7shs
48 9
武子康
|
3月前
|
存储 SQL 分布式计算
大数据-95 Spark 集群 SparkSQL Action与Transformation操作 详细解释与测试案例（一）
大数据-95 Spark 集群 SparkSQL Action与Transformation操作 详细解释与测试案例（一）
武子康
56 0

热门文章

最新文章

  • 1
    智能化软件测试：AI驱动的自动化测试策略与实践####
  • 2
    Selenium：强大的 Web 自动化测试工具
  • 3
    Selenium IDE：Web自动化测试的得力助手
  • 4
    slb测试基本配置检查
  • 5
    探索软件测试中的自动化框架选择####
  • 6
    Benchmark.NET：让 C# 测试程序性能变得既酷又简单
  • 7
    探索软件测试中的自动化测试框架选择与优化策略
  • 8
    使用Spring Boot编写测试用例：实践与最佳实践
  • 9
    Selenium IDE：Web自动化测试的得力助手
  • 10
    API接口自动化测试深度解析与最佳实践指南
  • 1
    Netty &amp; Mina 入门级总结(转)
    291
  • 2
    Springboot+Netty+WebSocket搭建简单的消息通知
    189
  • 3
    Netty的基础入门（上）
    256
  • 4
    Netty的基础入门（下）
    135
  • 5
    Spring Boot与Netty打造TCP服务端(解决粘包问题)
    1106
  • 6
    通信密码学：探秘Netty中解码器的神奇力量
    228
  • 7
    配置之道：深入研究Netty中的Option选项
    408
  • 8
    网络编程的魔法师：探索Netty中Handler的奇妙世界
    84
  • 9
    事件驱动的奇迹：深入理解Netty中的EventLoop
    352
  • 10
    阿里内部Netty实战小册，值得拥有
    153

    • 相关课程

    更多
  • MSE微服务测试最佳实践 - 自动化回归
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • Python语言基础 - 函数、面向对象、异常处理

    • 相关电子书

    更多
  • 移动互联网测试到质量的转变
  • 给ITer的技术实战进阶课-阿里CIO学院独家教材（四）
  • F2etest — 多浏览器兼容性测试整体解决方案

    • 相关实验场景

    更多
  • 灵活弹性的PolarDB Serverless确保数据业务持续在线
  • 使用Java面向对象编写网络通信程序应用
  • 快速上手并跑通AnalyticDB PostgreSQL版TPC-H测试
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月