java 集成测试_javadbf.jar

java 集成测试_javadbf.jar0、pom.xml依赖<!–LMDB–> <dependency> <groupId>org.lmdbjava</groupId> <artifactId>lmdbjava</artifactId> <version>0.7.0</version> </dependency>1、application.properties配置:#maven多环境打包的支持l

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

0、pom.xml依赖

<!-- LMDB -->
		<dependency>
			<groupId>org.lmdbjava</groupId>
			<artifactId>lmdbjava</artifactId>
			<version>0.7.0</version>
		</dependency>

1、application.properties配置:

lmdb.path=E:\\lmdb
#单位为MB
lmdb.max.size=256
lmdb.database.count=10

2、LmdbServier 工具类


import lombok.extern.slf4j.Slf4j;
import org.lmdbjava.*;
import org.springframework.stereotype.Service;
import javax.annotation.PostConstruct;
import java.io.File;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
import static java.lang.Integer.BYTES;
import static java.nio.ByteBuffer.allocateDirect;
import static org.lmdbjava.ByteBufferProxy.PROXY_OPTIMAL;
import static org.lmdbjava.DbiFlags.MDB_CREATE;
import static org.lmdbjava.Env.create;

/** * Lmdb操作工具类 * * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
@Slf4j
@Service
public class LmdbService { 
   

    /** * lmdb path */
    @Value("${lmdb.path}")
    private String lmdbPath;

    /** * env */
    private Env<ByteBuffer> env;

     /** * lmdb max size */
    @Value("${lmdb.max.size}")
    private int lmdbMaxSize;

    /** * lmdb库的数量 */
    @Value("${lmdb.database.count}")
    private int lmdbDatabaseCount;

    /** * Description: 初始化操作 <br> * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    @PostConstruct
    private void init(){ 
   
        try { 
   
            final File path = new File(lmdbPath);
            env = create(PROXY_OPTIMAL)
                    .setMapSize(lmdbMaxSize * 1024 * 1024)
                    .setMaxDbs(lmdbDatabaseCount)
                    .setMaxReaders(lmdbDatabaseCount*2)
                    .open(path);
            log.info("初始化Lmdb成功......");
        } catch (Exception e) { 
   
            throw new LmdbException("IO failure", e);
        }
    }

    /** * Description: 向库中插入数据 <br> * @param dbName dbname * @param key value 数据 * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    public void putValueToDb(String dbName, String key,String value) { 
   
        final Dbi<ByteBuffer> db = env.openDbi(dbName, MDB_CREATE);
        try (Txn<ByteBuffer> txn = env.txnWrite()) { 
   
            final Cursor<ByteBuffer> c = db.openCursor(txn);
            c.put(bb(key), bb(value));
            c.close();
            txn.commit();
        }

    }

    /** * Description: 根据指定的key获取数据 <br> * @param dbName dbname * @param key key * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    public String getValueByKey(String dbName, String key) { 
   

        final Dbi<ByteBuffer> db = env.openDbi(dbName, MDB_CREATE);
        final Cursor<ByteBuffer> c;
        String value ="";
        try (Txn<ByteBuffer> txn = env.txnRead()) { 
   
            c = db.openCursor(txn);
            c.get(bb(key),GetOp.MDB_SET_KEY);
            ByteBuffer byteBuffer = c.val();
            c.close();
            value =  StandardCharsets.UTF_8.decode(byteBuffer).toString();
        }
        return value;
    }

    /** * Description: 获取库下所有的数据 <br> * @param dbName dbname * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    public Map<String, String> getAllValueByDbName(String dbName) { 
   
        final Dbi<ByteBuffer> db = env.openDbi(dbName, MDB_CREATE);
        Map<String, String> map = new HashMap<>();
        try (Txn<ByteBuffer> txn = env.txnRead()) { 
   
            Cursor<ByteBuffer> cursor = db.openCursor(txn);
            while (cursor.next()) { 
   
                ByteBuffer key = cursor.key();
                ByteBuffer val = cursor.val();
                byte[] k = new byte[key.capacity()];
                byte[] v = new byte[val.capacity()];
                key.get(k);
                val.get(v);
                map.put(new String(k,StandardCharsets.UTF_8), new String(v,StandardCharsets.UTF_8));
            }
            cursor.close();
        }
        return map;
    }

    /** * Description: 根据dbname获取该库下的数量 <br> * @param dbName dbname * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    public long getDbCount(String dbName) { 
   
        return getAllValueByDbName(dbName).size();
    }

    /** * 格式化 ByteBuffer * @param value * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    static ByteBuffer bb(final int value) { 
   
        final ByteBuffer bb = allocateDirect(BYTES);
        bb.putInt(value).flip();
        return bb;
    }

    /** * 格式化 ByteBuffer * @param value * @author jack<br> * @version 1.0<br> * @CreateDate 2020年5月11日 <br> */
    static ByteBuffer bb(final String value) { 
   
        byte[] val = value.getBytes(StandardCharsets.UTF_8);
        final ByteBuffer bb = allocateDirect(val.length);
        bb.put(val).flip();
        return bb;
    }

}

