package xmemcache; import java.io.IOException; import java.util.concurrent.TimeoutException; import net.rubyeye.xmemcached.Counter; import net.rubyeye.xmemcached.GetsResponse; import net.rubyeye.xmemcached.MemcachedClient; import net.rubyeye.xmemcached.MemcachedClientBuilder; import net.rubyeye.xmemcached.XMemcachedClientBuilder; import net.rubyeye.xmemcached.auth.AuthInfo; import net.rubyeye.xmemcached.command.BinaryCommandFactory; import net.rubyeye.xmemcached.exception.MemcachedException; import net.rubyeye.xmemcached.transcoders.StringTranscoder; import net.rubyeye.xmemcached.utils.AddrUtil; /** * Description of this file. * * @author XiongNeng * @version 1.0 * @since 13-7-13 */ public class SimpleCache { private String addresses = "192.168.0.5:11211"; public void test1() throws IOException { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(addresses)); // AddrUtil.getAddresses("server1:11211 server2:11211") // 宕机报警 builder.setFailureMode(true); // 使用二进制文件 builder.setCommandFactory(new BinaryCommandFactory()); /** * 设置连接池大小,即客户端个数 * In a high concurrent enviroment,you may want to pool memcached clients. * But a xmemcached client has to start a reactor thread and some thread pools, * if you create too many clients,the cost is very large. * Xmemcached supports connection pool instreadof client pool. * you can create more connections to one or more memcached servers, * and these connections share the same reactor and thread pools, * it will reduce the cost of system. * 默认的pool size是1。设置这一数值不一定能提高性能,请依据你的项目的测试结果为准。 * 初步的测试表明只有在大并发下才有提升。 * 设置连接池的一个不良后果就是,同一个memcached的连接之间的数据更新并非同步的 * 因此你的应用需要自己保证数据更新的原子性(采用CAS或者数据之间毫无关联)。 */ builder.setConnectionPoolSize(10); MemcachedClient client = builder.build(); try { /** * 第一个是存储的key名称, * 第二个是expire时间(单位秒),超过这个时间,memcached将这个数据替换出去,0表示永久存储(默认是一个月) * 第三个参数就是实际存储的数据 */ client.set("hello", 0, "Hello,xmemcached"); String value = client.get("hello"); System.out.println("hello=" + value); client.delete("hello"); value = client.get("hello"); System.out.println("hello=" + value); // value=client.get(“hello”,3000); /** * Memcached是通过cas协议实现原子更新,所谓原子更新就是compare and set, * 原理类似乐观锁,每次请求存储某个数据同时要附带一个cas值, memcached比对这个cas值与当前存储数据的cas值是否相等, * 如果相等就让新的数据覆盖老的数据,如果不相等就认为更新失败, 这在并发环境下特别有用 */ GetsResponse<Integer> result = client.gets("a"); if (result == null) { client.add("a", 0, 12); } result = client.gets("a"); long cas = result.getCas(); // 尝试将a的值更新为2 if (!client.cas("a", 0, 2, cas)) { System.err.println("cas error"); } } catch (MemcachedException e) { System.err.println("MemcachedClient operation fail"); e.printStackTrace(); } catch (TimeoutException e) { System.err.println("MemcachedClient operation timeout"); e.printStackTrace(); } catch (InterruptedException e) { // ignore } try { // close memcached client client.shutdown(); } catch (IOException e) { System.err.println("Shutdown MemcachedClient fail"); e.printStackTrace(); } } public void test2() throws TimeoutException, InterruptedException, MemcachedException, IOException { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(addresses)); MemcachedClient client = builder.build(); client.flushAll(); if (!client.set("hello", 0, "world")) { System.err.println("set error"); } if (client.add("hello", 0, "dennis")) { System.err.println("Add error,key is existed"); } if (!client.replace("hello", 0, "dennis")) { System.err.println("replace error"); } client.append("hello", " good"); client.prepend("hello", "hello "); String name = client.get("hello", new StringTranscoder()); System.out.println(name); /** * 而删除数据则是通过deleteWithNoReply方法,这个方法删除数据并且告诉memcached * 不用返回应答,因此这个方法不会等待应答直接返回,特别适合于批量处理 */ client.deleteWithNoReply("hello"); } public void incrDecr() throws IOException, TimeoutException, InterruptedException, MemcachedException { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(addresses)); MemcachedClient client = builder.build(); /** * 第一个参数指定递增的key名称, 第二个参数指定递增的幅度大小, 第三个参数指定当key不存在的情况下的初始值。 * 两个参数的重载方法省略了第三个参数,默认指定为0。 */ assert (1 == client.incr("a", 5, 1)); assert (6 == client.incr("a", 5)); assert (10 == client.incr("a", 4)); assert (9 == client.decr("a", 1)); assert (7 == client.decr("a", 2)); } public void counter() throws Exception { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(addresses)); MemcachedClient client = builder.build(); Counter counter = client.getCounter("counter", 0); counter.incrementAndGet(); counter.decrementAndGet(); counter.addAndGet(-10); } public void auth() throws Exception { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses(addresses)); builder.addAuthInfo(AddrUtil.getOneAddress(addresses), AuthInfo.typical("cacheuser", "123456")); // Must use binary protocol builder.setCommandFactory(new BinaryCommandFactory()); MemcachedClient client = builder.build(); } public void nioPool() throws Exception { MemcachedClientBuilder builder = new XMemcachedClientBuilder( AddrUtil.getAddresses("localhost:11211")); builder.setConnectionPoolSize(5); } }
相关推荐
memcached 安装文件,libevent库, C/C++ memcached 客户端库:libmemcached 全套工具:libevent-1.3.tar.gz,memcached-1.2.2.tar.gz,libmemcached-0.42.tar.gz 测试通过的
PHP Memcached 客户端(模拟器) 由于windows现在没有php memcached扩展,搭建开发环境比较困难,所以这个类会很有帮助。 灵感来源: ://github.com/joonas-fi/xslib-memcached 用法: 就像 php_memcached 扩展...
NULL 博文链接:https://acooly.iteye.com/blog/1120347
用于hibernate集成memcached作为二级缓存所需要的包,1.2.2版本
XMemcached 是一个高性能、易用的 Java 阻塞多线程 memcached 客户端。 它基于 nio 并经过精心设计以获得最佳性能。 ##新闻和下载 。 Maven 依赖: <groupId>com.googlecode.xmemcached</groupId> ...
Memcached的java客户端已经存在三种了:官方提供的基于传统阻塞io由Greg Whalin维护的客户端;Dustin Sallings实现的基于java nio的Spymemcached;XMemcached
Cache :: Memcached :: AnyEvent-AnyEvent兼容的Memcached客户端 概要 use Cache::Memcached::AnyEvent; my $memd = Cache::Memcached::AnyEvent->new({ servers => [ '127.0.0.1:11211' ], compress_threshold =...
Xmemcached是基于java nio实现的高性能可扩展的memcached客户端。它的主要特点: 高性能,稳定可靠,已经在众多公司的众多项目里得到应用。 功能完备:客户端分布式、权重、最新最完整的协议支持。 ...
3.xmemcached,XMemcached也使用得比较广泛,而且有较详细的中文API文档,具有如下特点:高性 能、支持完整的协议、支持客户端分布、允许设置节点权重、动态增删节点、支持JMX、与Spring框架和Hibernate-memcached的...
memcached库通过SWIG包装了纯C的libmemcached客户端。 安装 您需要Ruby 1.8.7或Ruby 1.9.2。 其他版本可能会起作用,但不能保证。 您还需要libsasl2-dev和gettext库,它们应通过系统的程序包管理器提供。 安装gem...
memcached linux安装说明+ java客户端调用例子
memcached版本:memcached-1.5.2.tar.gz libevent版本:libevent-2.0.22-stable.tar.gz 依赖包:java_memcached-release_2.6.3.jar等
memcache java client 2.6.3版本,包括完整的jar包. memcached win 服务端.
建造Memcached导出器从Memcached服务器导出指标,以供Prometheus使用。 服务器被指定为程序的--memcached.address标志(默认为localhost:11211 )。 默认情况下,memcache_exporter在/metrics端口0.0.0.0:9150上0.0....
NULL 博文链接:https://da-zhuang.iteye.com/blog/2234078
memcache:Haskell Memcached客户端 Memcached群集的客户端库。 它支持二进制memcached协议和SASL身份验证。 不提供对ASCII协议的支持。 它支持连接到单个或集群的Memcached服务器。 连接到cluser时,一致性哈希用于...
测试类包括Xmemcached客户端与memcached client for java两者,可运行比较性能。 XMemcached简介: XMemcached是基于 java nio的Memcached客户端,java nio相比于传统阻塞 io 模型来说,有 效率高(特别在高并发下...
Memcache.jl:Julia memcached客户端
Blablacar Memcached 包装器 这个库提供了一个简单的 Memcached 连接包装器。 安装 安装此库的推荐方法是通过 。 需要blablacar/memcached-client包到你的composer.json文件中: { " require " : { " blablacar/...
内存缓存二进制 使用二进制协议的memcached客户端。