From 2f9c1c2e9a982f6ae35105804decc2c0c54e883a Mon Sep 17 00:00:00 2001
From: shaozhuguang <shaozhuguang@jd.com>
Date: Thu, 28 May 2020 14:29:26 +0800
Subject: [PATCH] modify args of rocksdb config

---
 .../impl/rocksdb/RocksDBConnectionFactory.java       | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/source/storage/storage-rocksdb/src/main/java/com/jd/blockchain/storage/service/impl/rocksdb/RocksDBConnectionFactory.java b/source/storage/storage-rocksdb/src/main/java/com/jd/blockchain/storage/service/impl/rocksdb/RocksDBConnectionFactory.java
index 852124ba..062719b9 100644
--- a/source/storage/storage-rocksdb/src/main/java/com/jd/blockchain/storage/service/impl/rocksdb/RocksDBConnectionFactory.java
+++ b/source/storage/storage-rocksdb/src/main/java/com/jd/blockchain/storage/service/impl/rocksdb/RocksDBConnectionFactory.java
@@ -85,12 +85,11 @@ public class RocksDBConnectionFactory implements DbConnectionFactory {
 	}
 
 	private Options initOptions() {
-		final Filter bloomFilter = new BloomFilter(32);
-		Cache cache = new LRUCache(2 * SizeUnit.GB);
+		final Filter bloomFilter = new BloomFilter(10);
+		Cache cache = new LRUCache(256 * SizeUnit.MB);
 
 		final BlockBasedTableConfig tableOptions = new BlockBasedTableConfig()
 				.setFilterPolicy(bloomFilter)
-				.setBlockSize(4 * SizeUnit.KB)
 				.setBlockSizeDeviation(10)
 				.setBlockCache(cache)
 				.setNoBlockCache(false)
@@ -107,6 +106,11 @@ public class RocksDBConnectionFactory implements DbConnectionFactory {
 		compressionLevels.add(CompressionType.SNAPPY_COMPRESSION); // 6-7
 
 		Options options = new Options()
+				// 最多占用256 * 7 + 256 = 2G内存
+				.setWriteBufferSize(256 * SizeUnit.MB)
+				.setMaxWriteBufferNumber(7)
+				.setMinWriteBufferNumberToMerge(2)
+				.setMaxOpenFiles(-1)
 				.setAllowConcurrentMemtableWrite(true)
 				.setEnableWriteThreadAdaptiveYield(true)
 				.setCreateIfMissing(true)
@@ -118,8 +122,6 @@ public class RocksDBConnectionFactory implements DbConnectionFactory {
 				.setMinWriteBufferNumberToMerge(4)
 				.setCompressionPerLevel(compressionLevels)
 				.setNumLevels(7)
-				.setCompressionType(CompressionType.SNAPPY_COMPRESSION)
-				.setCompactionStyle(CompactionStyle.UNIVERSAL)
 				.setMemTableConfig(new SkipListMemTableConfig())
 				;
 		return options;