java如何对接企业微信

#java如何对接企业微信| 来源: 网络整理| 查看: 265

前言

最近实现社群对接企业微信，对接的过程遇到一些点，在此记录。

企业微信介绍

企业微信具有和微信一样的体验，用于企业内部成员和外部客户的管理，可以由此构建出社群生态。企业微信提供了丰富的api进行调用获取数据管理，也提供了各种回调事件，当数据发生变化时，可以及时知道。我们分为两部分进行讲解，第一部分调用企业微信api，第二部分，接收企业微信的回调。

调用企业微信api

api的开发文档地址：work.weixin.qq.com/api/doc/900… 调用企业微信所必须的东西就是企业的accesstoken。获取accesstoken则需要我们的corpid和corpsercret。具体我们可以参照这里work.weixin.qq.com/api/doc/900… 有了token之后，我们就可以通过http请求来调用各种api，获取数据。举一个例子，创建成员的api，如下，我们只要使用http工具调用即可。

这里分享一个http调用工具。

@Slf4j public class HttpUtils { static CloseableHttpClient httpClient; private HttpUtils() { throw new IllegalStateException("Utility class"); } static { Registry registry = RegistryBuilder.create() .register("http", PlainConnectionSocketFactory.getSocketFactory()) .register("https", SSLConnectionSocketFactory.getSocketFactory()) .build(); PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(registry); connectionManager.setMaxTotal(200); connectionManager.setDefaultMaxPerRoute(200); connectionManager.setDefaultSocketConfig( SocketConfig.custom().setSoTimeout(15, TimeUnit.SECONDS) .setTcpNoDelay(true).build() ); connectionManager.setValidateAfterInactivity(TimeValue.ofSeconds(15)); httpClient = HttpClients.custom() .setConnectionManager(connectionManager) .disableAutomaticRetries() .build(); } public static String get(String url, Map paramMap, Map headerMap) { String param = paramMap.entrySet().stream().map(n -> n.getKey() + "=" + n.getValue()).collect(Collectors.joining("&")); String fullUrl = url + "?" + param; final HttpGet httpGet = new HttpGet(fullUrl); if (Objects.nonNull(headerMap) && headerMap.size() > 0) { headerMap.forEach((key, value) -> httpGet.addHeader(key, value)); } CloseableHttpResponse response = null; try { response = httpClient.execute(httpGet); String strResult = EntityUtils.toString(response.getEntity()); if (200 != response.getCode()) { log.error("HTTP get 返回状态非200[resp={}]", strResult); } return strResult; } catch (IOException | ParseException e) { log.error("HTTP get 异常", e); return ""; } finally { if (null != response) { try { EntityUtils.consume(response.getEntity()); } catch (IOException e) { e.printStackTrace(); } } } } public static String post(String url,Map paramMap, Map headerMap, String data) { CloseableHttpResponse response = null; try { String param = paramMap.entrySet().stream().map(n -> n.getKey() + "=" + n.getValue()).collect(Collectors.joining("&")); String fullUrl = url + "?" + param; final HttpPost httpPost = new HttpPost(fullUrl); if (Objects.nonNull(headerMap) && headerMap.size() > 0) { headerMap.forEach((key, value) -> httpPost.addHeader(key, value)); } StringEntity httpEntity = new StringEntity(data, StandardCharsets.UTF_8); httpPost.setEntity(httpEntity); response = httpClient.execute(httpPost); if (200 == response.getCode()) { String strResult = EntityUtils.toString(response.getEntity()); return strResult; } } catch (IOException | ParseException e) { e.printStackTrace(); return ""; } finally { if (null != response) { try { EntityUtils.consume(response.getEntity()); } catch (IOException e) { e.printStackTrace(); } } } return ""; } } 复制代码对接企业微信的回调

回调分为很多种，比如通讯录的回调如下： work.weixin.qq.com/api/doc/900…

整体的回调流程如下：配置回调服务，需要有三个配置项，分别是：URL, Token, EncodingAESKey。首先，URL为回调服务地址，由开发者搭建，用于接收通知消息或者事件。

其次，Token用于计算签名，由英文或数字组成且长度不超过32位的自定义字符串。开发者提供的URL是公开可访问的，这就意味着拿到这个URL，就可以往该链接推送消息。那么URL服务需要解决两个问题：

如何分辨出是否为企业微信来源如何分辨出推送消息的内容是否被篡改通过数字签名就可以解决上述的问题。具体为：约定Token作为密钥，仅开发者和企业微信知道，在传输中不可见，用于参与签名计算。企业微信在推送消息时，将消息内容与Token计算出签名。开发者接收到推送消息时，也按相同算法计算出签名。如果为同一签名，则可信任来源为企业微信，并且内容是完整的。

