Memcached Java Client API详解
针对Memcached官方网站提供的java_memcached-release_2.0.1版本进行阅读分析,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资源的浪费。
for ( int i = 0; i < servers.length; i+/+ ) { if ( this.weights /!= null && this.weights.length > i ) { for ( int k = 0; k < this.weights[i].intValue(); k+/+ ) { this.buckets.add( servers[i] ); if ( log.isDebugEnabled() ) log.debug( "++++ added " + servers[i] + " to server 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方法。
- 设置hash算法
- 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码,提高存储效率
- set方法
- cache数据读取操作方法
- 使用get方法从cache服务器获取一个数据
- 如果写入时是压缩的或序列化的,则get的返回会自动解压缩及反序列化
- get方法有3个重载方法,key是必须的参数,hash码和value是否字符串是可选参数
- 使用getMulti方法从cache服务器获取一组数据
- get方法的数组实现,输入参数keys是一个key数组
- 返回是一个map
- 使用get方法从cache服务器获取一个数据
- 通过cache使用计数器
- 使用storeCounter方法初始化一个计数器
- 使用incr方法对计数器增量操作
- 使用decr对计数器减量操作
Memcached Client API 优化(草)
实现memcached的遍历操作
有些应用情况下,需要遍历memcached服务器中所有被cache的数据,目前memcached client API不支持遍历操作,需要进行扩展。
实现get时刷新数据过期时间(应用于session,可能需要修改服务器端程序)
当memcached被用作session服务器的时候,需要支持session的access方法,根据最近访问时间刷新过期时间,目前memcached也不支持该操作,需要进行扩展。
转载于:https://www.cnblogs.com/quchengfeng/p/5129723.html
Memcached Java Client API详解相关推荐
- mq 接口 java_Rabbitmq Java Client Api详解
AMQP AMQP协议是一个高级抽象层消息通信协议,RabbitMQ是AMQP协议的实现. 基础概念快速入门 每个rabbitmq-server叫做一个Broker,等着tcp连接进入. 在rabbi ...
- java nio详解,Java NIO API详解
Java NIO API详解 在JDK 1.4以前,Java的IO操作集中在java.io这个包中,是基于流的阻塞(blocking)API.对于大多数应用来说,这样的API使用很方 便,然而,一些对 ...
- JAVA EXCEL API详解
2019独角兽企业重金招聘Python工程师标准>>> 使用Windows操作系统的朋友对Excel(电子表格)一定不会陌生,但是要使用Java语言来操纵Excel文件并不是一件容易 ...
- Java包装类API详解
在实际程序使用中,程序界面上用户输入的数据都是以字符串类型进行存储的.而程序开发中,我们需要把字符串数据,根据需求转换成指定的基本数据类型,如年龄需要转换成int类型,考试成绩需要转换成double类 ...
- Java Validation Api 详解
说明: 在我们应用程序的业务逻辑中,经常会碰到参数校验的情况,手动的在代码层上面进行校验就会带来很不好的体验,阅读.维护的成本会大大增加,造成冗余.因此有了这个JSR 303. Bean Valida ...
- Java 11中的新功能和API详解系列1
Java 11中的新功能和API详解系列1 2018.9.27 版权声明:本文为博主chszs的原创文章,未经博主允许不得转载. JDK 11在语言语法方面有一个小改动,增加了相当数量的新API,以及 ...
- Java 8 Stream API详解--转
原文地址:http://blog.csdn.net/chszs/article/details/47038607 Java 8 Stream API详解 一.Stream API介绍 Java 8引入 ...
- Java 8 Stream API详解
Java 8 Stream API详解 一.Stream API介绍 Java 8引入了全新的Stream API,此Stream与Java I/O包里的InputStream和OutputStrea ...
- 4.6 W 字总结!Java 11—Java 17特性详解
作者 | 民工哥技术之路 来源 | https://mp.weixin.qq.com/s/SVleHYFQeePNT7q67UoL4Q Java 11 特性详解 基于嵌套的访问控制 与 Java 语言 ...
最新文章
- Java快速创建大量对象_3分钟 快速理解JVM创建对象的步骤!
- 如何评价LoRa这项应用于低功率长距离场景的物联网传输技术?
- 面向对象三大特征——继承
- 台湾国立大学郭彦甫Matlab教程笔记(17)numerical integration
- 数据结构-排序(插入排序)
- 找到数组中第k小的值(利用快排的划分函数)
- HEOI 2017 游记
- OOD之问题空间到解空间—附FP的建模
- binarysearch java,java数据结构之二分查找法 binarySearch的实例
- 随想录(mac下c、c++的编译方法)
- JVM学习(1)——通过实例总结Java虚拟机的运行机制(转)
- Service的启动 源码分析之—startService()
- 平方取中法随机数函数
- 沪漂6年,我终于在上海买了第一套房
- c语言malloc(c语言malloc头文件)
- Word 2016插入公式快捷键
- 前端知识解构脑图(一张)和工具
- 最大子序列和问题(动态规划)
- 数据库的未来 - HTAP,软件、硬件、云生态的融合
- 【Hexo】如何才能在百度搜索到你的博客?SEO优化了解一下(上)
热门文章
- doxygen 无法生成图片_设计稿智能生成代码如何识别组件?Imgcook 3.0 解析
- 32位存储字长存储double_1GB多大?1GB与1MB的关系?详细数据存储单位转换来了...
- 【2020团体程序设计天梯赛】L2部分(PTA,L2-033到L2-036)题解代码复盘
- 【CCCC】L2-008 最长对称子串 (25分),直接枚举遍历
- 【Web前端】hexo+GitPages搭建博客
- 大学计算机课代表竞选稿,课代表竞选演讲稿
- 简单hbase java,Hbase 简单java API 操作
- git工作区状态(2)
- Python入门--函数传递过程中实参的变化
- layui获取select 文本_小程序富文本编辑器editor初体验