通過(guò)UCloud AI內容審核UAI-Censor免費搭建微信訂閱號

顧名思義，我們就是來(lái)做一個(gè)訂閱號機器人，大致是這樣一個(gè)過(guò)程：公眾號接收用戶(hù)消息 -> 微信平臺發(fā)送消息給我們的服務(wù)器 -> 我們的服務(wù)器處理消息 -> 返回處理結果給微信平臺 -> 微信平臺發(fā)送內容給用戶(hù)。

基于這樣一個(gè)大前提就有了下面的步驟：

1、填寫(xiě)服務(wù)器配置，可以接收微信平臺發(fā)送的內容
2、開(kāi)發(fā)服務(wù)端，并驗證服務(wù)器地址的有效性
3、處理具體的業(yè)務(wù)邏輯

1. 配置微信公眾號

首先肯定需要有一個(gè)訂閱號，然后在訂閱號后臺點(diǎn)擊 開(kāi)發(fā)者->基本配置進(jìn)入如下頁(yè)面，點(diǎn)擊確定

然后進(jìn)入配置頁(yè)面，我們一一對配置進(jìn)行講解

1. 開(kāi)發(fā)者ID，開(kāi)發(fā)者調用的唯一標示，調用接口的時(shí)候需要傳遞。
2. 開(kāi)發(fā)者密碼，這個(gè)很重要一定要保存在自己的服務(wù)器上面，用于驗證安全性。
3. 服務(wù)地址，這個(gè)就是我們用來(lái)接收微信平臺轉發(fā)的用戶(hù)消息的服務(wù)的地址
4. 令牌，用戶(hù)接收信息時(shí)候做驗證是否請求來(lái)自微信平臺
5. 用于加密消息，防止被截獲，如果 6 設置為明文模式不需要這個(gè)配置。
6. 是否加密傳輸消息

我們本期只做接收圖片消息，驗證完成以后回復消息，所以只需要配置 3、4。

1. 是我們具體的服務(wù)器地址，path是 weixin/receive 這個(gè)下文中具體代碼部分會(huì )詳細講解
2. Token 隨便生成一個(gè) UUID 就可以
3. 隨機生成，后面如果調用 API 會(huì )用到。

這時(shí)候你點(diǎn)擊提交會(huì )提示驗證失敗，是因為你還沒(méi)有部署 API，配置到這里我們就開(kāi)始編寫(xiě)代碼。

2. 編寫(xiě)服務(wù)端

服務(wù)器端使用現有的輪子非常簡(jiǎn)單，因為是 spring-boot 項目，直接引入一個(gè)現成的微信 starter，一定要添加 repository ，這個(gè)是依托 Github 自帶的倉庫。

 
  
   
    developer-weapons-repository
   
   
    https://raw.githubusercontent.com/developer-weapons/repository/master
   
  
 
 
  
   com.github.developer.weapons
  
  
   wechat-spring-boot-starter
  
  
   1.2.6
  
 

然寫(xiě)兩個(gè)接口，一個(gè) GET 用于第一次綁定微信后臺驗證用，一個(gè) 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();
}

編寫(xiě)到這里就可以找一個(gè)服務(wù)器部署起來(lái)，點(diǎn)擊驗證嘍，這時(shí)候點(diǎn)擊提交直接成功了，點(diǎn)擊啟用以后就生效了，生效以后你原來(lái)配置的自動(dòng)回復就會(huì )生效，所以這個(gè)操作請謹慎。

3. 處理業(yè)務(wù)邏輯

處理業(yè)務(wù)邏輯首先是接收消息，下面是接收消息的代碼。

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

第一步還是驗證消息是否來(lái)自微信平臺，然后使用 wechatOfficialService.toMap 方法解析出接收消息的內容，當前判斷比較簡(jiǎn)單，直接判斷是否是圖片消息，然后返回圖片的 URL 給發(fā)送消息的用戶(hù)。效果圖如下

那么接下來(lái)就到了最關(guān)鍵的一步，如何鑒黃，這個(gè)具體的邏輯可以參考這一篇文章《通過(guò)UCloud AI內容審核UAI-Censor免費搭建鑒黃平臺教程》，現在我們直接把相關(guān)代碼懟上。

按照上面的文章修改代碼后結果如下，具體的 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("小哥，你的圖片有點(diǎn)問(wèn)題哦");
  } else {
      officialAutoReplyMessage.withContent("騷年，你這圖片剛剛的沒(méi)問(wèn)題");
  }
  writer.print(officialAutoReplyMessage.toXml());
  writer.flush();
  writer.close();
  return;
}

最終效果如下

所以你會(huì )搭建自己的鑒黃機器人了嗎？獲取項目源碼>>（測試訂閱號“Q談面試”，“Q談面試” 訂閱號鑒黃能力僅供學(xué)習使用，后期會(huì )下線(xiàn)，如需體驗請盡快。）

來(lái)源： 碼匠筆記