使用 .NET 实现 Ajax 长连接
作者：http://www.cnblogs.com/cathsfz/
Ajax的长连接，或者有些人所说的Comet，就是指以XMLHttpRequest的方式连接服务器，连接后服务器并非即时写入相应并返回。服务器会保持连接并等待一个需要通知客户端的事件，该事件发生后马上将数据写入响应，这时候客户端就以相当“实时”的方式接收到事件通知。具体的通信模型，请参考这篇文章：《Comet：基于 HTTP 长连接的“服务器推”技术》，里面已经说得非常详细了，我就不再复述了。
我们接着开始讨论如何使用.NET实现这个模型。首先我们能想到的是，我们需要一个Web Service，可以是ASP.NET Web Service，也可以是WCF Web Service，ASP.NET AJAX Library两者都支持。在这里，为了简单起见，就选择大家更熟悉的ASP.NET Web Service举例。然后，我们写下以下两个函数签名：
public void Send(Message message);
public Message Wait();
其中，Send函数用来发送一个Message对象，而Wait函数用来等待一个Message对象。然后，让我们来讨论一些细节问题。
无事件导致超时
首先，长期保持连接时不行的。对于服务器和客户端来说，这不是个问题，但我们永远都要记住中间可能存在各式各样配置怪异的网关和代理，它们上面可能有各式各样的超时规则，因此Comet最好设计为定期重连。一般情况下，如果30秒没有任何事件发生，服务器端就应该通知客户端确实没有事件发生，结束掉本次请求，然后重新开始一次新的请求以便继续等待。
那么上述函数签名可否用来返回一个无事件的消息呢？这是显然可以的，我们可以选择返回null表示无事件，或者返回一个EmptyMessage常量，这视乎我们使用class还是struct来定义Message。（甚至，我们还可以做一个名为NoMessageMessage的Message派生类来做这个事情。）
定义发送目标
上述函数签名确实能用来收发消息，但是没指名发给谁。可能有人会说，发送给谁可以在Message类里面通过一个属性来定义啊。但是Wait()方法没有说明接受方是谁，服务器端依然不知道哪些消息应该让你接收。
因此，我们引入Channel的概念，Channel使用其名称来标识，相同名称的就必然是同一个Channel。在发送与接受时，通过名称指定要发送到哪个Channel，这样问题就解决了。此时，函数签名修改如下：
public void Send(string channelName, Message message);
public Message Wait(string channelName);
可靠的消息队列
想象一个可能发生的情况，服务器端向你发送一个消息，你没有成功接收，但是服务器端认为发送了就成功了，消息从队列删除了，然后这个消息就永久丢失掉了。可能有人会强调TCP多么可靠，服务器端发送的消息如果在TCP的层面发生问题了，肯定会引发Socket级别的Exception，这个Exception冒泡上来，服务器端就能截获，从而得知发送失败，然后先不删除队首消息。可是别忘了，中间是可能存在代理的，如果代理成功把消息收回去了，可是代理发送到客户端这一步失败了，服务器端就不一定会发生异常了。
因此，我们需要制定一种策略，来确保下行消息总能发送到客户端。在这里，我们选择了引入逐个ACK的机制，来确认消息的接收。也就是说，服务器端发送给客户端的消息带有一个序号，在客户端收到消息后就将该序号发回给服务器端，已确认它受到了该消息。这时候，函数签名更改如下：
public int Send(string channelName, Message message);
public Message Wait(string channelName, int sequence);
我们使用Wait()接收到的Message中，应该有一个Sequence的属性，标记它的序号。然后，再我们执行下一次Wait()时就将该序号加1的值通过sequence参数传递回去，让服务器知道我们期望下一条消息的编号是这个。例如我们收到Message，其Sequence属性为836，那么下一次调用Wait()的时候就传给服务器837。服务器端此时应该保留了编号为836的Message在对首，如果客户端继续请求836号消息，证明它上次没收到，这次仍然发送836号消息给它；如果客户端请求837号消息，证明它成功收到836号消息的，这次就发送837号消息给它。
如果都不是，那该怎么办？那意味着，这是一个错误的请求，甚至可能是攻击请求，因为正常情况下不应该出现这样的请求的，服务器端可以考虑抛个无关紧要的Exception（不要告诉攻击者你知道他在攻击了），甚至直接给个400 （bad request）的响应代号。
与Wait()类似的，Send()也可以加入ACK机制，只需要将返回类型从void改为int就可以了，这个值就专门用于传递消息编号，实现方式和Wait()是一样的，不过Send()是由客户端保存待发送消息的队列。
小结
到此为止。我们的Web Service就写好了。这就写好了？只有签名没有函数体？是的，复杂的工作留给model去做，Web Service在这里只是相当于一个view，用于将model的接口暴露出来。
在下一次的文章中，我们将开始讨论如何实现服务器端的消息传递机制。
在上一次的文章中，我们说到了如何设计一个ASP.NET Web Service来处理长连接请求。很多人对此就提出了问题，如何hold住请求让它30秒不断开了？这其实很简单，只需要Sleep()一下就可以了：
Thread.Sleep(30 * 1000);
然而问题是，我们不是要等30秒然后看看是否有事件需要返回，而是在这30秒内随时有事件随时返回。因此，我们需要一套机制来在等待的过程中检查是否有事件发生了。
Monitor模型
在.NET里面，大家最熟悉的线程同步模型应该就是Monitor模型了。没听说过？就是C#的那个lock关键字，实际上它编译出来就是一对Monitor.Enter()和Monitor.Exit()。
通过lock命令，我们可以针对一个对象创建一个临界区，代码执行到临界区入口时必须获取到该对象的锁才能执行下去，并且在临界区的出口释放该锁。然而这种模型不太适用于解决我们的问题，因为我们需要等待一个事件，如果使用lock来等待的话，那就是说要先在Web Service外部把对象锁上，然后等事件触发了就解锁，这时候Web Service才顺利进入临界区域。
事实上，要进行这类型的阻塞，还有一个更好的选择，那就是Mutex。
Mutex模型
Mutex，也就是mutual exclusive的缩写，“互斥”的意思。Mutex是如何运作的？这有点像是银行的排队叫号系统，所有等待服务的人都坐在大厅里等候（wait）被叫，当一个服务窗口空闲时它就会发出一个信号（signal）来通知下一位等候服务的人。总之，所有执行wait指令的线程都在等候，而每一个signal能够让一个线程结束等候继续执行。
在.NET里面，wait和signal这两个操作分别对应Mutex.WaitOne()和Mutex.ReleaseMutex()这两个方法。我们可以让Web Service的线程使用Mutex.WaitOne()进入等候状态，而在事件发生时使用Mutex.ReleaseMutex()来通知Web Service线程。因为必须在Mutex.ReleaseMutex()发生后Mutex.WaitOne()才可能继续执行下去，因此能够执行下去就证明必然有事件发生了并且调用了Mutex.ReleaseMutext()，这时候就可以放心地去读取事件消息了。
简单示例
在选定使用Mutex模型后，我们来编写一个简单的示例。首先，我们要在WebService派生类内定义一个Mutex，还有一个代表消息的字符串。
Mutex mutex = new Mutex();
string message;
然后，我们定义两个WebMethod。为了把问题简单化，我们选用上一篇文章中开头所说的两个函数签名，也就说只能在一个Web Service内自己发自己收，没有发送目标的概念，也没有超时的概念，还没有可靠性设计。同时，我们将Message类型替换为普通字符串，以便于我们测试。
我们先编写发送消息的函数：
public void Send(string message) {
this.message = message;
this.mutex.ReleaseMutex();
}
在这个发送函数里，首先我们把消息放进了类内全局的变量中，然后让全局的Mutex类释放一个signal。这时候，如果有线程在等待，它可以马上执行下去。如果此时没有线程在等待，那么下一个wait的线程执行到该阻塞的地方就能够不受阻塞继续执行下去。
现在我们来编写接收消息的函数：
public string Wait() {
this.mutex.WaitOne();
return this.message;
}
接收函数一开始就进入wait状态。在得到signal后，需要做的事情就是把全局的消息返回给客户端。
亲身体验
最后，我们可以通过ASP.NET Web Service本身支持的Web测试界面来测试一下我们的代码。我们开两个浏览器窗口，一个进入Send()调用，一个进入Wait()调用。然后我们按照如下方法来测试：
- 首先执行Send("Hello")，然后执行Wait()。这时候你可以马上看到"Hello"。
- 首先执行Wait()，让它等待返回，这时候执行Send("Hello")。随后你可以看到Wait()那段返回"Hello"了。
- 按如下顺序执行：Send("Hello");Wait();Send("World");Wait();
- 按如下顺序执行：Send("Hello");Send("World");Wait();Wait();
- 按如下顺序执行：Wait();Wait();Send("Hello");Send("World");
- 按如下顺序执行：Wait();Send("Hello");Wait();Send("World");
你会发现这样一些奇怪的结果：第3个测试返回的是"World"和"World"。第5个测试先返回"Hello"的并不一定是先执行的那个Wait()线程。后者在某些情况下不是什么问题，特别是长连接中一般之后一个Wait()线程在等待中，所以我们可以不管。而前者，则是因为没有消息队列所造成的，我们只有长度为1的消息窗口，所以只能缓存最后一个消息。这个问题我们将在下一篇文章中解决。
小结
在本文中，我们看到了不同的线程同步模型的差异。Monitor模型的lock本质上是一个Semaphore，也就是一个不能连续signal的Mutex，一个signal发出去后必须被一个wait接收了才能进行下一次的signal。同时，Semaphore也限制了signal和wait必须在同一个线程内成对执行，而Mutex则没有此限制。虽然.NET是针对Monitor模型优化的，但在我们的需求当中，只能通过Mutex模型来解决。
接着，我们便写了一个小小的消协发送与接收函数，实现了我们想要的阻塞式Web Service。同时我们也看到了没有消息队列造成的问题，因此确定接下来我们要做一个消息队列。
相关文章：
全员编程时代，人类高质量程序员应具备哪三大特质？
在美国公布的《新兴科技趋势报告》里，2045年，最保守预测也认为将会有超过1千亿的设备连接在互联网上，这些设备包括了移动设备、可穿戴设备、家用电器、医疗设备、工业探测器、监控摄像头、汽车，以及服装等。不久的将来，…
[Linux] ubuntu 格式化u盘
$sudo fdisks -l 基本功，格式化命令，以格式化 /dev/sdb4 分区为例： $ sudo umount /dev/sdb4 # 必须先卸载该分区 # 格式化为 FAT 分区 $ sudo mkfs.vfat -F 32 /dev/sdb4 # -F 参数必须大写，参数有 12，16 和…
搭建Mantis 缺陷管理系统（转）
转自 什么是Mantis MantisBT is a free popular web-based bugtracking system (feature list). It is written in the PHP scripting language and works with MySQL, MS SQL, and PostgreSQL databases and a webserver. MantisBT has been installed on Windows, Linux, Mac…
Http环境下的保持连接方式
Http环境本身是一种无连接状态的架构，在这种架构下服务器只能是被动的接受客户端的请求，返回结果，而无法主动的给客户端发送数据。而在很多需要实时数据交互（比如Web IM)的场景中，我们却希望能及时得到服务器给我们返回…
22岁专访库克、B站3天涨粉百万，他将毕设树莓派扫描仪升级，繁星散落在校空！...
整理 | 禾木木出品 | AI科技大本营（ID:rgznai100）近日，#何同学毕业#冲上了热搜，4 亿网友阅读词条，1.7 万讨论为他送上毕业祝福，最新毕业视频燃爆朋友圈。过去几个月，要说B站网友苦苦等待的UP主是…
Database Appliance并非Mini版的Exadata-还原真实的Oracle Unbreakable Database Appliance
Oracle甲骨文系统有限公司在北京时间9月23日发布了一款Oracle数据库机即Oracle Database Appliance。Oracle Database Appliance是一款面向中小型企业的使用简单、用得起的高可用数据库专用服务器，该数据库机基于Sun Fire服务器、Oracle Enterprise Linux和Oracle D…
一款基于jquery和css3的响应式二级导航菜单
今天给大家分享一款基于jquery和css3的响应式二级导航菜单，这款导航是传统的基于顶部，鼠标经过的时候显示二级导航，还采用了当前流行的响应式设计。效果图如下： 在线预览 源码下载 实现的代码。 html代码： <div i…
基于PyTorch，如何构建一个简单的神经网络
本文为 PyTorch 官方教程中：如何构建神经网络。基于 PyTorch 专门构建神经网络的子模块 torch.nn 构建一个简单的神经网络。完整教程运行 codelab→https://openbayes.com/console/open-tutorials/containers/OgcYkLjKw89torch.nn 文档→https://pytorch.org/docs/s…
C#语言的几个层次
作者： 李建忠 接到一位前不久C#培训学员的来信，这位学员虽然以前功底欠缺，但学习劲头很足，在培训中成长很快。即便基本吃透《.NET框架（修订版）》还嫌不够过瘾，一心要成为高手中的高手。来信的目…
确定安全威胁与漏洞-A
1、社会工程学攻击是一种使用欺骗和诡计说服不知情的用户提供敏感信息或做出违背安全准则行为的攻击类型。通常通过人、电子邮件、电话等方式表现出来。 2、社会工程学攻击类型主要有电子欺骗、冒名顶替、骗局、网络钓鱼、电话钓鱼、大型网络钓鱼（鱼叉式网络钓鱼&am…
C# 特性（Attribute）学习。
特性（attribute）是被指定给某一声明的一则附加的声明性信息。 在C#中，有一个小的预定义特性集合。在学习如何建立我们自己的定制特性（custom attributes）之前，我们先来看看在我们的代码中如何使用预定义特性…
JMeter学习（二十三）关联
话说LoadRunner有的一些功能，比如：参数化、检查点、集合点、关联，Jmeter也都有这些功能，只是功能可能稍弱一些，今天就关联来讲解一下。 JMeter的关联方法有两种：后置处理器－正则表达式提取器与X…
程序员千万不要选全栈开发
作者 | 千鸟（网名） 小路助手开发者责编 | 晋兆雨出品 | CSDN（ID：CSDNnews）对于大多数人来说，大学毕业后选择一家满意的公司，一路升职加薪才是正解，但他却偏偏选择了一条鲜有人知的…
手动初始化设置3PAR存储系统
准备工作 1. 具备串口的终端电脑（USB to serial）. 2. 使用标记为“180-055”灰色适配器(3par自带). 3. 标准RJ45网线. 4. 下载HP 3par OS及SP Patch包. 5. PuTTY软件（或其他串口软件） 其他说明 手动设置存储系统…
C# 里怎样得到当前执行的函数名，当前代码行，源代码文件名。
得到函数名： System.Diagnostics.StackTrace st new System.Diagnostics.StackTrace(); this.Text st.GetFrame(0).ToString(); 得到代码行，源代码文件名： StackTrace st new StackTrace(new StackFrame(true));Consol…
特斯拉Model 3国内起售价下调至23.59万元
7月30日11:00，特斯拉官方微博宣布，即日起，特斯拉Model 3标准续航升级版的价格下调15000元人民币，调整后的价格为235900元人民币（此为补贴后起售价）。此次价格调整反映了成本波动的实际情况。特斯拉一直秉承…
Maven内置变量
1、Maven内置变量说明： ${basedir} 项目根目录${project.build.directory} 构建目录，缺省为target${project.build.outputDirectory} 构建过程输出目录，缺省为target/classes${project.build.finalName} 产出物名称，缺省为${proje…
在客户端调用MOSS的搜索服务，实现更加灵活的搜索控制
MOSS中提供了很多web services的服务，都放在http://<Site>/_vti_bin下 我们可以在其他地方，比如winForm，webForm中调用，对MOSS的对象进行灵活操作。 下面我简单列一下调用一个MOSS中的搜索服务的方法： 1、在VS…
年收入百万美元AI科学家的烦恼与思考
AI 研究科学家 Alexis Conneau 只需敲击了几下键盘，包含数千亿字的信息洪流，就能在他的电脑屏幕窗口中滚动起来。多年来，自动化 “爬虫” 用 100 种语言将互联网中的古老诗歌、愤怒的评论、甜点食谱和其他一切信息吸进庞大的数据库中。作为人…
web架构设计经验分享
本人作为一位web工程师，着眼最多之处莫过于 性能与架构，本次幸得参与sd2.0大会，得以与同行广泛交流,于此二方面，有些心得，不敢独享，与众博友分享，本文是这次参会与众同撩交流的心得，…
BOM和DOM的区别
为什么80%的码农都做不了架构师？>>> BOM 浏览器对象模型提 供了独立于内容而与浏览器窗口进行交互的对象。描述了与浏览器进行交互的方法和接口，可以对浏览器窗口进行访问和操作，譬如可以弹出新的窗口，改变状态栏 中的…
C#编码简单性之语义篇（如何编写简短的C#代码，随时更新）
以前写C的时候曾经在自己网站上发表过一个编码“简单性”之文章，现在编写C#了才发现自己无意之间就会写下一些浪费屏幕的代码。下面是自己编码中偶然发现的一些案例，欢迎中等水平的编程者参考。因为要积累案例，所以随时更新。---------------…
网站性能越来越差怎么办？
新的一年，你的老板或客户，是否曾和你抱怨公司的网站性能愈来愈差？网站大家都会写，自从有了 Visual Studio 之后，连你家楼下的正妹小喵和隔壁的王大婶都会写 ASP.NET。但同样的一个画面，背后的性能却可能是天…
如何设计一个高性能CPU？
任何一种技术都会经历从阳春白雪到下里巴人的过程，就像我们对计算机的理解从“戴着鞋套才能进的机房”变成了随处可见的智能手机。在前面20年中，大数据技术也经历了这样的过程，从曾经高高在上的 “火箭科技（rocket science&#x…
Python包管理工具Distribute的安装
Python包管理工具Distribute的安装Python的包管理工具常见的有easy_install, setuptools, 还有pip, distribute，那麽这几个工具有什么关系呢，看一下下面这个图就明白了：可以看到distribute是setuptools的替代方案，pip是easy_insta…
如何用 Graylog 管理日志？- 每天5分钟玩转 Docker 容器技术（93）
上一节已经部署好了 Graylog，现在学习如何用它来管理日志。 首先启动测试容器。 docker run -d \ --log-drivergelf \ --log-opt gelf-addressudp://localhost:12201 \ --log-opt tag"log-test-container-A" \ b…
php调用C代码的方法详解
在php程序中需要用到C代码，应该是下面两种情况： 1 已有C代码，在php程序中想直接用2 由于php的性能问题，需要用C来实现部分功能针对第一种情况，最合适的方法是用system调用，把现有C代码写成一个独立的程序。…
如何在Django中接收JSON格式的数据
Django做了大量工作简化我们的Web开发工作, 这其中当然也包括接收来自客户端的数据这一普遍需求. 大部分时候,从客户端传入的数据主要是FORM的POST数据,和来自URL的GET数据, 在Django中对应了HttpRequest对象的POST和GET属性, 例如读取FORM表单中的用户名username输入框的内容:…
写了篇爬虫文章，收到律师函，怎么办
大家好，我是早起。从写公众号开始，不论是私信还是交流群，常常都会有粉丝会问出类似下面的问题xx网站能不能爬？爬xx数据有没有风险？其实我并不是爬虫从业人员，充其量算爬虫爱好者，去年也转载过一…
在SQL中使用CRL函数示例
在SQL中使用CRL函数 实验目标： 1. 在SQL中创建CRL函数，使之能够向指定的计算机发送消息 实验步骤 2. 在VS中创建类发送消息的类 3. 将以下代码黏贴进去 using System; using System.Collections.Generic; using System.Text; using System.Net.Sockets; …