肝了一晚上搞出来一个微信订阅号鉴黄机器人

「爱情、让人受尽委屈。」 2021-09-03 06:34 258阅读 0赞

点击上方 [Java后端][Java]，选择 设为星标

优质文章，及时送达

--------------------

顾名思义，我们就是来做一个订阅号机器人，大致是这样一个过程

公众号接收用户消息 -> 微信平台发送消息给我们的服务器 -> 我们的服务器处理消息 -> 返回处理结果给微信平台 -> 微信平台发送内容给用户。

基于这样一个大前提就有了下面的步骤。

1、填写服务器配置，可以接收微信平台发送的内容  
2、开发服务端，并验证服务器地址的有效性  
3、处理具体的业务逻辑

## 1. 配置微信公众号 ##

首先肯定需要有一个订阅号，然后在订阅号后台点击 开发者->基本配置进入如下页面，点击确定

![format_png][]

然后进入配置页面，我们一一对配置进行讲解

![format_png 1][]

1.  开发者ID，开发者调用的唯一标示，调用接口的时候需要传递。
2.  开发者密码，这个很重要一定要保存在自己的服务器上面，用于验证安全性。
3.  服务地址，这个就是我们用来接收微信平台转发的用户消息的服务的地址
4.  令牌，用户接收信息时候做验证是否请求来自微信平台
5.  用于加密消息，防止被截获，如果 6 设置为明文模式不需要这个配置。
6.  是否加密传输消息

我们本期只做接收图片消息，验证完成以后回复消息，所以只需要配置 3、4。

![format_png 2][]

1.  是我们具体的服务器地址，path是 weixin/receive 这个下文中具体代码部分会详细讲解
2.  Token 随便生成一个 UUID 就可以
3.  随机生成，后面如果调用 API 会用到。

这时候你点击提交会提示验证失败，是因为你还没有部署 API，配置到这里我们就开始编写代码。

![format_png 3][]

## 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。

@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();
    }

编写到这里就可以找一个服务器部署起来，点击验证喽，这时候点击提交直接成功了，点击启用以后就生效了，生效以后你原来配置的自动回复就会生效，所以这个操作请谨慎。

![format_png 4][]

## 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 给发送消息的用户。效果图如下：

![format_png 5][]

那么接下来就到了最关键的一步，如何鉴黄，这个具体的逻辑可以参考这一篇文章[《怒爬某 Hub 资源就为撸了一个鉴黄平台》][Hub]，现在我们直接把相关代码怼上。

按照上面的文章修改代码后结果如下，具体的 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;
    }

最终效果如下

![format_png 6][]

所以你会搭建自己的鉴黄机器人了吗？点击原文获取项目源码。

源码：https://github.com/codedrinker/irobot

Java后端交流群已成立
    公众号运营至今，离不开小伙伴们的支持。为了给小伙伴们提供一个互相交流的平台，特地开通了官方交流群。扫描下方二维码备注 进群 或者关注公众号 Java后端 后获取进群通道。

推荐阅读 1. GET 和 POST 两种基本请求方法的区别2. 牛逼！IntelliJ IDEA 从入门到上瘾！3. REST API URI 设计的七准则4. Java 项目实战天天酷跑5. 基于 Spring Boot 的 QQ 登陆实战

[Java]: http://mp.weixin.qq.com/s?__biz=Mzg2MjEwMjI1Mg%3D%3D&chksm=ce0da17bf97a286df119047a25b7de51621fe542816673bb4aa3ebd8ab97b09a86ed7db2e2ee&idx=3&mid=2247489272&scene=21&sn=ce74938072fc73a808d83ccb474db46d#wechat_redirect
[format_png]: /images/20210730/b4a5f99aea6141a1a9c43c367c900d10.png
[format_png 1]: /images/20210730/51dd2e2a1bb2477281408e66a73175b7.png
[format_png 2]: /images/20210730/bd8605929b924701ae5667e8b7bfe2b2.png
[format_png 3]: /images/20210730/bbce414a15ad426faf68e768606394b3.png
[format_png 4]: /images/20210730/dd6a36610bfe46b3a6ce4aa90ba29fa6.png
[format_png 5]: /images/20210730/ee33b452245d44caac1540d558b2062f.png
[Hub]: https://mp.weixin.qq.com/s?__biz=MzIyNzc1ODQ0MQ%3D%3D&idx=1&mid=2247487821&scene=21&sn=800e389506d6eff415cd6bbfb61377d0#wechat_redirect
[format_png 6]: /images/20210730/0a46977088ba40eb94920fed58968412.png