Récemment, nous avons implémenté une fonction de connexion d'autorisation d'association d'utilisateurs entre le compte officiel WeChat et les utilisateurs de notre propre site Web. L'objectif principal est que les utilisateurs suivent le compte officiel et cliquent sur le centre des membres, ainsi que sur l'autorisation de la page Web qui nécessite. l'autorisation associée apparaîtra : page Web OAuth2.0 Autoriser, puis l'utilisateur accepte d'obtenir des informations sur l'utilisateur, d'associer l'utilisateur au site Web, puis l'utilisateur peut se connecter à l'aide de WeChat.
Cette fois, nous créons une couche Action dans Java Process chaque paramètre de retour pour obtenir des données.
1. Outils utilisés :
1. ngrok, mappez votre propre machine locale au réseau public, afin que vous puissiez tester et développer à tout moment
1. Téléchargez ngrok sur : http://www.tunnel.mobi/ 2. Placez le fichier dans le répertoire Tomcat et exécutez ngrok -config ngrok.cfg -subdomain xinzhi dans cmd 8080 3. L'outil ngrok est vu sur MOOC.com @LAOBI 2. Compte de test du compte public WeChat, testez à tout moment, assurez-vous d'abord qu'il n'y a aucun problème sous le compte de test avant effectuer une transplantation publique du numéro. 2. Utilisez pour envoyer une requête Http en Java, puis renvoyez le paramètreJSON, obtenez le paramètre JSON, puis traitez-le <.> Tout d'abord, récupérez-le. Mettez le compte de test du compte public dans le fichier de propriétés afin que nous puissions l'appeler ou le remplacer. Par exemple : Veuillez utiliser https
Code des propriétés pour l'url. sera utilisé plus tard. Ensuite, deux classes d'outils sont nécessaires. La fonction de la classe d'outils est d'obtenir la valeur de retour après l'envoi d'une requête http dans l'action Java
et de permettre les modifications correspondantes. de ce projet : 
AppID = wxf00**c3dd2ebfa0 AppSecret = 3cb220755f****506dc35391aa5c03ec url = https://xinzhi.tunnel.mobi
Code Java
Pour les requêtes https, nous avons besoin d'un gestionnaire de gestion de confiance de certificat, ce La classe manager doit être définie par vous-même, mais elle doit implémenter l'interface X509TrustManager. Le code est le suivant :
Code Java
package com.zhtx.common.util;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ConnectException;
import java.net.URL;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* 公众平台通用接口工具类
*
* @author xinz
* @date 2015-10-14
*/
public class WeixinUtil {
private static Logger log = LoggerFactory.getLogger(WeixinUtil.class);
/**
* 发起https请求并获取结果
*
* @param requestUrl 请求地址
* @param requestMethod 请求方式（GET、POST）
* @param outputStr 提交的数据
* @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
*/
public static String httpRequest(String requestUrl, String requestMethod, String outputStr) {
StringBuffer buffer = new StringBuffer();
try {
// 创建SSLContext对象，并使用我们指定的信任管理器初始化
TrustManager[] tm = { new MyX509TrustManager() };
SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
sslContext.init(null, tm, new java.security.SecureRandom());
// 从上述SSLContext对象中得到SSLSocketFactory对象
SSLSocketFactory ssf = sslContext.getSocketFactory();
URL url = new URL(requestUrl);
HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();
httpUrlConn.setSSLSocketFactory(ssf);
httpUrlConn.setDoOutput(true);
httpUrlConn.setDoInput(true);
httpUrlConn.setUseCaches(false);
// 设置请求方式（GET/POST）
httpUrlConn.setRequestMethod(requestMethod);
if ("GET".equalsIgnoreCase(requestMethod))
httpUrlConn.connect();
// 当有数据需要提交时
if (null != outputStr) {
OutputStream outputStream = httpUrlConn.getOutputStream();
// 注意编码格式，防止中文乱码
outputStream.write(outputStr.getBytes("UTF-8"));
outputStream.close();
}
// 将返回的输入流转换成字符串
InputStream inputStream = httpUrlConn.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
String str = null;
while ((str = bufferedReader.readLine()) != null) {
buffer.append(str);
}
bufferedReader.close();
inputStreamReader.close();
// 释放资源
inputStream.close();
inputStream = null;
httpUrlConn.disconnect();
} catch (ConnectException ce) {
log.error("Weixin server connection timed out.");
} catch (Exception e) {
log.error("https request error:{}", e);
}
return buffer.toString();
}
}Une classe POJO de retour WeChat. paramètres :
Code Java
package com.zhtx.common.util;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import javax.net.ssl.X509TrustManager;
/**
* 证书信任管理器（用于https请求）
*
* @author xinz
* @date 2015-10-14
*/
public class MyX509TrustManager implements X509TrustManager {
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
public X509Certificate[] getAcceptedIssuers() {
return null;
}
}Classe de vérification des informations d'identification d'autorisation :
Code Java
private String openid; //用户的唯一标识 private String nickname;//用户昵称 private Integer sex;// 用户的性别，值为1时是男性，值为2时是女性，值为0时是未知 private String province;//用户个人资料填写的省份 private String city;//普通用户个人资料填写的城市 private String country;// 国家，如中国为CN private String headimgurl; // 用户头像，最后一个数值代表正方形头像大小（有0、46、64、96、132数值可选，0代表640*640正方形头像），用户没有头像时该项为空。若用户更换头像，原有头像URL将失效。 private String privilege;// 用户特权信息，json 数组，如微信沃卡用户为（chinaunicom） private String unionid;// 只有在用户将公众号绑定到微信开放平台帐号后，才会出现该字段。详见：获取用户个人信息（UnionID机制） private String access_token;
Code d'échange pour autorisation de page Web access_token
Code Java
private String errcode; private String errmsg;
Concernant l'avatar WeChat, ce que vous obtenez est une URL http, vous devez télécharger l'image sur le stockage du serveur, puis obtenir le chemin relatif :
Code Java
private String access_token; private String expires_in; private String refresh_token; private String openid; private String scope; private String unionid;
Maintenant que le travail de base est effectué, nous allons maintenant développer le code, puis nous développerons selon cette étape :
Étape 1 : L'utilisateur accepte d'autoriser, obtenir le code
/**
* 使用url或者http存入文件
* @Title: fileUpload
* @param @param fileUrl 文件url，可以是http
* @param @param path 文件存储路径
* @return void
* @throws xinz
*/
public static void fileUpload (String fileUrl,String path){
//读取文件
String s1 = fileUrl;
java.io.InputStream is = null; //定义一个输入流。
BufferedInputStream bis = null;//定义一个带缓冲的输入流 。
//写到本地
BufferedOutputStream bos = null; //定义一个带缓冲的输出流。
try{
java.net.URL url = new java.net.URL(s1);//创建一个URL对象。
is = url.openStream();//打开到此 URL 的连接并返回一个用于从该连接读入的 InputStream。
bis = new java.io.BufferedInputStream(is);
File file = new File(path);
if(!file.exists()){ //测试此抽象路径名表示的文件或目录是否存在。
file.createNewFile(); //创建此抽象路径名表示的文件或目录。
}
bos = new BufferedOutputStream(new FileOutputStream(file));;
byte[] b = new byte[1024]; //创建字节数组。
while(bis.read(b)!=-1){//输入流中的数据如果还有下一行(!=-1)将继续循环
bos.write(b);//将字节数组写入输出流。
}
}catch(Exception e){
System.out.println(e.toString());
}finally{
try{
bos.flush();//刷新此缓冲的输出流。
bis.close(); //关闭此输入流 。
}catch(Exception e){
System.out.println(e.toString());
}
}
}Java代码
/**
* 微信用户授权
* @Title: wechatOauth
* @param @param request
* @param @param response
* @param @param model
* @param @return
* @return String
* @throws xinz
*/
@RequestMapping("wechatOauth")
public String wechatOauth(HttpServletRequest request,HttpServletResponse response,Model model) {
/**
* 1 第一步：用户同意授权，获取code
*/
//首先拿到微信公众号的AppID、AppSecret等参数
String AppID = ZhtxHelper.getApplicationResourcesProp("sendSms","AppID");
String urlOpen = ZhtxHelper.getApplicationResourcesProp("sendSms","url");
//如果用户授权成功则跳转到此url
String loginUrl = ""+urlOpen+"/zhtx-wap/weixin/getAccessToken";
//用户授权，获取code
String url = "https://open.weixin.qq.com/connect/oauth2/authorize?"
+ "appid="+AppID+""
+ "&redirect_uri="+loginUrl+""
+ "&response_type=code"
+ "&scope=snsapi_userinfo"
+ "&state=123#wechat_redirect";
//forward redirect
return "redirect:"+url+"";
}Java代码
/**
* 通过code换取网页授权access_token
* @Title: getAccessToken
* @param @param request
* @param @param response
* @param @param model
* @param @return
* @return String
* @throws xinz
*/
@RequestMapping("getAccessToken")
public String getAccessToken(HttpServletRequest request,HttpServletResponse response,Model model) {
//获取到返回的参数
try {
//首先拿到微信公众号的AppID、AppSecret等参数
String AppID = ZhtxHelper.getApplicationResourcesProp("sendSms","AppID");
String AppSecret = ZhtxHelper.getApplicationResourcesProp("sendSms","AppSecret");
String code = request.getParameter("code");
String url = null;
if(code!=null){
/**
* 2 第二步：通过code换取网页授权access_token
*/
//用户授权，获取code
url = "https://api.weixin.qq.com/sns/oauth2/access_token?"
+ "appid="+AppID+""
+ "&secret="+AppSecret+""
+ "&code="+code+""
+ "&grant_type=authorization_code";
String requestMethod = "GET";
String outputStr = "";
String httpRequest = WeixinUtil.httpRequest(url, requestMethod, outputStr);
System.out.println("通过code换取网页授权access_token="+httpRequest);
AccessTokenModel accTok = JSON.parseObject(httpRequest, AccessTokenModel.class);
/**
* 4 第四步：拉取用户信息(需scope为 snsapi_userinfo)
*/
//用户授权，获取code
String urlUser = "https://api.weixin.qq.com/sns/userinfo?"
+ "access_token="+accTok.getAccess_token()+""
+ "&openid="+accTok.getOpenid()+""
+ "&lang=zh_CN";
String httpUser = WeixinUtil.httpRequest(urlUser, requestMethod, outputStr);
System.out.println("拉取用户信息=="+httpUser);
WechatUser wechatUser = JSON.parseObject(httpUser, WechatUser.class);
wechatUser.setAccess_token(accTok.getAccess_token());
/**
* 5 附：检验授权凭证（access_token）是否有效
*/
WechatMsg checkAccessToken = checkAccessToken(wechatUser.getAccess_token(), wechatUser.getOpenid());
if(checkAccessToken.getErrcode().equals("0")){
CurrentSession.setAttribute("wechatUser", wechatUser);
WechatUser wechatU = new WechatUser();
wechatU.setOpenid(wechatUser.getOpenid());
List<wechatuser> findWechatUser = wechatUserService.findWechatUser(wechatU);
if(findWechatUser.size()>0){
UserRegister userRegister = userService.findUserByOpenid(wechatUser.getOpenid());
CurrentSession.setAttribute("user", userRegister);
return "redirect:/user/userCenter";
}else{
return "/jsp/wechat/wechatregister";
}
}else{
//如果access_token失效，则再次进行调用，并存储access_token值，access_token有效期为2个小时
this.wechatOauth(request, response, model);
}
}
} catch (Exception e) {
System.out.println("===拉取用户出错===");
e.printStackTrace();
}
//forward redirect
return "/jsp/wechat/wechatregister";
}</wechatuser>Java代码
/**
* 微信关联用户
* @Title: saveWechatUser
* @param @param mobilePhone
* @param @param password
* @param @param validataCode
* @param @return
* @return String
* @throws xinz
*/
@RequestMapping("saveWechatUser")
public String saveWechatUser(HttpServletResponse response,String mobilePhone,String password,String validataCode){
//使用手机号来判断该手机是否在注册
UserRegister userRegister = userService.findUserByPhone(mobilePhone);
WechatUser wechatUser = (WechatUser)CurrentSession.getAttribute("wechatUser");
WechatUser wechatU = new WechatUser();
wechatU.setOpenid(wechatUser.getOpenid());
List<wechatuser> findWechatUser = wechatUserService.findWechatUser(wechatU);
if(findWechatUser.size()>0 && userRegister.getOpenid()!=null){
CurrentSession.setAttribute("user", userRegister);
return "redirect:/user/userCenter";
}else{
//如果没有注册，开始注册
if(userRegister==null){
Result<userregister> saveUserInfoApp = userRegisterService.saveUserInfoApp(mobilePhone, password, validataCode,wechatUser);
if(saveUserInfoApp.getState()==1){
//进行微信和用户的关联
wechatUserService.saveWechatUser(wechatUser);
CurrentSession.setAttribute("user", userRegister);
return "redirect:/user/userCenter";
}
}else if(userRegister.getOpenid()==null || userRegister.getOpenid().equals("")){
//否则，查询出用户信息，放入session中，关联微信，跳转到用户中心
UserRegister userReg = new UserRegister();
userReg.setId(userRegister.getId());
//存入微信openid
userReg.setOpenid(wechatUser.getOpenid());
userService.upUser(userReg);
UserInfo user = new UserInfo();
//存入微信头像
//图片类型
String dateStr =DateUtil.format(DateUtil.getCurrentDate(), "yyyyMMdd") + "/";
//图片类型
String imgType = "JPG";
//微信头像名称
String app2DBarNameAndType = UuidUtil.getUUID()+"."+imgType;
//微信头像路径
String path = ZhtxHelper.getApplicationResourcesProp("application","app.img.projectpath")+ SysConstant.GOODS2DBARPATH + dateStr;
File file1 = new File(path);
file1.mkdirs();
//图片全路径
String imgUrl = SysConstant.GOODS2DBARPATH + dateStr+app2DBarNameAndType;
FileUtil.fileUpload(wechatUser.getHeadimgurl(), path);
user.setRegisterId(userRegister.getId());
user.setImageUrl(imgUrl);
userInfoService.updateUserInfo(user);
//存入微信用户
wechatUserService.saveWechatUser(wechatUser);
UserRegister userW = userService.findUserByPhone(mobilePhone);
CurrentSession.setAttribute("user", userW);
return "redirect:/user/userCenter";
}else{
CurrentSession.setAttribute("user", userRegister);
return "redirect:/user/userCenter";
}
}
return "redirect:/user/userCenter";
}</userregister></wechatuser>Java代码
/**
* 检验授权凭证（access_token）是否有效
* @Title: checkAccessToken
* @param @param access_token 网页授权接口调用凭证,注意：此access_token与基础支持的access_token不同
* @param @param openid 用户的唯一标识
* @return WechatMsg 返回消息实体
* @throws xinz
*/
public static WechatMsg checkAccessToken(String access_token,String openid){
String requestMethod = "GET";
String outputStr = "";
String url = "https://api.weixin.qq.com/sns/auth?"
+ "access_token="+access_token+""
+ "&openid="+openid+"";
String httpmsg = WeixinUtil.httpRequest(url, requestMethod, outputStr);
System.out.println("拉取用户信息返回消息=="+httpmsg);
WechatMsg msg = JSON.parseObject(httpmsg, WechatMsg.class);
return msg;
}然后在网页端，则是需要编写H5页面，进行自己网站和微信用户的关联，我这里是使用手机号，用户输入手机号，进行判断，如果注册过就直接关联，如果用户没有注册则进行注册后关联，完成后跳转到会员中心。
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Pourquoi les mots après avoir tapé le mot disparaissent-ils ?
Comment utiliser la fonction mois
Utilisation de setInterval dans JS
Tutoriel sur la fabrication de pièces inscrites
Analyse coût-efficacité de l'apprentissage de Python, Java et C++
Introduction aux méthodes de maintenance des variateurs de fréquence
Comment utiliser fusioncharts.js
Combien de types d'interfaces USB existe-t-il ?
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
