服务器之家

服务器之家 > 正文

实例讲解分布式缓存软件Memcached的Java客户端使用

时间:2020-03-24 13:35     来源/作者:张钊

Memcached介绍
下面就来介绍一下Memcached。

1、什么是Memcached

Memcached是一个开源的高性能,分布式的内存对象缓存系统,通过键值队的形式来对数据进行存取,Memcached是简单而强大,它的简单设计促进快速部署,易于开发,解决了大数据缓存面临的许多问题。


官方网址是:http://memcached.org/,目前已经有很多知名的互联网应用使用到了Memcached,比如Wikipedia、Flickr、Youtube、Wordpress等等。

2、下载Windows平台下的MemCached,地址为:

http://code.jellycan.com/files/memcached-1.2.6-win32-bin.zip

对应的源码地址为:

http://code.jellycan.com/files/memcached-1.2.6-win32-src.zip

然后,解压开来,会看到一个memcached.exe文件,进行如下图的安装,将以系统服务的形式安装到机上

实例讲解分布式缓存软件Memcached的Java客户端使用

然后查看系统服务,会发现已经可以看到memcached服务了

实例讲解分布式缓存软件Memcached的Java客户端使用

然后,选中此服务点鼠标右键,启动此服务。

在DOS界面中输入:telnet 127.0.0.1 11211来确认服务是否启动无误,如果无误,则会显示如下窗口:

实例讲解分布式缓存软件Memcached的Java客户端使用

上面图中显示的ERROR是我随便输入字符后按回车显示的,这是因为你需要安装memcached规定的协议来进行输入,否则就显示如上所示错误。

3、 memcached的协议与数据存取

所谓协议,可以理解为对其操作(数据存取)的语法规则,存取数据的常用命令和参数如下:

set:存入一条记录

key:记录的键值

flags:十进制的int,标识存储记录时的客户端标志,在记录取出时会返回。

exptim:数据的过期时间,0表示不过期,其他数值则表示有效的毫秒数,在过期后,客户端将取不到这条记录,memcached中的过期记录会被清空或删除。

get:表示从memcached取出key对应的值,如果没有对应的值则返回结束标志END

append:表示对key所对应的值在最后再加入输入的内容

delete:删除key对应的值

更多协议可参考:memcached包中所带的protocol.txt

具体例子如:

需要注意的是:在set时如果指定的字符长度为5,而输入的内容超过了这个长度,那么就会报错:CLIENT_ERROR bad data chunk

实例讲解分布式缓存软件Memcached的Java客户端使用

4、 编写代码对memcached进行数据存取操作

一般而言,可以使用开源已封装好的memcached客户端来对memcached进行操作,当然你也可以根据memcached的协议在代码中通过编写socket通信程序实现。

Memcached-Java-Client的下载页面:

http://github.com/gwhalin/Memcached-Java-Client/downloads,然后选择下载:

java_memcached-release_2.5.1.zip

在解压开的Test目录中可以看到有些写好的例子,可以通过运行com.danga.MemCached.test. TestMemcached来查看数据存入和取出情况,这里也贴出其代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
package com.danga.MemCached.test;
 
import com.danga.MemCached.MemCachedClient;
 
import com.danga.MemCached.SockIOPool;
 
import org.apache.log4j.*;
 
public class TestMemcached {
 
public static void main(String[] args) {
 
// memcached should be running on port 11211 but NOT on 11212
 
BasicConfigurator.configure();
 
//缓存服务器地址,多台服务器则以逗号隔开,11211为memcached使用的端口号
 
String[] servers = { “localhost:11211″ };
 
//得到一个链接池对象并进行一些初始化工作
 
SockIOPool pool = SockIOPool.getInstance();
 
pool.setServers( servers );
 
pool.setFailover( true );
 
pool.setInitConn( 10 );
 
pool.setMinConn( 5 );
 
pool.setMaxConn( 250 );
 
//pool.setMaintSleep( 30 );
 
pool.setNagle( false );
 
pool.setSocketTO( 3000 );
 
pool.setAliveCheck( true );
 
pool.initialize();
 
MemCachedClient mcc = new MemCachedClient();
 
// turn off most memcached client logging:
 
//Logger.getLogger( MemCachedClient.class.getName() ).setLevel( com.schooner.MemCached.Logger. );
 
//以下是数据写入和取出操作例子
 
for ( int i = 0; i < 10; i++ ) {
 
boolean success = mcc.set( “” + i, “Hello!” );
 
String result = (String)mcc.get( “” + i );
 
System.out.println( String.format( “set( %d ): %s”, i, success ) );
 
System.out.println( String.format( “get( %d ): %s”, i, result ) );
 
}
 
System.out.println( “\n\t — sleeping –\n” );
 
try { Thread.sleep( 10000 ); } catch ( Exception ex ) { }
 
for ( int i = 0; i < 10; i++ ) {
 
boolean success = mcc.set( “” + i, “Hello!” );
 
String result = (String)mcc.get( “” + i );
 
System.out.println( String.format( “set( %d ): %s”, i, success ) );
 
System.out.println( String.format( “get( %d ): %s”, i, result ) );
 
}
 
}
 
}

MemCached的java客户端实例

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
package com.danga.MemCached.test;
 
import com.danga.MemCached.*;
public class TestMemcached {
 public static void main(String[] args) {
  /*初始化SockIOPool,管理memcached的连接池*/
  String[] servers = { "192.168.105.217:11211" };
  SockIOPool pool = SockIOPool.getInstance();
  pool.setServers(servers);
  pool.setFailover(true);
  pool.setInitConn(10);
  pool.setMinConn(5);
  pool.setMaxConn(250);
  pool.setMaintSleep(30);
  pool.setNagle(false);
  pool.setSocketTO(3000);
  pool.setAliveCheck(true);
  pool.initialize();
  /*建立MemcachedClient实例*/
  MemCachedClient memCachedClient = new MemCachedClient();
  for (int i = 0; i < 10; i++) {
   /*将对象加入到memcached缓存*/
   boolean success = memCachedClient.set("" + i, "Hello!");
   /*从memcached缓存中按key值取对象*/
   String result = (String) memCachedClient.get("" + i);
   System.out.println(String.format("set( %d ): %s", i, success));
   System.out.println(String.format("get( %d ): %s", i, result));
  }
 }
}

1.解压(本例中解压到c:\memcached)。
2、在命令行状态下输入: c:\memcached\memcached.exe -d install 。至此memcached已经安装成windows服务
3、在命令行下输入: c:\memcached\memcached.exe -d start 以启动memcached服务。当然也可以选择在windows服务中启动

相关文章

热门资讯

沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意
沙雕群名称大全2019精选 今年最火的微信群名沙雕有创意 2019-07-07
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分
玄元剑仙肉身有什么用 玄元剑仙肉身境界等级划分 2019-06-21
男生常说24816是什么意思?女生说13579是什么意思?
男生常说24816是什么意思?女生说13579是什么意思? 2019-09-17
超A是什么意思 你好a表达的是什么
超A是什么意思 你好a表达的是什么 2019-06-06
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情
华为nova5pro和p30pro哪个好 华为nova5pro和华为p30pro对比详情 2019-06-22
返回顶部