Introduction à la méthode d'utilisation de C# pour développer des comptes publics WeChat afin de recevoir des événements push et la déduplication de messages-Développement WeChat-php.cn

Cet article présente principalement la méthode d'utilisation de C# pour développer des comptes publics WeChat afin de recevoir le push d'événements et la déduplication de messages. Il analyse en détail les compétences d'utilisation du push d'événements et de la déduplication de messages. Il a une certaine valeur de référence pour le développement de WeChat. nécessaire Les amis peuvent se référer à

Cet article décrit la méthode de réception du push d'événements et de la déduplication des messages dans le développement de comptes publics C# WeChat. Partagez-le avec tout le monde pour votre référence. L'analyse spécifique est la suivante :

Si le serveur WeChat ne reçoit pas de réponse dans les 5 secondes, il déconnectera la connexion et relancera la demande, en réessayant trois fois au total. Dans ce cas, le problème se pose. Il existe un tel scénario : lorsqu'un utilisateur suit un compte WeChat, les informations de l'utilisateur actuel sont obtenues, puis les informations sont écrites dans la base de données. Semblable à l’inscription sur le site Web du PC. C'est peut-être à cause de cette préoccupation que la logique métier que nous devons gérer est relativement complexe. Tels que l'envoi de points, la rédaction de journaux d'utilisateurs et l'attribution de groupes d'utilisateurs. Attendez... Une série de logiques doit être exécutée, ou l'environnement réseau est relativement complexe et il n'y a aucune garantie que l'opération de l'utilisateur actuel recevra une réponse dans les 5 secondes. Ensuite, si l'opération n'est pas encore terminée, le serveur WeChat. pousse le même événement d'attention sur notre serveur. Nous exécuterons à nouveau notre logique, ce qui peut conduire à des données en double dans la base de données (certains chaussures d'enfants diront, avant d'insérer les données, je détermine d'abord si elles existent déjà, et si elles existent, l'insertion ne sera pas effectuée. Ce que je veux dire, c'est que je le pensais aussi au début, mais il y a encore un écart entre l'environnement d'exploitation réel et notre environnement de débogage. Ce n'est que lorsque j'ai découvert qu'il y en avait beaucoup. d'informations utilisateur en double dans la base de données que j'ai découvert l'importance de la déduplication des messages.).

Il existe une différence entre la déduplication des messages ordinaires et les messages d'événement. Les messages ordinaires utilisent msgid, tandis que les messages d'événement utilisent FromUserName CreateTime. Mon idée est la suivante :

Créer une nouvelle classe BaseMsg avec trois attributs : FromUser, MsgFlag et CreateTime. Le code est le suivant :

Le code est le suivant :

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; }
}

Copier après la connexion

Créez une _file d'attente de liste statique pour stocker la liste de messages. la liste est List Avant de traiter le corps du message WeChat, déterminez d'abord si la liste est instanciée. Sinon, instanciez-la. Sinon, déterminez si la longueur de la liste est supérieure ou égale à 50 (ceci. peut être personnalisé et est utilisé pour le volume de messages simultanés de WeChat) ), s'il est supérieur ou égal à 50, conserver les messages qui n'ont pas répondu dans les 20 secondes (réessayer une fois toutes les 5 secondes, un total de 3 tentatives, soit 15 secondes , écrivez 20 secondes ici pour être prudent).
Obtenez le type de message du corps du message actuel et déterminez si le message actuel a été demandé en fonction de _queue. S'il s'agit d'un événement, FromUser et l'heure de création sont enregistrés. S'il s'agit d'un message normal, MsgFlag est enregistré. Voici le code :

Le code est le suivant :

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;
 }
}

Copier après la connexion

Lorsque le message existe déjà dans la file d'attente, le message actuel ne sera pas être converti directement en entité. Renvoie null Lors de l'appel, aucun traitement ne sera effectué lorsque null est renvoyé.

Commençons par l’actualité de l’événement. Suite de l'article précédent. Tous les messages héritent de BaseMessage et tous les types d'événements contiennent une propriété Event. Pour faciliter l'appel, le code du message

est le suivant :

/// <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
}

Copier après la connexion

Après avoir défini l'énumération, il est temps de définir l'entité du message .

Suivre/ne plus suivre l'événement
le paquet de données XML est le suivant :

Le code est le suivant :

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

Copier après la connexion

