Curator Framework如何写单元测试

概述

使用curator framework框架去操作zookeeper时,我们知道因其的方法风格是那种流式的编写风格,所以我们在写单元测试的时候要把链接zookeeper的操作给mock掉,那么着实是不太好写单测。不过好在curator framework有一个专门用于测试的模块,可以让我们在单测运行之前就在本地启动一个zookeeper server实例,以便于让单测可以直接连接本地的zookeeper实例创建curator client,便于做单元测试。

实现

引入依赖

            <dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.3.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-test</artifactId><version>4.3.0</version><scope>test</scope></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.14</version></dependency>

启动zookeeper

    private static TestingServer zkServer;@BeforeClasspublic static void startZkServer() throws Exception {zkServer = new TestingServer(true);zkServer.start();}

创建curator framework client

    private CuratorFramework zkClient;@BeforeAllpublic CuratorFramework createCuratorClient() {zkClient = CuratorFrameworkFactory.builder()//本地启动的zookeeper实例端口,跑单测用.connectString(zkServer.getConnectString()).retryPolicy(new RetryNTimes(5, 1000)).connectionTimeoutMs(40 * 1000).sessionTimeoutMs(5 * 1000).build();zkClient.start();}

单元测试-创建临时节点

    @Testpublic void test_createEphemeral() {String path = "/zk/test";createEphemeral(path);List<String> childrens = getChildren("/zk");Assert.assertEquals(1, childrens.size());}private void createEphemeral(String path) {try {zkClient.create().withMode(CreateMode.EPHEMERAL).forPath(path);} catch (NodeExistsException e) {logger.warn("ZNode " + path + " already exists.", e);throw new IllegalStateException(e.getMessage(), e);} catch (Exception e) {throw new IllegalStateException(e.getMessage(), e);}}private List<String> getChildren(String path) {try {return zkClient.getChildren().forPath(path);} catch (NoNodeException e) {return new ArrayList<>();} catch (Exception e) {throw new IllegalStateException(e.getMessage(), e);}}

单测完毕后关闭zookeeper server

@AfterClass
public static void closeZkServer() throws IOException {zkServer.close();
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/17304.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

诚心分享!主食冻干横向对比:希喂、爱立方、K9等谁最值得入手?

主食冻干到底有必要喂吗&#xff1f;七年铲龄铲屎官告诉你&#xff0c;是真的很有必要喂&#xff01; 这些年随着宠物经济的发展、科学养宠的普及&#xff0c;现在养猫不仅局限在让猫吃饱就行&#xff0c;更多人开始关注到猫的饮食健康。大量的实际喂养案例证明了&#xff0c;传…

第2章 物理层

王道学习 考纲内容 &#xff08;一&#xff09;通信基础 信道、信号、带宽、码元、波特、速率、信源与信宿等基本概念&#xff1b; 奈奎斯特定理与香农定理&#xff1b;编码与调制&#xff1b; 电路交换、报文交换与分组交换&#xff1b;数…

接口响应断言-json

json认识JSONPath源码类学习/json串的解析拓展学习 目的&#xff1a;数据返回值校验测试 json认识 json是什么-是一种数据交换格式&#xff0c;举例平时看到的json图2&#xff0c;在使用中查看不方便&#xff0c;会有格式转化的平台&#xff0c;json格式的展示 JSON在线视图…

推荐二轮电动车仪表盘蓝牙主芯片方案-HS6621CGC

随着国内二轮电动车的火热开启&#xff0c;电动车的智能化程度越来越高&#xff1b;电动车的智能操控需求也越来越高&#xff0c;现在介绍蓝牙控制面板的一些功能&#xff1b;例如&#xff1a;定位&#xff08;GNSS&#xff09;&#xff0c;设防&#xff0c;实时上报数据&#…

rocketmq跨版本升级方案参考—— 筑梦之路

这篇文章写的比较好&#xff0c;可以作为参考&#xff0c;抽空再来按照这个思路进行实践实验。 https://www.cnblogs.com/zhyg/p/10132598.html 对于rocketmq和kafka如何选择&#xff0c;可阅读搭建项目 Kafka 和 RocketMQ 你选哪个&#xff1f;

什么是光栅化?

一、 什么是光栅化? 光栅化作用是将几何数据变换后转换为像素呈现在显示设备上的一个过程。几何数据转换为像素&#xff0c; 本质是坐标变换、几何离散化&#xff0c;如下&#xff1a; 其中包含了坐标变换和几何离散化&#xff1a; 二、光栅化完成了什么 3D中&#xff0c;物…

element-ui 实现输入框下拉树组件(2024-05-23)

用element-ui的 el-input&#xff0c;el-tree&#xff0c;el-popover组件组合封装 import url("//unpkg.com/element-ui2.15.14/lib/theme-chalk/index.css"); <script src"//unpkg.com/vue2/dist/vue.js"></script> <script src"//…

枣庄高防服务器如何实现全球覆盖?

利用 枣庄高防服务器如何实现全球覆盖&#xff1f; 嗨&#xff0c;亲爱的读者们&#xff01;今天我们将带你探索如何利用枣庄高防服务器实现全球覆盖&#xff0c;让你的网站在世界各地都能稳定快速地访问。而我们这次推荐的服务器商是莱卡云&#xff08;Lcayun&#xff09;&am…

C数据结构:二叉树

目录 二叉树的数据结构 前序遍历 中序遍历 后序遍历 二叉树的创建 二叉树的销毁 二叉树的节点个数 二叉树叶子节点个数 二叉树第K层节点个数 二叉树的查找 层序遍历 判断二叉树是否为完全二叉树 完整代码 二叉树的数据结构 typedef char BTDataType; typedef str…

使用numpy手写一个神经网络

本文主要包含以下内容&#xff1a; 推导神经网络的误差反向传播过程使用numpy编写简单的神经网络&#xff0c;并使用iris数据集和california_housing数据集分别进行分类和回归任务&#xff0c;最终将训练过程可视化。 1. BP算法的推导过程 1.1 导入 前向传播和反向传播的总体…

Three.js——相机

在Three.js中&#xff0c;相机&#xff08;Camera&#xff09;是用于定义视图和渲染场景的一个关键组件。相机决定了你从哪个角度和位置观察场景中的物体&#xff0c;以及如何呈现这些物体。Three.js 提供了几种不同类型的相机&#xff0c;每种相机都有其特定的用途和特性。以下…

Unity OutLine 模型外描边效果

效果展示&#xff1a; 下载链接

【Rust日报】ratatui版本更新

[new ver] ratatui v0.26.3 一个构建终端用户界面的库。新版本包括&#xff1a; 修复Unicode 截断 bug对颜色更好地序列化更快的渲染弃用assert_buffer_eq宏暴露错误类型常量函数和类型 官网: https://ratatui.rs/ 链接: https://ratatui.rs/highlights/v0263/ [new lib] ansi2…

618电商选品爆款攻略,谁掌握谁爆单

618电商节是各大电商平台和品牌商家的重要促销节点&#xff0c;选品和营销策略对于销售成绩至关重要。以下是一些选品和营销攻略的要点&#xff1a; 一、市场分析与目标定位 1、分析当前经营类目市场的流行趋势、热门品类以及消费者需求的变化。 目前市场上商品繁多&#xf…

Java 命令执行某一个特定类

在Java中&#xff0c;要执行一个特定的类&#xff08;通常是包含main方法的类&#xff09;&#xff0c;你需要使用java命令&#xff0c;并指定类的完全限定名&#xff08;包括包名&#xff09;。通常&#xff0c;这还需要你设置正确的类路径&#xff08;classpath&#xff09;&…

Apache Cassandra和Java:介绍如何在Java中连接和使用Apache Cassandra这款数据库

1. Apache Cassandra简介 Apache Cassandra是一个开源的分布式NoSQL数据库系统,最初由Facebook开发,用来处理大量的结构化数据 across many commodity servers. Cassandra在高可用性和无单点故障的同时,提供了出色的数据分布策略。 Apache Cassandra的主要特点: 分布式…

超详细避坑指南!OrangpiAIPro转换部署模型全流程!

目录 OrangepiPro初体验 前述&#xff1a; 一、硬件准备 二、安装CANN工具链&#xff08;虚拟机&#xff09; 三、配置模型转换环境&#xff08;虚拟机&#xff09; 1.安装miniconda 。 2.创建环境。 3.安装依赖包 四、转换模型 1. 查看设备号&#xff08;开发板&…

一步一脚印:轻松掌握服务器硬件的奥秘

在这个信息化飞速发展的时代&#xff0c;无论是企业还是个人&#xff0c;对数据处理和存储的需求日益增长。服务器&#xff0c;作为互联网的基石&#xff0c;其重要性不言而喻。但对于大多数人来说&#xff0c;服务器的内部世界似乎既复杂又遥远。不过&#xff0c;不用担心&…

在Anaconda中修改查找和安装软件包的存储库的来源channels

以下是一些关键的步骤和命令&#xff0c;用于修改Anaconda的channels&#xff1a; 查看当前channels 使用命令 conda config --show channels 可以查看当前配置的channels。 添加新的channel 使用命令 conda config --add channels <channel_url> 来添加一个新的channel…

TIM定时器PWM输出

tim.c #include "tim.h" #include "stm32mp1xx_tim.h" #include "stm32mp1xx_gpio.h" #include "stm32mp1xx_rcc.h"//tim4初始化(蜂鸣器) void tim4_init(){//1.使能GPIOB的外设时钟RCC->MP_AHB4ENSETR | (0x1<<1);//使能TI…