memcached 02

fswdnr

　　下载客户端驱动，java客户端下载地址：http://code.google.com/p/memcached/wiki/Clients
　　其他也没有什么好说的！



package com.fox;
import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;
/**
* @author huangfox
* @data 2012-8-1
* @email huangfox009@126.com
* @desc
*/
public class MemCached {
static MemCachedClient mcc = new MemCachedClient();
static MemCached mc = new MemCached();
static {
String[] servers = { "192.168.10.103:11211" };
Integer[] weights = { 3 };
// socke pool
SockIOPool pool = SockIOPool.getInstance();
// set server config
pool.setServers(servers);
pool.setWeights(weights);
// set other params
pool.setInitConn(5);
pool.setMinConn(5);
pool.setMaxConn(250);
pool.setMaxIdle(1000 * 60 * 60 * 6);
// set main thread sleep
pool.setMaintSleep(30);
// set tcp params
pool.setNagle(false);
pool.setSocketTO(3000);
pool.setSocketConnectTO(0);
// init
pool.initialize();
}
private MemCached() {
}
public static MemCached getInstance() {
return mc;
}
public boolean add(String key, Object value) {
return mcc.add(key, value);
}
public boolean replaced(String key, Object value) {
return mcc.replace(key, value);
}
public Object get(String key) {
return mcc.get(key);
}
public static void main(String[] f) {
MemCached cache = MemCached.getInstance();
cache.add("name", "huangfox");
System.out.println(cache.get("name"));
}
}

　　
　　几个关键类！（转自：http://www.linuxso.com/architecture/21013.html）
　　sockIOPool
　　这个类用来创建管理客户端和服务器通讯连接池，客户端主要的工作包括数据通讯、服务器定位、hash码生成等都是由这个类完成的。

• public static SockIOPool getInstance()
  
  
  
  • 获得连接池的单态方法。这个方法有一个重载方法getInstance( String poolName )，每个poolName只构造一个SockIOPool实例。缺省构造的poolName是default。
    
  • 如果在客户端配置多个memcached服务，一定要显式声明poolName。
    
  
  
  

• public void setServers( String[] servers )
  
  
  
  • 设置连接池可用的cache服务器列表，server的构成形式是IP:PORT（如：127.0.0.1:11211）
    
  
  
  

• public void setWeights( Integer[] weights )
  
  
  
  • 设置连接池可用cache服务器的权重，和server数组的位置一一对应
    
  • 其实现方法是通过根据每个权重在连接池的bucket中放置同样数目的server（如下代码所示），因此所有权重的最大公约数应该是1，不然会引起bucket资源的浪费。
    
  
  
  

• public void setInitConn( int initConn )
  
  
  
  • 设置开始时每个cache服务器的可用连接数
    
  
  
  

• public void setMinConn( int minConn )
  
  
  
  • 设置每个服务器最少可用连接数
    
  
  
  

• public void setMaxConn( int maxConn )
  
  
  
  • 设置每个服务器最大可用连接数
    
  
  
  

• public void setMaxIdle( long maxIdle )
  
  
  
  • 设置可用连接池的最长等待时间
    
  
  
  

• public void setMaintSleep( long maintSleep )
  
  
  
  • 设置连接池维护线程的睡眠时间
    
  • 设置为0，维护线程不启动
    
  • 维护线程主要通过log输出socket的运行状况，监测连接数目及空闲等待时间等参数以控制连接创建和关闭。
    
  
  
  

• public void setNagle( boolean nagle )
  
  
  
  • 设置是否使用Nagle算法，因为我们的通讯数据量通常都比较大（相对TCP控制数据）而且要求响应及时，因此该值需要设置为false（默认是true）
    
  
  
  

• ublic void setSocketTO( int socketTO )
  
  
  
  • 设置socket的读取等待超时值
    
  
  
  

• public void setSocketConnectTO( int socketConnectTO )
  
  
  
  • 设置socket的连接等待超时值
    
  
  
  

• public void setAliveCheck( boolean aliveCheck )
  
  
  
  • 设置连接心跳监测开关。
    
  • 设为true则每次通信都要进行连接是否有效的监测，造成通信次数倍增，加大网络负载，因此该参数应该在对HA要求比较高的场合设为TRUE，默认状态是false。
    
  
  
  

