C#----Memcached 的揣摩记录

高峰之巅

自己在公司任务暂时不重的时候，揣摩并顺理了关于高效访问的方案之一--利用Memcacherd来处理
网上很多PHP版本的，其实他的客户端API包含很多版本，因为我目前主要以.NET为主，所以下面的内容全部是C#的相关：
1。关于服务器端的布置-----安装Memcached for win32
网络上的地址很多，下载后，在CMD里运行文件夹里的安装程序   
       memcached.exe -d intall     //安装
      memcached.exe -d start      //开机启动

2。首先去网上下载个客户端的API，里面含有DLL；
关于程序里，也就是客户端里的操作-----分布式缓存
       注意：一定要写在类里面，而不能直接写在xxx.asp.cs里，是不同的命名空间
第一步，类：当然要引用了，第一步中下载的里面，一般都含有，直接引入即可。
DLL有：Memcached.ClientLibrary.dll，log4net.dll，ICSharpCode.SharpZipLib.dll

Code
using Memcached.ClientLibrary //就OK
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using Memcached.ClientLibrary;
using System.Data;
/// <summary>
///Mem 的摘要说明
/// </summary>
public class Mem
{
    public static SockIOPool pool = null;
    public static MemcachedClient mc = null;
    public Mem()
    {
        //
        //TODO: 在此处添加构造函数逻辑
        //               
    }
    ~Mem()
    {
        pool.Shutdown();
    }
    public static string Memcacher1()
    {
        mc = new MemcachedClient();
        if (!mc.KeyExists("1"))
        {
            Initer();
            mc.Set("1", "wen");                        //mc.Set(key,value)  将值放到缓存里,value是任意类型的值，string/int/dt
        }
        string restr = mc.Get("1").ToString();        //mc.Get(key)  的返回值是Object，可以任意强转换  
        return restr;
    }
    public static string Memcacher2()
    {
        mc = new MemcachedClient();
        if (!mc.KeyExists("2"))
        {
            Initer();            
            mc.Set("2", "dong");
        }
        string restr = mc.Get("2").ToString();
        return restr;
    }
    public static DataTable GetMemDt()
    {
        mc = new MemcachedClient();
        if (!mc.KeyExists("dt"))
        {
            Initer();
            DBMaster dbm = new DBMaster();
            mc.Set("dt", dbm.GetDt());
        }
        return (DataTable)mc.Get("dt");
    }
    public static void Initer()
    {
        string[] serverlist = { "192.168.0.102:11211", "192.168.0.102:11211" };
        pool = SockIOPool.GetInstance();         //初始化SockIOPool，管理memcached的连接池 实例
        pool.SetServers(serverlist);             //服务器设置  serverlist：IP序列（must 安装了Memcached）
        pool.InitConnections = 3;           // 初始化连接数
        pool.MinConnections = 3;            //最小连接数
        pool.MaxConnections = 5;            //最大连接数
        pool.SocketConnectTimeout = 1000;    //Socket连接超时
        pool.SocketTimeout = 3000;           //Socket超时
        pool.MaintenanceSleep = 30;    //主线程的休眠时间
        pool.Failover = true;            //失效转移(一种备份操作模式)
        pool.Nagle = false;        //是否用nagle算法启动socket
        mc.EnableCompression = false;      
        pool.Initialize();     //初始化
    }
}
　　第二步：用这个类：

代码

using System.Data;
public partial class Mem2 : System.Web.UI.Page
{
    public string outstr = "";
    protected void Page_Load(object sender, EventArgs e)
    {        
        //for (int i = 0; i < 50; i++)
        //{
        //    outstr += Mem.Memcacher2();            
        //}

        DataTable dt = Mem.GetMemDt();
        outstr = ReadDt(dt);
        Response.Write(outstr);
    }
    protected void Button1_Click(object sender, EventArgs e)
    {
        Response.Redirect("Memcached.aspx");
    }
    public string ReadDt(DataTable dt)
    {
        string dtstring = "";
        foreach (DataRow dr in dt.Rows)
        {
            dtstring += dr[0].ToString();
        }
        return dtstring;
    }
}
　　
　　附录：连接数据库的类：

代码

public DataTable GetDt()
    {
        SqlConnection con = new SqlConnection("Data Source=192.168.0.102;Initial Catalog=test;Persist Security Info=True;User ID=sa;Password=sa;Max Pool Size=50");
        con.Open();
        SqlCommand cmd = new SqlCommand("select * from Sheet", con);
        DataSet ds = new DataSet();
        SqlDataAdapter sda = new SqlDataAdapter();
        sda.SelectCommand = cmd;
        sda.Fill(ds);
        return ds.Tables[0];
    }
　　
　　我在揣摩的时候，主要问题有：
如果类写不好，会重复初始化，就会导致线程错误。原则是先判断KEY是否在缓存里有值，如果没有才初始化下。否则就直接用。
在页面第一次进来的时候要注意。
由于工作比较忙，先大致把我的程序COPY来，以后有时间了在续，哎，又上课，又工作，又自己写东西，还要考研准备 .