企微配置回调服务-阿里云开发者社区

企微配置回调服务

2023-10-26 98

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 企微配置回调服务

一、简介

1、概述

什么时候需要回调服务

在集成企业微信与内部系统时，我们往往需要搭建一个回调服务。回调服务，可以实现：

自定义丰富的服务行为。比如，用户向应用发消息时，识别消息关键词，回复不同的消息内容；用户点击应用菜单时，转化为指令，执行自动化任务。
可以及时获取到状态变化。比如，通讯录发生变化时，不需要定时去拉取通讯录对比，而是实时地获取到变化的通讯录结点，进行同步。

回调流程：

企业微信会先判断URL服务是否具备解析企业微信推送消息的能力。
具体方式是，企业微信往URL服务上发一条Get请求带签名及密文参数到URL服务上，如果URL服务检查签名通过，并能正确返回密文参数对应的明文字符串，则验证通过。此时在企业微信的配置就开始生效。
后续的业务请求（比如应用菜单的点击事件，用户消息等），都会类似的方式（签名+密文）向服务URL推送消息。URL服务验证签名通过后，需要将POST数据解密，就可以得到对应的业务消息明文。

企业收到消息后，需要作如下处理：

对msg_signature进行校验
解密Encrypt，得到明文的消息结构体（消息结构体后面章节会详说）
如果需要被动回复消息，构造被动响应包
正确响应本次请求
· 企业微信服务器在五秒内收不到响应会断掉连接，并且重新发起请求，总共重试三次
· 当接收成功后，http头部返回200表示接收ok，其他错误码企业微信后台会一律当做失败并发起重试

2、相关文档地址

1、回调配置

https://developer.work.weixin.qq.com/document/path/90930

2、接收消息与事件

https://developer.work.weixin.qq.com/document/10514

3、加解密方案说明

https://developer.work.weixin.qq.com/document/path/90968

4、加解密库下载与返回码

https://developer.work.weixin.qq.com/document/path/90307

二、企微配置消息服务器

1、配置消息接收参数

URL：http://8.131.239.157
Token：UPN8pOCL
EncodingAESKey：Wz0cWqM7VcqPOLpNrMCaaxMMif3USVLOjhvK19tEQaX

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-OZwjp3T2-1692458157388)(/Users/liyangda/Library/Application Support/typora-user-images/image-20230819222344569.png)]

2、参数解析

整体会用到8个参数。

参数	必须	说明
url		URL是企业后台接收企业微信推送请求的访问协议和地址，支持http或https协议。
token		Token可由企业任意填写，用于生成签名。
encodingAesKey		EncodingAESKey用于消息体的加密，是AES密钥的Base64编码。
receiveid		加解密库里，ReceiveId 在各个场景的含义不同： 1. 企业应用的回调，表示corpid。 2. 第三方事件的回调，表示suiteid。 3. 个人主体的第三方应用的回调，ReceiveId是一个空字符串
msg_signature	是	企业微信加密签名，msg_signature结合了企业填写的token、请求中的timestamp、nonce参数、加密的消息体
timestamp	是	时间戳
nonce	是	随机数
echostr	是	加密的字符串。需要解密得到消息内容明文，。

3、参数拼接规则

请求方式：GET

请求地址：

http://api.3dept.com/?msg_signature=ASDFQWEXZCVAQFASDFASDFSS&timestamp=13500001234&nonce=123412323&echostr=ENCRYPT_STR

http://8.131.239.157?msg_signature=ed7c74fcb19645d3c8312e703063539fe96a532c&timestamp=1692450209&nonce=1693051991&echostr=9fGql+XxePufd9E71gh4kXooAJJ+PtxH3MwwZWzxFNdZwTT3qccs6zHxFEDtGuaxJHWktTV97BiKkJI+rOhcPw==

三、代码编写—使用已有库

这次采用的是企微提供的已由库方式，进行验证。

1、代码下载

源代码地址：https://developer.work.weixin.qq.com/document/path/90307

2、代码修改

因为参数执行有一些问题，需要对提供的工具类进行修改。

修改内容

// 密钥，公众账号的app secret
    // 提取密文
//    Object[] encrypt = JsonParse.extract(postData);
    Object[] encrypt = new Object[]{postData,postData};

3、服务代码编写

<dependency>
    <groupId>commons-codec</groupId>
    <artifactId>commons-codec</artifactId>
    <version>1.9</version>
</dependency>
<dependency>
    <groupId>org.json</groupId>
    <artifactId>json</artifactId>
    <version>20180813</version>
</dependency>

代码编写

import com.lydms.demowechat0.WechatUtils.AesException;
import com.lydms.demowechat0.WechatUtils.WXBizJsonMsgCrypt;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
public class AllTwoController {
    @RequestMapping("/*")
    public String getCheckInfo(String msg_signature, String timestamp, String nonce, String echostr) throws AesException {
        String token = "UPN8pOCL";
        String encodingAesKey = "Wz0cWqM7VcqPOLpNrMCaaxMMif3USVLOjhvK19tEQaX";
        String receiveid = "ww3e40cde07cc21a01";
        log.info("msg_signature:{},timestamp:{},nonce:{},echostr:{}", msg_signature, timestamp, nonce, echostr);
        log.info("token:{},encodingAesKey:{},receiveid:{}", token, timestamp, receiveid);
        WXBizJsonMsgCrypt wxBizJsonMsgCrypt = new WXBizJsonMsgCrypt(token, encodingAesKey, receiveid);
        String str = wxBizJsonMsgCrypt.DecryptMsg(msg_signature, timestamp, nonce, echostr);
        log.info("return:{}", str);
        return str;
    }
}

测试代码：

/**
 * 测试代码
 *
 * @param args
 * @throws AesException
 */
public static void main(String[] args) throws AesException {
    //  Token
    String token = "UPN8pOCL";
    //
    String encodingAesKey = "Wz0cWqM7VcqPOLpNrMCaaxMMif3USVLOjhvK19tEQaX";
    //
    String receiveid = "ww3e40cde07cc21a01";
    //  企业微信加密签名
    String msgSignature = "359410caca920fe74a426f5a3057ad437b3b9fa4";
    //  时间戳
    String timeStamp = "1692448043";
    //  随机数
    String nonce = "1692495025";
    //  加密的字符串
    String echostr = "BrO11qZxqM8TBczJq17VRzSnhJff5aGXgnTvWl+yGaoAZ+dd5xg1VxbmmPzMJMmkNPv6DSlpMQ6vz4lwoCXMjg==";
    WXBizJsonMsgCrypt wxBizJsonMsgCrypt = new WXBizJsonMsgCrypt(token, encodingAesKey, receiveid);
    //  解析后的值：7695278663958312959
    String s = wxBizJsonMsgCrypt.DecryptMsg(msgSignature, timeStamp, nonce, echostr);
    System.out.println(s);
}