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)
blank

相关推荐

  • 关于引用mshtml的问题[通俗易懂]

    今天看了个验证码识别的代码,其中引用到了mshtml.dll,找了半天原来就是microsoft.mshtml.dll。查这个dll的时候还发现了好几篇关于这个dll添加问题的文章。顺便看了下,原来这个dll有三个,添加引用时要注意了。   第一篇文章:   1.添加引用的问题   一般在开发环境下会在三个地方存有microsoft.mshtml.dll文件。所以在添加引用时,也

  • 转让malloc()该功能后,发生了什么事内核?附malloc()和free()实现源

    转让malloc()该功能后,发生了什么事内核?附malloc()和free()实现源

  • 学生信息管理系统的用例图和图书管理系统系统分析及用例图[通俗易懂]

    学生信息管理系统的用例图和图书管理系统系统分析及用例图[通俗易懂]练习一:请画出学生信息管理系统的用例图“学生信息管理系统”功能性需求包括以下内容:      (1)系统管理员登录后可以对班级的基本信息进行增加、删除、修改、查询等操作。学校领导登录后可以对班级基本信息进行查询操作。      (2)教师登录后可以对学生的考试成绩进行录入、删除、修改、查询等操作。学生登录后可以对考试成绩进行查询操作。      (3)学生登录后可以了解所有

  • java httprequest选项_HTTPRequest类

    java httprequest选项_HTTPRequest类原标题:HTTPRequest类HTTPRequest类java.lang.Objectcom.google.appengine.api.urlfetch.HTTPRequestpublicclassHTTPRequest扩展java.lang.ObjectHTTPRequest封装通过URLFetchService进行的单个HTTP请求。构造函数概述HTTPRequest(ja…

  • 惠普电脑有电脑管家吗_电脑管家检测硬件就蓝屏

    惠普电脑有电脑管家吗_电脑管家检测硬件就蓝屏据海外媒体WindowsLatest的报道,大量的Windows10用户的设备最近频繁出现蓝屏,多家硬件设备厂商均中招。联想电脑管家安全团队已证实暂不涉及联想设备的国内用户。同时提醒广大国内用户,暂停近期微软发布的任何更新业务(包括暂停通过Vantage应用程序进行BIOS更新),等待微软官方给出修复补丁。据悉该蓝屏问题是由于近期的一次更新造成,蓝屏(BSOD)错误将会阻止windows10设备的…

  • JavaScript中几种常用的设计模式

    JavaScript中几种常用的设计模式设计模式:代码书写经验,为了应对各种场景,经过前人不断的总结,压缩,形成的一套又一套的代码的书写规范,形成了设计模式。1.单例模式单例模式是一种常用的设计模式,如果需要多次创建同一个对象,完成

发表回复

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

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