一晚上,搞出来一个微信订阅号鉴黄机器人
顾名思义,我们就是来做一个订阅号机器人,大致是这样一个过程
公众号接收用户消息 -> 微信平台发送消息给我们的服务器 -> 我们的服务器处理消息 -> 返回处理结果给微信平台 -> 微信平台发送内容给用户。
基于这样一个大前提就有了下面的步骤。
1、填写服务器配置,可以接收微信平台发送的内容
2、开发服务端,并验证服务器地址的有效性
3、处理具体的业务逻辑
1. 配置微信公众号
首先肯定需要有一个订阅号,然后在订阅号后台点击 开发者->基本配置进入如下页面,点击确定
然后进入配置页面,我们一一对配置进行讲解
开发者ID,开发者调用的唯一标示,调用接口的时候需要传递。
开发者密码,这个很重要一定要保存在自己的服务器上面,用于验证安全性。
服务地址,这个就是我们用来接收微信平台转发的用户消息的服务的地址
令牌,用户接收信息时候做验证是否请求来自微信平台
用于加密消息,防止被截获,如果 6 设置为明文模式不需要这个配置。
是否加密传输消息
我们本期只做接收图片消息,验证完成以后回复消息,所以只需要配置 3、4。
是我们具体的服务器地址,path是 weixin/receive 这个下文中具体代码部分会详细讲解
Token 随便生成一个 UUID 就可以
随机生成,后面如果调用 API 会用到。
这时候你点击提交会提示验证失败,是因为你还没有部署 API,配置到这里我们就开始编写代码。
2. 编写服务端
服务器端使用现有的轮子非常简单,因为是 spring-boot 项目,直接引入一个现成的微信 starter,一定要添加 repository ,这个是依托 Github 自带的仓库。
<repositories>
<repository>
<id>developer-weapons-repository</id>
<url>https://raw.githubusercontent.com/developer-weapons/repository/master</url>
</repository>
</repositories>
<dependency>
<groupId>com.github.developer.weapons</groupId>
<artifactId>wechat-spring-boot-starter</artifactId>
<version>1.2.6</version>
</dependency>
然写两个接口,一个 GET 用于第一次绑定微信后台验证用,一个 POST 用于以后接收消息 /weixin/receive
把之前准备好的 token 配置到 application.properties 然后注入到 Controller 里面,大致的验证代码如下,如果验证签名成功就返回 echostr,算是通信的标示,如果验证失败返回 error。
@Autowiredprivate 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 {
Map<String, String> map = 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 给发送消息的用户。效果图如下
那么接下来就到了最关键的一步,如何鉴黄,现在我们直接把相关代码怼上。
按照上面的文章修改代码后结果如下,具体的 publicKey 和 privateKey 自己参考下哦。
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;}
最终效果如下
所以你会搭建自己的鉴黄机器人了吗?点击原文获取项目源码。