当前位置:   article > 正文

微信小程序之获取并解密用户数据(获取openId、unionId)

/wxa/business/getuserencryptkey encryptkey解密数据

【版权声明:本文为博主原创文章,若需转载,请注明出处。】

前言

  • 微信小程序API文档:https://mp.weixin.qq.com/debug/wxadoc/dev/api/api-login.html
  • 在实际的小程序开发中,往往需要用户授权登陆并获取用户的数据,快速对接用户系统。
  • openId : 用户在当前小程序的唯一标识 
  • unionId : 如果开发者拥有多个移动应用、网站应用、和公众帐号(包括小程序),可通过unionid来区分用户的唯一性,因为只要是同一个微信开放平台帐号下的移动应用、网站应用和公众帐号(包括小程序),用户的unionid是唯一的。换句话说,同一用户,对同一个微信开放平台下的不同应用,unionId是相同的。详情登录微信开放平台(open.weixin.qq.com) 。
  • 在微信小程序开发中,unionId等敏感数据则被加密在encryptedData,于是需要以下流程来解密敏感数据,从而获取unionId等信息。

 

流程

1、(客户端)微信小程序客户端调用 wx.login()接口获取登录凭证(code)

  1. //1、调用微信登录接口,获取code
  2. wx.login({
  3. success: function (r) {
  4. var code = r.code;//登录凭证
  5. if (code) {
  6. //2、调用获取用户信息接口
  7. //...
  8. } else {
  9. console.log('获取用户登录态失败!' + r.errMsg)
  10. }
  11. },
  12. fail: function () {
  13. callback(false)
  14. }
  15. })

2、(客户端)微信小程序客户端调用 wx.getUserInfo()接口获取 用户基本信息、encryptedData(用户敏感信息加密数据) 和 iv(加密算法的初始向量 )

  1. //1、调用微信登录接口,获取code
  2. wx.login({
  3. success: function (r) {
  4. var code = r.code;//登录凭证
  5. if (code) {
  6. //2、调用获取用户信息接口
  7. wx.getUserInfo({
  8. success: function (res) {
  9. console.log({encryptedData: res.encryptedData, iv: res.iv, code: code})
  10. //3.解密用户信息 获取unionId
  11. //...
  12. },
  13. fail: function () {
  14. console.log('获取用户信息失败')
  15. }
  16. })
  17. } else {
  18. console.log('获取用户登录态失败!' + r.errMsg)
  19. }
  20. },
  21. fail: function () {
  22. callback(false)
  23. }
  24. })

3、(客户端)将前面获取到的 code 、encryptedData、iv发送到自己的服务器(开发者服务器),通过自己的服务器(开发者服务器)解密获取信息

  1. //1、调用微信登录接口,获取code
  2. wx.login({
  3. success: function (r) {
  4. var code = r.code;//登录凭证
  5. if (code) {
  6. //2、调用获取用户信息接口
  7. wx.getUserInfo({
  8. success: function (res) {
  9. console.log({encryptedData: res.encryptedData, iv: res.iv, code: code})
  10. //3.请求自己的服务器,解密用户信息 获取unionId等加密信息
  11. wx.request({
  12. url: 'https://xxxx.com/wxsp/decodeUserInfo',//自己的服务接口地址
  13. method: 'post',
  14. header: {
  15. 'content-type': 'application/x-www-form-urlencoded'
  16. },
  17. data: {encryptedData: res.encryptedData, iv: res.iv, code: code},
  18. success: function (data) {
  19. //4.解密成功后 获取自己服务器返回的结果
  20. if (data.data.status == 1) {
  21. var userInfo_ = data.data.userInfo;
  22. console.log(userInfo_)
  23. } else {
  24. console.log('解密失败')
  25. }
  26. },
  27. fail: function () {
  28. console.log('系统错误')
  29. }
  30. })
  31. },
  32. fail: function () {
  33. console.log('获取用户信息失败')
  34. }
  35. })
  36. } else {
  37. console.log('获取用户登录态失败!' + r.errMsg)
  38. }
  39. },
  40. fail: function () {
  41. console.log('登陆失败')
  42. }
  43. })

