ホームページ >WeChat アプレット >WeChatの開発 >C# を使用してイベント プッシュとメッセージの重複排除を受信する WeChat パブリック アカウントを開発する方法の紹介
C# を使用してイベント プッシュとメッセージの重複排除を受信する WeChat パブリック アカウントを開発する方法の紹介
- 高洛峰オリジナル
- 2017-03-19 18:00:561481ブラウズ
この記事では主に、C# を使用してイベント プッシュとメッセージ重複排除を受信して WeChat パブリック アカウントを開発する方法を紹介します。イベント プッシュとメッセージ重複排除の使用スキルを詳細に分析します。これは、WeChat 開発を必要とする友人にとって一定の参考になります。ご参考までに
この記事の例では、C# WeChat パブリック アカウント開発におけるイベント プッシュの受信とメッセージの重複排除の方法について説明します。皆さんの参考に共有してください。具体的な分析は次のとおりです:
WeChat サーバーが 5 秒以内に応答を受信しない場合、接続を切断してリクエストを再開始し、合計 3 回再試行します。この場合、問題が発生します。このようなシナリオがあります。ユーザーが WeChat アカウントをフォローすると、現在のユーザー情報が取得され、その情報がデータベースに書き込まれます。 PCサイトでの登録と同様です。おそらくこの懸念のため、処理する必要があるビジネス ロジックは比較的複雑です。ポイントの送信、ユーザー ログの書き込み、ユーザー グループの割り当てなど。お待ちください... 一連のロジックを実行する必要があるか、ネットワーク環境が比較的複雑で、現在のユーザーの操作が 5 秒以内に応答されるという保証はありません。操作がまだ完了していない場合は、WeChat サーバーが応答します。同じアテンション イベントをサーバーにプッシュします。ロジックを再度実行します。これにより、データベース内にデータが重複する可能性があります (データを挿入する前に、まずデータが存在するかどうかを確認し、存在する場合は、何が言いたいかというと、最初はそう思っていましたが、実際の動作環境とデバッグ環境にはまだ大きな差があることに初めて気づきました。データベース内の重複したユーザー情報を調べて、メッセージの重複排除の重要性を発見しました。)
メッセージの重複排除と、通常のメッセージおよびイベント メッセージには違いがあります。通常のメッセージでは msgid が使用されますが、イベント メッセージでは FromUserName + CreateTime が使用されます。私のアイデアは次のとおりです:
FromUser、MsgFlag、CreateTime の 3 つの属性を持つ新しいクラス 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; }
}
メッセージ リストを保存する静的 list_queue を作成します。リストのタイプは Listf822bda892e76d613fb5d807a4e9e7c8 です。
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_ パラメーターとチケットがメッセージ本文に含まれるため、ここで 2 つの属性が定義されています。そしてチケット。 EventKey に値を割り当てるときは、qrscene_ を置き換えます。実際に必要なのは次のパラメーターであるためです。
パラメーターを使用して QR コード イベントをスキャンする
ユーザーがシーン値を使用して QR コードをスキャンすると、次の 2 つのイベントがプッシュされる場合があります:
ユーザーが公式アカウントをフォローしていない場合、ユーザーはフォローした後、公式アカウントをフォローできます。シーン値を含むイベントを開発者にプッシュします。
ユーザーが公式アカウントをフォローしている場合、WeChat はシーン値を含むスキャン イベントを開発者にプッシュします。 ,
最初のタイプについては上で説明しましたが、ここでは 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<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);
}
}
}以上がC# を使用してイベント プッシュとメッセージの重複排除を受信する WeChat パブリック アカウントを開発する方法の紹介の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。