|
|
@@ -0,0 +1,27 @@
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.rocksdb.Options;
|
|
|
+import org.rocksdb.RocksDB;
|
|
|
+import org.rocksdb.RocksDBException;
|
|
|
+
|
|
|
+import java.nio.charset.StandardCharsets;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author reghao
|
|
|
+ * @date 2022-06-20 14:31:14
|
|
|
+ */
|
|
|
+@Slf4j
|
|
|
+public class RocksDBTest {
|
|
|
+ static String metaDir = "/opt/file/meta";
|
|
|
+
|
|
|
+ public static void main(String[] args) throws RocksDBException {
|
|
|
+ Options options = new Options().setCreateIfMissing(true);
|
|
|
+ RocksDB db = RocksDB.open(options, metaDir);
|
|
|
+
|
|
|
+ String key = "key1";
|
|
|
+ /*String value = "json value";
|
|
|
+ db.put(key.getBytes(StandardCharsets.UTF_8), value.getBytes(StandardCharsets.UTF_8));*/
|
|
|
+
|
|
|
+ byte[] value1 = db.get(key.getBytes(StandardCharsets.UTF_8));
|
|
|
+ log.info("value -> {}", new String(value1));
|
|
|
+ }
|
|
|
+}
|
