肝了一晚上搞出来一个微信订阅号鉴黄机器人
共 4563字,需浏览 10分钟
·
2022-02-26 17:42
阅读本文大概需要 4 分钟。
来自:网络
2、开发服务端,并验证服务器地址的有效性
3、处理具体的业务逻辑
1. 配置微信公众号
开发者ID,开发者调用的唯一标示,调用接口的时候需要传递。
开发者密码,这个很重要一定要保存在自己的服务器上面,用于验证安全性。
服务地址,这个就是我们用来接收微信平台转发的用户消息的服务的地址
令牌,用户接收信息时候做验证是否请求来自微信平台
用于加密消息,防止被截获,如果 6 设置为明文模式不需要这个配置。
是否加密传输消息
是我们具体的服务器地址,path是 weixin/receive 这个下文中具体代码部分会详细讲解
Token 随便生成一个 UUID 就可以
随机生成,后面如果调用 API 会用到。
2. 编写服务端
<repositories>
<repository>
<id>developer-weapons-repositoryid>
<url>https://raw.githubusercontent.com/developer-weapons/repository/masterurl>
repository>
repositories>
<dependency>
<groupId>com.github.developer.weaponsgroupId>
<artifactId>wechat-spring-boot-starterartifactId>
<version>1.2.6version>
dependency>
@Autowired
private WechatOfficialService wechatOfficialService;
@Value("${weixin.token}")
private String token;
@RequestMapping(value = "/weixin/receive", method = RequestMethod.GET)
public void receive(
@RequestParam(value = "signature") String signature,
@RequestParam(value = "timestamp") String timestamp,
@RequestParam(value = "nonce") String nonce,
@RequestParam(value = "echostr") String echostr,
HttpServletResponse response) throws IOException {
boolean valid = wechatOfficialService.isValid(signature, timestamp, nonce, token);
PrintWriter writer = response.getWriter();
if (valid) {
writer.print(echostr);
} else {
writer.print("error");
}
writer.flush();
writer.close();
}
3. 处理业务逻辑
@RequestMapping(value = "/weixin/receive", method = RequestMethod.POST)
public void receive(
@RequestParam(value = "signature") String signature,
@RequestParam(value = "timestamp") String timestamp,
@RequestParam(value = "nonce") String nonce,
HttpServletRequest request,
HttpServletResponse response) throws IOException {
request.setCharacterEncoding("UTF-8");
response.setCharacterEncoding("UTF-8");
boolean valid = wechatOfficialService.isValid(signature, timestamp, nonce, token);
PrintWriter writer = response.getWriter();
if (!valid) {
writer.print("error");
writer.flush();
writer.close();
return;
}
try {
Mapmap = wechatOfficialService.toMap(request.getInputStream());
if (map.get("MsgType").equals("image")) {
String msg = OfficialAutoReplyMessage.build()
.withContent("接收到图片链接为:" + map.get("PicUrl"))
.withMsgtype(MessageTypeEnum.TEXT)
.withFromUserName(map.get("ToUserName"))
.withToUserName(map.get("FromUserName"))
.toXml();
writer.print(msg);
writer.flush();
writer.close();
return;
}
} catch (Exception e) {
log.error("WeixinController receive error", e);
}
writer.print("success");
writer.flush();
writer.close();
}
wechatOfficialService.toMap
方法解析出接收消息的内容,当前判断比较简单,直接判断是否是图片消息,然后返回图片的 URL 给发送消息的用户。效果图如下if (map.get("MsgType").equals("image")) {
String res = checkService.check(publicKey, privateKey, map.get("PicUrl"));
OfficialAutoReplyMessage officialAutoReplyMessage =
OfficialAutoReplyMessage.build()
.withMsgtype(MessageTypeEnum.TEXT)
.withFromUserName(map.get("ToUserName"))
.withToUserName(map.get("FromUserName"));
if (StringUtils.equals("forbid", res)) {
officialAutoReplyMessage.withContent("小哥,你的图片有点问题哦");
} else {
officialAutoReplyMessage.withContent("骚年,你这图片刚刚的没问题");
}
writer.print(officialAutoReplyMessage.toXml());
writer.flush();
writer.close();
return;
}
推荐阅读:
内容包含Java基础、JavaWeb、MySQL性能优化、JVM、锁、百万并发、消息队列、高性能缓存、反射、Spring全家桶原理、微服务、Zookeeper、数据结构、限流熔断降级......等技术栈!
⬇戳阅读原文领取! 朕已阅