使用ASP.NET MVC 4 Async Action+jQuery實(shí)現(xiàn)消息通知機(jī)制的實(shí)現(xiàn)代碼

更新時(shí)間：2013年02月26日 16:36:30 作者：

這兩天在使用Asp.net MVC 4開發(fā)COMET消息通知機(jī)制，在后端使用異步線程對(duì)消息進(jìn)行訂閱，客戶端通過AJAX長(zhǎng)連接請(qǐng)求MVC中的ACTION

這兩天在使用Asp.net MVC 4開發(fā)COMET消息通知機(jī)制，在后端使用異步線程對(duì)消息進(jìn)行訂閱，客戶端通過AJAX長(zhǎng)連接請(qǐng)求MVC中的ACTION，如：http://localhost/event/imageSet，即表示獲取ImageSet對(duì)象的變更消息（新增，更新和刪除消息)。

1.事件消息的類IEventEntity<TEntity>類的定義

復(fù)制代碼代碼如下:

public interface IEntityEvent<TEntity>
    {
        //變更的實(shí)體類對(duì)象
        TEntity[] Entities
        {
            get;
        }

        //操作類型
        EntityEventType Type
        {
            get;
        }
    }

    public enum EntityEventType : int
    {
        Create = 0,
        Update = 1,
        Removed = 2
    }

2.EntityEventController類

復(fù)制代碼代碼如下:

[SessionState(SessionStateBehavior.ReadOnly)]
    public class EntityEventController : Controller
    {
        //異步獲取對(duì)ImageSet對(duì)象操作的變更事件Action，millsecondsTimeout為超時(shí)時(shí)間。
        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 技術(shù)文章)的技術(shù)，其中方法前的async關(guān)鍵字可以和Task對(duì)象進(jìn)行配合使用，表示該方法為異步方法，由編譯器生成運(yùn)行時(shí)所需的相關(guān)異步操作的邏輯代碼，另外方法中必須使用到await語(yǔ)句來(lái)等待一個(gè)異步操作的結(jié)束，await和Task<T>結(jié)合來(lái)返回Task完成的Result

(2) 如果Controller層面應(yīng)用或者Filter中操作過Session，那么為了避免長(zhǎng)鏈接時(shí)不會(huì)導(dǎo)至同一Session在其他調(diào)用中Session Block的情況，需要在Controller頭上加入[SessionState(SessionStateBehavior.ReadOnly)] 的Attribute，來(lái)表示當(dāng)前Controller對(duì)Session為只讀操作，這樣就其他操作就不會(huì)被阻塞了。

3.這里就不具體寫EntityEventSubscriber消息訂閱器的代碼了，以后將在“消息訂閱與發(fā)布”的文章中詳細(xì)描述。

4.jQuery AJAX客戶端代碼

復(fù)制代碼代碼如下:

$(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: 處理實(shí)體類新增

if(i == data.EntityEvent.Entities.length - 1){

                                getEvent();
                            }
                        });

return;
}

//Update
if(data.EntityEvent.Type == 1){

$.each(data.EntityEvent.Entities, function(i, entity){

//TODO: 處理實(shí)體類更新

if(i == data.EntityEvent.Entities.length - 1){

                                getEvent();
                            }
                        });

return;
}

//Delete
if(data.EntityEvent.Type == 2){

$.each(data.EntityEvent.Entities, function(i, entity){