淘寶開放平台主動通知的實現

　前言

　　畢業一年多了，很少寫點什么東西。自從進入現在的公司，就主要負責淘寶應用的項目，從開始的沒聽說過，到現在了解一二，一路摸爬滾打，苦逼的生活歷歷在目。

　　最開始的時候也百度谷歌，在CSDN上問個問題，留了個QQ后，也有好幾個人來問我淘寶主動通知的實現（那時我已經知道怎么實現了），今天又有人來問我，索性寫點東西分享給大家。這里吐槽一下淘寶的開放平台，sdk（老版本）里面都沒看到注釋，完全憑自己理會，去只是中心提問，支持中心的人讓你看文檔，好像別個不看文檔似的。不過新版本有了注釋了。好了，進入正題：

　　主動通知，就是淘寶主動發消息給你，前提是你實現了它的接口。

　　先在http://api.taobao.com/myresources/mySdk.htm?appkey=21612266下載好sdk，我下的是標准版的.net的，你也可以根據自己訂購的消息下載對應的sdk。

　正題

　　為方便講解，建個控制台的項目，引用下載的TopSdk.dll，右鍵項目屬性，將應用程序的目標框架改為.NET Framework 4

　　新建個TaoSession類

public class TaoSession : IConnectionLifeCycleListener, ITopCometMessageListener
    {
        #region 連接接口實現
        public void OnBeforeConnect()
        {
            Console.WriteLine("Before Connect...");
        }

        public void OnConnect()
        {
            Console.WriteLine("Connect...");
        }

        public void OnConnectError(Exception e)
        {
            throw new NotImplementedException();
        }

        public void OnException(Exception throwable)
        {
            throw new NotImplementedException();
        }

        public void OnMaxReadTimeoutException()
        {
            throw new NotImplementedException();
        }

        public void OnReadTimeout()
        {
            Console.WriteLine("Time Out！");
        }

        public void OnSysErrorException(Exception e)
        {
            throw new NotImplementedException();
        }
        #endregion

        #region 消息接口實現
        public void OnClientKickOff()
        {
            throw new NotImplementedException();
        }

        public void OnConnectMsg(string message)
        {
            Console.WriteLine(DateTime.Now.ToString() + ":Connected...");
        }

        public void OnConnectReachMaxTime()
        {
            throw new NotImplementedException();
        }

        public void OnDiscardMsg(string message)
        {
            // 丟棄了的消息
            Console.WriteLine(DateTime.Now.ToString() + ":DiscardMsg...");
        }

        public void OnHeartBeat()
        {
            // 接受心跳包
            Console.WriteLine(DateTime.Now.ToString() + ":HeartBeat...");
        }

        public void OnOtherMsg(string message)
        {
            // 其他消息
            Console.WriteLine(DateTime.Now.ToString() + ":Other message...");
        }

        public void OnReceiveMsg(string message)
        {
            try
            {
                // 接受到的消息
                Console.WriteLine("Receives a message...");

                // 輸出消息
                Console.WriteLine("接受到的消息：" + message);

                // 解析消息
                //object obj = MessageDecode.DecodeMsg(message);
            }
            catch (Exception e)
            {
                Console.WriteLine("處理消息時出錯了···");
            }
        }

        public void OnServerKickOff()
        {
            throw new NotImplementedException();
        }

        public void OnServerRehash()
        {
            throw new NotImplementedException();
        }

        public void OnServerUpgrade(string message)
        {
            // 淘寶服務器在升級
            Console.WriteLine("Taobao Server is Upgrade！");
        }
        #endregion
    }

　　然后Program.cs開始啟動監聽

    class Program
    {
        static void Main(string[] args)
        {
            // 淘寶的appkey和appsecret，申請就有了
            string appkey = "", appsecret = "";
            // 沙箱環境的監聽地址
            string taotaoListenerUrl = "http://stream.api.tbsandbox.com/stream";

            Configuration conf = new Configuration(appkey, appsecret, null);
            conf.SetConnectUrl(taotaoListenerUrl);

            ITopCometStream stream = new TopCometStreamImpl(conf);

            stream.SetConnectionListener(new TaoSession());
            stream.SetMessageListener(new TaoSession());

            stream.Start();
            
            // 停止
            //stream.Stop();
        }
    }

　　這樣就可以接受到淘寶的消息了，看起來很簡單，具體的消息怎么處理，還是根據不同的業務來定，還要將接收到的消息解析（json格式），淘寶開放平台有提供解析的類

　　

　　上圖沙箱環境測試的，HeartBeat為心跳，接受到的是沙箱發貨的消息，忘了補充：要接受消息，先要在應用設置的主動通知管理訂閱消息