微信公众号-消息推送-实现固定模式下的私人订制

2024-05-05 05:18
文章标签 实现 模式 微信 推送 消息 公众 固定 私人 订制

本文主要是介绍微信公众号-消息推送-实现固定模式下的私人订制，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

开发微信已经将近4个月了，但是还是不会本地调试，只能部署到服务器上，通过打日志，来看是否有错，@ALL哪位同志，如果有好的方法，可以告诉我。

先简要介绍一下微信公众号，消息推送的原理。

微信公众号只是一个平台，这个平台的功能是一样的，但是这个功能的内容却可以由这个公众号的主人决定。这些内容实现了微信公众号的私人订制。

就像关注一个公众号之后，会有一个欢迎词，都是欢迎词的功能。有的公众号推送了满满一屏的文字，有的公众号只是寥寥数字。

利用内容的不同，微信公众号得以推广。

这个功能一个测试公众号就可以完成,对微信开发有兴趣的同学可以尝试一下。

https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login

 

本姑娘从事的是java开发，所以文中所有的代码均为java。

  1. 第一步，我们要写代码部署到一个解析了域名的服务器上，让外界可以访问到。

为了实现消息推送功能，我们需要@RequestMapping value值一样的2个方法，但是RequestMethod一个为GET，一个为POST.

GET方法，用于微信公众号后台配置url+token，POST方法用于接收微信公众号推送的消息。

无论GET方法，还是POST方法,都需要验证签名的正确性。

代码附上：

/**

* 验证url+token token+timestamp+nonce asc排序SHA1加密与signature对比，相同

* 

*@param request

*@return ture验证通过，false验证未通过

*/

public boolean checkSignature(HttpServletRequestrequest) {

 

String signature = request.getParameter("signature");

String timestamp = request.getParameter("timestamp");

String nonce = request.getParameter("nonce");

String echostr = request.getParameter("echostr");

 

logger.debug("signature=============================:" +signature);

logger.debug("timestamp=============================:" +timestamp);

logger.debug("nonce=================================:" +nonce);

logger.debug("echostr===============================:" +echostr);

 

// 1.将token，timestamp,nonce三个参数排序

//TODO 这个参数之后可能会变，暂时先写死

String token = "qichejiadaojavaweixintoken";//这里的token值就是微信公众号后台配置的token，值必须一样。

String[] str = new String[] { token, timestamp, nonce };

Arrays.sort(str);

// 2.将三个参数字符串接成一个字符串

StringBuilder buff = new StringBuilder();

for (inti = 0; i <str.length;i++) {

buff.append(str[i]);

}

// 3.进行sha1加密

MessageDigest md = null;

String result = "";

try {

md = MessageDigest.getInstance("SHA-1");

byte[]date = md.digest(buff.toString().getBytes());

// 将字节数组转换成字符串

result = bytesToStr(date);

logger.debug("加密后" +result);

 

} catch (NoSuchAlgorithmException e) {

e.printStackTrace();

}

returnresult != null ? (result.equals(signature.toUpperCase())) :false;

}

 

// 将直接数组转换成十六进制字符串

private static String bytesToStr(byte[]byteArray) {

String strDigest = "";

for (inti = 0; i <byteArray.length;i++) {

strDigest += byteToHexStr(byteArray[i]);

}

returnstrDigest;

}

 

// 将一个字节转换成16进制字符串

private static String byteToHexStr(bytemByte) {

char[]Digit = { '0','1', '2', '3', '4', '5','6', '7', '8', '9', 'A','B', 'C', 'D', 'E', 'F' };

char[]temp1 = new char[2];

temp1[0] =Digit[mByte >>> 4 & 0X0F];

temp1[1] =Digit[mByte & 0X0F];

String str = new String(temp1);

returnstr;

}

 

GET方法验证签名正确后，直接返回签名，微信服务端得到的签名与后台配置的签名一致。url+token，即可配置成功。

代码附上：

/**

* 验证url和token，当所请求的方法为GET时，正常返回echostr即可

* 

*@param request

*@param response

*@throws IOException

*/

@RequestMapping(value ="/eventpush", method = RequestMethod.GET)

public void EventPushGet(HttpServletRequestrequest, HttpServletResponse response) throws IOException {

 

logger.debug("==================eventpush:Get========================");

PrintWriter out = response.getWriter();

if (checkSignature(request)) {

out.write(request.getParameter("echostr"));

} else {

out.write("error");

}

}

完成了GET方法，我们将代码部署到服务器上。到微信公众号后台，找到开发-->基本配置。

url处填写，我们刚刚完成的get方法的访问地址，当然要是全域名的例如：http://test.mywechat.cn/eventpush

Token处填写我们代码中用到的token，这个值可以随便定义，但是验证签名的代码用到的token值一定要和这里的一致。否则验证不通过。

EncodingASEKey处生成就可以。

消息加解密方式没有深的研究。

提交并启用。

url+token，配置成功，我们只做到了消息推送的第一步。

  1. 接下来我们来看一下，我们第一步中强调的POST方法能为我们做些什么。

