memcached-client for java 改进,更好支持tokyo
2011-03-16 14:26
405 查看
使用注意:
接口:ICache,定义顶级方法
接口:IMemcachedCache,继承 ICache,定义应用级方法。
类:MemcachedCache 实现 IMemcachedCache 接口,主要的几个方法:
// 设置数据,同时删除本地缓存和做cluster异步分发
public Object put(String key, Object value, Date expiry)
public Object put(String key, Object value, int TTL)
public Object put(String key, Object value)
//先从本地缓存中获取,获取不到再到memcached中获取,同时加入本地缓存,TTL:失效时间,带有此参数的操作都按上述流程走。
public Object get(String key, int localTTL)
// 不走本地缓存,直接从memcached主机获取,如果获取不到,尝试从集群主机中获取,基于性考虑,只从集群中其他某个主机再获取
//如果获取不到,就直接返回。
public Object get(String key)
spring集成:
<bean id="memcachedCacheManager" class="com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager"
init-method="start" destroy-method="stop">
<property name="configFile" value="cache/memcached-detail.xml"/>
</bean>
<bean id="mainService"
class="cn.com.xxxx.service.impl.MainServiceImpl">
<property name="memcachedCacheManager" ref="memcachedCacheManager"/>
</bean>
类中获取Manager:
protected MemcachedCacheManager memcachedCacheManager;
public MemcachedCacheManager getMemcachedCacheManager() {
return memcachedCacheManager;
}
public void setMemcachedCacheManager(MemcachedCacheManager memcachedCacheManager) {
this.memcachedCacheManager = memcachedCacheManager;
}
获取Cache:
IMemcachedCache memcachedCache1=memcachedCacheManager.getCache("mclient1");
IMemcachedCache memcachedCache2=memcachedCacheManager.getCache("mclient2");
改进,支持tokyo存取:
第一步:
修改MemCachedClient类中的set方法:
private boolean set( String cmdname, String key, Object value, Date expiry, Integer hashCode, boolean asString )
先定义两个常量:
//flags length
private static final int F_NUM_TOVAL =1;
private static final int F_VAULE_DEFAULT =32768;
在// now write the data to the cache server位置加入如下内容:
// now write the data to the cache server
try {
//解决ttserver不保存flags的问题
byte headflag=15;
try{
headflag=(byte)(Math.log(flags)/Math.log(2));
}catch (Exception e){}
byte[] cval=new byte[val.length+F_NUM_TOVAL];
cval[0]=headflag;
System.arraycopy(val,0,cval,1,val.length);
//完成
String cmd = new StringBuilder().append(cmdname).append(" ")
.append(key).append(" ").append(flags).append(" ")
.append(expiry.getTime() / 1000).append(" ")
.append(val.length).append("/r/n").toString();
//String.format( "%s %s %d %d %d/r/n", cmdname, key, flags, (expiry.getTime() / 1000), val.length );
sock.write( cmd.getBytes() );
红色部分是新添加的,然后将此类上述代码下的val 变量全部替换成cval变量。
第二步:
修改类MemCachedClient中的public Object get( String key, Integer hashCode, boolean asString ) 方法。
// read obj into buffer
byte[] tmpBuf = sock.readBytes(length);
/**
* 修正,使得可获取tokyo的数据
*/
int flag=F_VAULE_DEFAULT;
try{
flag=(int)Math.pow(2,tmpBuf[0]);
}catch(Exception e){
log.error("memcached get(),flag get error!");
}
byte[] buf = new byte[length-1];
System.arraycopy(tmpBuf,1,buf,0,length-1);
/**
* 修正结束
*/
if ( (flag & F_COMPRESSED) == F_COMPRESSED ) {
红色部分是新添加的,如果添加后变量flag显示已经定义,请将前面的定义注释掉。
接口:ICache,定义顶级方法
接口:IMemcachedCache,继承 ICache,定义应用级方法。
类:MemcachedCache 实现 IMemcachedCache 接口,主要的几个方法:
// 设置数据,同时删除本地缓存和做cluster异步分发
public Object put(String key, Object value, Date expiry)
public Object put(String key, Object value, int TTL)
public Object put(String key, Object value)
//先从本地缓存中获取,获取不到再到memcached中获取,同时加入本地缓存,TTL:失效时间,带有此参数的操作都按上述流程走。
public Object get(String key, int localTTL)
// 不走本地缓存,直接从memcached主机获取,如果获取不到,尝试从集群主机中获取,基于性考虑,只从集群中其他某个主机再获取
//如果获取不到,就直接返回。
public Object get(String key)
spring集成:
<bean id="memcachedCacheManager" class="com.alisoft.xplatform.asf.cache.memcached.MemcachedCacheManager"
init-method="start" destroy-method="stop">
<property name="configFile" value="cache/memcached-detail.xml"/>
</bean>
<bean id="mainService"
class="cn.com.xxxx.service.impl.MainServiceImpl">
<property name="memcachedCacheManager" ref="memcachedCacheManager"/>
</bean>
类中获取Manager:
protected MemcachedCacheManager memcachedCacheManager;
public MemcachedCacheManager getMemcachedCacheManager() {
return memcachedCacheManager;
}
public void setMemcachedCacheManager(MemcachedCacheManager memcachedCacheManager) {
this.memcachedCacheManager = memcachedCacheManager;
}
获取Cache:
IMemcachedCache memcachedCache1=memcachedCacheManager.getCache("mclient1");
IMemcachedCache memcachedCache2=memcachedCacheManager.getCache("mclient2");
改进,支持tokyo存取:
第一步:
修改MemCachedClient类中的set方法:
private boolean set( String cmdname, String key, Object value, Date expiry, Integer hashCode, boolean asString )
先定义两个常量:
//flags length
private static final int F_NUM_TOVAL =1;
private static final int F_VAULE_DEFAULT =32768;
在// now write the data to the cache server位置加入如下内容:
// now write the data to the cache server
try {
//解决ttserver不保存flags的问题
byte headflag=15;
try{
headflag=(byte)(Math.log(flags)/Math.log(2));
}catch (Exception e){}
byte[] cval=new byte[val.length+F_NUM_TOVAL];
cval[0]=headflag;
System.arraycopy(val,0,cval,1,val.length);
//完成
String cmd = new StringBuilder().append(cmdname).append(" ")
.append(key).append(" ").append(flags).append(" ")
.append(expiry.getTime() / 1000).append(" ")
.append(val.length).append("/r/n").toString();
//String.format( "%s %s %d %d %d/r/n", cmdname, key, flags, (expiry.getTime() / 1000), val.length );
sock.write( cmd.getBytes() );
红色部分是新添加的,然后将此类上述代码下的val 变量全部替换成cval变量。
第二步:
修改类MemCachedClient中的public Object get( String key, Integer hashCode, boolean asString ) 方法。
// read obj into buffer
byte[] tmpBuf = sock.readBytes(length);
/**
* 修正,使得可获取tokyo的数据
*/
int flag=F_VAULE_DEFAULT;
try{
flag=(int)Math.pow(2,tmpBuf[0]);
}catch(Exception e){
log.error("memcached get(),flag get error!");
}
byte[] buf = new byte[length-1];
System.arraycopy(tmpBuf,1,buf,0,length-1);
/**
* 修正结束
*/
if ( (flag & F_COMPRESSED) == F_COMPRESSED ) {
红色部分是新添加的,如果添加后变量flag显示已经定义,请将前面的定义注释掉。
相关文章推荐
- memcached client -- memcached client for java使用
- memcached client -- memcached client for java使用
- java-httpclient-18k 改进一,支持http异步,回调,https
- Memcached Client Forjava API
- spring调用memcached client for java
- [Java] Memcached Client For Java使用
- spring调用memcached client for java
- memcached client -- memcached client for java使用
- memcache-client-forjava 源码分析之MemcachedCacheManager
- 转:Memcached Java Client API详解
- memcached java client
- 实战Memcached缓存系统(2)Memcached Java API基础之MemcachedClient
- Java client 访问 memcached
- Memcached Java Client API详解
- 【转】memcache-client-forjava
- MemCached Cache Java Client封装优化历程
- HandlerSocket client for java――MySql as NoSQL
- memcached Java Client
- memcached java client
- java MemCachedClient遍历memcache中所有的key