微信公众号回调java_处理微信公众号消息回调

「爱情、让人受尽委屈。」 2022-10-23 02:59 1202阅读 0赞

1、背景

在上一节中，咱们知道如何接入微信公众号，可是以后公众号会与咱们进行交互，那么微信公众号如何通知到咱们本身的服务器呢？咱们知道咱们接入的时候提供的url是 GET /mp/entry，那么公众号以后产生的事件将会以 POST /mp/entry 发送到咱们本身的服务器上。html

2、代码实现，此处仍是使用 weixin-java-mp 这个框架实现

一、引入 weixin-java-mp

com.github.binarywang

weixin-java-mp

4.0.0

二、编写 配置

@Configuration

public class WxMpConfiguration \{

@Autowired

private WxMpProperties wxMpProperties;

@Autowired

private SubscribeHandler subscribeHandler;

@Autowired

private UnsubscribeHandler unsubscribeHandler;

@Bean

public WxMpService wxMpService() \{

WxMpServiceImpl wxMpService = new WxMpServiceImpl();

wxMpService.setWxMpConfigStorage(wxMpConfigStorage());

// 设置多个微信公众号的配置

// wxMpService.setMultiConfigStorages();

return wxMpService;

/\*\*

\* 这个地方的配置是保存在本地，生产环境须要本身扩展，能够保存在Redis中等等

\* @return WxMpConfigStorage

\*/

public WxMpConfigStorage wxMpConfigStorage() \{

WxMpDefaultConfigImpl storage = new WxMpDefaultConfigImpl();

storage.setAppId(wxMpProperties.getAppId());

storage.setSecret(wxMpProperties.getAppSecret());

storage.setAesKey(wxMpProperties.getAesKey());

storage.setToken(wxMpProperties.getToken());

return storage;

@Bean

public WxMpMessageRouter messageRouter(WxMpService wxMpService) \{

WxMpMessageRouter router = new WxMpMessageRouter(wxMpService);

// 消息去重

router.setMessageDuplicateChecker(new WxMessageInMemoryDuplicateChecker());

// 关注事件

router.rule().async(false).msgType(EVENT).event(SUBSCRIBE)

.handler(this.subscribeHandler)

.end();

// 取消关注事件

router.rule().async(false).msgType(EVENT).event(UNSUBSCRIBE)

.handler(this.unsubscribeHandler)

.end();

return router;

一、公众号回调给咱们的消息会经过 WxMpMessageRouter 来处理。

二、配置的时候须要作好消息的去重处理，若是咱们的服务器5s种没给微信服务器响应，微信服务器会重试 3次。

三、处理消息实现WxMpMessageHandler接口java

三、回调入口

/\*\*

\* 微信回调

\* @param requestBody

\* @param signature

\* @param timestamp

\* @param nonce

\* @param openid

\* @param encType

\* @param msgSignature

\* @return

\*/

@PostMapping("/mp/entry")

public String entryCallback(@RequestBody String requestBody,

@RequestParam("signature") String signature,

@RequestParam("timestamp") String timestamp,

@RequestParam("nonce") String nonce,

@RequestParam("openid") String openid,

@RequestParam(name = "encrypt\_type", required = false) String encType,

@RequestParam(name = "msg\_signature", required = false) String msgSignature) \{

log.info("\\n接收微信请求：\[openid=\[\{\}\], \[signature=\[\{\}\], encType=\[\{\}\], msgSignature=\[\{\}\],"

\+ " timestamp=\[\{\}\], nonce=\[\{\}\], requestBody=\[\\n\{\}\\n\] ",

openid, signature, encType, msgSignature, timestamp, nonce, requestBody);

if (!wxMpService.checkSignature(timestamp, nonce, signature)) \{

throw new IllegalArgumentException("非法请求，可能属于伪造的请求！");

String out = null;

if (encType == null) \{

// 明文传输的消息

WxMpXmlMessage inMessage = WxMpXmlMessage.fromXml(requestBody);

WxMpXmlOutMessage outMessage = this.wxMpMessageRouter.route(inMessage);

if (outMessage == null) \{

return "";

out = outMessage.toXml();

\} else if ("aes".equalsIgnoreCase(encType)) \{

// aes加密的消息

WxMpXmlMessage inMessage = WxMpXmlMessage.fromEncryptedXml(requestBody, wxMpService.getWxMpConfigStorage(),

timestamp, nonce, msgSignature);

log.info("\\n消息解密后内容为：\\n\[\{\}\] ", inMessage.toString());

WxMpXmlOutMessage outMessage = this.wxMpMessageRouter.route(inMessage);

if (outMessage == null) \{

return "";

out = outMessage.toEncryptedXml(wxMpService.getWxMpConfigStorage());

log.info("\\n组装回复信息：\[\{\}\]", out);

return out;

3、参考文档

4、代码实现

微信公众号回调java_处理微信公众号消息回调

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关微信公众号开发——模板消息

相关微信公众号回调java_处理微信公众号消息回调

相关微信公众号回调接口HttpServletRequest 操作

相关微信公众号-消息推送

相关【微信公众号】微信公众号开发——Werobot入门指南

相关微信公众号调起扫码功能

相关微信公众号

相关微信公众号开发——微信获取、操作公众号文章

相关微信公众号发送模板消息

相关微信公众号模板消息发送