イベントプッシュ受信とメッセージ重複排除の WeChat 開発-WeChatの開発-php.cn

前回のブログ投稿で述べたように、WeChat メッセージは、テキスト、音声、写真などを含む通常のメッセージと、この記事で説明するイベントタイプに大別されます。含まれるもの: イベントのフォロー/フォロー解除、パラメーターを使用した QR コードイベントのスキャン、地理的位置イベントのレポート、カスタムメニュー関連イベントなど。この記事では、それらを 1 つずつ説明します。

前の記事で述べたように、WeChatサーバーが5秒以内に応答を受信しない場合、接続を切断してリクエストを再開始し、合計3回再試行します。 この場合、問題が発生します。このようなシナリオがあります。ユーザーが WeChat アカウントをフォローすると、現在のユーザー情報が取得され、その情報がデータベースに書き込まれます。 PCサイトでの登録と同様です。おそらくこの懸念のため、処理する必要があるビジネスロジックは比較的複雑です。ポイントの送信、ユーザーログの書き込み、ユーザーグループの割り当てなど。お待ちください... 一連のロジックを実行する必要があるか、ネットワーク環境が比較的複雑で、現在のユーザーの操作が 5 秒以内に応答されるという保証はありません。操作がまだ完了していない場合は、WeChat サーバーが応答します。同じアテンションイベントをサーバーにプッシュします。ロジックを再度実行します。これにより、データベース内にデータが重複する可能性があります (データを挿入する前に、まずデータが存在するかどうかを判断し、存在する場合は、と言う人もいます)。何が言いたいかというと、私も最初はそう思っていましたが、実際の動作環境とデバッグ環境にはまだ大きな差があることに初めて気づきました。データベース内の重複したユーザー情報の重要性を発見しました)。

メッセージの重複排除と、通常のメッセージおよびイベントメッセージには違いがあります。通常のメッセージでは msgid が使用されますが、イベントメッセージでは FromUserName + CreateTime が使用されます。私のアイデアは次のとおりです:

3 つの
属性、つまり FromUser、MsgFlag、および CreateTime を持つ新しいクラス BaseMsg を作成します。コードは次のとおりです。

public class BaseMsg
    {        /// <summary>
        /// 发送者标识        /// </summary>
        public string FromUser { get; set; }        /// <summary>
        /// 消息表示。普通消息时，为msgid，事件消息时，为事件的创建时间        /// </summary>
        public string MsgFlag { get; set; }        /// <summary>
        /// 添加到队列的时间        /// </summary>
        public DateTime CreateTime { get; set; }
    }

ログイン後にコピー

メッセージリストを保存するための
staticlist_queue を作成します。リストのタイプは List です。
WeChat メッセージ本文を処理する前に、まず次のことを決定します。リストはインスタンスであり、インスタンス化されていない場合はインスタンス化します。そうでない場合は、リストの長さが 50 以上であるかどうかを判断します (これはカスタマイズ可能で、WeChat の同時メッセージ量に使用されます)。 50 以上の場合、応答のないメッセージは 20 秒以内に保持します (5 秒ごとに 1 回再試行し、合計 3 回の再試行で 15 秒になります。念のため、ここには 20 秒と記入します)。
現在のメッセージ本文のメッセージタイプを取得し、_queue に基づいて現在のメッセージが要求されたかどうかを判断します。イベントの場合はFromUserと作成時間が保存されます。通常のメッセージであればMsgFlagが保存されます。コードは次のとおりです。