3、lmdb数据库名称枚举:LmdbNameEnum

主要用于:定义lmdb中的dbName

public enum LmdbNameEnum { 
   
	//点位状态
	PointStatus("pointStatus");

	private String dbName;

	LmdbNameEnum(String dbName) { 
   
		this.dbName = dbName;
	}

	public String getDbName() { 
   
		return dbName;
	}

	@Override
	public String toString() { 
   
		return "LmdbNameEnum{" + "dbName=" + dbName + '}';
	}
}

4、Demo测试:LmdbController

package com.jack.maintain.controller;

import com.jack.framework.json.resp.BaseResp;
import com.jack.maintain.cache.LmdbService;
import com.jack.maintain.enums.LmdbNameEnum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import java.util.Map;

@Controller
@RequestMapping(value = "/lmdb")
public class LmdbController{ 
   

    @Autowired
    private LmdbService lmdbOperation;


    @RequestMapping(value = "setPoint/{point}",method = RequestMethod.GET)
    @ResponseBody
    public BaseResp setPoint(@PathVariable("point") String point){ 
   
        lmdbOperation.putValueToDb(LmdbNameEnum.PointStatus.getDbName(),point,point);
        return BaseResp.success("设值成功");
    }

    @RequestMapping(value = "getPoint/{point}",method = RequestMethod.GET)
    @ResponseBody
    public BaseResp getPoint(@PathVariable("point") String point){ 
   
        String val = lmdbOperation.getValueByKey(LmdbNameEnum.PointStatus.getDbName(),point);
        return BaseResp.success("成功",val);
    }

    @RequestMapping(value = "getPointCount",method = RequestMethod.GET)
    @ResponseBody
    public BaseResp getPointCount(){ 
   
        long count = lmdbOperation.getDbCount(LmdbNameEnum.PointStatus.getDbName());
        return BaseResp.success("成功",count);
    }

    @RequestMapping(value = "getPointList",method = RequestMethod.GET)
    @ResponseBody
    public BaseResp getDbVal(){ 
   
        Map<String,String> resultMap = lmdbOperation.getAllValueByDbName(LmdbNameEnum.PointStatus.getDbName());
        return BaseResp.success("成功",resultMap);
    }

}

测试结果:

插入值:
在这里插入图片描述
获取值:
在这里插入图片描述
在这里插入图片描述
配置文件中定义的lmdb数据路径:
在这里插入图片描述

资源补全:(相关的公共方法类)

BaseResp.java(接口统一返回封装类)


import java.util.List;

import com.jack.framework.json.JsonMsgUtil;
import com.fasterxml.jackson.annotation.JsonView;

import lombok.Data;
import lombok.experimental.Accessors;

/** * @Description: 基础返回类 * @date 2018年5月21日 下午9:28:00 */
@Data
@Accessors(chain = true)
public class BaseResp { 
   

	public interface DefaultJsonView { 
   
	};

	@JsonView(DefaultJsonView.class)
	private boolean rs;

	@JsonView(DefaultJsonView.class)
	private int code;

	@JsonView(DefaultJsonView.class)
	private String msg;

	@JsonView(DefaultJsonView.class)
	private Object data;

	@JsonView(DefaultJsonView.class)
	private List<?> datas;