• public void setFailback( boolean failback )
  
  
  
  • 设置连接失败恢复开关
    
  • 设置为TRUE，当宕机的服务器启动或中断的网络连接后，这个socket连接还可继续使用，否则将不再使用，默认状态是true，建议保持默认。
    
  
  
  

• public void setFailover( boolean failover )
  
  
  
  • 设置容错开关
    
  • 设置为TRUE，当当前socket不可用时，程序会自动查找可用连接并返回，否则返回NULL，默认状态是true，建议保持默认。
    
  
  
  

• public void setHashingAlg( int alg )
  
  
  
  • 设置hash算法
    
    
    
    • alg=0 使用String.hashCode()获得hash code,该方法依赖JDK，可能和其他客户端不兼容，建议不使用
      
    • alg=1 使用original 兼容hash算法，兼容其他客户端
      
    • alg=2 使用CRC32兼容hash算法，兼容其他客户端，性能优于original算法
      
    • alg=3 使用MD5 hash算法
      
    
    
    
  • 采用前三种hash算法的时候，查找cache服务器使用余数方法。采用最后一种hash算法查找cache服务时使用consistent方法。
    
  
  
  

• public void initialize()
  
  
  
  • 设置完pool参数后最后调用该方法，启动pool。
    
  
  
  

　　
　　MemCachedClient

• public void setCompressEnable( boolean compressEnable )
  
  
  
  • 设定是否压缩放入cache中的数据
    
  • 默认值是ture
    
  • 如果设定该值为true，需要设定CompressThreshold?
    
  
  
  

• public void setCompressThreshold( long compressThreshold )
  
  
  
  • 设定需要压缩的cache数据的阈值
    
  • 默认值是30k
    
  
  
  

• public void setPrimitiveAsString( boolean primitiveAsString )
  
  
  
  • 设置cache数据的原始类型是String
    
  • 默认值是false
    
  • 只有在确定cache的数据类型是string的情况下才设为true，这样可以加快处理速度。
    
  
  
  

• public void setDefaultEncoding( String defaultEncoding )
  
  
  
  • 当primitiveAsString为true时使用的编码转化格式
    
  • 默认值是utf-8
    
  • 如果确认主要写入数据是中文等非ASCII编码字符，建议采用GBK等更短的编码格式
    
  
  
  

• cache数据写入操作方法
  
  
  
  • set方法
    
    
    
    • 将数据保存到cache服务器，如果保存成功则返回true
      
    • 如果cache服务器存在同样的key，则替换之
      
    • set有5个重载方法，key和value是必须的参数，还有过期时间，hash码，value是否字符串三个可选参数
      
    
    
    
  • add方法
    
    
    
    • 将数据添加到cache服务器,如果保存成功则返回true
      
    • 如果cache服务器存在同样key，则返回false
      
    • add有4个重载方法，key和value是必须的参数，还有过期时间，hash码两个可选参数
      
    
    
    
  • replace方法
    
    
    
    • 将数据替换cache服务器中相同的key,如果保存成功则返回true
      
    • 如果cache服务器不存在同样key，则返回false
      
    • replace有4个重载方法，key和value是必须的参数，还有过期时间，hash码两个可选参数
      
    
    
    
  • 建议分析key的规律，如果呈现某种规律有序，则自己构造hash码，提高存储效率
    
  
  
  
• cache数据读取操作方法
  
  
  
  • 使用get方法从cache服务器获取一个数据
    
    
    
    • 如果写入时是压缩的或序列化的，则get的返回会自动解压缩及反序列化
      
    • get方法有3个重载方法，key是必须的参数，hash码和value是否字符串是可选参数
      
    
    
    
  • 使用getMulti方法从cache服务器获取一组数据
    
    
    
    • get方法的数组实现，输入参数keys是一个key数组
      
    • 返回是一个map
      
    
    
    
  
  
  
• 通过cache使用计数器
  
  
  
  • 使用storeCounter方法初始化一个计数器
    
  • 使用incr方法对计数器增量操作
    
  • 使用decr对计数器减量操作