附上controller代码：

@RequestMapping(value ="/eventpush", method = RequestMethod.POST)

public void EventPushPost(HttpServletRequestrequest, HttpServletResponse response) throws IOException {

 

// 1.判断推动的数据类型

logger.debug("==================eventpush:POST========================");

PrintWriter out = response.getWriter();

if (checkSignature(request)) {

String message = eventPushService.DoEvent(request);

out.write(message);

} else {

out.write("error");

}

}

微信公众号会将用户发送的消息（语音，图片），点击的事件(例如用户点击的底部的菜单)推送到我们上边完成的POST方法中。

我们如何处理这些消息，这些事件，就是我们的私人订制。

附上service代码：

public String DoEvent(HttpServletRequestrequest) {

 

String respContent = "success";

try {

// 调用parseXml方法解析请求消息

Map<String, String> requestMap = MessageUtil.parseXml(request);

// 发送方帐号

String fromUserName = requestMap.get("FromUserName").toString();

logger.debug("FromUserName==================================>" +fromUserName);

// 开发者微信号

String toUserName = requestMap.get("ToUserName").toString();

logger.debug("ToUserName====================================>" +toUserName);

// 消息类型

String msgType = requestMap.get("MsgType").toString();

logger.debug("MsgType=======================================>" +msgType);

 

String eventKey = requestMap.get("EventKey") ==null ? null :requestMap.get("EventKey").toString();

logger.debug("EventKey===========================>" +eventKey);

 

String ticket = requestMap.get("Ticket") ==null ? null :requestMap.get("Ticket").toString();

logger.debug("Ticket===========================> " +ticket);

 

// 回复文本消息

TextMessage textMessage = new TextMessage();

textMessage.setToUserName(fromUserName);

textMessage.setFromUserName(toUserName);

textMessage.setCreateTime(new Date().getTime());

textMessage.setMsgType(MessageConstant.RESP_MESSAGE_TYPE_TEXT);

 

// 文本消息

if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_TEXT)) {

 

}

// 图片消息

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_IMAGE)) {

 

}

// 语音消息

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_VOICE)) {

 

}

// 视频消息

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_VIDEO)) {

 

}

// 地理位置消息

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_LOCATION)) {

 

}

// 链接消息

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_LINK)) {

 

}

// 事件推送

else if (msgType.equals(MessageConstant.REQ_MESSAGE_TYPE_EVENT)) {

// 事件类型

String eventType = requestMap.get("Event").toString();

 

logger.debug("Event================================>" +eventType);

 

// 关注

if (eventType.equals(MessageConstant.EVENT_TYPE_SUBSCRIBE)) {

booleanbool = false;

logger.debug(eventType +"==" + MessageConstant.EVENT_TYPE_SUBSCRIBE +":"

+ eventType.equals(MessageConstant.EVENT_TYPE_SUBSCRIBE));

if (true ==bool) {

 

String content = "关注欢迎词";

Integer time = (int) (new Date().getTime() / 1000);

respContent ="<xml><ToUserName><![CDATA[" + fromUserName

+ "]]></ToUserName><FromUserName><![CDATA[" + toUserName

+ "]]></FromUserName><CreateTime>" + time

+ "</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[" + content

+ "]]></Content></xml>";

}

}

// 取消关注

else if (eventType.equals(MessageConstant.EVENT_TYPE_UNSUBSCRIBE)) {

logger.debug(eventType +"==" + MessageConstant.EVENT_TYPE_UNSUBSCRIBE +":"

+ eventType.equals(MessageConstant.EVENT_TYPE_UNSUBSCRIBE));

 

// wxUserService.AddOrUpdateWxUser(requestMap);

}

// 扫描带参数二维码

else if (eventType.equals(MessageConstant.EVENT_TYPE_SCAN)) {

 

}

// 上报地理位置

else if (eventType.equals(MessageConstant.EVENT_TYPE_LOCATION)) {

 

}

// 自定义菜单 CLICK

else if (eventType.equals(MessageConstant.EVENT_TYPE_CLICK)) {

logger.debug("EVENTKEY==================>" +requestMap.get("EventKey").toString());

if (requestMap.get("EventKey").toString().equals("V1001_GOOD")) {

String content = "推送消息内容";

Integer time = (int) (new Date().getTime() / 1000);

respContent ="<xml><ToUserName><![CDATA[" + fromUserName

+ "]]></ToUserName><FromUserName><![CDATA[" + toUserName

+ "]]></FromUserName><CreateTime>" + time

+ "</CreateTime><MsgType><![CDATA[text]]></MsgType><Content><![CDATA[" + content

+ "]]></Content></xml>";

}

 

}

}

 

} catch (Exception e) {

e.printStackTrace();

}

logger.debug("respContent==>" +respContent);

returnrespContent;

}

 

 

 

MessageConstant类

 

/**

 * 此类用来汇总公众号消息类型和事件类型

 *@author zeqi

 *

 */

