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

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。

相关文章

Vue中动态权限到按钮的完整实现方案详解

Vue中动态权限到按钮的完整实现方案详解

《Vue中动态权限到按钮的完整实现方案详解》这篇文章主要为大家详细介绍了Vue如何在现有方案的基础上加入对路由的增、删、改、查权限控制,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、数据库设计扩展1.1 修改路由表（routes）1.2 修改角色与路由权限表（role_routes）二、后端接口设计
阅读更多...
C#集成DeepSeek模型实现AI私有化的流程步骤(本地部署与API调用教程)

C#集成DeepSeek模型实现AI私有化的流程步骤(本地部署与API调用教程)

《C#集成DeepSeek模型实现AI私有化的流程步骤(本地部署与API调用教程)》本文主要介绍了C#集成DeepSeek模型实现AI私有化的方法,包括搭建基础环境,如安装Ollama和下载DeepS... 目录前言搭建基础环境1、安装 Ollama2、下载 DeepSeek R1 模型客户端 ChatBo
阅读更多...
Qt实现发送HTTP请求的示例详解

Qt实现发送HTTP请求的示例详解

《Qt实现发送HTTP请求的示例详解》这篇文章主要为大家详细介绍了如何通过Qt实现发送HTTP请求,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1、添加network模块2、包含改头文件3、创建网络访问管理器4、创建接口5、创建网络请求对象6、创建一个回复对
阅读更多...
C++实现回文串判断的两种高效方法

C++实现回文串判断的两种高效方法

《C++实现回文串判断的两种高效方法》文章介绍了两种判断回文串的方法：解法一通过创建新字符串来处理,解法二在原字符串上直接筛选判断,两种方法都使用了双指针法,文中通过代码示例讲解的非常详细,需要的朋友... 目录一、问题描述示例二、解法一：将字母数字连接到新的 string思路代码实现代码解释复杂度分析三、
阅读更多...
grom设置全局日志实现执行并打印sql语句

grom设置全局日志实现执行并打印sql语句

《grom设置全局日志实现执行并打印sql语句》本文主要介绍了grom设置全局日志实现执行并打印sql语句,包括设置日志级别、实现自定义Logger接口以及如何使用GORM的默认logger,通过这些... 目录gorm中的自定义日志gorm中日志的其他操作日志级别Debug自定义 Loggergorm中的
阅读更多...
Spring Boot整合消息队列RabbitMQ的实现示例

Spring Boot整合消息队列RabbitMQ的实现示例

《SpringBoot整合消息队列RabbitMQ的实现示例》本文主要介绍了SpringBoot整合消息队列RabbitMQ的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的... 目录RabbitMQ 简介与安装1. RabbitMQ 简介2. RabbitMQ 安装Spring
阅读更多...
Gin框架中的GET和POST表单处理的实现

Gin框架中的GET和POST表单处理的实现

《Gin框架中的GET和POST表单处理的实现》Gin框架提供了简单而强大的机制来处理GET和POST表单提交的数据,通过c.Query、c.PostForm、c.Bind和c.Request.For... 目录一、GET表单处理二、POST表单处理1. 使用c.PostForm获取表单字段：2. 绑定到结
阅读更多...
springMVC返回Http响应的实现

springMVC返回Http响应的实现

《springMVC返回Http响应的实现》本文主要介绍了在SpringBoot中使用@Controller、@ResponseBody和@RestController注解进行HTTP响应返回的方法,... 目录一、返回页面二、@Controller和@ResponseBody与RestController
阅读更多...
nginx中重定向的实现

nginx中重定向的实现

《nginx中重定向的实现》本文主要介绍了Nginx中location匹配和rewrite重定向的规则与应用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下... 目录一、location1、 location匹配2、 location匹配的分类2.1 精确匹配2
阅读更多...
Nginx之upstream被动式重试机制的实现

Nginx之upstream被动式重试机制的实现

《Nginx之upstream被动式重试机制的实现》本文主要介绍了Nginx之upstream被动式重试机制的实现,可以通过proxy_next_upstream来自定义配置,具有一定的参考价值,感兴... 目录默认错误选择定义错误指令配置proxy_next_upstreamproxy_next_upst
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2