【消息队列开发】实现DataBaseManagerTests(测试单元)

简介: 【消息队列开发】实现DataBaseManagerTests(测试单元)

🍃前言

今天我们来对前面所开发的数据库操作的功能进行测试一下

🌳准备工作

由于我们接下来要写很多测试用例

并且我们希望每个方法都是一个/一组单元测试用例,互不干扰

所以我们还做一些准备工作,需要写两个方法, 分别用于进行 “准备工作” 和 “收尾工作”

这里我们使用注解的方式进行实现

添加@BeforeEach,表示每个测试单元开始前都要执行该方法

在这个方法里我们需要做的事情有:

  • 调用 init 方法进行建库建表
  • 但是由于我们的 init 方法是手动获取bean对象的,需要依赖context ,所以我们这里要先把context对象先搞出来

实现代码如下:

// 使用这个方法, 来执行准备工作. 每个用例执行前, 都要调用这个方法.
@BeforeEach
public void setUp() {
    // 由于在 init 中, 需要通过 context 对象拿到 metaMapper 实例的.
    // 所以就需要先把 context 对象给搞出来.
    MqApplication.context = SpringApplication.run(MqApplication.class);
    dataBaseManager.init();
}

使用@AfterEach来进行收尾工作

此处我们要做的工作有:

  • 这里要进行的操作, 就是把数据库给清空~~ (把数据库文件,meta.db 直接删了就行了)
  • 但是,请注意, 此处不能直接就删除, 而需要先关闭上述 context 对象
  • 而此处的 context 对象, 持有了 MetaMapper 的实例,MetaMapper 实例又打开了 meta.db 数据库文件.
  • 如果 meta.db 被别人打开了, 此时的删除文件操作是不会成功的 (Windows 系统的限制, Linux 则没这个问题).
  • 另一方面, 获取 context 操作, 会占用 8080 端口. 此处的 close 也是释放 8080.

所以我们需要进行关闭context对象之后,再进行删除删表操作

代码实现如下:

@AfterEach
    public void tearDown() {
        // 这里要进行的操作, 就是把数据库给清空~~ (把数据库文件, meta.db 直接删了就行了)
        // 注意, 此处不能直接就删除, 而需要先关闭上述 context 对象!!
        // 此处的 context 对象, 持有了 MetaMapper 的实例, MetaMapper 实例又打开了 meta.db 数据库文件.
        // 如果 meta.db 被别人打开了, 此时的删除文件操作是不会成功的 (Windows 系统的限制, Linux 则没这个问题).
        // 另一方面, 获取 context 操作, 会占用 8080 端口. 此处的 close 也是释放 8080.
        MqApplication.context.close();
        dataBaseManager.deleteDB();
    }

🎍书写测试代码

这里的测试代码逻辑简单,一一进行测试就好,这里我就不进行讲解

这里有一点需要注意的是,我们在观察结果的时候,我们可以使用打印到控制台的方式进行观察,但是这样难免不准确或不易观察

这里我们使用断言操作进行判断,使用方法如下:

Assertions.assertEquals(expected, actual);

我们只需要在这里面添加我们所需要比对的参数就好,那个在前那个在后不重要

  • 但是 assertEquals 的形参, 第一个形参叫做 expected (预期的), 第二个形参叫做 actual (实际的)

具体使用看个人习惯

需要注意的是:

  • 正确使用断言后,如果测试代码没有出现问题,说明测试通过
  • 如果预期值与实际值不符合,就会进行报错,如下图所示

如此一来我们便可以进行测试了

测试代码如下;