Entité correspondante :

Le code est le suivant :

/// <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; }
}

Copier après la connexion

Ce qu'il faut noter ici, c'est que lorsque l'utilisateur scanne le code QR avec les paramètres , si l'utilisateur ne suit pas le numéro public actuel, lorsque l'utilisateur y prête attention, le paramètre qrscene_ et Ticket seront inclus dans le corps du message, donc deux attributs sont définis ici : EventKey et Ticket. Lorsque vous attribuez une valeur à EventKey, remplacez qrscene_, car ce dont nous avons réellement besoin, ce sont les paramètres suivants.

Événement de numérisation de code QR avec paramètres
Lorsqu'un utilisateur scanne un code QR avec une valeur de scène, deux événements peuvent être poussés :

Si l'utilisateur n'a pas suivi le compte officiel, l'utilisateur Vous pouvez suivre le compte officiel. Après avoir suivi, WeChat transmettra les événements suivants avec les valeurs de la scène aux développeurs.
Si l'utilisateur a suivi le compte officiel, WeChat transmettra l'événement d'analyse avec la valeur de la scène au développeur. ,
Le premier type a été discuté ci-dessus, et seul le deuxième type sera expliqué ici.

Evénement push lorsque l'utilisateur a suivi

Le package xml est le suivant :

Le code est le suivant :

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

Copier après la connexion

Les entités correspondantes sont les suivantes :

Le code est le suivant :

/// <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; }
}

Copier après la connexion

Déclaration des événements de localisation géographique
Lorsque le compte officiel active le rapport des événements de localisation géographique, chaque Lors de la première connexion à une session de compte public, une fois que l'utilisateur a accepté de signaler l'emplacement géographique, l'emplacement géographique sera signalé lors de l'entrée, ou l'emplacement géographique sera signalé toutes les 5 secondes après avoir entré la conversation. Le compte officiel peut modifier les paramètres en arrière-plan de la plateforme publique. Lors du signalement de l'emplacement géographique, WeChat transmettra l'événement de localisation géographique signalé vers l'URL renseignée par le développeur.

Le package de données XML est le suivant :

Le code est le suivant :

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

Copier après la connexion

L'entité correspondante est la suivante :

Le code est le suivant :

/// <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; }
}

Copier après la connexion

自定义菜单事件常用的事件有：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>

Copier après la connexion

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

代码如下:

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

Copier après la connexion

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>

Copier après la connexion

对应的实体如下：

代码如下:

/// <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; }
}

Copier après la connexion

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

代码如下:

public class MessageFactory
{
        private static List<BaseMsg> _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<TextMessage>(xml);
                case MsgType.IMAGE: return Utils.ConvertObj<ImgMessage>(xml);
                case MsgType.VIDEO: return Utils.ConvertObj<VideoMessage>(xml);
                case MsgType.VOICE: return Utils.ConvertObj<VoiceMessage>(xml);
                case MsgType.LINK:
                    return Utils.ConvertObj<LinkMessage>(xml);
                case MsgType.LOCATION:
                    return Utils.ConvertObj<LocationMessage>(xml);
                case MsgType.EVENT://事件类型
                {
                    var eventtype = (Event)Enum.Parse(typeof(Event), xdoc.Element("Event").Value.ToUpper());
                    switch (eventtype)
                    {
                        case Event.CLICK:
                            return Utils.ConvertObj<NormalMenuEventMessage>(xml);
                        case Event.VIEW: return Utils.ConvertObj<NormalMenuEventMessage>(xml);
                        case Event.LOCATION: return Utils.ConvertObj<LocationEventMessage>(xml);
                        case Event.LOCATION_SELECT: return Utils.ConvertObj<LocationMenuEventMessage>(xml);
                        case Event.SCAN: return Utils.ConvertObj<ScanEventMessage>(xml);
                        case Event.SUBSCRIBE: return Utils.ConvertObj<SubEventMessage>(xml);
                        case Event.UNSUBSCRIBE: return Utils.ConvertObj<SubEventMessage>(xml);
                        case Event.SCANCODE_WAITMSG: return Utils.ConvertObj<ScanMenuEventMessage>(xml);
                        default:
                            return Utils.ConvertObj<EventMessage>(xml);
                    }
                } break;
                default:
                    return Utils.ConvertObj<BaseMessage>(xml);
            }
        }
}

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!