這兩天在使用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()方法來進行消息獲取的循環。

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com