@Test
public void testInitTable() {
    // 由于 init 方法, 已经在上面 setUp 中调用过了. 直接在测试用例代码中, 检查当前的数据库状态即可.
    // 直接从数据库中查询. 看数据是否符合预期.
    // 查交换机表, 里面应该有一个数据(匿名的 exchange); 查队列表, 没有数据; 查绑定表, 没有数据.
    List<Exchange> exchangeList = dataBaseManager.selectAllExchanges();
    List<MSGQueue> queueList = dataBaseManager.selectAllQueues();
    List<Binding> bindingList = dataBaseManager.selectAllBindings();
    // 直接打印结果, 通过肉眼来检查结果, 固然也可以. 但是不优雅, 不方便.
    // 更好的办法是使用断言.
    // System.out.println(exchangeList.size());
    // assertEquals 判定结果是不是相等.
    // 注意这俩参数的顺序. 虽然比较相等, 谁在前谁在后, 无所谓.
    // 但是 assertEquals 的形参, 第一个形参叫做 expected (预期的), 第二个形参叫做 actual (实际的)
    Assertions.assertEquals(1, exchangeList.size());
    Assertions.assertEquals("", exchangeList.get(0).getName());
    Assertions.assertEquals(ExchangeType.DIRECT, exchangeList.get(0).getType());
    Assertions.assertEquals(0, queueList.size());
    Assertions.assertEquals(0, bindingList.size());
}
private Exchange createTestExchange(String exchangeName) {
    Exchange exchange = new Exchange();
    exchange.setName(exchangeName);
    exchange.setType(ExchangeType.FANOUT);
    exchange.setAutoDelete(false);
    exchange.setDurable(true);
    exchange.setArguments("aaa", 1);
    exchange.setArguments("bbb", 2);
    return exchange;
}
@Test
public void testInsertExchange() {
    // 构造一个 Exchange 对象, 插入到数据库中. 再查询出来, 看结果是否符合预期.
    Exchange exchange = createTestExchange("testExchange");
    dataBaseManager.insertExchange(exchange);
    // 插入完毕之后, 查询结果
    List<Exchange> exchangeList = dataBaseManager.selectAllExchanges();
    Assertions.assertEquals(2, exchangeList.size());
    Exchange newExchange = exchangeList.get(1);
    Assertions.assertEquals("testExchange", newExchange.getName());
    Assertions.assertEquals(ExchangeType.FANOUT, newExchange.getType());
    Assertions.assertEquals(false, newExchange.isAutoDelete());
    Assertions.assertEquals(true, newExchange.isDurable());
    Assertions.assertEquals(1, newExchange.getArguments("aaa"));
    Assertions.assertEquals(2, newExchange.getArguments("bbb"));
}
@Test
public void testDeleteExchange() {
    // 先构造一个交换机, 插入数据库; 然后再按照名字删除即可!
    Exchange exchange = createTestExchange("testExchange");
    dataBaseManager.insertExchange(exchange);
    List<Exchange> exchangeList = dataBaseManager.selectAllExchanges();
    Assertions.assertEquals(2, exchangeList.size());
    Assertions.assertEquals("testExchange", exchangeList.get(1).getName());
    // 进行删除操作
    dataBaseManager.deleteExchange("testExchange");
    // 再次查询
    exchangeList = dataBaseManager.selectAllExchanges();
    Assertions.assertEquals(1, exchangeList.size());
    Assertions.assertEquals("", exchangeList.get(0).getName());
}
private MSGQueue createTestQueue(String queueName) {
    MSGQueue queue = new MSGQueue();
    queue.setName(queueName);
    queue.setDurable(true);
    queue.setAutoDelete(false);
    queue.setExclusive(false);
    queue.setArguments("aaa", 1);
    queue.setArguments("bbb", 2);
    return queue;
}
@Test
public void testInsertQueue() {
    //构造队列对象
    MSGQueue queue = createTestQueue("testQueue");
    dataBaseManager.insertQueue(queue);
    List<MSGQueue> queueList = dataBaseManager.selectAllQueues();
    Assertions.assertEquals(1, queueList.size());
    MSGQueue newQueue = queueList.get(0);
    Assertions.assertEquals("testQueue", newQueue.getName());
    Assertions.assertEquals(true, newQueue.isDurable());
    Assertions.assertEquals(false, newQueue.isAutoDelete());
    Assertions.assertEquals(false, newQueue.isExclusive());
    Assertions.assertEquals(1, newQueue.getArguments("aaa"));
    Assertions.assertEquals(2, newQueue.getArguments("bbb"));
}
@Test
public void testDeleteQueue() {
    MSGQueue queue = createTestQueue("testQueue");
    dataBaseManager.insertQueue(queue);
    List<MSGQueue> queueList = dataBaseManager.selectAllQueues();
    Assertions.assertEquals(1, queueList.size());
    // 进行删除
    dataBaseManager.deleteQueue("testQueue");
    queueList = dataBaseManager.selectAllQueues();
    Assertions.assertEquals(0, queueList.size());
}
private Binding createTestBinding(String exchangeName, String queueName) {
    Binding binding = new Binding();
    binding.setExchangeName(exchangeName);
    binding.setQueueName(queueName);
    binding.setBindingKey("testBindingKey");
    return binding;
}
@Test
public void testInsertBinding() {
    Binding binding = createTestBinding("testExchange", "testQueue");
    dataBaseManager.insertBinding(binding);
    List<Binding> bindingList = dataBaseManager.selectAllBindings();
    Assertions.assertEquals(1, bindingList.size());
    Assertions.assertEquals("testExchange", bindingList.get(0).getExchangeName());
    Assertions.assertEquals("testQueue", bindingList.get(0).getQueueName());
    Assertions.assertEquals("testBindingKey", bindingList.get(0).getBindingKey());
}
@Test
public void testDeleteBinding() {
    Binding binding = createTestBinding("testExchange", "testQueue");
    dataBaseManager.insertBinding(binding);
    List<Binding> bindingList = dataBaseManager.selectAllBindings();
    Assertions.assertEquals(1, bindingList.size());
    // 删除
    Binding toDeleteBinding = createTestBinding("testExchange", "testQueue");
    dataBaseManager.deleteBinding(toDeleteBinding);
    bindingList = dataBaseManager.selectAllBindings();
    Assertions.assertEquals(0, bindingList.size());
}