4、(服务端 java)自己的服务器发送code到微信服务器获取openid(用户唯一标识)和session_key(会话密钥),最后将encryptedData、iv、session_key通过AES解密获取到用户敏感数据

    a、获取秘钥并处理解密的controller(这里用的是springMVC)

  1. /**
  2. * 解密用户敏感数据
  3. *
  4. * @param encryptedData 明文,加密数据
  5. * @param iv 加密算法的初始向量
  6. * @param code 用户允许登录后,回调内容会带上 code(有效期五分钟),开发者需要将 code 发送到开发者服务器后台,使用code 换取 session_key api,将 code 换成 openid 和 session_key
  7. * @return
  8. */
  9. @ResponseBody
  10. @RequestMapping(value = "/decodeUserInfo", method = RequestMethod.POST)
  11. public Map decodeUserInfo(String encryptedData, String iv, String code) {
  12. Map map = new HashMap();
  13. //登录凭证不能为空
  14. if (code == null || code.length() == 0) {
  15. map.put("status", 0);
  16. map.put("msg", "code 不能为空");
  17. return map;
  18. }
  19. //小程序唯一标识 (在微信小程序管理后台获取)
  20. String wxspAppid = "xxxxxxxxxxxxxx";
  21. //小程序的 app secret (在微信小程序管理后台获取)
  22. String wxspSecret = "xxxxxxxxxxxxxx";
  23. //授权(必填)
  24. String grant_type = "authorization_code";
  25. 1、向微信服务器 使用登录凭证 code 获取 session_key 和 openid
  26. //请求参数
  27. String params = "appid=" + wxspAppid + "&secret=" + wxspSecret + "&js_code=" + code + "&grant_type=" + grant_type;
  28. //发送请求
  29. String sr = HttpRequest.sendGet("https://api.weixin.qq.com/sns/jscode2session", params);
  30. //解析相应内容(转换成json对象)
  31. JSONObject json = JSONObject.fromObject(sr);
  32. //获取会话密钥(session_key)
  33. String session_key = json.get("session_key").toString();
  34. //用户的唯一标识(openid)
  35. String openid = (String) json.get("openid");
  36. 2、对encryptedData加密数据进行AES解密
  37. try {
  38. String result = AesCbcUtil.decrypt(encryptedData, session_key, iv, "UTF-8");
  39. if (null != result && result.length() > 0) {
  40. map.put("status", 1);
  41. map.put("msg", "解密成功");
  42. JSONObject userInfoJSON = JSONObject.fromObject(result);
  43. Map userInfo = new HashMap();
  44. userInfo.put("openId", userInfoJSON.get("openId"));
  45. userInfo.put("nickName", userInfoJSON.get("nickName"));
  46. userInfo.put("gender", userInfoJSON.get("gender"));
  47. userInfo.put("city", userInfoJSON.get("city"));
  48. userInfo.put("province", userInfoJSON.get("province"));
  49. userInfo.put("country", userInfoJSON.get("country"));
  50. userInfo.put("avatarUrl", userInfoJSON.get("avatarUrl"));
  51. userInfo.put("unionId", userInfoJSON.get("unionId"));
  52. map.put("userInfo", userInfo);
  53. return map;
  54. }
  55. } catch (Exception e) {
  56. e.printStackTrace();
  57. }
  58. map.put("status", 0);
  59. map.put("msg", "解密失败");
  60. return map;
  61. }

    b、AesCbcUtil.java 工具类

  1. package com.yfs.util;
  2. import org.apache.commons.codec.binary.Base64;
  3. import org.bouncycastle.jce.provider.BouncyCastleProvider;
  4. import javax.crypto.BadPaddingException;
  5. import javax.crypto.Cipher;
  6. import javax.crypto.IllegalBlockSizeException;
  7. import javax.crypto.NoSuchPaddingException;
  8. import javax.crypto.spec.IvParameterSpec;
  9. import javax.crypto.spec.SecretKeySpec;
  10. import java.io.UnsupportedEncodingException;
  11. import java.security.*;
  12. import java.security.spec.InvalidParameterSpecException;
  13. /**
  14. * Created by yfs on 2017/2/6.
  15. * <p>
  16. * AES-128-CBC 加密方式
  17. * 注:
  18. * AES-128-CBC可以自己定义“密钥”和“偏移量“。
  19. * AES-128是jdk自动生成的“密钥”。
  20. */
  21. public class AesCbcUtil {
  22. static {
  23. //BouncyCastle是一个开源的加解密解决方案,主页在http://www.bouncycastle.org/
  24. Security.addProvider(new BouncyCastleProvider());
  25. }
  26. /**
  27. * AES解密
  28. *
  29. * @param data //密文,被加密的数据
  30. * @param key //秘钥
  31. * @param iv //偏移量
  32. * @param encodingFormat //解密后的结果需要进行的编码
  33. * @return
  34. * @throws Exception
  35. */
  36. public static String decrypt(String data, String key, String iv, String encodingFormat) throws Exception {
  37. // initialize();
  38. //被加密的数据
  39. byte[] dataByte = Base64.decodeBase64(data);
  40. //加密秘钥
  41. byte[] keyByte = Base64.decodeBase64(key);
  42. //偏移量
  43. byte[] ivByte = Base64.decodeBase64(iv);
  44. try {
  45. Cipher cipher = Cipher.getInstance("AES/CBC/PKCS7Padding");
  46. SecretKeySpec spec = new SecretKeySpec(keyByte, "AES");
  47. AlgorithmParameters parameters = AlgorithmParameters.getInstance("AES");
  48. parameters.init(new IvParameterSpec(ivByte));
  49. cipher.init(Cipher.DECRYPT_MODE, spec, parameters);// 初始化
  50. byte[] resultByte = cipher.doFinal(dataByte);
  51. if (null != resultByte && resultByte.length > 0) {
  52. String result = new String(resultByte, encodingFormat);
  53. return result;
  54. }
  55. return null;
  56. } catch (NoSuchAlgorithmException e) {
  57. e.printStackTrace();
  58. } catch (NoSuchPaddingException e) {
  59. e.printStackTrace();
  60. } catch (InvalidParameterSpecException e) {
  61. e.printStackTrace();
  62. } catch (InvalidKeyException e) {
  63. e.printStackTrace();
  64. } catch (InvalidAlgorithmParameterException e) {
  65. e.printStackTrace();
  66. } catch (IllegalBlockSizeException e) {
  67. e.printStackTrace();
  68. } catch (BadPaddingException e) {
  69. e.printStackTrace();
  70. } catch (UnsupportedEncodingException e) {
  71. e.printStackTrace();
  72. }
  73. return null;
  74. }
  75. }

    c、HttpRequest.java 工具类

  1. package com.yfs.util;
  2. import java.io.BufferedReader;
  3. import java.io.IOException;
  4. import java.io.InputStreamReader;
  5. import java.io.PrintWriter;
  6. import java.net.URL;
  7. import java.net.URLConnection;
  8. import java.util.List;
  9. import java.util.Map;
  10. public class HttpRequest {
  11. public static void main(String[] args) {
  12. //发送 GET 请求
  13. String s=HttpRequest.sendGet("http://v.qq.com/x/cover/kvehb7okfxqstmc.html?vid=e01957zem6o", "");
  14. System.out.println(s);
  15. // //发送 POST 请求
  16. // String sr=HttpRequest.sendPost("http://www.toutiao.com/stream/widget/local_weather/data/?city=%E4%B8%8A%E6%B5%B7", "");
  17. // JSONObject json = JSONObject.fromObject(sr);
  18. // System.out.println(json.get("data"));
  19. }
  20. /**
  21. * 向指定URL发送GET方法的请求
  22. *
  23. * @param url
  24. * 发送请求的URL
  25. * @param param
  26. * 请求参数,请求参数应该是 name1=value1&name2=value2 的形式。
  27. * @return URL 所代表远程资源的响应结果
  28. */
  29. public static String sendGet(String url, String param) {
  30. String result = "";
  31. BufferedReader in = null;
  32. try {
  33. String urlNameString = url + "?" + param;
  34. URL realUrl = new URL(urlNameString);
  35. // 打开和URL之间的连接
  36. URLConnection connection = realUrl.openConnection();
  37. // 设置通用的请求属性
  38. connection.setRequestProperty("accept", "*/*");
  39. connection.setRequestProperty("connection", "Keep-Alive");
  40. connection.setRequestProperty("user-agent",
  41. "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  42. // 建立实际的连接
  43. connection.connect();
  44. // 获取所有响应头字段
  45. Map<String, List<String>> map = connection.getHeaderFields();
  46. // 遍历所有的响应头字段
  47. for (String key : map.keySet()) {
  48. System.out.println(key + "--->" + map.get(key));
  49. }
  50. // 定义 BufferedReader输入流来读取URL的响应
  51. in = new BufferedReader(new InputStreamReader(
  52. connection.getInputStream()));
  53. String line;
  54. while ((line = in.readLine()) != null) {
  55. result += line;
  56. }
  57. } catch (Exception e) {
  58. System.out.println("发送GET请求出现异常!" + e);
  59. e.printStackTrace();
  60. }
  61. // 使用finally块来关闭输入流
  62. finally {
  63. try {
  64. if (in != null) {
  65. in.close();
  66. }
  67. } catch (Exception e2) {
  68. e2.printStackTrace();
  69. }
  70. }
  71. return result;
  72. }
  73. /**
  74. * 向指定 URL 发送POST方法的请求
  75. *
  76. * @param url
  77. * 发送请求的 URL
  78. * @param param
  79. * 请求参数,请求参数应该是 name1=value1&name2=value2 的形式。
  80. * @return 所代表远程资源的响应结果
  81. */
  82. public static String sendPost(String url, String param) {
  83. PrintWriter out = null;
  84. BufferedReader in = null;
  85. String result = "";
  86. try {
  87. URL realUrl = new URL(url);
  88. // 打开和URL之间的连接
  89. URLConnection conn = realUrl.openConnection();
  90. // 设置通用的请求属性
  91. conn.setRequestProperty("accept", "*/*");
  92. conn.setRequestProperty("connection", "Keep-Alive");
  93. conn.setRequestProperty("user-agent",
  94. "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  95. // 发送POST请求必须设置如下两行
  96. conn.setDoOutput(true);
  97. conn.setDoInput(true);
  98. // 获取URLConnection对象对应的输出流
  99. out = new PrintWriter(conn.getOutputStream());
  100. // 发送请求参数
  101. out.print(param);
  102. // flush输出流的缓冲
  103. out.flush();
  104. // 定义BufferedReader输入流来读取URL的响应
  105. in = new BufferedReader(
  106. new InputStreamReader(conn.getInputStream()));
  107. String line;
  108. while ((line = in.readLine()) != null) {
  109. result += line;
  110. }
  111. } catch (Exception e) {
  112. System.out.println("发送 POST 请求出现异常!"+e);
  113. e.printStackTrace();
  114. }
  115. //使用finally块来关闭输出流、输入流
  116. finally{
  117. try{
  118. if(out!=null){
  119. out.close();
  120. }
  121. if(in!=null){
  122. in.close();
  123. }
  124. }
  125. catch(IOException ex){
  126. ex.printStackTrace();
  127. }
  128. }
  129. return result;
  130. }
  131. }

 

备注

  1. 代码中需要用到的jar包,请自行下载并添加到项目中。
  2. 这里需要注意的是,AES解密的时候需要用到javax.crypto.*包的类,在jdk的 jce.jar中提供,是jdk自带的库。如果是MAVEN项目,则需要在pom.xml文件中配置指定编译路径jce.jar

    在bootclasspath中添加jce.jar的地址 :<bootclasspath>${JAVA_HOME}/jre/lib/rt.jar:${JAVA_HOME}/jre/lib/jce.jar</bootclasspath> ,注意rt.jar 和 jce.jar 间以:号连接

    如:

  1. <build>
  2. <finalName>com.yfs.app</finalName>
  3. <plugins>
  4. <plugin>
  5. <groupId>org.apache.maven.plugins</groupId>
  6. <artifactId>maven-compiler-plugin</artifactId>
  7. <version>2.5.1</version>
  8. <configuration>
  9. <source>1.7</source>
  10. <target>1.7</target>
  11. <compilerArguments>
  12. <verbose />
  13. <bootclasspath>${JAVA_HOME}/jre/lib/rt.jar:${JAVA_HOME}/jre/lib/jce.jar</bootclasspath>
  14. </compilerArguments>
  15. <encoding>utf-8</encoding>
  16. </configuration>
  17. </plugin>
  18. </plugins>
  19. </build>

 

总结

    好了,总算完成数据解密了,接下来对接新的或已有的用户系统都妥妥的。

    有一点需要注意的是,要对接已有的用户系统可能需要用到unionId,如果通过以上方法获取不到unionId,那么你就要去检查一下你的微信开放平台(https://open.weixin.qq.com)是否有绑定微信小程序咯~

    

    前段时间刚做完微信小程序的项目,之间遇到的一些问题会陆续发布,欢迎大家一起来探讨。

  【版权声明:本文为博主原创文章,若需转载,请注明出处。https://my.oschina.net/u/3235888/blog/832895

转载于:https://my.oschina.net/magicalSam/blog/832895

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家自动化/article/detail/525060
推荐阅读
相关标签
  

闽ICP备14008679号