如果非企业微信来源，由于攻击者没有正确的Token，无法算出正确的签名；如果消息内容被篡改，由于开发者会将接收的消息内容与Token重算一次签名，该值与参数的签名不一致，则会拒绝该请求。

最后，EncodingAESKey用于消息内容加密，由英文或数字组成且长度为43位的自定义字符串。由于消息是在公开的因特网上传输，消息内容是可被截获的，如果内容未加密，则截获者可以直接阅读消息内容。若消息内容包含一些敏感信息，就非常危险了。EncodingAESKey就是在这个背景基础上提出，将发送的内容进行加密，并组装成一定格式后再发送。

对接回调，我们就要实现上述的加密，篡改等代码。这里分享java版本的实现。 AesException

public class AesException extends Exception { public final static int OK = 0; public final static int ValidateSignatureError = -40001; public final static int ParseXmlError = -40002; public final static int ComputeSignatureError = -40003; public final static int IllegalAesKey = -40004; public final static int ValidateCorpidError = -40005; public final static int EncryptAESError = -40006; public final static int DecryptAESError = -40007; public final static int IllegalBuffer = -40008; private int code; private static String getMessage(int code) { switch (code) { case ValidateSignatureError: return "签名验证错误"; case ParseXmlError: return "xml解析失败"; case ComputeSignatureError: return "sha加密生成签名失败"; case IllegalAesKey: return "SymmetricKey非法"; case ValidateCorpidError: return "corpid校验失败"; case EncryptAESError: return "aes加密失败"; case DecryptAESError: return "aes解密失败"; case IllegalBuffer: return "解密后得到的buffer非法"; default: return null; } } public int getCode() { return code; } AesException(int code) { super(getMessage(code)); this.code = code; } } 复制代码

MessageUtil

