memcached之java客户端:spymemcached使用
2012-09-11 08:29
417 查看
memcached之java客户端:spymemcached使用
---------
一个简单的示例:
[java]
view plaincopy
MemcachedClient c = new MemcachedClient(new InetSocketAddress("hostname",portNum));
//异步方式存储一个值一个小时
c.set("someKey",3600,someObject);
//同步方式获取一个值
Object myObject = c.get("someKey");
利用异步获取的优势
MemcachedClient可以异步处理消息,如果一个memcached服务器不能连接,如例,MemcachedConnection将继续尝试重新连接。为了防止造成你的应用程序挂起,可以使用异步机制,异步获取数据并对超时的请求取消对服务器的操作。
[java]
view plaincopy
//获取一个连接到几个服务端的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.建立一个二进制协议连接
如例:
[java]
view plaincopy
//获取一个通过二进制协议连接到几个服务端的memcached的客户端
MemcachedClient c = new MemcachedClient(new BinaryConnectionFactory(),
AddrUtil.getAddresses("server1:11212 server2:11212"));
......
2.建立一个二进制协议的SASL连接
[java]
view plaincopy
//创建一个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数据库)
[java]
view plaincopy
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);
---------
一个简单的示例:
[java]
view plaincopy
MemcachedClient c = new MemcachedClient(new InetSocketAddress("hostname",portNum));
//异步方式存储一个值一个小时
c.set("someKey",3600,someObject);
//同步方式获取一个值
Object myObject = c.get("someKey");
利用异步获取的优势
MemcachedClient可以异步处理消息,如果一个memcached服务器不能连接,如例,MemcachedConnection将继续尝试重新连接。为了防止造成你的应用程序挂起,可以使用异步机制,异步获取数据并对超时的请求取消对服务器的操作。
[java]
view plaincopy
//获取一个连接到几个服务端的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.建立一个二进制协议连接
如例:
[java]
view plaincopy
//获取一个通过二进制协议连接到几个服务端的memcached的客户端
MemcachedClient c = new MemcachedClient(new BinaryConnectionFactory(),
AddrUtil.getAddresses("server1:11212 server2:11212"));
......
2.建立一个二进制协议的SASL连接
[java]
view plaincopy
//创建一个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数据库)
[java]
view plaincopy
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之java客户端:spymemcached使用
- memcached之java客户端:spymemcached与spring整合
- memcached之java客户端:spymemcached与spring整合
- 分布式缓存技术memcached学习系列(五)—— memcached java客户端的使用
- memcached-java客户端xmemcached使用总结 & 与Spring 集成
- Memcached学习笔记 — 第四部分:Memcached Java 客户端-gwhalin(1)-介绍及使用
- 实例讲解分布式缓存软件Memcached的Java客户端使用
- Memcached学习笔记 — 第四部分:Memcached Java 客户端-gwhalin(1)-介绍及使用
- 转: memcached Java客户端spymemcached的一致性Hash算法
- memcached之java客户端:spymemcached与spring整合 .
- memcached-java客户端xmemcached使用总结
- memcached之java客户端:spymemcached与spring整合
- memcached之java客户端:spymemcached与spring整合(身份验证)
- memcached-java客户端xmemcached使用总结
- memcached-java客户端xmemcached使用总结
- memcached-java客户端xmemcached使用总结
- memcached之java客户端:spymemcached与spring整合
- memcached-java客户端xmemcached使用总结
- memcached java客户端的简单使用
- memcached第一个程序(memcached --Java客户端spymemcached-2.10.6.jar)