ttServer缓存的简单使用

时间：2017-06-10 20:23:42 阅读：300 评论：0 收藏：0 [点我收藏+]

标签：play comment article mil sans 0.11 boa 127.0.0.1 star

ttserver是一款 DBM 数据库，该数据库读写非常快，哈希模式写入100万条数据只需0.643秒，读取100万条数据只需0.773秒，是 Berkeley DB 等 DBM 的几倍。利用Tokyo Tyrant构建兼容Memcached协议、支持故障转移、高并发的分布式key-value持久存储系统。key-value分布式存储系统查询速度快、存放数据量大、支持高并发，非常适合通过主键进行查询，但不能进行复杂的条件查询。

[java] view plaincopy
import java.util.Properties;  
  
import org.apache.commons.logging.Log;  
import org.apache.commons.logging.LogFactory;  
import org.springframework.core.io.ClassPathResource;  
  
import tokyotyrant.MRDB;  
import tokyotyrant.networking.NodeAddress;  
import tokyotyrant.transcoder.StringTranscoder;  
/** 
 * 和ttServer服务端连接的工具类 
 * 使用jar包:tokyotyrant-0.11.jar 
 * @author 7q 
 */  
public class TokyoTyrantDB {  
  
    private static TokyoTyrantDB db = new TokyoTyrantDB();  
    //默认值  
    private String IP = "127.0.0.1";  
    private String PORT = "8888";  
    MRDB rdb = null;  
    private Log logger = LogFactory.getLog(TokyoTyrantDB.class);  
      
    /** 
     * 创建对象的时候,加载配置文件,创建和ttServer服务器的连接 
     */  
    private TokyoTyrantDB() {  
        try {  
            /* 
             * 读取配置文件(配置文件放在src下,或者放在src下的META-INF文件夹下,没有这个文件夹可以创建一个) 
             * ip=192.168.0.100 
             * port=99 
             */  
            ClassPathResource resource = new ClassPathResource("tt.properties");  
            Properties properties = new Properties();  
            properties.load(resource.getInputStream());  
            if (properties.getProperty("ip") != null) {  
                IP = properties.getProperty("ip");  
            }  
            //System.out.println(IP);  
            if (properties.getProperty("port") != null) {  
                PORT = properties.getProperty("port");  
            }  
            //System.out.println(PORT);  
            rdb = new MRDB();  
            //创建连接  
            rdb.open(NodeAddress.addresses("tcp://" + IP + ":" + PORT));  
              
        } catch (Exception e) {  
            logger.error(e.getMessage(), e);  
        }  
    }  
  
    public static TokyoTyrantDB getInstance() {  
        return db;  
    }  
    /** 
     * 保存数据到ttServer 
     * @param key 
     * @param value 
     * @return  保存成功,返回true,保存失败,返回false 
     */  
    public boolean save(String key, String value) {  
        try {  
            if (rdb.put(key, value).get()) {  
                return true;  
            } else {  
                return false;  
            }  
        } catch (Exception e) {  
            logger.error(e.getMessage(), e);  
            //如果保存数据出异常,重试再连接一次  
            try {  
                if (rdb == null) {  
                    rdb = new MRDB();  
                    rdb.open(NodeAddress.addresses("tcp://" + IP + ":" + PORT));  
                }  
            } catch (Exception ex) {  
                logger.error(ex.getMessage(), ex);  
            }  
            return false;  
        }  
    }  
      
    /** 
     * 通过key获取value 
     * @param key 
     * @return  通过key获取value 
     */  
    public String getValueByKey(String key) {  
        try {  
            Object object = rdb.get(key, new StringTranscoder()).get();  
            if (object != null) {  
                return object.toString();  
            }  
            return null;  
        } catch (Exception e) {  
            logger.error(e.getMessage(), e);  
            try {  
                if (rdb == null) {  
                    rdb = new MRDB();  
                    rdb.open(NodeAddress.addresses("tcp://" + IP + ":" + PORT));  
                }  
                  
            } catch (Exception ex) {  
                logger.error(ex.getMessage(), ex);  
            }  
            return null;  
        }  
    }  
}  

使用方式:

[java] view plaincopy
public static void main(String[] args) {  
    TokyoTyrantDB.getInstance().save(key, value);  
    TokyoTyrantDB.getInstance().getValueByKey(key);  
}  

ttServer缓存的简单使用

标签：play comment article mil sans 0.11 boa 127.0.0.1 star

原文地址：http://www.cnblogs.com/edgedance/p/6979648.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行