devbox
我家小花儿
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

java微信小程序登录，公众号登录（复制即可使用）

作者：我家小花儿 | 2024-05-28 04:45:01

赞

踩

java微信小程序登录

前置条件

一、需要开发者ID（AppId）和密钥（AppSecret）（注意：小程序和公众号主体需要和微信开放平台绑定，并进行开发者资质认定）

 二、代码实现

1.引入相关jar包

  1. <!--httpclient-->
  2. <dependency>
  3.     <groupId>org.apache.httpcomponents</groupId>
  4.     <artifactId>httpclient</artifactId>
  5.     <version>4.5.6</version>
  6. </dependency>
  7.  
  8. <dependency>
  9.     <groupId>com.alibaba</groupId>
  10.     <artifactId>fastjson</artifactId>
  11.     <version>2.0.4</version>
  12. </dependency>

2.所用工具类（小程序，公众号通用）

  1. package com.xiaoqiu.driving.utils;
  2.  
  3. import org.apache.http.NameValuePair;
  4. import org.apache.http.client.entity.UrlEncodedFormEntity;
  5. import org.apache.http.client.methods.CloseableHttpResponse;
  6. import org.apache.http.client.methods.HttpGet;
  7. import org.apache.http.client.methods.HttpPost;
  8. import org.apache.http.client.utils.URIBuilder;
  9. import org.apache.http.entity.ContentType;
  10. import org.apache.http.entity.StringEntity;
  11. import org.apache.http.impl.client.CloseableHttpClient;
  12. import org.apache.http.impl.client.HttpClients;
  13. import org.apache.http.message.BasicNameValuePair;
  14. import org.apache.http.util.EntityUtils;
  15.  
  16. import java.io.*;
  17. import java.net.MalformedURLException;
  18. import java.net.URI;
  19. import java.net.URL;
  20. import java.util.ArrayList;
  21. import java.util.List;
  22. import java.util.Map;
  23.  
  24. public class HttpClientUtil {
  25.  
  26.     public static String doGet(String url, Map<String, String> param) {
  27.  
  28.         // 创建Httpclient对象
  29.         CloseableHttpClient httpclient = HttpClients.createDefault();
  30.  
  31.         String resultString = "";
  32.         CloseableHttpResponse response = null;
  33.         try {
  34.             // 创建uri
  35.             URIBuilder builder = new URIBuilder(url);
  36.             if (param != null) {
  37.                 for (String key : param.keySet()) {
  38.                     builder.addParameter(key, param.get(key));
  39.                 }
  40.             }
  41.             URI uri = builder.build();
  42.  
  43.             // 创建http GET请求
  44.             HttpGet httpGet = new HttpGet(uri);
  45.  
  46.             // 执行请求
  47.             response = httpclient.execute(httpGet);
  48.             // 判断返回状态是否为200
  49.             if (response.getStatusLine().getStatusCode() == 200) {
  50.                 resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
  51.             }
  52.         } catch (Exception e) {
  53.             e.printStackTrace();
  54.         } finally {
  55.             try {
  56.                 if (response != null) {
  57.                     response.close();
  58.                 }
  59.                 httpclient.close();
  60.             } catch (IOException e) {
  61.                 e.printStackTrace();
  62.             }
  63.         }
  64.         return resultString;
  65.     }
  66.  
  67.     public static String doGet(String url) {
  68.         return doGet(url, null);
  69.     }
  70.  
  71.     public static String doPost(String url, Map<String, String> param) {
  72.         // 创建Httpclient对象
  73.         CloseableHttpClient httpClient = HttpClients.createDefault();
  74.         CloseableHttpResponse response = null;
  75.         String resultString = "";
  76.         try {
  77.             // 创建Http Post请求
  78.             HttpPost httpPost = new HttpPost(url);
  79.             // 创建参数列表
  80.             if (param != null) {
  81.                 List<NameValuePair> paramList = new ArrayList<>();
  82.                 for (String key : param.keySet()) {
  83.                     paramList.add(new BasicNameValuePair(key, param.get(key)));
  84.                 }
  85.                 // 模拟表单
  86.                 UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
  87.                 httpPost.setEntity(entity);
  88.             }
  89.             // 执行http请求
  90.             response = httpClient.execute(httpPost);
  91.             resultString = EntityUtils.toString(response.getEntity(), "utf-8");
  92.         } catch (Exception e) {
  93.             e.printStackTrace();
  94.         } finally {
  95.             try {
  96.                 response.close();
  97.             } catch (IOException e) {
  98.                 e.printStackTrace();
  99.             }
  100.         }
  101.  
  102.         return resultString;
  103.     }
  104.  
  105.  
  106.  
  107.     public static String doPost(String url) {
  108.         return doPost(url, null);
  109.     }
  110.  
  111.     public static String doPostJson(String url, String json) {
  112.         // 创建Httpclient对象
  113.         CloseableHttpClient httpClient = HttpClients.createDefault();
  114.         CloseableHttpResponse response = null;
  115.         String resultString = "";
  116.         try {
  117.             // 创建Http Post请求
  118.             HttpPost httpPost = new HttpPost(url);
  119.             // 创建请求内容
  120.             StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
  121.             httpPost.setEntity(entity);
  122.             // 执行http请求
  123.             response = httpClient.execute(httpPost);
  124.             resultString = EntityUtils.toString(response.getEntity(), "utf-8");
  125.         } catch (Exception e) {
  126.             e.printStackTrace();
  127.         } finally {
  128.             try {
  129.                 response.close();
  130.             } catch (IOException e) {
  131.                 e.printStackTrace();
  132.             }
  133.         }
  134.  
  135.         return resultString;
  136.     }
  137.  
  138.     //链接url下载图片
  139.     public static void downloadPicture(String urlList, String path) {
  140.         URL url = null;
  141.         try {
  142.             url = new URL(urlList);
  143.             DataInputStream dataInputStream = new DataInputStream(url.openStream());
  144.             FileOutputStream fileOutputStream = new FileOutputStream(new File(path));
  145.             ByteArrayOutputStream output = new ByteArrayOutputStream();
  146.  
  147.             byte[] buffer = new byte[1024];
  148.             int length;
  149.  
  150.             while ((length = dataInputStream.read(buffer)) > 0) {
  151.                 output.write(buffer, 0, length);
  152.             }
  153.             fileOutputStream.write(output.toByteArray());
  154.             dataInputStream.close();
  155.             fileOutputStream.close();
  156.         } catch (MalformedURLException e) {
  157.             e.printStackTrace();
  158.         } catch (IOException e) {
  159.             e.printStackTrace();
  160.         }
  161.     }
  162. }

