Java memcache缓存实现for Windows
Memcache是一个高性能的分布式的内存对象缓存系统,通过在内存里维护一个统一的巨大的hash表,它能够用来存储各种格式的数据,包括图像、视频、文件以及数据库检索的结果等。简单的说就是将数据调用到内存中,然后从内存中读取,从而大大提高读取速度。
Memcache是danga的一个项目,最早是LiveJournal 服务的,最初为了加速 LiveJournal 访问速度而开发的,后来被很多大型的网站采用。
Memcached是以守护程序方式运行于一个或多个服务器中,随时会接收客户端的连接和操作。
目前memcached支持C/C++、Perl、PHP、Python、Ruby、Java、C#、Postgres、Chicken Scheme、Lua、MySQL和Protocol等语言客户端。
1、Windows 下安装 memcache
1. 下载memcache的windows稳定版,解压放某个盘下面,比如在d:\memcached
2. 在终端(也即cmd命令界面)下输入 'd:\ -d install' 安装
3. 再输入: 'd:\ -d start' 启动。NOTE: 以后memcached将作为windows的一个服务每次开机时自动启动。这样服务器端已经安装完毕了。
2、Memcached Java Client API详解
Memcached Java客户端lib库主要提供的调用类是SockIOPool和MemCachedClient?,关键类及方法整理说明如下。
·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)
public void setSocketTO( int socketTO )
·设置socket的读取等待超时值
public void setSocketConnectTO( int socketConnectTO )
·设置socket的连接等待超时值
public void setAliveCheck( boolean aliveCheck )
·设置连接心跳监测开关。
·设为true则每次通信都要进行连接是否有效的监测,造成通信次数倍增,加大网络负载,因此该参数应该在对HA要求比较高的场合设为TRUE,默认状态是false。
ruby 字符串转数组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
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论