- 浏览: 167282 次
- 来自: ...
文章分类
最新评论
-
hellostory:
不知所云………………
如何使用反射访问类的private域和方法 -
xusong_zidingyi:
如果在linux下面的话就没有办法运行了,因为linux没有办 ...
使用tesseract破解checkCode -
javajava22:
Errors accessing files. There m ...
使用tesseract破解checkCode -
suncathay:
qljobs 写道cmd.add("E:/Works ...
使用tesseract破解checkCode -
zuoxu128:
TIFFImageWriteParam ,这个类是哪个包的啊
使用tesseract破解checkCode
在napoli的代码中发现这个berkeleydb,版本为3.2.43,使用代码如下
接口定义如下:
/** * Project: napoli.client * * File Created at Sep 15, 2009 * $Id$ * * Copyright 2008 Alibaba.com Croporation Limited. * All rights reserved. * * This software is the confidential and proprietary information of * Alibaba Company. ("Confidential Information"). You shall not * disclose such Confidential Information and shall use it only in * accordance with the terms of the license agreement you entered into * with Alibaba.com. */ package com.alibaba.napoli.client.inner.persistencestore; import java.io.Serializable; import java.util.List; import java.util.Map; /** * 持久化仓库的接口。 * * @author ding.lid * @author guolin.zhuanggl */ public interface PersistenceStore<T extends Serializable> { /** * 写入一条数据。会自动生成一个与之对应的key。 * * @param data */ void write(T data); /** * 写入多条数据。 * * @param dataList */ void batchWrite(List<T> dataList); /** * 读一条数据。<br> * 如果读多条数据的情况下,尽量使用{@link #batchRead(int)}方法,有更好的效率。 * * @return 读到的数据。如果store中没有数据,则返回<code>null</code>。 */ Map.Entry<String, T> read(); /** * 读多条数据。 * * @param count 要读数据的条数 * @return 读到的数据。如果store中没有数据,则返回空的Map(即size ==0)。 */ Map<String, T> batchRead(int count); /** * 删除一条数据。 * * @param key */ void delete(String key); /** * 删除多条数据。 * * @param keys 要删除数据的Key */ void delete(List<String> keys); }
采用berkeleydb的实现如下:
/** * Project: napoli.client * * File Created at Sep 15, 2009 * $Id$ * * Copyright 2008 Alibaba.com Croporation Limited. * All rights reserved. * * This software is the confidential and proprietary information of * Alibaba Company. ("Confidential Information"). You shall not * disclose such Confidential Information and shall use it only in * accordance with the terms of the license agreement you entered into * with Alibaba.com. */ package com.alibaba.napoli.client.inner.persistencestore.impl; import java.io.File; import java.io.Serializable; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.Map.Entry; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import com.alibaba.napoli.client.inner.persistencestore.PersistenceStore; import com.sleepycat.bind.EntryBinding; import com.sleepycat.bind.serial.SerialBinding; import com.sleepycat.bind.serial.StoredClassCatalog; import com.sleepycat.bind.tuple.TupleBinding; import com.sleepycat.je.Cursor; import com.sleepycat.je.Database; import com.sleepycat.je.DatabaseConfig; import com.sleepycat.je.DatabaseEntry; import com.sleepycat.je.DatabaseException; import com.sleepycat.je.Environment; import com.sleepycat.je.EnvironmentConfig; import com.sleepycat.je.EnvironmentMutableConfig; import com.sleepycat.je.LockMode; import com.sleepycat.je.OperationStatus; import com.sleepycat.je.Transaction; import com.sleepycat.je.TransactionConfig; /** * @author guolin.zhuanggl * @author ding.lid */ public class BdbPersistenceStore<T extends Serializable> implements PersistenceStore<T> { private static final Log log = LogFactory.getLog(BdbPersistenceStore.class); private final static String MESSAGE_DBNAME = "MESSAGE_DB"; private final static String MESSAGE_CLASS_DBNAME = "MESSAGE_CLASS_DB"; private String bdbStorePath; // 默认值 10M private long bdbCheckpointBytes = 10 * 1024 * 1024; // 默认值 5M private long bdbCacheSize = 5 * 1024 * 1024; private Environment bdbEnvironment; private Database bdb; private StoredClassCatalog bdbClassCatalog; private final Class<T> dataClass; public String getBdbStorePath() { return bdbStorePath; } /** * 设定BDB数据的存储目录。如果这个目录不存在,会被自动创建。 * * @param storePath BDB数据的存储目录 */ public void setBdbStorePath(final String storePath) { this.bdbStorePath = storePath; } public long getBdbCheckpointBytes() { return bdbCheckpointBytes; } /** * 设置DBD的CheckpointBytes参数。默认值 10M。 */ public void setBdbCheckpointBytes(final long dbdCheckpointBytes) { this.bdbCheckpointBytes = dbdCheckpointBytes; } public long getBdbCacheSize() { return bdbCacheSize; } /** * 设置DBD的CacheSize参数。默认值 5M。 */ public void setBdbCacheSize(final long dbdCacheSize) { this.bdbCacheSize = dbdCacheSize; } public void init() throws DatabaseException { if (null == bdbStorePath) { throw new IllegalStateException("Member bdbStorePath is null!"); } open(); } private void open() throws DatabaseException { final File bdbDir = new File(bdbStorePath); if (!bdbDir.exists()) { if (!bdbDir.mkdirs()) { throw new RuntimeException("Fail to create the store directory(" + bdbStorePath + ") for bdb persistence store!"); } } final boolean readOnly = false; final EnvironmentConfig envConfig = new EnvironmentConfig(); envConfig.setReadOnly(readOnly); envConfig.setAllowCreate(true); envConfig.setTransactional(true); // must setting // checkpoint occupied after data file increase some bytes envConfig.setConfigParam("je.checkpointer.bytesInterval", String .valueOf(bdbCheckpointBytes)); final EnvironmentMutableConfig envMutableConfig = new EnvironmentMutableConfig(); envMutableConfig.setCacheSize(bdbCacheSize); bdbEnvironment = new Environment(bdbDir, envConfig); bdbEnvironment.setMutableConfig(envMutableConfig); final DatabaseConfig dbConfig = new DatabaseConfig(); dbConfig.setReadOnly(readOnly); dbConfig.setAllowCreate(!readOnly); dbConfig.setSortedDuplicates(false); dbConfig.setTransactional(true); bdb = bdbEnvironment.openDatabase(null, MESSAGE_DBNAME, dbConfig); // create class info db final Database classDb = bdbEnvironment.openDatabase(null, MESSAGE_CLASS_DBNAME, dbConfig); bdbClassCatalog = new StoredClassCatalog(classDb); } public void close() throws DatabaseException { // close db first, then close enviroment if (null != bdb) { bdb.close(); bdb = null; } if (null != bdbClassCatalog) { bdbClassCatalog.close(); bdbClassCatalog = null; } if (bdbEnvironment != null) { bdbEnvironment.cleanLog(); bdbEnvironment.close(); bdbEnvironment = null; } } /** * 也可以使用 {@link #createBdbPersistenceStore(Class)} 来获得一个实例。 * * @param clazz 存储数据的类型的class。 */ public BdbPersistenceStore(final Class<T> clazz) { dataClass = clazz; } /** * 生成BdbPersistenceStore工厂方法。功能上和构造函数一样,形式上简单些。 * * @param <DT> 存储数据的类型。 * @param dataType 存储数据的类型的class。 * @return 返回存储该数据类型的BdbPersistenceStore的泛型对象。 */ public static <DT extends Serializable> BdbPersistenceStore<DT> createBdbPersistenceStore( final Class<DT> dataType) { return new BdbPersistenceStore<DT>(dataType); } /** * 使用UUID字符串产生DatabaseEntry作为Key。 */ private static DatabaseEntry generateKeyEntry() { final String uuid = UUID.randomUUID().toString(); return generateKeyEntry(uuid); } /** * 根据一个字符串产生DatabaseEntry作为Key。 */ private static DatabaseEntry generateKeyEntry(final String key) { final DatabaseEntry entry = new DatabaseEntry(); final EntryBinding keyBinding = TupleBinding.getPrimitiveBinding(String.class); keyBinding.objectToEntry(key, entry); return entry; } /** * 从DatabaseEntry还原出Key */ private static String restoreKey(final DatabaseEntry entry) { final EntryBinding keyBinding = TupleBinding.getPrimitiveBinding(String.class); return (String) keyBinding.entryToObject(entry); } private DatabaseEntry generateDataEntry(final Object object) { final DatabaseEntry entry = new DatabaseEntry(); final EntryBinding dataBinding = new SerialBinding(bdbClassCatalog, dataClass); dataBinding.objectToEntry(object, entry); return entry; } /** * 从DatabaseEntry还原出数据 */ private T restoreData(final DatabaseEntry entry) { final EntryBinding dataBinding = new SerialBinding(bdbClassCatalog, dataClass); @SuppressWarnings("unchecked") final T data = (T) dataBinding.entryToObject(entry); return data; } /** * 写入一个对象。会自动生成一个与之对应的key。 <br> * 如果出错,写入失败,忽略掉! */ // FIXME 忽略出错? 是否有其它的解决办法?? public void write(final T object) { if (object != null) { try { bdb.put(null, generateKeyEntry(), generateDataEntry(object)); if (log.isTraceEnabled()) { log.trace("write object to db: " + object); } } catch (final DatabaseException e) { log.fatal("write message failed ", e); } } } /** * 写入多个对象。 <br> * 如果出错,写入失败,忽略掉! */ // FIXME 忽略出错? 是否有其它的解决办法?? public void batchWrite(final List<T> objectList) { for (final T obj : objectList) { write(obj); } } /** * 读数据。 * * @return 返回读到的数据。 如果store中没有数据、或是读出错,则返回null。 */ public Entry<String, T> read() { SimpleEntry<String, T> entry = null; Cursor cursor = null; try { cursor = bdb.openCursor(null, null); final DatabaseEntry foundKey = new DatabaseEntry(); final DatabaseEntry foundData = new DatabaseEntry(); if (cursor.getNext(foundKey, foundData, LockMode.DEFAULT) == OperationStatus.SUCCESS) { entry = new SimpleEntry<String, T>(restoreKey(foundKey), restoreData(foundData)); } if (log.isTraceEnabled()) { log.trace("read object from db"); } } catch (final DatabaseException e) { log.error("Don't warry, read message from db error, " + "late read again: " + e.getMessage()); } finally { if (cursor != null) { try { cursor.close(); } catch (final DatabaseException e) { // ignore } } } return entry; } /** * 读数据。 * * @return 返回读到的数据。 如果store中没有数据、或是读出错,则返回空的Map(即size为0的Map)。 */ public Map<String, T> batchRead(final int count) { final Map<String, T> map = new HashMap<String, T>(count); Cursor cursor = null; try { cursor = bdb.openCursor(null, null); final DatabaseEntry foundKey = new DatabaseEntry(); final DatabaseEntry foundData = new DatabaseEntry(); int readedNum = 0; while (cursor.getNext(foundKey, foundData, LockMode.DEFAULT) == OperationStatus.SUCCESS && readedNum < count) { map.put(restoreKey(foundKey), restoreData(foundData)); readedNum++; } if (log.isTraceEnabled()) { log.trace("read object from db, count= " + readedNum); } } catch (final DatabaseException e) { log.error("Don't warry, read message from db error, " + "late read again: " + e.getMessage()); } finally { if (cursor != null) { try { cursor.close(); } catch (final DatabaseException e) { // ignore } } } return map; } // FIXME 实现 忽略了 出错的情况。 public void delete(final String key) { if (key == null) { return; } Transaction transaction = null; try { final TransactionConfig txnConfig = new TransactionConfig(); txnConfig.setSync(true); transaction = bdbEnvironment.beginTransaction(null, txnConfig); if (log.isTraceEnabled()) { log.trace("BDB: begin to transaction"); } bdb.delete(transaction, generateKeyEntry(key)); if (log.isTraceEnabled()) { log.trace("BDB: delete message key=" + key); } transaction.commit(); transaction = null; if (log.isTraceEnabled()) { log.trace("BDB: end of transaction"); } } catch (final DatabaseException e) { log.fatal("BDB: delete failed: " + e.getMessage()); } catch (final Throwable t) { log.fatal("BDB: delete failed: " + t.getMessage()); } finally { if (transaction != null) { try { transaction.abort(); } catch (final DatabaseException e1) { } } } } public void delete(final List<String> keys) { // TODO 优化这个方法,以避免多次开关事务! for (final String key : keys) { delete(key); } } }
发表评论
-
一些随想
2012-06-01 22:05 0需求 idea 方案 执 ... -
Redis的安装与使用
2011-10-24 20:04 1280今天看了下redis相关的东东,做个备忘。 Re ... -
Redis的安装与使用
2011-10-24 20:00 0Redis 服务端: http://cocos.iteye. ... -
GenericDAO
2011-07-31 14:49 0GenericDAO -
loadfromproperties
2011-07-31 14:48 0loadfromproperties -
resultcode
2011-07-31 14:47 0resultcode -
几种简单的Load Balance方法
2011-07-31 13:44 0以下代码出自napoli (1)定义Selec ... -
参数断言工具
2011-07-31 12:58 944见代码: public final class Argume ... -
如何检测线上代码的运行情况---BTrace使用分享
2011-04-10 17:36 2083(1)你是否有时发现线上的代码运行效率不高,但却无法定位到底具 ... -
napoli和JMS,mq的一些知识
2010-11-26 21:01 01 jms和mq (1)jms activeMQ 应用 h ... -
Taglib基础知识
2010-11-26 12:41 0浅论taglib设计 : http://wenku.bai ... -
java编码问题的一些文章
2010-11-11 17:30 0http://www.iteye.com/topic/8047 ... -
URL在转码的过程中数据丢失
2010-10-25 14:52 0示例代码 import java.io.Unsuppo ... -
遍历大容量map的正确方法
2010-10-08 13:20 11179首先,遍历map有以下方法: import java.uti ... -
B2B-Code Review规范
2010-08-31 10:15 01.目标 凡事知其然还要知其所以然,我们首先需要知道什么 ... -
多线程书写及code review规范
2010-08-31 10:09 14451. 不允许将Calendar用于类的静态成员 ... -
域名白名单检查
2010-08-24 21:05 0首先准备一份白名单名为safe-domain.xml ,如下: ... -
如何使用反射访问类的private域和方法
2010-08-17 21:44 5124如何使用反射访问类的private域和方法?非常简单,由 ... -
FindBugs插件的安装与使用
2010-04-21 10:54 19081 什么是FindBugs FindBugs 是一个静态分析 ... -
JAVA调用ICE接口实践
2010-04-01 11:37 5286最近刚开发了一个需求,使用ICE调用服务器端的接口,过程如下: ...
相关推荐
### Berkeley DB 使用方法简介(C接口) #### 一、引言 Berkeley DB 是一个高性能、可嵌入式的键值数据库系统,它提供了一个非 SQL 的解决方案,特别适合那些需要高速内存操作的应用场景。Berkeley DB 支持多种...
BerkeleyDB 多库联合操作 (Secondary Databases) - **3.1 二级数据库介绍** - **概念解释**:二级数据库是对主数据库的一个索引,用于提高查询效率。 - **应用场景**:快速查找、数据统计等。 - **3.2 创建二级...
Berkeley DB 使用文档大全 Berkeley DB 是一种高性能的数据库管理系统,它提供了一个灵活的存储引擎,可以用于各种类型的应用程序。Berkeley DB 的使用可以分为两大部分:游标操作和记录操作。 一、游标操作 ...
### Berkeley DB 使用详解 Berkeley DB(BDB)是一个高性能的键/值存储数据库系统,以其卓越的稳定性和跨平台性著称。它几乎适用于所有主流的操作系统,并且支持多种编程语言,包括C/C++、Java等。Berkeley DB不仅...
- **20.5 BerkeleyDB使用C++实例** - **示例代码**:给出使用C++访问Berkeley DB的具体代码示例。 - **20.6 BerkeleyDB使用C++实例** - **更多示例**:提供更多的C++代码示例以加深理解。 - **20.7 BerkeleyDB中...
《BerkeleyDB Manual C/C++》是一份详尽的官方文档,主要针对使用C和C++语言进行数据库操作的开发者。BerkeleyDB是一款轻量级、高性能的关系型数据库管理系统,常用于嵌入式系统和分布式应用程序。这篇手册将深入...
- 在并发处理方面,Sqlite 使用行级锁定,而 BerkeleyDB 使用多版本并发控制,对于高并发环境,BerkeleyDB 可能表现更好。 总的来说,BerkeleyDB 和 Sqlite 都是优秀的嵌入式数据库解决方案,选择哪一个取决于具体...
3. **空间效率**:Berkeley DB通常关注内存和磁盘空间的使用效率,4.8版本可能进一步降低了存储开销,从而在资源有限的环境中更高效。 4. **错误处理和恢复**:为了提高系统的健壮性,4.8版本可能增强了错误检测和...
Berkeley DB Java Edition (JE) 是一款由Oracle公司开发的全Java实现的轻量级数据库管理系统,特别适用于处理大量简单数据。其主要特点包括: 1. **高效性能**:JE能有效处理从1到100万条记录,性能瓶颈通常在于...
在Je-3.1.0版本中,BerkeleyDB使用特定的数据库文件格式,这些文件可以在不同平台上进行迁移,确保了跨平台的兼容性。 **7. 性能优化** BerkeleyDB提供了多种性能调优选项,如缓存大小设置、日志文件管理等,...
**Berkeley DB 知识详解** Berkeley DB(简称 BDB)是一...通过深入阅读提供的 "Berkeley DB 参考资料.pdf",你可以更全面地了解 Berkeley DB 的使用方法、API 实例以及最佳实践,进一步提升在实际项目中的应用能力。
在"BerkeleyDB测试程序"中,我们将探讨如何使用BerkeleyDB进行散列文件的入库操作,以及测试其读取速度。 **散列文件入库** 散列文件入库是将数据以键值对的形式存储到BerkeleyDB的过程。在这个过程中,键(key)...
Berkeley DB 6.2.32_64.msi Windows 64-bit binary installer Berkeley DB是一个嵌入式数据库,为应用程序提供可伸缩的、高性能的、有事务保护功能的数据管理服务。 主要特点: 嵌入式:直接链接到应用程序中,与...
**Berkeley DB** 是一款轻...总之,这个“Berkeley DB 完整资料”集合为学习和使用Berkeley DB 提供了宝贵的资源。无论是初学者还是有经验的开发者,都能从中获取到有价值的信息,提升对Berkeley DB 的理解和应用能力。
**Berkeley DB数据库详解** Berkeley DB(简称BDB)是一种高性能、轻量级的嵌入式数据库系统,由Oracle公司开发并维护。它最初在伯克利大学诞生,因此得名“Berkeley DB”。这款数据库系统广泛应用于需要快速、可靠...
在“BerkeleyDB概念”部分,文档会介绍Berkeley DB的基本概念,如BTree和Hash数据库的访问方式选择,以及Queue和Recno之间的选择。 接下来,教程会讨论数据库的限制与可移植性、环境设置、异常处理和错误返回。然后...
5. **日志与恢复**:Berkeley DB使用日志文件记录所有对数据库的修改,确保在系统崩溃或异常情况下能够恢复数据。书中会介绍日志管理机制和如何执行数据库恢复。 6. **备份与迁移**:学习如何进行数据库的备份、...
4. **BerkeleyDB-Java-Collections.pdf**:对于Java开发者,此文档展示了如何使用BerkeleyDB与Java集合框架集成,提供了一种将数据库操作与Java编程无缝结合的方式。 5. **DBMessageTextReference.pdf**:这份文档...
它支持多种编程语言,包括Java,这使得开发人员能够在Java应用程序中直接使用Berkeley DB进行数据管理。在本文中,我们将详细探讨如何在Java环境下使用Berkeley DB。 首先,我们需要了解Berkeley DB的一般操作流程...
Berkeley DB 使用一种名为Btree的文件格式,这是一种高效的数据结构,用于在磁盘上组织数据,支持快速的查找、插入和删除操作。此外,它还支持Hash和Queue文件格式,分别适用于不同的应用场景。 ### 5. **多版本...