memcached-官方推荐jar操作

喜欢ヅ旅行 2022-07-16 15:57 150阅读 0赞

package memcache;

import java.io.Serializable;  
import java.util.Date;

import com.danga.MemCached.MemCachedClient;  
import com.danga.MemCached.SockIOPool;  
import com.schooner.MemCached.MemcachedItem;

class TBean implements Serializable \{

private static final long serialVersionUID = 1945562032261336919L;
    
    private String name;
    
    public String getName() {
        return name;
    }
    
    public void setName(String name) {
        this.name = name;
    }
    
    @Override
    public String toString() {
        return "TBean [name=" + name + "]";
    }

public class MemCachedManager \{  
// 创建全局的唯一实例  
protected static MemCachedClient mcc = new MemCachedClient();

protected static MemCachedManager memCachedManager = new MemCachedManager();
    
    // 设置与缓存服务器的连接池
    static {
        // 服务器列表和其权重
        String[] servers = { "127.0.0.1:11211" };
        Integer[] weights = { 3 };
    
        // 获取socke连接池的实例对象
        SockIOPool pool = SockIOPool.getInstance();
    
        // 设置服务器信息
        pool.setServers(servers);
        pool.setWeights(weights);
    
        // 设置初始连接数、最小和最大连接数以及最大处理时间
        pool.setInitConn(5);
        pool.setMinConn(5);
        pool.setMaxConn(250);
        pool.setMaxIdle(1000 * 60 * 60 * 6);
    
        // 设置主线程的睡眠时间
        pool.setMaintSleep(30);
    
        // 设置TCP的参数，连接超时等
        pool.setNagle(false);
        pool.setSocketTO(3000);
        pool.setSocketConnectTO(0);
    
        // 初始化连接池
        pool.initialize();
    
        // 压缩设置，超过指定大小（单位为K）的数据都会被压缩
        /*  mcc.setCompressEnable(true);
            mcc.setCompressThreshold(64 * 1024);*/
    }
    
    protected MemCachedManager() {
    
    }
    
    public static MemCachedManager getInstance() {
        return memCachedManager;
    }
    
    public boolean set(String key, Object value) {
        return mcc.set(key, value);
    }
    
    public boolean add(String key, Object value) {
        return mcc.add(key, value);
    }
    
    public boolean add(String key, Object value, Date expiry) {
        return mcc.add(key, value, expiry);
    }
    
    public boolean replace(String key, Object value) {
        return mcc.replace(key, value);
    }
    
    public boolean replace(String key, Object value, Date expiry) {
        return mcc.replace(key, value, expiry);
    }
    
    public Object get(String key) {
        return mcc.get(key);
    }
    
    public boolean flush() {
        return mcc.flushAll();
    }
    
    public boolean flush(String[] params) {
        return mcc.flushAll(params);
    }
    
    public static void main(String[] args) {
        MemCachedManager cache = MemCachedManager.getInstance();
        cache.add("hello", 234);
        System.out.println("get value : " + cache.get("hello"));
    
        // 操作对象
        TBean tb = new TBean();
        tb.setName("E网打进");
        cache.add("bean", tb);
    
        TBean tb1 = (TBean) cache.get("bean");
        System.out.println(tb1);
    
        tb1.setName("E网打进_修改的");
        cache.set("bean", tb1);
        tb1 = (TBean) cache.get("bean");
        System.out.println(tb1);
        //
        MemcachedItem item = mcc.gets("key1");
        System.out.println("GETS: value=" + item.getValue() + ",CasUnique:"
                + item.getCasUnique());
        System.out.println("SET: " + mcc.set("key1", "value1_1"));
        System.out.println("CAS: "
                + mcc.cas("key1", "value1_2", item.getCasUnique())); // 必须FALSE
        System.out.println("getMulti:"
                + mcc.getMulti(new String[] { "key1", "key2", "key3" }));
    }

\}  
==========spring整合