淘宝开放平台主动通知的实现

　前言

　　毕业一年多了，很少写点什么东西。自从进入现在的公司，就主要负责淘宝应用的项目，从开始的没听说过，到现在了解一二，一路摸爬滚打，苦逼的生活历历在目。

　　最开始的时候也百度谷歌，在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为心跳，接受到的是沙箱发货的消息，忘了补充：要接受消息，先要在应用设置的主动通知管理订阅消息