⭕总结

关于《【消息队列开发】实现DataBaseManagerTests(测试单元》就讲解到这儿,感谢大家的支持,欢迎各位留言交流以及批评指正,如果文章对您有帮助或者觉得作者写的还不错可以点一下关注,点赞,收藏支持一下!

相关文章
|
1月前
|
测试技术 网络安全
什么是软件测试? 软件测试都有什么岗位 ?软件测试和调试的区别? 软件测试和开发的区别? 一位优秀的测试人员应该具备哪些素质? 软件测试等相关概念入门篇
文章全面介绍了软件测试的基本概念、目的、岗位分类、与开发和调试的区别,并阐述了成为优秀测试人员应具备的素质和技能。
118 1
什么是软件测试? 软件测试都有什么岗位 ?软件测试和调试的区别? 软件测试和开发的区别? 一位优秀的测试人员应该具备哪些素质? 软件测试等相关概念入门篇
|
16天前
|
人工智能 监控 测试技术
云应用开发平台测试
云应用开发平台测试
32 2
|
10天前
|
消息中间件 中间件 Kafka
解锁Kafka等消息队列中间件的测试之道
在这个数字化时代,分布式系统和消息队列中间件(如Kafka、RabbitMQ)已成为日常工作的核心组件。本次公开课由前字节跳动资深专家KK老师主讲,深入解析消息队列的基本原理、架构及测试要点,涵盖功能、性能、可靠性、安全性和兼容性测试,并探讨其主要应用场景,如应用解耦、异步处理和限流削峰。课程最后设有互动答疑环节,助你全面掌握消息队列的测试方法。
11 0
|
1月前
|
敏捷开发 测试技术
开发模型(瀑布、螺旋、scrum) 和 测试模型(V、W)、增量和迭代、敏捷(思想)及敏捷开发 scrum
文章详细介绍了软件开发过程中的不同开发模型(瀑布、螺旋、Scrum)和测试模型(V模型、W模型),以及增量和迭代的概念,最后阐述了敏捷思想及其在敏捷开发(如Scrum)中的应用。
45 0
开发模型(瀑布、螺旋、scrum) 和 测试模型(V、W)、增量和迭代、敏捷(思想)及敏捷开发 scrum
|
2月前
|
测试技术 持续交付 UED
软件测试的艺术与科学:平衡创新与质量的探索在软件开发的波澜壮阔中,软件测试如同灯塔,指引着产品质量的方向。本文旨在深入探讨软件测试的核心价值,通过分析其在现代软件工程中的应用,揭示其背后的艺术性与科学性,并探讨如何在追求技术创新的同时确保产品的高质量标准。
软件测试不仅仅是技术活动,它融合了创造力和方法论,是软件开发过程中不可或缺的一环。本文首先概述了软件测试的重要性及其在项目生命周期中的角色,随后详细讨论了测试用例设计的创新方法、自动化测试的策略与挑战,以及如何通过持续集成/持续部署(CI/CD)流程优化产品质量。最后,文章强调了团队间沟通在确保测试有效性中的关键作用,并通过案例分析展示了这些原则在实践中的应用。
69 1
|
2月前
|
测试技术 UED 开发者
软件测试的艺术:从代码审查到用户反馈的全景探索在软件开发的宇宙中,测试是那颗确保星系正常运转的暗物质。它或许不总是站在聚光灯下,但无疑是支撑整个系统稳定性与可靠性的基石。《软件测试的艺术:从代码审查到用户反馈的全景探索》一文,旨在揭开软件测试这一神秘面纱,通过深入浅出的方式,引领读者穿梭于测试的各个环节,从细微处着眼,至宏观视角俯瞰,全方位解析如何打造无懈可击的软件产品。
本文以“软件测试的艺术”为核心,创新性地将技术深度与通俗易懂的语言风格相结合,绘制了一幅从代码审查到用户反馈全过程的测试蓝图。不同于常规摘要的枯燥概述,这里更像是一段旅程的预告片,承诺带领读者经历一场从微观世界到宏观视野的探索之旅,揭示每一个测试环节背后的哲学与实践智慧,让即便是非专业人士也能领略到软件测试的魅力所在,并从中获取实用的启示。
|
3月前
|
测试技术 C# 开发者
“代码守护者:详解WPF开发中的单元测试策略与实践——从选择测试框架到编写模拟对象,全方位保障你的应用程序质量”
【8月更文挑战第31天】单元测试是确保软件质量的关键实践,尤其在复杂的WPF应用中更为重要。通过为每个小模块编写独立测试用例,可以验证代码的功能正确性并在早期发现错误。本文将介绍如何在WPF项目中引入单元测试,并通过具体示例演示其实施过程。首先选择合适的测试框架如NUnit或xUnit.net,并利用Moq模拟框架隔离外部依赖。接着,通过一个简单的WPF应用程序示例,展示如何模拟`IUserRepository`接口并验证`MainViewModel`加载用户数据的正确性。这有助于确保代码质量和未来的重构与扩展。
66 0
|
3月前
|
前端开发 JavaScript 测试技术
React 与前端自动化测试也太重要啦!各种测试框架助力确保应用质量,快来开启优质开发之旅!
【8月更文挑战第31天】随着前端技术的发展,React 成为了构建用户界面的热门选择。然而,随着应用复杂性的增加,确保应用质量变得至关重要。本文介绍了前端自动化测试的重要性,并详细综述了常用的测试框架如 Jest、Enzyme 和 Cypress,以及如何通过它们进行高效的 React 组件测试。通过遵循最佳实践,如编写可维护的测试用例、覆盖关键场景、集成 CI/CD 流程和进行性能测试,可以显著提高应用的稳定性和可靠性。
56 0
|
22天前
|
JSON 算法 数据可视化
测试专项笔记(一): 通过算法能力接口返回的检测结果完成相关指标的计算(目标检测)
这篇文章是关于如何通过算法接口返回的目标检测结果来计算性能指标的笔记。它涵盖了任务描述、指标分析(包括TP、FP、FN、TN、精准率和召回率),接口处理,数据集处理,以及如何使用实用工具进行文件操作和数据可视化。文章还提供了一些Python代码示例,用于处理图像文件、转换数据格式以及计算目标检测的性能指标。
36 0
测试专项笔记(一): 通过算法能力接口返回的检测结果完成相关指标的计算(目标检测)
|
2月前
|
移动开发 JSON Java
Jmeter实现WebSocket协议的接口测试方法
WebSocket协议是HTML5的一种新协议,实现了浏览器与服务器之间的全双工通信。通过简单的握手动作,双方可直接传输数据。其优势包括极小的头部开销和服务器推送功能。使用JMeter进行WebSocket接口和性能测试时,需安装特定插件并配置相关参数,如服务器地址、端口号等,还可通过CSV文件实现参数化,以满足不同测试需求。
200 7
Jmeter实现WebSocket协议的接口测试方法