	public BaseResp() { 
   
		this(0);
	}

	public BaseResp(int code) { 
   
		this.code = code;
	}

	public BaseResp(int code, String msg) { 
   
		this.code = code;
		this.msg = msg;
	}

	public String getMsg() { 
   
		if (msg == null) { 
   
			this.msg = JsonMsgUtil.getMsg(code);
		}
		if (this.msg == "") { 
   
			this.msg = JsonMsgUtil.getMsg(9999);
		}
		return msg;
	}

	public boolean getRs() { 
   
		rs = code == 0;
		return rs;
	}

	public boolean isRs() { 
   
		rs = code == 0;
		return rs;
	}

	public static boolean isSuccess(BaseResp resp) { 
   
		return resp.isRs();
	}

	/** * 功能描述:请求成功 * @param filePath */
	public static BaseResp success(String msg) { 
   
		BaseResp r = new BaseResp(0);
		r.setMsg(msg);
		return r;
	}
	//
	public static BaseResp success(String msg, Object data) { 
   
		BaseResp r = new BaseResp(0);
		r.setMsg(msg);
		r.setData(data);
		return r;
	}
	public static BaseResp success(String msg, List<?> datas) { 
   
		BaseResp r = new BaseResp(0);
		r.setMsg(msg);
		r.setDatas(datas);
		return r;
	}
	/** * 功能描述:参数出错 */
	public static BaseResp paramsError(String msg) { 
   
		BaseResp r = new BaseResp(100);
		r.setMsg(msg);
		return r;
	}

	/** * 功能描述:验证出错 */
	public static BaseResp validError(String msg) { 
   
		BaseResp r = new BaseResp(101);
		r.setMsg(msg);
		return r;
	}

	/** * 功能描述:逻辑判断出错 */
	public static BaseResp logicError(String msg) { 
   
		BaseResp r = new BaseResp(102);
		r.setMsg(msg);
		return r;
	}

	/** * 功能描述:未登录 */
	public static BaseResp invalidLogin(String url) { 
   
		BaseResp r = new BaseResp(9888);
		r.data = url;
		return r;
	}

	/** * 功能描述:无权限 */
	public static BaseResp invalidPerms(String msg) { 
   
		BaseResp r = new BaseResp(9889);
		r.setMsg(msg);
		return r;
	}

}

JsonMsgUtil.java(获取.properties文件属性的工具类)

package com.jack.framework.json;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.Properties;

import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.core.io.support.PropertiesLoaderUtils;

import lombok.extern.slf4j.Slf4j;

/** * 功能说明:资源工具类 */
@Slf4j
public final class JsonMsgUtil { 
   

	private static Properties propertie = new Properties();

	private static String DEFAULT_MESSAGE = "";

	static { 
   
		try { 
   
			propertie = PropertiesLoaderUtils.loadProperties(new PathMatchingResourcePatternResolver().getResource("classpath:conf/json-msg.properties"));
		} catch (IOException e1) { 
   
			String s = "Load resource file failed.";
			log.error(s);
		}
	}

	public static String getMsg(String key) { 
   
		String message = propertie.getProperty(key, DEFAULT_MESSAGE);
		try { 
   
			message = new String(message.getBytes("UTF-8"), "UTF-8");
		} catch (UnsupportedEncodingException e) { 
   
			e.printStackTrace();
			return DEFAULT_MESSAGE;
		}
		return message;
	}

	public static String getMsg(int key) { 
   
		String message = propertie.getProperty("" + key, DEFAULT_MESSAGE);
		try { 
   
			message = new String(message.getBytes("UTF-8"), "UTF-8");
		} catch (UnsupportedEncodingException e) { 
   
			e.printStackTrace();
			return DEFAULT_MESSAGE;
		}
		return message;
	}

}

json-msg.properties(定义系统的统一返回码)
通常中文需要转成Unicode格式

##################
#JSON MSG
#返回码规划如下
#100 --默认参数异常
#1XXX --通用错误异常
#2XXX --业务模块异常
#3XXX --API模块异常

#8XXX --管理模块异常
#9XXX --系统异常
##################

##########################正常############################
0=成功

##########################业务模块异常############################
#2X0X--业务通用模块
2001=文件上传失败
2002=业务参数异常
2003=你无权操作