if (_queue == null)
            {
                _queue = new List<BaseMsg>();
            }            else if(_queue.Count>=50)
            {
                _queue = _queue.Where(q => { return q.CreateTime.AddSeconds(20) > DateTime.Now; }).ToList();//保留20秒内未响应的消息            }
            XElement xdoc = XElement.Parse(xml);            var msgtype = xdoc.Element("MsgType").Value.ToUpper();            var FromUserName = xdoc.Element("FromUserName").Value;            var MsgId = xdoc.Element("MsgId").Value;            var CreateTime = xdoc.Element("CreateTime").Value;
            MsgType type = (MsgType)Enum.Parse(typeof(MsgType), msgtype);            if (type!=MsgType.EVENT)
            {                if (_queue.FirstOrDefault(m => { return m.MsgFlag == MsgId; }) == null)
                {
                    _queue.Add(new BaseMsg
                    {
                        CreateTime = DateTime.Now,
                        FromUser = FromUserName,
                        MsgFlag = MsgId
                    });
                }                else
                {                    return null;
                }
               
            }            else
            {                if (_queue.FirstOrDefault(m => { return m.MsgFlag == CreateTime; }) == null)
                {
                    _queue.Add(new BaseMsg
                    {
                        CreateTime = DateTime.Now,
                        FromUser = FromUserName,
                        MsgFlag = CreateTime
                    });
                }                else
                {                    return null;
                }
            }

ログイン後にコピー

メッセージがすでにキューに存在する場合、現在のメッセージはエンティティに変換されず、直接 null が返されます。呼び出し時に null が返された場合、処理は行われません。

それではイベントニュースの説明を始めましょう。前回の記事からの続きです。すべてのメッセージは

BaseMessage を継承し、すべてのイベントタイプには Event プロパティが含まれます。呼び出しの便宜上、メッセージタイプは列挙として定義されます。コードは次のとおりです。

/// <summary>
    /// 事件类型枚举    /// </summary>
    public enum Event
    {        /// <summary>
        /// 非事件类型        /// </summary>        NOEVENT,        /// <summary>
        /// 订阅        /// </summary>        SUBSCRIBE,        /// <summary>
        /// 取消订阅        /// </summary>        UNSUBSCRIBE,        /// <summary>
        /// 扫描带参数的二维码        /// </summary>        SCAN,        /// <summary>
        /// 地理位置        /// </summary>        LOCATION,        /// <summary>
        /// 单击按钮        /// </summary>        CLICK,        /// <summary>
        /// 链接按钮        /// </summary>        VIEW,        /// <summary>
        /// 扫码推事件        /// </summary>        SCANCODE_PUSH,        /// <summary>
        /// 扫码推事件且弹出“消息接收中”提示框        /// </summary>        SCANCODE_WAITMSG,        /// <summary>
        /// 弹出系统拍照发图        /// </summary>        PIC_SYSPHOTO,        /// <summary>
        /// 弹出拍照或者相册发图        /// </summary>        PIC_PHOTO_OR_ALBUM,        /// <summary>
        /// 弹出微信相册发图器        /// </summary>        PIC_WEIXIN,        /// <summary>
        /// 弹出地理位置选择器        /// </summary>        LOCATION_SELECT,        /// <summary>
        /// 模板消息推送        /// </summary>        TEMPLATESENDJOBFINISH
    }

ログイン後にコピー

列挙を定義した後、メッセージエンティティを定義します。

フォロー/フォロー解除イベント

xmlデータパッケージは次のとおりです:

<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[subscribe]]></Event></xml>

ログイン後にコピー

対応するエンティティ:

/// <summary>
    /// 订阅/取消订阅事件    /// </summary>
    public class SubEventMessage : EventMessage
    {        private string _eventkey;        /// <summary>
        /// 事件KEY值，qrscene_为前缀，后面为二维码的参数值（已去掉前缀，可以直接使用）        /// </summary>
        public string EventKey
        {            get { return _eventkey; }            set { _eventkey = value.Replace("qrscene_", ""); }
        }        /// <summary>
        /// 二维码的ticket，可用来换取二维码图片        /// </summary>
        public string Ticket { get; set; }

    }

ログイン後にコピー

ここで、ユーザーがパラメータを使用してQRコードをスキャンするときに、ユーザーが現在のイベントに従っていない場合に注意する必要があります。公式アカウントでは、ユーザーが注目すると、メッセージ本文に qrscene_ パラメーターと Ticket が含まれるため、ここでは EventKey と Ticket の 2 つの属性を定義します。 EventKey に値を割り当てるときは、qrscene_ を置き換えます。実際に必要なのは次のパラメーターであるためです。

パラメータを使用してQRコードイベントをスキャン

ユーザーがシーン値を使用してQRコードをスキャンすると、2つのイベントがプッシュされる可能性があります:

ユーザーが

xmlパッケージをフォローしたときのイベントプッシュは次のとおりです:

<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[SCAN]]></Event><EventKey><![CDATA[SCENE_VALUE]]></EventKey><Ticket><![CDATA[TICKET]]></Ticket></xml>

ログイン後にコピー

対応するエンティティは次のとおりです:

/// <summary>
    /// 扫描带参数的二维码实体    /// </summary>
    public class ScanEventMessage : EventMessage
    {        /// <summary>
        /// 事件KEY值，是一个32位无符号整数，即创建二维码时的二维码scene_id        /// </summary>
        public string EventKey { get; set; }        /// <summary>
        /// 二维码的ticket，可用来换取二维码图片        /// </summary>
        public string Ticket { get; set; }

    }

ログイン後にコピー

地理的位置イベントのレポート

公式アカウントがオンになったとき地理的位置報告機能、毎回パブリックアカウントセッションに入るとき、ユーザーは地理的位置を報告することに同意した後、入力時に地理的位置を報告するか、または返信を入力してから5秒ごとに地理的位置を報告します。パブリックプラットフォームのバックグラウンドで設定を変更できます。地理的位置を報告する場合、WeChat は報告された地理的位置イベントを開発者が入力した URL にプッシュします。

xml データパッケージは次のとおりです:

<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[fromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[LOCATION]]></Event><Latitude>23.137466</Latitude><Longitude>113.352425</Longitude><Precision>119.385040</Precision></xml>

ログイン後にコピー

対応するエンティティは次のとおりです:

/// <summary>
    /// 上报地理位置实体    /// </summary>
    public class LocationEventMessage : EventMessage
    {        /// <summary>
        /// 地理位置纬度        /// </summary>
        public string Latitude { get; set; }        /// <summary>
        /// 地理位置经度        /// </summary>
        public string Longitude { get; set; }       /// <summary>
        /// 地理位置精度       /// </summary>
        public string Precision { get; set; }

    }

