這兩天在使用Asp.net MVC 4開發(fā)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中使現(xiàn)異步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在其他調(diào)用中Session Block的情況，需要在Controller頭上加入[SessionState(SessionStateBehavior.ReadOnly)] 的Attribute，來表示當前Controller對Session為只讀操作，這樣就其他操作就不會被阻塞了。
3.這里就不具體寫EntityEventSubscriber消息訂閱器的代碼了，以后將在“消息訂閱與發(fā)布”的文章中詳細描述。
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();
});
代碼中主要需要控制住在一次獲得消息（無論是有消息還是無消息），都需要在恰當?shù)臅r機現(xiàn)一次的調(diào)用getEvent()方法來進行消息獲取的循環(huán)。
