memcached之java客户端:spymemcached使用
2011-09-09 15:53
423 查看
memcached之java客户端:spymemcached使用
---------
一个简单的示例:
利用异步获取的优势
MemcachedClient可以异步处理消息,如果一个memcached服务器不能连接,如例,MemcachedConnection将继续尝试重新连接。为了防止造成你的应用程序挂起,可以使用异步机制,异步获取数据并对超时的请求取消对服务器的操作。
建立连接
1.建立一个二进制协议连接
如例:
---------
一个简单的示例:
MemcachedClient c = new MemcachedClient(new InetSocketAddress("hostname",portNum)); //异步方式存储一个值一个小时 c.set("someKey",3600,someObject); //同步方式获取一个值 Object myObject = c.get("someKey");
利用异步获取的优势
MemcachedClient可以异步处理消息,如果一个memcached服务器不能连接,如例,MemcachedConnection将继续尝试重新连接。为了防止造成你的应用程序挂起,可以使用异步机制,异步获取数据并对超时的请求取消对服务器的操作。
//获取一个连接到几个服务端的memcached的客户端 MemcachedClient c = new MemcachedClient(AddrUtil.getAddresses("server1:11211 server2:11211")); //获取值,如果在5秒内没有返回值,将取消 Object myObj = null; Future<Object> f = c.asyncGet("someKey"); try{ myObj = f.get(5,TimeUnit.SECONDS); }catch(TimeoutException e){ f.cancel(false); }
建立连接
1.建立一个二进制协议连接
如例:
//获取一个通过二进制协议连接到几个服务端的memcached的客户端 MemcachedClient c = new MemcachedClient(new BinaryConnectionFactory(), AddrUtil.getAddresses("server1:11212 server2:11212")); ......2.建立一个二进制协议的SASL连接
//创建一个AuthDescriptor,这是一个PLAIN的SASL,因此用户名与密码仅仅是字符串 MemcachedClient mc = null; AuthDescriptor ad = new AuthDescriptor(new String[]{"PLAIN"}, new PlainCallbackHandler(username,password)); //然后连接使用ConnectionFactoryBuilder,二进制是必须的 try{ if(mc == null){ mc = new MemcachedClient(new ConnectionFactoryBuilder() .setProtocol(Protocol.BINARY) .setAuthDescriptor(ad).build(), AddrUtil.getAddresses(host)); } }catch(IOException ex){ System.err.println("Couldn't create a connection,bailing out:\nIOException" +ex.getMessage()); }3.建立Membase连接(Membase是nosql数据库)
MemcachedClient mc; try{ URI base = new URI("http://localhost:8091/pools"); ArrayList baseURIs = new ArrayList(); baseURIs.add(base); mc = new MemcachedClient(baseURIs,"bucket_name","bucket_password"); ... }catch(IOException ex){ Logger.getLogger(Main.class.getName).log(Level.SEVERE,null,ex); }catch(ConfigurationException ex){ Logger.getLogger(Main.class.getName).log(Level.SEVERE,null,ex); }catch(URISyntaxException ex){ Logger.getLogger(Main.class.getName).log(Level.SEVERE,null,ex); } mc.set("hello",0,"world"); String result = (String)mc.get("hello"); assert(result.equals("world")); mc.shutdown(3,TimeUnit.SECONDS);
相关文章推荐
- Memcached学习笔记 — 第四部分:Memcached Java 客户端-gwhalin(3)-Spring整合
- 缓存系统MemCached的Java客户端优化历程
- 原创:分享封装好的面向JAVA的memcached客户端操作类
- Memcached的几种Java客户端(待实践)
- 三种memcached的JAVA客户端比较
- 为了在本机上测试,必须先安装memcache的服务器端,安装文件见附件,只能在Administrator用户下才能启动memcached服务。 首先要下载memcache的客户端java实现的jar
- Memcached Java客户端2.6.1发布
- memcached的java语言客户端和访问集群
- JAVA客户端调用memcached
- memcached的java客户端有几种?
- Memcached Java客户端编程
- Java 客户端连接 Memcached & Spring 集成
- 缓存系统MemCached的Java客户端优化历程
- MemCached的安装和JAVA客户端连接Memcached示例代码
- Memcached学习笔记 ― 第四部分:Memcached Java 客户端-gwhalin(5)-主要API解析
- JAVA客户端调用memcached比较
- java memcached客户端,模糊查询/批量删除/查询所有的key
- memcached之java客户端:spymemcached与spring整合
- memcached java客户端的简单使用
- java客户端调用Memcached的三种方式(整合)