使用ASP.NET MVC 4 Async Action+jQuery实现消息通知机制的实现代码
这两天在使用Asp.net MVC 4开发COMET消息通知机制，在后端使用异步线程对消息进行订阅，客户端通过AJAX长连接请求MVC中的ACTION，如：http://localhost/event/imageSet，即表示获取ImageSet对象的变更消息（新增，更新和删除消息)。
1.事件消息的类IEventEntity<TEntity>类的定义
public interface IEntityEvent<TEntity>
{
//变更的实体类对象
TEntity[] Entities
{
get;
}
//操作类型
EntityEventType Type
{
get;
}
}
public enum EntityEventType : int
{
Create = 0,
Update = 1,
Removed = 2
}
2.EntityEventController类
[SessionState(SessionStateBehavior.ReadOnly)]
public class EntityEventController : Controller
{
//异步获取对ImageSet对象操作的变更事件Action，millsecondsTimeout为超时时间。
public async Task<ActionResult> ImageSet(int millisecondsTimeout = 10000)
{
return await this.EventAsync<ImageSetData>(millisecondsTimeout);
}
private async Task<ActionResult> EventAsync<TEntity>(int millisecondsTimeout)
{
IEntityEvent<TEntity> entityEvent = await EntityEventSubcriber.Instance.WaitForEntityEvent<TEntity>(millisecondsTimeout);
return this.Json(new
{
HasEvent = null != entityEvent,
EntityEvent = entityEvent
}, JsonRequestBehavior.AllowGet);
}
}
(1)这里使用到了.Net Framework 4.5中使现异步asp.net mvc async action(可以参考：Using Asynchronous Methods in ASP.NET MVC 4 技术文章)的技术，其中方法前的async关键字可以和Task对象进行配合使用，表示该方法为异步方法，由编译器生成运行时所需的相关异步操作的逻辑代码，另外方法中必须使用到await语句来等待一个异步操作的结束，await和Task<T>结合来返回Task完成的Result
(2) 如果Controller层面应用或者Filter中操作过Session，那么为了避免长链接时不会导至同一Session在其他调用中Session Block的情况，需要在Controller头上加入[SessionState(SessionStateBehavior.ReadOnly)] 的Attribute，来表示当前Controller对Session为只读操作，这样就其他操作就不会被阻塞了。
3.这里就不具体写EntityEventSubscriber消息订阅器的代码了，以后将在“消息订阅与发布”的文章中详细描述。
4.jQuery AJAX客户端代码
$(document).ready(function () {
var $hoverList = $("#imageSets").hoverList({title:"图片集列表", selectedIndex: 1 });
var getEvent = function(){
var getPattern = "/EasyshirtBackend/imageSet/0";
$.getJSON("/EasyshirtBackend/event/imageSet/100000" , function(data){
if(data.HasEvent){
//Create
if(data.EntityEvent.Type == 0){
$.each(data.EntityEvent.Entities, function(i, entity){
//TODO: 处理实体类新增
if(i == data.EntityEvent.Entities.length - 1){
getEvent();
}
});
return;
}
//Update
if(data.EntityEvent.Type == 1){
$.each(data.EntityEvent.Entities, function(i, entity){
//TODO: 处理实体类更新
if(i == data.EntityEvent.Entities.length - 1){
getEvent();
}
});
return;
}
//Delete
if(data.EntityEvent.Type == 2){
$.each(data.EntityEvent.Entities, function(i, entity){
//TODO: 处理实体类删除
if(i == data.EntityEvent.Entities.length - 1){
getEvent();
}
});
}
}else{
$("#imageSets").hoverList("add", data);
getEvent();
}
});
};
getEvent();
});
代码中主要需要控制住在一次获得消息（无论是有消息还是无消息），都需要在恰当的时机现一次的调用getEvent()方法来进行消息获取的循环。
相关文章
在asp.net下，经常需要页面的跳转，下面是具体的几种方法。跳转页面是大部编辑语言中都会有的，正面我们来分别介绍一下关于.net中response.redirect sever.execute server.transfer 三种页面跳转的方法2009-11-11
动态方法,在使用时需要先创建实例,才能调用实例方法,而静态方法则不需要，直接使用即可。2013-06-06
点击一个按钮做两件事情，一件需要点击按钮马上完成，另一件事情是点击按钮后做其他事情，不会的朋友一起来看看下面是如何实现的2014-11-11
最近做的一个Web项目需要对URL进行过滤，在网上搜了一下，知道J2EE有个Filter的东西，而在.NET方面，其实也可以实现2013-01-01
.NET Core使用FluentEmail发送邮件的示例代码
这篇文章主要介绍了.NET Core使用FluentEmail发送邮件的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-10-10
the sourcesafe database has been locked by the administrator
今天早上打开soucesafe的时候出现提示：“the sourcesafe database has been locked by the administrator"。仔细想想， 可能是前天晚上用"f:\analyze.exe" -I- -DB -F -V3 -D "f:\vssData\data" 命今分析的时候锁定了database2009-04-04
Jmeter是Apache开源的一个使用纯Java编写的压力测试工具，它最初是为测试web应用程序而设计的，但后来扩展到了其他测试功能，这篇文章主要介绍了通过jmeter压测surging的相关知识,需要的朋友可以参考下2022-07-07
2008-01-01
ASP.NET Web API 是非常棒的技术。编写 Web API 十分容易，以致于很多开发者没有在应用程序结构设计上花时间来获得很好的执行性能。2014-08-08
HashSet定义在System.Collections.Generic中，是一个不重复、无序的泛型集合，本文学习下HashSet的工作原理，对.NET中的HashSet相关知识感兴趣的朋友一起看看吧2022-03-03
最新评论