.Net分布式缓存应用实例：Couchbase

<?xml version="1.0" encoding="utf-8" ?>
<configuration>

  <!--Couchbase客户端配置节点定义-->
  <configSections>
    <sectionGroup name="couchbaseClients">
      <section name="couchbase" type="Couchbase.Configuration.Client.Providers.CouchbaseClientSection, Couchbase.NetClient" />
    </sectionGroup>
  </configSections>

  <!--Couchbase客户端配置，参考：http://developer.couchbase.com/documentation/server/4.1-dp/sdks/dotnet-2.2/configuring-the-client.html-->
  <couchbaseClients>
    <couchbase useSsl="false" operationLifespan="1000">
      <servers>
        <add uri="http://127.0.0.1:8091/pools"></add>
      </servers>
      <buckets>
        <add name="default" useSsl="false" password="" operationLifespan="2000">
          <connectionPool name="defaultPool" maxSize="10" minSize="5" sendTimeout="12000"></connectionPool>
        </add>
      </buckets>
    </couchbase>
  </couchbaseClients>

  <!--约束Newtonsoft.Json版本-->
  <runtime>
    <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">
      <dependentAssembly>
        <assemblyIdentity name="Newtonsoft.Json" culture="neutral" publicKeyToken="30ad4fe6b2a6aeed" />
        <bindingRedirect oldVersion="0.0.0.0-7.0.0.0" newVersion="7.0.0.0" />
      </dependentAssembly>
    </assemblyBinding>
  </runtime>
  
</configuration>

using System;
using System.Collections.Generic;
using System.Linq;
using Newtonsoft.Json;
using Couchbase;
using Couchbase.Core;
using Couchbase.Configuration.Client;

namespace ZhengHe.Cache.Couchbase
{
    /// <summary>
    /// Couchbase工具
    /// </summary>
    public static class Helper
    {
        /// <summary>
        /// 初始化 ClusterHelper
        /// 参考：http://developer.couchbase.com/documentation/server/4.1-dp/sdks/dotnet-2.2/cluster-helper.html
        /// </summary>
        static Helper()
        {
            //使用配置节点进行初始化
            ClusterHelper.Initialize("couchbaseClients/couchbase");
        }

        /// <summary>
        /// 在Bucket中获取一个文档
        /// </summary>
        /// <typeparam name="T">动态数据类型</typeparam>
        /// <param name="key">文档唯一标识</param>
        /// <param name="bucketName">指定Bucket名称</param>
        /// <returns></returns>
        public static T DocumentGet<T>(string key, string bucketName = "default")
        {
            var bucket = ClusterHelper.GetBucket(bucketName);

            var result = bucket.GetDocument<T>(key);
            if (result.Success)
            {
                return result.Content;
            }

            return default(T);
        }

        /// <summary>
        /// 在Bucket中添加/更新一个文档
        /// </summary>
        /// <typeparam name="T">动态数据类型, The actual document value to store. This can be a scalar value, an object, or a dynamic type.</typeparam>
        /// <param name="key">文档唯一标识</param>
        /// <param name="content">动态数据</param>
        /// <param name="expiry">过期时间(秒)，如果小于或等于0表示持久存在</param>
        /// <param name="bucketName">指定Bucket名称</param>
        /// <returns></returns>
        public static bool DocumentUpsert<T>(string key, T content, int expiry = 0, string bucketName = "default")
        {
            if (expiry < 0)
                expiry = 0;

            var bucket = ClusterHelper.GetBucket(bucketName);

            var result = bucket.Upsert(
                new Document<T> { 
                    Id = key, 
                    Content = content, 
                    Expiry = (uint)(expiry * 1000) //将秒转换为毫秒
                });

            if (result.Success)
                return true;

            return false;
        }

        /// <summary>
        /// 在Bucket中删除一个文档
        /// </summary>
        /// <param name="key">文档唯一标识</param>
        /// <param name="bucketName">指定Bucket名称</param>
        /// <returns></returns>
        public static bool DocumentRemove(string key, string bucketName = "default")
        {
            var bucket = ClusterHelper.GetBucket(bucketName);

            var result = bucket.Remove(key);
            if (result.Success)
                return true;

            return false;
        }
        
    }//end class
}