ログイン後にコピー

自定义菜单事件常用的事件有：click，view，scancode_puth，scancode_waitmsg，location_select。另外还有三种发图的事件，由于并不常用，笔者也没想到使用场景，再次就不一一讲述了，有兴趣的可以自己研究下，或者和我进行交流。

click事件推送的xml数据包：

<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[CLICK]]></Event><EventKey><![CDATA[EVENTKEY]]></EventKey></xml>

ログイン後にコピー

view事件推送的xml数据包和click的格式是一样的，所以定义一个类就可以了，如下：

/// <summary>
    /// 普通菜单事件，包括click和view    /// </summary>
    public class NormalMenuEventMessage : EventMessage
    {        /// <summary>
        /// 事件KEY值，设置的跳转URL        /// </summary>
        public string EventKey { get; set; }
  

    }

ログイン後にコピー

scancode事件的xml数据包如下：

<xml><ToUserName><![CDATA[ToUserName]]></ToUserName><FromUserName><![CDATA[FromUserName]]></FromUserName><CreateTime>1419265698</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[scancode_push]]></Event><EventKey><![CDATA[EventKey]]></EventKey><ScanCodeInfo><ScanType><![CDATA[qrcode]]></ScanType><ScanResult><![CDATA[http://weixin.qq.com/r/JEy5oRLE0U_urVbC9xk2]]></ScanResult></ScanCodeInfo></xml>

ログイン後にコピー

对应的实体如下：

/// <summary>
    /// 菜单扫描事件    /// </summary>
    public class ScanMenuEventMessage : EventMessage
    {        /// <summary>
        /// 事件KEY值        /// </summary>
        public string EventKey { get; set; }        /// <summary>
        /// 扫码类型。qrcode是二维码，其他的是条码        /// </summary>
        public string ScanType { get; set; }        /// <summary>
        /// 扫描结果        /// </summary>
        public string ScanResult { get; set; }
    }

ログイン後にコピー

至此，当前常用的事件类型消息都已定义完毕，结合上一篇所讲的，将xml数据包转换成对象的完整代码如下：

public class MessageFactory
    {        private static List _queue; 
        public static BaseMessage CreateMessage(string xml)
        {            if (_queue == null)
            {
                _queue = new List<BaseMsg>();
            }            else if(_queue.Count>=50)
            {
                _queue = _queue.Where(q => { return q.CreateTime.AddSeconds(20) > DateTime.Now; }).ToList();//保留20秒内未响应的消息            }
            XElement xdoc = XElement.Parse(xml);            var msgtype = xdoc.Element("MsgType").Value.ToUpper();            var FromUserName = xdoc.Element("FromUserName").Value;            var MsgId = xdoc.Element("MsgId").Value;            var CreateTime = xdoc.Element("CreateTime").Value;
            MsgType type = (MsgType)Enum.Parse(typeof(MsgType), msgtype);            if (type!=MsgType.EVENT)
            {                if (_queue.FirstOrDefault(m => { return m.MsgFlag == MsgId; }) == null)
                {
                    _queue.Add(new BaseMsg
                    {
                        CreateTime = DateTime.Now,
                        FromUser = FromUserName,
                        MsgFlag = MsgId
                    });
                }                else
                {                    return null;
                }
               
            }            else
            {                if (_queue.FirstOrDefault(m => { return m.MsgFlag == CreateTime; }) == null)
                {
                    _queue.Add(new BaseMsg
                    {
                        CreateTime = DateTime.Now,
                        FromUser = FromUserName,
                        MsgFlag = CreateTime
                    });
                }                else
                {                    return null;
                }
            }            switch (type)
            {                case MsgType.TEXT: return Utils.ConvertObj(xml);                case MsgType.IMAGE: return Utils.ConvertObj(xml);                case MsgType.VIDEO: return Utils.ConvertObj(xml);                case MsgType.VOICE: return Utils.ConvertObj(xml);                case MsgType.LINK:                    return Utils.ConvertObj(xml);                case MsgType.LOCATION:                    return Utils.ConvertObj(xml);                case MsgType.EVENT://事件类型                {                    var eventtype = (Event)Enum.Parse(typeof(Event), xdoc.Element("Event").Value.ToUpper());                    switch (eventtype)
                    {                        case Event.CLICK:                            return Utils.ConvertObj(xml);                        case Event.VIEW: return Utils.ConvertObj(xml);                        case Event.LOCATION: return Utils.ConvertObj(xml);                        case Event.LOCATION_SELECT: return Utils.ConvertObj(xml);                        case Event.SCAN: return Utils.ConvertObj(xml);                        case Event.SUBSCRIBE: return Utils.ConvertObj(xml);                        case Event.UNSUBSCRIBE: return Utils.ConvertObj(xml);                        case Event.SCANCODE_WAITMSG: return Utils.ConvertObj(xml);                        default:                            return Utils.ConvertObj(xml);
                    }
                } break;                default:                    return Utils.ConvertObj(xml);
            }
        }
    }