public class MessageUtil { /** * 解析微信发来的请求（XML）. * * @param msg 消息 * @return map */ public static Map parseXml(final String msg) { // 将解析结果存储在HashMap中 Map map = new HashMap(); // 从request中取得输入流 try (InputStream inputStream = new ByteArrayInputStream(msg.getBytes(StandardCharsets.UTF_8.name()))) { // 读取输入流 SAXReader reader = new SAXReader(); Document document = reader.read(inputStream); // 得到xml根元素 Element root = document.getRootElement(); // 得到根元素的所有子节点 List elementList = root.elements(); // 遍历所有子节点 for (Element e : elementList) { map.put(e.getName(), e.getText()); } } catch (Exception e) { e.printStackTrace(); } return map; } } 复制代码 public enum QywechatEnum { TEST("测试", "123123123123", "123123123123", "12312312312"); /** * 应用名 */ private String name; /** * 企业ID */ private String corpid; /** * 回调url配置的token */ private String token; /** * 随机加密串 */ private String encodingAESKey; QywechatEnum(final String name, final String corpid, final String token, final String encodingAESKey) { this.name = name; this.corpid = corpid; this.encodingAESKey = encodingAESKey; this.token = token; } public String getCorpid() { return corpid; } public String getName() { return name; } public String getToken() { return token; } public String getEncodingAESKey() { return encodingAESKey; } } 复制代码 public class QywechatInfo { /** * 签名 */ private String msgSignature; /** * 随机时间戳 */ private String timestamp; /** * 随机值 */ private String nonce; /** * 加密的xml字符串 */ private String sPostData; /** * 企业微信回调配置 */ private QywechatEnum qywechatEnum; } 复制代码 public class SHA1Utils { /** * 用SHA1算法生成安全签名 * * @param token 票据 * @param timestamp 时间戳 * @param nonce 随机字符串 * @param encrypt 密文 * @return 安全签名 * @throws AesException */ public static String getSHA1(String token, String timestamp, String nonce, String encrypt) throws AesException { try { String[] array = new String[]{token, timestamp, nonce, encrypt}; StringBuffer sb = new StringBuffer(); // 字符串排序 Arrays.sort(array); for (int i = 0; i < 4; i++) { sb.append(array[i]); } String str = sb.toString(); // SHA1签名生成 MessageDigest md = MessageDigest.getInstance("SHA-1"); md.update(str.getBytes()); byte[] digest = md.digest(); StringBuffer hexstr = new StringBuffer(); String shaHex = ""; for (int i = 0; i < digest.length; i++) { shaHex = Integer.toHexString(digest[i] & 0xFF); if (shaHex.length() < 2) { hexstr.append(0); } hexstr.append(shaHex); } return hexstr.toString(); } catch (Exception e) { e.printStackTrace(); throw new AesException(AesException.ComputeSignatureError); } } } 复制代码 public class WXBizMsgCrypt { static Charset CHARSET = Charset.forName("utf-8"); Base64 base64 = new Base64(); byte[] aesKey; String token; String receiveid; /** * 构造函数 * * @throws AesException 执行失败，请查看该异常的错误码和具体的错误信息 */ public WXBizMsgCrypt(final QywechatEnum qywechatEnum) throws AesException { this.token = qywechatEnum.getToken(); this.receiveid = qywechatEnum.getCorpid(); String encodingAesKey = qywechatEnum.getEncodingAESKey(); if (encodingAesKey.length() != 43) { throw new AesException(AesException.IllegalAesKey); } aesKey = Base64.decodeBase64(encodingAesKey + "="); } // 生成4个字节的网络字节序 byte[] getNetworkBytesOrder(int sourceNumber) { byte[] orderBytes = new byte[4]; orderBytes[3] = (byte) (sourceNumber & 0xFF); orderBytes[2] = (byte) (sourceNumber >> 8 & 0xFF); orderBytes[1] = (byte) (sourceNumber >> 16 & 0xFF); orderBytes[0] = (byte) (sourceNumber >> 24 & 0xFF); return orderBytes; } // 还原4个字节的网络字节序 int recoverNetworkBytesOrder(byte[] orderBytes) { int sourceNumber = 0; for (int i = 0; i < 4; i++) { sourceNumber public class CallbackController { @Resource private CallbackProducer callbackProducer; /** * get请求用于验签 */ @GetMapping(value = "/callback") public void receiveMsg(@RequestParam(name = "msg_signature") final String msgSignature, @RequestParam(name = "timestamp") final String timestamp, @RequestParam(name = "nonce") final String nonce, @RequestParam(name = "echostr") final String echostr, final HttpServletResponse response) throws Exception { QywechatEnum qywechatEnum = QywechatEnum.JXPP; log.info("get验签请求参数 msg_signature {}, timestamp {}, nonce {} , echostr {}", msgSignature, timestamp, nonce, echostr); WXBizMsgCrypt wxBizMsgCrypt = new WXBizMsgCrypt(qywechatEnum); String sEchoStr = wxBizMsgCrypt.verifyURL(msgSignature, timestamp, nonce, echostr); PrintWriter out = response.getWriter(); try { //必须要返回解密之后的明文 if (StringUtils.isBlank(sEchoStr)) { log.info("get验签URL验证失败"); } else { log.info("get验签验证成功!"); } } catch (Exception e) { log.error("get验签报错！", e); } log.info("get验签的echo是{}", sEchoStr); out.write(sEchoStr); out.flush(); } /** * 企业微信客户联系回调 */ @ResponseBody @PostMapping(value = "/callback") public String acceptMessage(final HttpServletRequest request, @RequestParam(name = "msg_signature") final String sMsgSignature, @RequestParam(name = "timestamp") final String sTimestamp, @RequestParam(name = "nonce") final String sNonce) { QywechatEnum qywechatEnum = QywechatEnum.TEST; try { InputStream inputStream = request.getInputStream(); String sPostData = IOUtils.toString(inputStream, "UTF-8"); QywechatInfo qywechatInfo = new QywechatInfo(); qywechatInfo.setMsgSignature(sMsgSignature); qywechatInfo.setNonce(sNonce); qywechatInfo.setQywechatEnum(qywechatEnum); qywechatInfo.setTimestamp(sTimestamp); qywechatInfo.setSPostData(sPostData); WXBizMsgCrypt msgCrypt = new WXBizMsgCrypt(qywechatInfo.getQywechatEnum()); String sMsg = msgCrypt.decryptMsg(qywechatInfo); Map dataMap = MessageUtil.parseXml(sMsg); log.info("回调的xml数据转为map的数据{}", JsonHelper.toJSONString(dataMap)); } catch (Exception e) { log.info("回调报错", e); } return "success"; } } 复制代码

如上代码拷贝好后，我们便可以在企业微信的回调事件配置界面，增加回调的连接地址。

实现方案过程中遇到的点

1、回调配置的地址只支持一个，所以要把回调服务抽取出来，申请公网域名。要注意将接收到的回调消息放到消息队列，供其他所有服务接收处理。 2、处理回调要注意逆序问题，假如更新操作先来了，新增操作还没有开始。 3、可以采用消息补偿，定时任务刷新机制，手动同步机制，保证数据的一致性。 4、要实现重试机制，因为可能触发微信的并发调用限制。

【本文地址】

公司简介

联系我们