3.小程序登录接口实现

  1. package com.xiaoqiu.driving.pojo.vo;
  2.  
  3. import lombok.Data;
  4.  
  5. @Data
  6. public class WxLoginVo {
  7.     /** 微信code */
  8.     private String code;
  9.     /** 微信昵称 */
  10.     private String nickName;
  11.     /** 微信头像 */
  12.     private String avatarUrl;
  13. }
  1. package com.xiaoqiu.driving.controller;
  2.  
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  5. import com.xiaoqiu.driving.pojo.Users;
  6. import com.xiaoqiu.driving.pojo.vo.WxLoginVo;
  7. import com.xiaoqiu.driving.service.UsersService;
  8. import com.xiaoqiu.driving.utils.HttpClientUtil;
  9. import com.xiaoqiu.driving.utils.R;
  10. import io.swagger.annotations.Api;
  11. import io.swagger.annotations.ApiOperation;
  12. import org.apache.commons.codec.binary.Base64;
  13. import org.apache.commons.lang3.StringUtils;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.http.HttpEntity;
  16. import org.springframework.http.HttpHeaders;
  17. import org.springframework.http.ResponseEntity;
  18. import org.springframework.web.bind.annotation.*;
  19. import org.springframework.web.client.RestTemplate;
  20.  
  21. import java.util.HashMap;
  22. import java.util.Map;
  23.  
  24. /**
  25.  * <p>
  26.  * 用户信息表 前端控制器
  27.  * </p>
  28.  *
  29.  * @author 
  30.  * @since 2023-04-13
  31.  */
  32. @Api
  33. @RestController
  34. @RequestMapping("/driving/users")
  35. public class UsersController {
  36.  
  37.     public final static String appId = "********";
  38.     public final static String secret = "*************";
  39.     // 微信小程序授权登录请求的网址
  40.     public static final String WX_LOGIN_URL = "https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=authorization_code";
  41.  
  42.     @Autowired
  43.     private UsersService userService;
  44.     @Autowired
  45.     private RestTemplate restTemplate;
  46.  
  47.  
  48.     @PostMapping("/weixinLogin")
  49.     @ResponseBody
  50.     @ApiOperation("用户授权登录")
  51.     public R weixinLogin(@RequestBody WxLoginVo userLoginVo) throws Exception {
  52.         // 接收前端参数
  53.         String code = userLoginVo.getCode();  //code
  54.         String avatar = userLoginVo.getAvatarUrl();   //头像
  55.         String nickname = userLoginVo.getNickName();  //微信昵称
  56.         System.out.println("小程序登录");
  57.         if (StringUtils.isEmpty(code)) {
  58.             return R.error().message("code不能为空");
  59.         }
  60.         //需要拿客户端获得的code换取openId
  61.         String url = String.format(WX_LOGIN_URL, appId, secret, code);
  62.         //调用微信api授权
  63.         String data = HttpClientUtil.doGet(url);
  64.         System.out.println("请求结果：" + data);
  65.         //解析返回的json字符串属性	类型	说明
  66.         JSONObject jsonObject = JSONObject.parseObject(data);
  67.         String openId = jsonObject.getString("openid");
  68.         if (StringUtils.isEmpty(openId)){
  69.             return R.error().message("未获取到openId");
  70.         }
  71.         Users user = this.userService.getOne(new QueryWrapper<Users>().eq("openid",openId));
  72.         if (user != null){
  73.             System.out.println("老用户");
  74.             user.setAvatar(avatar);
  75.  
  76.             //存入数据库的微信昵称采用base64编码处理
  77.             byte[] bytes = Base64.encodeBase64(nickname.getBytes("utf-8"));
  78.             user.setNickname(new String(bytes));
  79.             this.userService.updateById(user);
  80.             //返回昵称还用原来的
  81.             user.setNickname(nickname);
  82.             return R.ok().data("user",user);
  83.         }else {
  84.             System.out.println("新用户");
  85.             // 新用户
  86.             Users newUser = new Users();
  87.             newUser.setOpenid(openId);
  88.             newUser.setAvatar(avatar);
  89.             //存入数据库的微信昵称采用base64编码处理
  90.             byte[] bytes = Base64.encodeBase64(nickname.getBytes("utf-8"));
  91.             newUser.setNickname(new String(bytes));
  92.             boolean save = this.userService.save(newUser);
  93.             // 返回用户信息
  94.             Users byId = this.userService.getById(newUser.getId());
  95.             //返回昵称还用原来的
  96.             byId.setNickname(nickname);
  97.             return save ? R.ok().data("user",byId) : R.error().message("添加新用户失败");
  98.         }
  99.     }
  100.  
  101. }