##########################API模块异常############################
3999=时间戳错误
3998=随机码错误
3997=签名错误

3000=未登录或已失效,请重新登录

##########################系统异常############################
9400=无效请求
9404=非法请求
9405=方法不被允许
9406=无法接受
9415=不支持的媒体类型
9500=执行异常

9900=运行时异常
9901=空值异常
9902=数据类型转换异常
9903=IO异常
9904=未知方法异常
9905=数组越界异常

9888=未登录或已失效,请重新登录
9889=权限不足

9997=Json格式错误
9998=数据格式错误
9999=系统异常

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/189014.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 论文DepthTrack: Unveiling the Power of RGBD Tracking阅读及代码讲解[通俗易懂]

    论文DepthTrack: Unveiling the Power of RGBD Tracking阅读及代码讲解[通俗易懂]最近终于有了一篇的顶会像样的RGBDtracking的论文了:ICCV2021:DepthTrack:UnveilingthePowerofRGBDTrackingGithub:https://github.com/xiaozai/DeT数据集简介这边看完就随手记录一下关键的部分:主要是创建了个大规模的RGBDtrackingbenchmark:DepthTrack(有数据集之后才能促进算法的研究),当然随之也搞了个baselinetracker—DeT,这也是现在搞d

  • 莫兰指数(Moran’s I)的小总结

    莫兰指数(Moran’s I)的小总结莫兰指数分为全局莫兰指数(GlobalMoran’sI)和局部莫兰指数(LocalMoran’sI),前者是PatrickAlfredPierceMoran开发的空间自相关的度量;后者是美国亚利桑那州立大学地理与规划学院院长LucAnselin教授在1995年提出的。通常情况,先做一个地区的全局I指数,全局指数只是告诉我们空间是否出现了集聚或异常值,但并没有告诉我们在哪里出…

  • rj45管脚定义_rj45接口定义,rj45插座引脚定义

    RJ45是布线系统中信息插座(即通信引出端)连接器的一种,连接器由插头(接头、水晶头)和插座(模块)组成,插头有8个凹槽和8个触点。RJ是RegisteredJack的缩写,意思是“注册的插座”。在FCC(美国联邦通信委员会标准和规章)中RJ是描述公用电信网络的接口,计算机网络的RJ45是标准8位模块化接口的俗称。rj45插座引脚定义:常见的RJ45接口有两类:用于以太网网卡、路由器以太网接口等…

  • 临界段CCriticalSection的使用[通俗易懂]

    临界段CCriticalSection的使用[通俗易懂]类CCriticalSection的对象表示一个“临界区”,它是一个用于同步的对象,同一时刻仅仅同意一个线程存取资源或代码区。临界区在控制一次仅仅有一个线程改动数据或其他的控制资源时很实用。比如,在链表中添加�一个结点就仅仅同意一次一个线程进行。通过使用CCriticalSection对象来控制链表,就能够达到这个目的。它就像是一把钥匙,哪个线程获得了它就获得了执行线程的权力,而把其…

  • JDK安装包和Mysql安装包整理

    肯定有许多许多小伙伴在找jdk和MySQL这些东西的安装包,去官网下载有特别慢,所以想在网上找一下,来吧,看完总有一款是你喜欢的。。。。JDK安装包jdk-7u80-windows-x64.exe(jdk1.7win64位)jdk-7u80-windows-x86.exe(jdk1.7win32位)jdk-7u80-linux-i586.tar.gz(jdk1.7Li…

  • 论文写作利器—LaTeX教程(入门篇)(更新中)

    论文写作利器—LaTeX教程(入门篇)(更新中)一、LaTeX简介结合维基百科及LaTeX官网可知:LaTeX(/ˈlɑːtɛx/,常被读作/ˈlɑːtɛk/或/ˈleɪtɛk/)是一种基于TeX的高品质排版系统,由美国计算机科学家莱斯利·兰伯特在20世纪80年代初期开发,非常适用于生成高印刷质量的科技和数学、物理文档,尤其擅长于复杂表格和数学公式的排版。LaTeX是科学文献交流和出版的事实标准。简单来说,相比于Word排版时需要设…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号