快捷導(dǎo)航

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

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

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

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

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

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

public interface IEntityEvent<TEntity>
    {
        //變更的實體類對象
        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
    {
        //異步獲取對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 技術(shù)文章)的技術(shù)，其中方法前的async關(guān)鍵字可以和Task對象進(jìn)行配合使用，表示該方法為異步方法，由編譯器生成運行時所需的相關(guān)異步操作的邏輯代碼，另外方法中必須使用到await語句來等待一個異步操作的結(jié)束，await和Task<T>結(jié)合來返回Task完成的Result

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

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: 處理實體類新增

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){