高峰之巅 发表于 2015-9-1 12:21:02

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.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;
    }
  
  我在揣摩的时候,主要问题有:
如果类写不好,会重复初始化,就会导致线程错误。原则是先判断KEY是否在缓存里有值,如果没有才初始化下。否则就直接用。
在页面第一次进来的时候要注意。
由于工作比较忙,先大致把我的程序COPY来,以后有时间了在续,哎,又上课,又工作,又自己写东西,还要考研准备.
页: [1]
查看完整版本: C#----Memcached 的揣摩记录