一、简介
JAVA中调用LevelDB用于Linux和Window环境下快速存储KV结构
二、依赖
org.fusesource.leveldbjni
leveldbjni-all
1.8
三、代码
package com.dearcloud.utils.leveldb;
import lombok.extern.log4j.Log4j2;
import org.fusesource.leveldbjni.JniDBFactory;
import org.iq80.leveldb.DB;
import org.iq80.leveldb.Options;
import java.io.File;
import java.io.IOException;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ConcurrentLinkedQueue;
@Log4j2
public class LeveldbUtils {
private DB db;
private File file;
private Options options;
public LeveldbUtils(File file, Integer cahceSize, Integer blockSize) {
Objects.requireNonNull(file);
File[] files = file.listFiles();
if (files != null && files.length > 0) {
log.warn("levelDb directory is not empty. file=[{}]", file);
}
this.file = file;
if (blockSize == null) blockSize = 1024 * 1024 * 10;
if (cahceSize == null) cahceSize = 1024 * 1024 * 20;
options = new Options();
options.cacheSize(cahceSize);
options.blockSize(blockSize);
options.maxOpenFiles(5);
options.writeBufferSize(10000000);//单个文件32MB
reOpenDb();
}
private void openDb() {
synchronized (this) {
boolean isok = false;
try {
JniDBFactory.factory.destroy(file, options);
isok = true;
} catch (Exception ex) {
log.warn("levelDb destroy failed. file=[{}]", file);
}
try {
db = JniDBFactory.factory.open(file, options);
isok = isok && true;
} catch (IOException e) {
log.error("levelDb rebuild init failed. file=[{}]", file);
}
if (isok)
log.info("leveldb rebuild success.");
}
}
public synchronized void put(String key, byte[] value) {
try {
db.put(JniDBFactory.bytes(key), value);
} catch (Exception ex) {
log.warn("[save to localDb] save single item to localDb failed.", ex);
}
}
public synchronized void put(ConcurrentLinkedQueue> data) {
for (Map.Entry datum : data) {
try {
db.put(datum.getKey(), datum.getValue());
} catch (Exception ex) {
log.warn("[save to localDb] save to localDb failed.", ex);
}
}
}
public synchronized void close() {
try {
db.close();
JniDBFactory.factory.destroy(file, options);
} catch (IOException e) {
log.error("[LeveldbUtils]:levelDb close failed.", e);
}
}
}
linux和window环境下安装ruby和sass
linux下安装ruby 下载linux的ruby安装包 http://www.ruby-lang.org/en/downloads/ 将ruby安装包在linux环境下解压 tar -x ...
java中调用dll文件的两种方法
一中是用JNA方法,另外是用JNative方法,两种都是转载来的, JNA地址:http://blog.csdn.net/shendl/article/details/3589676 JNativ ...
如何在Java中调用Python代码
有时候,我们会碰到这样的问题:与A同学合作写代码,A同学只会写Python,而不会Java, 而你只会写Java并不擅长Python,并且发现难以用Java来重写对方的代码,这时,就不得不想方设法“调 ...
在Java中调用Python
写在前面 在微服务架构大行其道的今天,对于将程序进行嵌套调用的做法其实并不可取,甚至显得有些愚蠢.当然,之所以要面对这个问题,或许是因为一些历史原因,或者仅仅是为了简单.恰好我在项目中就遇到了这个问题 ...
在Java中调用Python代码
极少数时候,我们会碰到类似这样的问题:与A同学合作写代码, A同学只会写Python,不熟悉Java ,而你只会写Java不擅长Python,并且发现难以用Java来重写对方的代码,这时,就不得不想方 ...
Tensorflow 保存模型 &; 在java中调用
本节涉及: 保存TensorFlow 的模型供其他语言使用 java中调用模型并进行预测计算 一.保存TensorFlow 的模型供其他语言使用 如果用户选择“y” ,则执行下面的步骤: 判断程序执行 ...
java中调用js脚本
JDK1.6加入了对Script(JSR223)的支持.这是一个脚本框架,提供了让脚本语言来访问Java内部的方法.你可以在运行的时候找到脚本引擎,然后调用这个引擎去执行脚本.这个脚本API允许你为脚 ...
autoit 处理文件上传弹出框,并在JAVA中调用
Java 代码 //定义exe 文件存放的绝对路径 File file2 = new File("."); String command = file2.getCanonical ...
随机推荐
sql搜索like通配符的用法详解
http://www.lmwlove.com/ac/ID878 有很多朋友写了几年的like搜索,可能对like后面通配符的用法都不了解,甚至于%的作用是什么都不清楚.在这篇文章中,我们就一起来学习一 ...
iOS 使用AFNetworking遇到错误 Request failed: unacceptable content-type: text/html
错误日志: Error Domain=com.alamofire.error.serialization.response Code=-1016 "Request failed: unacc ...
codeforces 286 div2 B
思路:质因子累乘的值即为所求#include #include #include #include< ...
IDEA运行编译后配置文件无法找到,或配置文件修改后无效的问题
1.触发事件 今天正好在学习log4j,为了测试其配置文件log4j.properties中的各种配置,进行了频繁修改和程序启动以确认效果,因为是使用的IDEA建立的Web项目,接着问题就来了,配置文 ...
css3 ajax加载进度线
最近想了想ajax加载时的进项,便着手写了这个,我想css3的支持度已经够了 button
基于上三角变换或基于DFS的行(列)展开的n阶行列式求值算法分析及性能评估
进入大一新学期,看完前几节后,笔者有了用计算机实现行列式运算的想法.这样做的目的,一是巩固自己对相关概念的理解,二是通过独立设计算法练手,三是希望通过图表直观地展现涉及的两种算 ...
【BZOJ4919】[Lydsy六月月赛]大根堆
题解: 我觉得数据结构写成结构体还是有必要的 因为不然一道题里出现了两个相同的数据结构由于名字很像很容易出错 另外初始化用segmenttree(){ } 首先裸的dp很好想 f[i][j]表示在i点 ...
Android学习系列(4)--App自适应draw9patch不失真背景
做人要大度,海纳百川,做事要圆滑,左右逢源,这让我想到了编程也是如此,代码要扩展,界面也要考虑自适应.这篇文章是Android开发人员的必备知识,是我特别为大家整理和总结的,不求完美,但是有用. 1. ...
TensorFlow基础笔记(4) Tensor Transformation
https://segmentfault.com/a/1190000008793389 抽取 tf.slice(input_, begin, size, name=None):按照指定的下标范围抽取连 ...