[转载]Memcached 两款.NET客户端的郁闷事儿 – 汤家大院 – 博客园.
不久以后就要负责一个比较大的项目，有多大？反正就是挺大的。现在处于筹备阶段，我主要负责系统框架搭建，在系统缓存这一块决定采用Http运 行时缓存+memcached。
memcached 以前用过几次 不过也是小打小闹型，尚未正式大型应用过。这次也算是个难得的练手机会吧。memcached服务器打算分布在web应用服务器以及数据库服务器上。
（两台服务器有点花大手笔了 两台Dell PowerEdge R810 自定义了配置 大约单台6.5万）。
关于Memcached的.NET 客户端的选择这一块，主要有两款候选库，Memcached.ClientLibrary（discuz .net版本企业版使用的缓存客户端） 以及 Enyim 。
这两款类库都比较好用，后者使用更加方便，只需简单的配置。我选择了Enyim。
在测试的时候发现了一个共同的问题，假如在使用多个Memcached服务时，当其中一台服务器网络不通（其它至少存在一个可用的 Memcached服务）的情况下，
Memcached.ClientLibrary 的缓存功能失效，Enyim 在缓存操作的时候实例化socket对象时没有进行连接超时的处理（Memcached.ClientLibrary处理了）。
一般都要等待10秒以上线程才能继续，线程被卡住不放了。在以往的应用中都是 memcached 与 web 共存在一台服务器上，所以没遇到过这个问题，
但是这次打算 web 服务器上开一个memcached实例，数据库服务器上开一个memcached实例，所以才关注到了这个问题。一般情况下这个问题也不会有太大影响，
但是心里总是感觉不爽。不打算使用Memcached.ClientLibrary ，所以找了 Enyim 的源代码，打算自己修改一下。
翻看了一下源代码, Enyim 的问题主要存在于 Enyim.Caching.Memcached.PooledSocket，该类主要用于创建socket 连接 。
以下是构造函数
01 |
internal PooledSocket(IPEndPoint endpoint, TimeSpan connectionTimeout, TimeSpan receiveTimeout, Action<PooledSocket> cleanupCallback) |
05 |
this.endpoint = endpoint; |
07 |
this.cleanupCallback = cleanupCallback; |
11 |
this.socket = new Socket(endpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp); |
15 |
this.socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.SendTimeout, connectionTimeout == TimeSpan.MaxValue ? Timeout.Infinite : (int)connectionTimeout.TotalMilliseconds); |
17 |
this.socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, receiveTimeout == TimeSpan.MaxValue ? Timeout.Infinite : (int)receiveTimeout.TotalMilliseconds); |
23 |
this.socket.NoDelay = true; |
27 |
this.socket.Connect(endpoint); |
29 |
this.inputStream = new BufferedStream(new BasicNetworkStream(this.socket)); |
由于Socket （我对Socket没啥研究 几乎就是文盲）对象没法设置连接超时之类的属性（这下怎么办呀），并且在源代码中可以看出 this.socket.Connect(endpoint)
的时候没有做任何处理，导致当连接有问题的服务时出现了较长时间的线程等待。我在网上找啊找，找到了类似问题的解决方案，就是使用线程池。
网上找的代码修修改改 差不多能用了，创建了 Enyim.Caching.Memcached.SocketConnector,其中有一个核心的静态方法,用来创建Socket对象，并且运行定义 超时时间。
01 |
public static Socket GetConnectdSocket(IPEndPoint endpoint, TimeSpan connectionTimeout, TimeSpan receiveTimeout, int millisecondsTimeout) |
05 |
ConnectorState state = new ConnectorState(); |
07 |
state.Endpoint = endpoint; |
09 |
state.ConnectionTimeout = connectionTimeout; |
11 |
state.ReceiveTimeout = receiveTimeout; |
13 |
ThreadPool.QueueUserWorkItem(new WaitCallback(SocketConnector.ConnectThreaded), state); |
15 |
if (state.Completed.WaitOne(millisecondsTimeout, false)) |
19 |
if (state.Socket == null) |
23 |
throw state.Exception; |
33 |
throw new SocketException(0x2af9); |
然后修改PooledSocket的构造为：
01 |
internal PooledSocket(IPEndPoint endpoint, TimeSpan connectionTimeout, TimeSpan receiveTimeout, Action<PooledSocket> cleanupCallback) |
05 |
this.endpoint = endpoint; |
07 |
this.cleanupCallback = cleanupCallback; |
09 |
this.socket = SocketConnector.GetConnectdSocket(endpoint, connectionTimeout, receiveTimeout, 100); |
11 |
this.inputStream = new BufferedStream(new BasicNetworkStream(this.socket)); |
我将连接超时设置为100毫秒，那个恶心的问题基本算是解决了。
Mikel