public class MessageConstant {

public static final StringRESP_MESSAGE_TYPE_TEXT = null;

public static final StringREQ_MESSAGE_TYPE_TEXT = "text";

public static final StringREQ_MESSAGE_TYPE_IMAGE = "image";

public static final StringREQ_MESSAGE_TYPE_VOICE = "voice";

public static final StringREQ_MESSAGE_TYPE_VIDEO = "video";

public static final StringREQ_MESSAGE_TYPE_SHORT_VIDEO = "shortvideo";

public static final StringREQ_MESSAGE_TYPE_LOCATION = "location";

public static final StringREQ_MESSAGE_TYPE_LINK = "link";

public static final StringREQ_MESSAGE_TYPE_EVENT = "event";

public static final StringEVENT_TYPE_SUBSCRIBE = "subscribe";

public static final StringEVENT_TYPE_UNSUBSCRIBE = "unsubscribe";

public static final StringEVENT_TYPE_SCAN = "SCAN";

public static final StringEVENT_TYPE_LOCATION = "LOCATION";

public static final StringEVENT_TYPE_CLICK = "CLICK";

public static final StringEVENT_TYPE_VIEW = "VIEW";

}

 

当然如果不是特别个性的公众号，许多私人订制是不需要的，那么那些不需要回复的消息，响应的事件，我们统一回复“success”字符串，如果我们不回复任何内容，微信这边会发送5次重试，如果我们的服务器5秒之内给不出任何回复，微信公众号提示用户的就：

 

       下篇博客，说一下我遇到的“该公众号暂时无法提供服务，请稍后再试”的坑。


这篇关于微信公众号-消息推送-实现固定模式下的私人订制的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/960880。

相关文章

W外链微信推广短连接怎么做？

W外链微信推广短连接怎么做？

制作微信推广链接的难点分析 一、内容创作难度 制作微信推广链接时，首先需要创作有吸引力的内容。这不仅要求内容本身有趣、有价值，还要能够激起人们的分享欲望。对于许多企业和个人来说，尤其是那些缺乏创意和写作能力的人来说，这是制作微信推广链接的一大难点。 二、精准定位难度 微信用户群体庞大，不同用户的需求和兴趣各异。因此，制作推广链接时需要精准定位目标受众，以便更有效地吸引他们点击并分享链接
阅读更多...
hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

hdu1043（八数码问题，广搜 + hash（实现状态压缩） ）

利用康拓展开将一个排列映射成一个自然数，然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu
阅读更多...
【C++】_list常用方法解析及模拟实现

【C++】_list常用方法解析及模拟实现

相信自己的力量，只要对自己始终保持信心，尽自己最大努力去完成任何事，就算事情最终结果是失败了，努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一：什么是list？ •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二：list常用接口 •🌰1.默认成员函数 🔥构造函数（⭐） 🔥析构函数 •🌰2.list对象
阅读更多...
【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯，先赞后看哦~🎈🎈 🏆 作者简介：景天科技苑 🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。 🏆《博客》：Python全栈，前后端开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi
阅读更多...
让树莓派智能语音助手实现定时提醒功能

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现，因为rasa本身是带有remindschedule模块的。不过经过一番折腾后，忽然发现，chatbot上实现的定时，语音助手不一定会有响应。因为，我目前语音助手的代码设置了长时间无应答会结束对话，这样一来，chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢？ 我最后选择的方法是用threading.Time
阅读更多...
Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸（两张壁纸可不一致）

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸： 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  （注意不能是bmp格式） 替换默认锁屏壁纸： 将图片资源放入vendo
阅读更多...
在JS中的设计模式的单例模式、策略模式、代理模式、原型模式浅讲

在JS中的设计模式的单例模式、策略模式、代理模式、原型模式浅讲

1. 单例模式（Singleton Pattern） 确保一个类只有一个实例，并提供一个全局访问点。 示例代码： class Singleton {constructor() {if (Singleton.instance) {return Singleton.instance;}Singleton.instance = this;this.data = [];}addData(value)
阅读更多...
C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

C#实战|大乐透选号器[6]：实现实时显示已选择的红蓝球数量

哈喽，你好啊，我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记，这是第6篇； 接下来实现实时显示当前选中红球数量，蓝球数量； 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时，在对应的位置显示实时已选择的红球、蓝球的数量； 02 标签名称 分别设置Label标签名称为：lblRedCount、lblBlueCount
阅读更多...
Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy：PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注，收藏不迷路💖 Kubernetes的PodSecurityPolicy（PSP）是一个关键的安全特性，它在Pod创建之前实施安全策略，确保P
阅读更多...
工厂ERP管理系统实现源码（JAVA）

工厂ERP管理系统实现源码（JAVA）

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本，并实时掌握各环节的运营状况。 在采购管理方面，系统能够处理采购订单、供应商管理和采购入库等流程，确保采购过程的透明和高效。仓库管理方面，实现库存的精准管理，包括入库、出库、盘点等操作，确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2