4.公众号登录实现

  1. package com.xqkj.jingqu.controller;
  2.  
  3.  
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  6. import com.xqkj.jingqu.entity.Fangwen;
  7. import com.xqkj.jingqu.entity.User;
  8. import com.xqkj.jingqu.service.FangwenService;
  9. import com.xqkj.jingqu.service.UserService;
  10. import com.xqkj.jingqu.util.*;
  11. import io.swagger.annotations.ApiOperation;
  12. import org.apache.commons.codec.binary.Base64;
  13. import org.apache.commons.lang3.StringUtils;
  14. import org.apache.http.entity.ContentType;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.mock.web.MockMultipartFile;
  17. import org.springframework.web.bind.annotation.*;
  18. import org.springframework.web.multipart.MultipartFile;
  19.  
  20. import javax.validation.Valid;
  21. import java.io.*;
  22. import java.text.SimpleDateFormat;
  23. import java.util.ArrayList;
  24. import java.util.Date;
  25. import java.util.List;
  26.  
  27. /**
  28.  * <p>
  29.  * 用户 前端控制器
  30.  * </p>
  31.  *
  32.  * @author yaodongqiang
  33.  * @since 2022-08-05
  34.  */
  35. @RestController
  36. @CrossOrigin
  37. @RequestMapping("/jingqu/user")
  38. public class UserController {
  39.  
  40.     public final static String appId = "*********";
  41.     public final static String secret = "*********";
  42.  
  43.     SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
  44.  
  45.  
  46.     // 微信公众号授权登录请求的网址
  47.     public static final String WX_LOGIN_URL = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code";
  48.  
  49.  
  50.     @Autowired
  51.     private UserService userService;
  52.     
  53.  
  54.     @GetMapping("/weixinLoginCeshi/{code}")
  55.     @ResponseBody
  56.     @ApiOperation("用户授权登录")
  57.     public R weixinLoginCeshi(@PathVariable String code) throws Exception {
  58.         System.out.println("公众号登录");
  59.         if (StringUtils.isEmpty(code)) {
  60.             return R.error().message("code不能为空");
  61.         }
  62.         //需要拿客户端获得的code换取openId
  63.         String url = String.format(WX_LOGIN_URL, appId, secret, code);
  64.         //调用微信api授权
  65.         String data = HttpClientUtil.doGet(url);
  66.         System.out.println("请求结果：" + data);
  67.         //解析返回的json字符串
  68.         JSONObject jsonObject = JSONObject.parseObject(data);
  69.         //获取openid和token值
  70.         String openId = jsonObject.getString("openid");
  71.         String accessToken = jsonObject.getString("access_token");
  72.  
  73.         if (StringUtils.isEmpty(openId)) {
  74.             return R.error().message("未获取到openId");
  75.         }
  76.         // 通过openid 和 accessToken 来获取用户信息
  77.         // 拼接请求地址
  78.         String requestUrl = "https://api.weixin.qq.com/sns/userinfo?access_token=ACCESS_TOKEN&openid=OPENID";
  79.         requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken).replace("OPENID", openId);
  80.         //发送请求
  81.         String urlRequest = HttpClientUtil.doGet(requestUrl);
  82.         //解析返回的json字符串
  83.         JSONObject userInfo = JSONObject.parseObject(urlRequest);
  84.         //获取用户微信昵称和头像
  85.         String nickname = userInfo.getString("nickname");
  86.         String avatar = userInfo.getString("headimgurl");
  87.         //根据openid从数据库中查询用户
  88.         User user = this.userService.getOne(new QueryWrapper<User>().eq("openid",openId));
  89.         if (user != null) {
  90.             System.out.println("老用户");
  91.             user.setAvatar(avatar);
  92.             //存入数据库的微信昵称采用base64编码处理
  93.             byte[] bytes = Base64.encodeBase64(nickname.getBytes("utf-8"));
  94.             user.setNickname(new String(bytes));
  95.             this.userService.updateById(user);
  96.             //返回昵称还用原来的
  97.             user.setNickname(nickname);
  98.             return R.ok().data("user", user);
  99.         } else {
  100.             System.out.println("新用户");
  101.             // 新用户
  102.             User newUser = new User();
  103.             newUser.setOpenid(openId);
  104.             newUser.setAvatar(avatar);
  105.             //存入数据库的微信昵称采用base64编码处理
  106.             byte[] bytes = Base64.encodeBase64(nickname.getBytes("utf-8"));
  107.             newUser.setNickname(new String(bytes));
  108.             boolean save = this.userService.save(newUser);
  109.             //返回昵称还用原来的
  110.             newUser.setNickname(nickname);
  111.             return save ? R.ok().data("user", newUser) : R.error().message("添加新用户失败");
  112.         }
  113.     }
  114. }

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

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号