为什么我的Memcached设置expiry 日期c 正则取出日期值为空,是为什么

2012人阅读
.net(65)
windows下的&&安装的exe文件。(此exe文件已经打包了所需的dll了,即exe中包含dll组件)
2.安装步骤
&一、缓存服务Memcached-1.4.5(W64)安装步骤:
1. 将Memcached-1.4.5(W64)解压放某个盘下面,比如在
E:\ApabiCourse\memcached\memcached-1.4.5(W64).exe;
2. 在运行中启动CMD,然后输入
【“E:\ApabiCourse\memcached\memcached-1.4.5(W64).exe” -d install】 安装;
3. 在运行下输入“regedit”打开注册表, &找到路径&HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\memcached,下面找到一个ImagePath 的字符串项,正好是服务的执行路径的字符串,双击该串,在后面追加入“-m 2048 -c 20000”( 使用2048M内存,链接数为20000)。
4. 再输入:【“E:\ApabiCourse\memcached\memcached-1.4.5(W64).exe”-d start】启动。 以后memcached将作为windows的一个服务每次开机时自动启动。这样服务器端已经安装完毕了。
检测是否安装成功
5.检测服务是否可用:
&执行cmd命令,启动telnet到memcached服务所在的ip的端口,例如【telnet 172.18.89.5 11211】,其中,11211是memcached的默认端口
输入stats,即可看到下图,证明安装服务成功。
常用命令:
将memcached.exe安装为Windows服务:memcached.exe -d install
启动memcached服务:memcached.exe -d start
启动memcached服务(windows命令):net start &memcached Server&
停止memcached服务(windows命令):net stop &memcached Server&
连接到memcached控制台:telnet ServerIP 11211
打印当前memcached服务器状态:stats
打印当前memcached服务器Items(记录)的统计信息:stats items
打印当前memcached服务器Slab(分区)及Chunk(块)的统计信息:stats slabs
打印指定Slab中的KEY列表(可用于遍历items,但效率较低,慎用!):stats cachedump&SlabId&Limit_num。显示结果:ITEM&KeyName&[ValueByteLength&b;&LastAccessTime&s]。值得注意的是,经过测试确认:那个LastAccessTime并不是记录到期时间,而是最后一次的get时间,并且get之后,也不会自动延长expiry(到期时间)。
添加新记录:add&KeyName&0
0&ValueByteLength&[回车]&ValueContent
删除记录 :&delete&KeyName
添加或更新记录 :&set&KeyName&0
0&ValueByteLength&[回车]&ValueContent
更新记录 :&replace&KeyName&0
0&ValueByteLength&[回车]&ValueContent
通过这个数据我们就可以了解Memcached的状态了。
这些数据所代表的意义如下:
pid:32u,服务器进程ID。
uptime:32u, 服务器运行时间,单位秒。
time :32u, 服务器当前的UNIX时间。
version :string, 服务器的版本号。
curr_items :32u, 服务器当前存储的内容数量 Current number of items stored by the server
total_items :32u, 服务器启动以来存储过的内容总数。
bytes :64u, 服务器当前存储内容所占用的字节数。
curr_connections :32u, 连接数量。
total_connections :32u, 服务器运行以来接受的连接总数。
connection_structures:32u, 服务器分配的连接结构的数量。
cmd_get :32u, 取回请求总数。
cmd_set :32u, 存储请求总数。
get_hits :32u, 请求成功的总次数。
get_misses :32u, 请求失败的总次数。
bytes_read :64u, 服务器从网络读取到的总字节数。
bytes_written :64u, 服务器向网络发送的总字节数。
limit_maxbytes :32u, 服务器在存储时被允许使用的字节总数。
上面的描述中32u和64u表示32位和64位无符号整数,string表示是string类型数据。
三、memcache客户端的安装(.net版本)
& Memcached Client
源码地址:&&&&&&&
(开源项目,可提供研究学习)
Enyim也是应用比较广泛的Memcached .net客户端,和之前的Memchachedonet 客户端相比,分布式算法应该做了相应优化
下载 Memcached Client 和 Memcached Providers,解压后会发现, Memcached Client中,还包含了著名的Log4net日志框架。
而Memcached Providers中其实包含了Enyim.Caching.dll,也包含了Log4netDLL。
Memcached Providers更强大,MemcachedProviders是对Enyim.Caching的再次封装,并加入了客户端计数器功能以及Session数据库管理功能。
当然,使用和配置起来也同样简单,方便,只是对于一些负责的操作和处理方面,功能更强大一些。
如果只是简单的应用,推荐直接使用 Memcached Client。除了添加必要的Enyim.Caching.dll引用,还需要修改应用程序的配置文件。
下面的代码贴出这两种方式的配置文件和测试代码:(放心,有详细的注释)
测试代码(实现最简单的功能)
using System.Collections.G
using System.L
using System.W
using System.Web.UI;
using System.Web.UI.WebC
using Enyim.C
using MemcachedProviders.C
using System.T
namespace MemcachedProject
public partial class _Default : System.Web.UI.Page
protected void Page_Load(object sender, EventArgs e)
testMemcachedProviders();
/// &summary&
/// 测试Enyim.Caching(注意:Enyim.Caching只具有MemcachedProviders的一部分功能,后者更强大。还可以集成Log4Net日志框架)
/// &/summary&
public void testEnyimCaching()
MemcachedClient client = new MemcachedClient(&/memcached&);
//存值
--不带过期时间的存储,Memcached将根据LRU来决定过期策略
bool result = client.Store(Enyim.Caching.Memcached.StoreMode.Add, &name&, &dinglang&);
//带过期时间的缓存
//bool success = client.Store(StoreMode.Add, person.UserName, person, DateTime.Now.AddMinutes(10));
if (result)
Response.Write(&成功存入缓存&);
//取值
object name = client.Get(&name&);
if (name != null)
Response.Write(&取出的值为:& + name);
Response.Write(&取值失败&);
Response.Write(&存入缓存失败&);
/// &summary&
/// 使用MemcachedProviders客户端
/// &/summary&
public void testMemcachedProviders()
string key = &myName&;
string value = &Dylan&;
bool result = false;
string val = string.E
#region 存/取最简单的数据类型
//如果缓存中没有,就尝试着去存入缓存
if (DistCache.Get(key) == null)
//DistCache.DefaultExpireTime = 1200;//缓存时间
result = DistCache.Add(key, value);
if (result)
//如果存入成功,就试着去取
Thread.Sleep(500);
string ret = (string)DistCache.Get(key);
//Assert.AreEqual(value, ret);
if (ret != null)
Response.Write(ret);
Response.Write(&&br/&&);
//取出来的值为null,直接移除该缓存对象
DistCache.Remove(key);//移除
// DistCache.RemoveAll();//移除所有
//缓存中有,直接拿数据
string ret = (string)DistCache.Get(key);
if (ret != null)
Response.Write(ret);
Response.Write(&&br/&&);
DistCache.Remove(key);
#endregion
存/取一个Person对象
Person person = new Person() { Id = 007, Name = &Dylan& };//new 一个Person对象的实例
//如果缓存中没有,则尝试着放入缓存
if (DistCache.Get&Person&(&myObj&) == null)
result = DistCache.Add(&myObj&, person);
if (result)
Thread.Sleep(500);
val = DistCache.Get(&myObj&).ToString();
if (val != null)
Response.Write(val);
Response.Write(&&br/&&);
DistCache.Remove(&myObj&);
//缓存中已经有该对象,就直接从缓存取
Person p = DistCache.Get&Person&(&myObj&);
val = person.ToString();
//也可以直接这样取
// val = DistCache.Get(&myObj&).ToString();
if (val != null)
Response.Write(val);
Response.Write(&&br/&&);
DistCache.Remove(&myObj&);
#endregion
Person类的定义代码:
这里需要说明的是如果我们需要向Memcached中添加自定义数据类型时,我们需要将该数据类型添加上[Serializable]标记。
[Serializable]
public class Person
private int
public int Id
get { return
set { id = value; }
private string
public string Name
get { return
set { name = value; }
/// &summary&
/// 重写Tostring(),方便输出验证
/// &/summary&
/// &returns&&/returns&
public override string ToString()
return &Person:& + &{name:& + Name + &,id:& + Id + &}&;
web.config 配置信息:
&?xml version=&1.0&?&
有关如何配置 ASP.NET 应用程序的详细信息,请访问
/fwlink/?LinkId=169433
&configuration&
&!--Enyim.Caching配置(省略了Log4Net框架)
For Memcached--&
&!--&configSections&
&sectionGroup name=&&&
&section name=&memcached& type=&Enyim.Caching.Configuration.MemcachedClientSection, Enyim.Caching& /&
&/sectionGroup&
&/configSections&
& protocol=&Binary&&
&memcached&
&add address=&127.0.0.1& port=&11121&
&/servers&
&socketPool minPoolSize=&10& maxPoolSize=&100& connectionTimeout=&00:00:10& deadTimeout=&00:02:00& /&
&/memcached&
&!--The Enyim.Caching配置 End --&
&!--MemcachedProviders的配置
&configSections&
&section name=&cacheProvider& type=&MemcachedProviders.Cache.CacheProviderSection, MemcachedProviders&
allowDefinition=&MachineToApplication& restartOnExternalChanges=&true&/&
&sectionGroup name=&&&
&section name=&memcached& type=&Enyim.Caching.Configuration.MemcachedClientSection, Enyim.Caching& /&
&/sectionGroup&
&section name=&log4net& type=&log4net.Config.Log4NetConfigurationSectionHandler,log4net&/&
&/configSections&
&cacheProvider defaultProvider=&MemcachedCacheProvider&&
&providers&
&add name=&MemcachedCacheProvider&
type=&MemcachedProviders.Cache.MemcachedCacheProvider, MemcachedProviders&
keySuffix=&_MySuffix_& defaultExpireTime=&2000&/&
&/providers&
&/cacheProvider&
&memcached&
&!-- put your own server(s) here--&
&add address=&127.0.0.1& port=&11121& /&
&/servers&
&socketPool minPoolSize=&10& maxPoolSize=&100& connectionTimeout=&00:00:10& deadTimeout=&00:02:00& /&
&/memcached&
&appender name=&ConsoleAppender& type=&log4net.Appender.ConsoleAppender&&
&layout type=&log4net.Layout.PatternLayout&&
&conversionPattern value=&%date [%thread] %-5level %logger [%property{NDC}]- %message%newline& /&
&/appender&
&priority value=&WARN&/&
&appender-ref ref=&ConsoleAppender&&
&filter type=&log4net.Filter.LevelRangeFilter&&
&levelMin value=&WARN&/&
&levelMax value=&FATAL&/&
&/appender-ref&
&/log4net&
&!--The MemcachedProviders配置 End
配置结束,下面的都是一些其他的配置,例如连数据库之类的,和我们的
memcache 无关--&
&connectionStrings&
&add name=&ApplicationServices&
connectionString=&data source=.\SQLEXPRESS;Integrated Security=SSPI;AttachDBFilename=|DataDirectory|\aspnetdb.User Instance=true&
providerName=&System.Data.SqlClient& /&
&/connectionStrings&
&system.web&
&compilation debug=&true& targetFramework=&4.0& /&
&authentication mode=&Forms&&
&forms loginUrl=&~/Account/Login.aspx& timeout=&2880& /&
&/authentication&
&membership&
&providers&
&add name=&AspNetSqlMembershipProvider& type=&System.Web.Security.SqlMembershipProvider& connectionStringName=&ApplicationServices&
enablePasswordRetrieval=&false& enablePasswordReset=&true& requiresQuestionAndAnswer=&false& requiresUniqueEmail=&false&
maxInvalidPasswordAttempts=&5& minRequiredPasswordLength=&6& minRequiredNonalphanumericCharacters=&0& passwordAttemptWindow=&10&
applicationName=&/& /&
&/providers&
&/membership&
&providers&
&add name=&AspNetSqlProfileProvider& type=&System.Web.Profile.SqlProfileProvider& connectionStringName=&ApplicationServices& applicationName=&/&/&
&/providers&
&/profile&
&roleManager enabled=&false&&
&providers&
&add name=&AspNetSqlRoleProvider& type=&System.Web.Security.SqlRoleProvider& connectionStringName=&ApplicationServices& applicationName=&/& /&
&add name=&AspNetWindowsTokenRoleProvider& type=&System.Web.Security.WindowsTokenRoleProvider& applicationName=&/& /&
&/providers&
&/roleManager&
&/system.web&
&system.webServer&
&modules runAllManagedModulesForAllRequests=&true&/&
&/system.webServer&
&/configuration&
/whoknows/articles/memcache_php5-3-10_win32.html& introduce
/memcached-144-windows-32-bit-binary-now-available& down
/luminji/archive//2140804.html& winform example
/zhoufoxcn/archive//2515609.html& 周公
/p/memcached/wiki/NewServerMaint google
参考知识库
* 以上用户言论只代表其个人观点,不代表CSDN网站的观点或立场
访问:350122次
积分:4767
积分:4767
排名:第4932名
原创:109篇
转载:137篇
评论:67条
(3)(3)(2)(4)(2)(1)(1)(2)(1)(4)(1)(1)(1)(1)(1)(1)(1)(2)(4)(1)(1)(1)(1)(3)(3)(4)(1)(4)(1)(3)(1)(4)(3)(3)(2)(2)(4)(8)(2)(4)(1)(1)(4)(1)(4)(4)(2)(3)(1)(2)(1)(1)(1)(2)(3)(4)(3)(1)(2)(2)(1)(1)(2)(1)(2)(1)(3)(1)(2)(1)(1)(7)(4)(2)(3)(6)(6)(3)(4)(1)(3)(12)(1)(1)(2)(3)(12)(25)(1)2830人阅读
数据与性能(44)
C# 操作Memcached
环境 c# vs2013 ,要在nuget里引用(安装) EnyimMemcached ,下面是以调用阿里云的ocs(memcached)服务为例
using Enyim.C
namespace MemcacheTest
/// &summary&
/// MemcachedClient 帮组类 对外提供接口方法
/// &/summary&
public class MemcachedHelper
/// &summary&
/// 定义一个静态MemcachedClient客户端,它随类一起加载,所有对象共用
/// &/summary&
private static MemcachedC
/// &summary&
/// 静态构造函数,初始化Memcached客户端
/// &/summary&
static MemcachedHelper()
mclient = MemCached.getInstance();
/// &summary&
/// 向Memcached缓存中添加一条数据
/// &/summary&
/// &param name=&groupName&&组名,用来区分不同的服务或应用场景&/param&
/// &param name=&key&&键&/param&
/// &param name=&value&&值&/param&
/// &param name=&expiry&&过期时间&/param&
/// &returns&返回是否添加成功&/returns&
public static bool SetValue(string groupName,string key, object value, DateTime expiry)
key = groupName + &-& +
return mclient.Store(Enyim.Caching.Memcached.StoreMode.Set,key, value, expiry);
/// &summary&
/// 向Memcached缓存中添加一条数据 默认超时24小时
/// &/summary&
/// &param name=&groupName&&组名,用来区分不同的服务或应用场景&/param&
/// &param name=&key&&&/param&
/// &param name=&value&&&/param&
/// &returns&&/returns&
public static bool SetValue(string groupName, string key, object value)
key = groupName + &-& +
return mclient.Store(Enyim.Caching.Memcached.StoreMode.Set, key, value, DateTime.Now.AddHours(24));
/// &summary&
/// 通过key 来得到一个对象
/// &/summary&
/// &param name=&groupName&&组名,用来区分不同的服务或应用场景&/param&
/// &param name=&key&&键&/param&
/// &returns&对象&/returns&
public static object GetValue(string groupName, string key)
key = groupName + &-& +
return mclient.Get(key);
/// &summary&
/// 通过key 来得到一个对象(前类型)
/// &/summary&
/// &typeparam name=&T&&类型&/typeparam&
/// &param name=&groupName&&组名,用来区分不同的服务或应用场景&/param&
/// &param name=&key&&键&/param&
/// &returns&&/returns&
public static T GetValue&T&(string groupName, string key)
key = groupName + &-& +
return mclient.Get&T&(key);
/// &summary&
/// 清除指定key的cache
/// &/summary&
/// &param name=&groupName&&组名,用来区分不同的服务或应用场景&/param&
/// &param name=&key&&键&/param&
/// &returns&&/returns&
public static bool Remove(string groupName, string key)
key = groupName + &-& +
return mclient.Remove(key);
/// &summary&
/// 清除所有cache
/// &/summary&
public static void RemoveAll()
mclient.FlushAll();
using System.N
using Enyim.C
using Enyim.Caching.C
using Enyim.Caching.M
namespace MemcacheTest
/// &summary&
/// MemcachedClient 配置类
/// &/summary&
public sealed class MemCached
private static MemcachedClient MemC
static readonly object padlock = new object();
//线程安全的单例模式
public static MemcachedClient getInstance()
if (MemClient == null)
lock (padlock)
if (MemClient == null)
MemClientInit();
return MemC
static void MemClientInit()
//初始化缓存
MemcachedClientConfiguration memConfig = new MemcachedClientConfiguration();
IPAddress newaddress = IPAddress.Parse(Dns.GetHostEntry(&hzalicm10pub001.&).AddressList[0].ToString()); //xxxx替换为ocs控制台上的“内网地址”
IPEndPoint ipEndPoint = new IPEndPoint(newaddress, 11211);
// 配置文件 - ip
memConfig.Servers.Add(ipEndPoint);
// 配置文件 - 协议
memConfig.Protocol = MemcachedProtocol.B
// 配置文件-权限,如果使用了免密码功能,则无需设置userName和password
memConfig.Authentication.Type = typeof(PlainTextAuthenticator);
memConfig.Authentication.Parameters[&zone&] = &&;
memConfig.Authentication.Parameters[&userName&] = &XXXXXXXXXXXXXXXXX&;
memConfig.Authentication.Parameters[&password&] = &XXXXXXXXXX&;
//下面请根据实例的最大连接数进行设置
memConfig.SocketPool.MinPoolSize = 5;
memConfig.SocketPool.MaxPoolSize = 200;
MemClient = new MemcachedClient(memConfig);
MemcachedHelper.SetValue(groupName,strKey, strValue, DateTime.Now.AddMinutes(5));
var restr = MemcachedHelper.GetValue(groupName,strKey);
var obj = MemcachedHelper.GetValue&Product&(groupName,&p001&);
参考知识库
* 以上用户言论只代表其个人观点,不代表CSDN网站的观点或立场
访问:1599767次
积分:17074
积分:17074
排名:第452名
原创:210篇
转载:437篇
评论:223条
(5)(11)(6)(9)(6)(4)(33)(6)(7)(6)(5)(1)(10)(4)(2)(8)(7)(16)(8)(2)(4)(7)(4)(4)(14)(8)(20)(59)(7)(9)(3)(6)(5)(5)(5)(28)(5)(1)(1)(4)(5)(4)(4)(12)(6)(12)(11)(1)(10)(1)(1)(3)(4)(4)(2)(6)(7)(10)(7)(9)(3)(4)(3)(1)(10)(8)(8)(9)(4)(9)(10)(4)(2)(8)(1)(1)(1)(1)(1)(3)(3)(3)(3)(4)(15)(25)(7)(13)(8)(15)(26)Memcached Demo - 我很忙 - ITeye技术网站
博客分类:
1.先下载memcached-1.2.1-win32.jar
2.将其放在C盘解压(随便哪里)
3.在cmd命令中
& cd \memcached
& memcached.exe -d install
& memcached.exe -d start
以上是在windows创建了服务端
以下创建客户端:
1.导入memcached-2.0.1.jar包
package com.edong.memcached.
import java.util.D
import com.danga.MemCached.MemCachedC
import com.danga.MemCached.SockIOP
import com.edong.memcached.model.U
* @author 张 柏
* @copyright qwnbc TODO
*/
public class Memcached {
// 创建全局的唯一实例
protected static MemCachedClient mcc = new MemCachedClient();
protected static Memcached memCached = new Memcached();
// 设置与缓存服务器的连接池
// 服务器列表和其权重
String[] servers = { "127.0.0.1:11211" };
Integer[] weights = { 3 };
// 获取socke连接池的实例对象
SockIOPool pool = SockIOPool.getInstance();
// 设置服务器信息
pool.setServers(servers);
pool.setWeights(weights);
// 设置初始连接数、最小和最大连接数以及最大处理时间
pool.setInitConn(5);
pool.setMinConn(5);
pool.setMaxConn(250);
pool.setMaxIdle(1000 * 60 * 60 * 6);
// 设置主线程的睡眠时间
pool.setMaintSleep(30);
// 设置TCP的参数,连接超时等
pool.setNagle(false);
pool.setSocketTO(3000);
pool.setSocketConnectTO(0);
pool.setFailover( true );
pool.setAliveCheck( true );
// 初始化连接池
pool.initialize();
// 压缩设置,超过指定大小(单位为K)的数据都会被压缩
mcc.setCompressEnable(true);
mcc.setCompressThreshold(64 * 1024);
* 保护型构造方法,不允许实例化!
protected Memcached() {
* 获取唯一实例.
public static Memcached getInstance() {
return memC
* 添加一个指定的值到缓存中.
* @param key
* @param value
public boolean add(String key, Object value) {
return mcc.set(key, value);
public boolean add(String key, Object value, Date expiry) {
return mcc.set(key, value, expiry);
public boolean replace(String key, Object value) {
return mcc.replace(key, value);
public boolean replace(String key, Object value, Date expiry) {
return mcc.replace(key, value, expiry);
/**
&&&& * 根据指定的关键字获取对象.
&&&& * @param key
&&&& * @return
&&&& */
&&& public Object get(String key)
&&& {
&&&&&&& return mcc.get(key);
&&& }
&&& public static void main(String[] args){
&&&
Memcached mc=getInstance();
&&&
String key = "jay";//最好是用md5加密
&&&
User user1=new User();
&&&
user1.setUserName("周杰伦");
&&&
user1.setPassWord("123456");
&&&
* 保存到缓存里
&&&
mc.add(key, user1);
* 从缓存里拿出
Object value=mc.get(key);
User user2=(User)
System.out.println(user2.getUserName());
System.out.println(user2.getPassWord());
浏览: 37846 次
来自: 上海Memcached 入门介绍(安装与配置)
投稿:mdxy-dxy
字体:[ ] 类型:转载 时间:
Memcached是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提供动态、数据库驱动网站的速度
Memcached是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载。
它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提供动态、数据库驱动网站的速度。
Memcached基于一个存储键值对的hashmap。其守护进程(daemon )是用C写的,但是客户端可以用任何语言来编写,并通过memcached协议与守护进程通信。
下面来了解下Memcached怎么用~~
一、准备工作
下载memcached的windows版
再下载一个
解压memcached-1.2.5-win32-bin.zip,CMD进入其目录,然后执行如下命令:
c:&memcached.exe -d install
c:&memcached.exe -l 127.0.0.1 -m 32 -d start第一行是安装memcached成为服务,这样才能正常运行,否则运行失败!
第二行是启动memcached的,这里简单的只分配32M内存了(默认64M),然后监听本机端口和以守护进行运行。
执行完毕后,我们就可以在任务管理器中看到memcached.exe这个进程了。
如果想要在同一台Windows机器中安装2个Memcached,请看这里
现在服务器已经正常运行了,下面我们就来写java的客户端连接程序。
将java_memcached-release.zip解压,把java_memcached-release.jar文件复制到java项目的lib目录下,
然后我们来编写代码,比如我提供的一个应用类如下:
package memcached.
import java.util.D
import com.danga.MemCached.MemCachedC
import com.danga.MemCached.SockIOP
* 使用memcached的缓存实用类.
public class MemCached {
// 创建全局的唯一实例
protected static MemCachedClient mcc = new MemCachedClient();
protected static MemCached memCached = new MemCached();
// 设置与缓存服务器的连接池
// 服务器列表和其权重
String[] servers = { "127.0.0.1:11211" };
Integer[] weights = { 3 };
// 获取socke连接池的实例对象
// 这个类用来创建管理客户端和服务器通讯连接池,
// 客户端主要的工作(包括数据通讯、服务器定位、hash码生成等)都是由这个类完成的。
SockIOPool pool = SockIOPool.getInstance();
// 设置服务器信息
pool.setServers(servers);
// 设置Server权重
pool.setWeights(weights);
// 设置初始连接数、最小和最大连接数以及最大处理时间
pool.setInitConn(5);
pool.setMinConn(5);
pool.setMaxConn(250);
pool.setMaxIdle(1000 * 60 * 60 * 6);
// 设置主线程的睡眠时间
pool.setMaintSleep(30);
// 设置连接心跳监测开关
// true:每次通信都要进行连接是否有效的监测,造成通信次数倍增,加大网络负载,
// 因此在对HighAvailability要求比较高的场合应该设为true
// 默认状态是false,建议保持默认。
pool.setAliveCheck(false);
// 设置连接失败恢复开关
// 设置为true,当宕机的服务器启动或中断的网络连接后,这个socket连接还可继续使用,否则将不再使用.
// 默认状态是true,建议保持默认。
pool.setFailback(true);
// 设置容错开关
// true:当当前socket不可用时,程序会自动查找可用连接并返回,否则返回NULL
// 默认状态是true,建议保持默认。
pool.setFailover(true);
// 设置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方法。
// 默认值为0
pool.setHashingAlg(0);
// 设置是否使用Nagle算法,因为我们的通讯数据量通常都比较大(相对TCP控制数据)而且要求响应及时,
// 因此该值需要设置为false(默认是true)
pool.setNagle(false);
// 设置socket的读取等待超时值
pool.setSocketTO(3000);
// 设置socket的连接等待超时值
pool.setSocketConnectTO(0);
// 初始化连接池
pool.initialize();
// 压缩设置,超过指定大小(单位为K)的数据都会被压缩
// mcc.setCompressEnable(true);
//UnsupportedOperation
// mcc.setCompressThreshold(64 * 1024);
private MemCached() {
* 获取唯一实例.
* singleton
public static MemCached getInstance() {
return memC
* 添加一个指定的键值对到缓存中.
* @param key
* @param value
public boolean add(String key, Object value) {
return mcc.add(key, value);
* 添加一个指定的键值对到缓存中.
* @param key
* @param value
* @param expiry 多久之后过期
public boolean add(String key, Object value, Date expiry) {
return mcc.add(key, value, expiry);
public boolean set(String key, Object value) {
return mcc.set(key, value);
public boolean set(String key, Object value, Date expiry) {
return mcc.set(key, value, expiry);
public boolean replace(String key, Object value) {
return mcc.replace(key, value);
public boolean replace(String key, Object value, Date expiry) {
return mcc.replace(key, value, expiry);
* 根据指定的关键字获取对象.
* @param key
public Object get(String key) {
return mcc.get(key);
写个Main方法测试下:
public static void main(String[] args) {
MemCached cache = MemCached.getInstance();
boolean result1 = cache.add("hello", 1234, new Date(1000 * 2));// 设置2秒后过期
System.out.println("第一次add : " + result1);
System.out.println("Value : " + cache.get("hello"));
boolean result2 =cache.add("hello", 12345, new Date(1000 * 2));// add fail
System.out.println("第二次add : " + result2);
boolean result3 =cache.set("hello", 12345, new Date(1000 * 2));// set successes
System.out.println("调用set : " + result3);
System.out.println("Value : " + cache.get("hello"));
Thread.sleep(1000 * 2);
System.out.println("已经sleep2秒了....");
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("Value : " + cache.get("hello"));
执行结果如下:
第一次add : true
Value : 1234
第二次add : false
调用set : true
Value : 12345
已经sleep2秒了....
Value : null
1.第二次add失败是因为"hello"这个key已经存在了。
2.调用set成功,是因为set的时候覆盖了已存在的键值对,这正是add和set的不同之处
3.设置过期之间之后,cache按时自动失效
上面的例子是对于基本数据类型,对于普通的POJO而言,如果要进行存储的话,那么比如让其实现java.io.Serializable接口。
因为memcached是一个分布式的缓存服务器,多台服务器间进行数据共享需要将对象序列化的,所以必须实现该接口,否则会报错的(java.io.NotSerializableException)。
下面来试试POJO的存储:
package memcached.
public class Person implements java.io.Serializable {
private static final long serialVersionUID = 1L;
public String getName() {
public void setName(String name) {
this.name =
简单的POJO对象
Main方法如下:
public static void main(String[] args) {
MemCached cache = MemCached.getInstance();
Person p1 = new Person();
p1.setName("Jack");
cache.add("bean", p1);
Person p2 = (Person) cache.get("bean");
System.out.println("name=" + p2.getName());//Jack
p2.setName("Rose");
// cache.replace("bean", p2);
Person p3 = (Person) cache.get("bean");
System.out.println("name=" + p3.getName());
上面的代码中,我们通过p2.setName("Rose")修改了对象的名字,
最后一行打印的会是什么呢?
name=JackWhy?
这是因为我们修改的对象并不是缓存中的对象,而是通过序列化过来的一个实例对象
那么要修改怎么办?使用replace,注释掉的那一行把注释去掉就可以了。
Memcached的命令参数说明
-p &num&&&&&&&&&&&&&&&& 监听的端口
-l &ip_addr&&&&&&&&&&&& 连接的IP地址, 默认是本机
-d start&&&&&&&&&&&&&&&&&& 启动memcached服务
-d restart&&&&&&&&&&&&&&& 重起memcached服务
-d stop|shutdown&&& 关闭正在运行的memcached服务
-d install&&&&&&&&&&&&&&&&& 安装memcached服务
-d uninstall&&&&&&&&&&&&& 卸载memcached服务
-u &username&&&&&&& 以&username&的身份运行 (仅在以root运行的时候有效)
-m &num&&&&&&&&&&&&&& 最大内存使用,单位MB。默认64MB
-M&&&&&&&&&&&&&&&&&&&&&&&&& 内存耗尽时返回错误,而不是删除项
-c &num&&&&&&&&&&&&&&&& 最大同时连接数,默认是1024
-f &factor&&&&&&&&&&&&&& 块大小增长因子,默认是1.25
-n &bytes&&&&&&&&&&&&& 最小分配空间,key+value+flags默认是48
-h&&&&&&&&&&&&&&&&&&&&&&&&& 显示帮助
&Memcached也可以在控制台中添加键值对,首先使用命令“telnet 127.0.0.1 11211”进入到Memcached控制台,
然后使用set、add、replace、get、delete来操作。
更详细操作可参照这里
五、Memcached的优势和不足
说到Memcached的优势,那当然是:速度快,操作简便,易扩展
不足的话,主要有2点:
1.数据的临时性(数据仅保存在内存中)
2.只能通过指定键来读取数据,不支持模糊查询
六、Memcached停止时的保障措施
如果数据库的访问量比较大,就需要提前做好准备,以便应对在memcached停止时发生的负载问题。
如果能在停止memcached之前,把数据复制到其他的server就好了。恩,这个可以通过repcached来实现。
repcached是日本人开发的实现memcached复制功能,
它是一个单master、单slave的方案,但它的master/slave都是可读写的,而且可以相互同步
如果master坏掉,slave侦测到连接断了,它会自动listen而成为master
您可能感兴趣的文章:
大家感兴趣的内容
12345678910
最近更新的内容
常用在线小工具}

我要回帖

更多关于 php数据库取出日期 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信