SpringBoot整合微信登录

博主：微风
发布时间：2021 年 08 月 14 日
1010 次浏览
暂无评论
21093字数
分类： Java

最终效果演示

首先在pom文件中导入相关依赖

<dependencies>
        <!--httpclient-->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
        </dependency>
        <!--commons-io-->
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
        </dependency>
        <!--gson-->
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
        </dependency>
    </dependencies>

在配置文件中（application.properties或application.yml），对其进行配置，我这里使用的是application.properties

# 微信开放平台
# 开放平台appid
wx.open.app_id=你的应用id
# 开放平台密匙
wx.open.app_secret=你的应用密匙
# 微信开放平台 重定向url
wx.open.redirect_url=重定向地址

创建第一个工具类（主要用于获取配置文件中的数据）：ConstantWxUtils.java

package cn.luocome.educenter.utils;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @author 微风
 * @version 1.0
 * @date 2021/8/14 15:17
 */
@Component
public class ConstantWxUtils implements InitializingBean {

    @Value("${wx.open.app_id}")
    private String appId;

    @Value("${wx.open.app_secret}")
    private String appSecret;

    @Value("${wx.open.redirect_url}")
    private String redirectUrl;

    public static String WX_OPEN_APP_ID;
    public static String WX_OPEN_APP_SECRET;
    public static String WX_OPEN_REDIRECT_URL;

    @Override
    public void afterPropertiesSet() throws Exception {
        WX_OPEN_APP_ID = appId;
        WX_OPEN_APP_SECRET = appSecret;
        WX_OPEN_REDIRECT_URL = redirectUrl;
    }
}

创建第二个工具类（用于网络请求）：HttpClientUtils.java

package cn.luocome.educenter.utils;

import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.config.RequestConfig.Builder;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContextBuilder;
import org.apache.http.conn.ssl.TrustStrategy;
import org.apache.http.conn.ssl.X509HostnameVerifier;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;

import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import java.io.IOException;
import java.net.SocketTimeoutException;
import java.security.GeneralSecurityException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

/**
 *  依赖的jar包有：commons-lang-2.6.jar、httpclient-4.3.2.jar、httpcore-4.3.1.jar、commons-io-2.4.jar
 *
 */
public class HttpClientUtils {

    public static final int connTimeout=10000;
    public static final int readTimeout=10000;
    public static final String charset="UTF-8";
    private static HttpClient client = null;

    static {
        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
        cm.setMaxTotal(128);
        cm.setDefaultMaxPerRoute(128);
        client = HttpClients.custom().setConnectionManager(cm).build();
    }

    public static String postParameters(String url, String parameterStr) throws ConnectTimeoutException, SocketTimeoutException, Exception{
        return post(url,parameterStr,"application/x-www-form-urlencoded",charset,connTimeout,readTimeout);
    }

    public static String postParameters(String url, String parameterStr,String charset, Integer connTimeout, Integer readTimeout) throws ConnectTimeoutException, SocketTimeoutException, Exception{
        return post(url,parameterStr,"application/x-www-form-urlencoded",charset,connTimeout,readTimeout);
    }

    public static String postParameters(String url, Map<String, String> params) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {
        return postForm(url, params, null, connTimeout, readTimeout);
    }

    public static String postParameters(String url, Map<String, String> params, Integer connTimeout,Integer readTimeout) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {
        return postForm(url, params, null, connTimeout, readTimeout);
    }

    public static String get(String url) throws Exception {
        return get(url, charset, null, null);
    }

    public static String get(String url, String charset) throws Exception {
        return get(url, charset, connTimeout, readTimeout);
    }

    /**
     * 发送一个 Post 请求, 使用指定的字符集编码.
     *
     * @param url
     * @param body RequestBody
     * @param mimeType 例如 application/xml "application/x-www-form-urlencoded" a=1&b=2&c=3
     * @param charset 编码
     * @param connTimeout 建立链接超时时间,毫秒.
     * @param readTimeout 响应超时时间,毫秒.
     * @return ResponseBody, 使用指定的字符集编码.
     * @throws ConnectTimeoutException 建立链接超时异常
     * @throws SocketTimeoutException  响应超时
     * @throws Exception
     */
    public static String post(String url, String body, String mimeType,String charset, Integer connTimeout, Integer readTimeout)
            throws ConnectTimeoutException, SocketTimeoutException, Exception {
        HttpClient client = null;
        HttpPost post = new HttpPost(url);
        String result = "";
        try {
            if (StringUtils.isNotBlank(body)) {
                HttpEntity entity = new StringEntity(body, ContentType.create(mimeType, charset));
                post.setEntity(entity);
            }
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            post.setConfig(customReqConf.build());

            HttpResponse res;
            if (url.startsWith("https")) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(post);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(post);
            }
            result = IOUtils.toString(res.getEntity().getContent(), charset);
        } finally {
            post.releaseConnection();
            if (url.startsWith("https") && client != null&& client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
        return result;
    }


    /**
     * 提交form表单
     *
     * @param url
     * @param params
     * @param connTimeout
     * @param readTimeout
     * @return
     * @throws ConnectTimeoutException
     * @throws SocketTimeoutException
     * @throws Exception
     */
    public static String postForm(String url, Map<String, String> params, Map<String, String> headers, Integer connTimeout,Integer readTimeout) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {

        HttpClient client = null;
        HttpPost post = new HttpPost(url);
        try {
            if (params != null && !params.isEmpty()) {
                List<NameValuePair> formParams = new ArrayList<NameValuePair>();
                Set<Entry<String, String>> entrySet = params.entrySet();
                for (Entry<String, String> entry : entrySet) {
                    formParams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
                }
                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formParams, Consts.UTF_8);
                post.setEntity(entity);
            }

            if (headers != null && !headers.isEmpty()) {
                for (Entry<String, String> entry : headers.entrySet()) {
                    post.addHeader(entry.getKey(), entry.getValue());
                }
            }
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            post.setConfig(customReqConf.build());
            HttpResponse res = null;
            if (url.startsWith("https")) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(post);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(post);
            }
            return IOUtils.toString(res.getEntity().getContent(), "UTF-8");
        } finally {
            post.releaseConnection();
            if (url.startsWith("https") && client != null
                    && client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
    }




    /**
     * 发送一个 GET 请求
     *
     * @param url
     * @param charset
     * @param connTimeout  建立链接超时时间,毫秒.
     * @param readTimeout  响应超时时间,毫秒.
     * @return
     * @throws ConnectTimeoutException   建立链接超时
     * @throws SocketTimeoutException   响应超时
     * @throws Exception
     */
    public static String get(String url, String charset, Integer connTimeout,Integer readTimeout)
            throws ConnectTimeoutException,SocketTimeoutException, Exception {

        HttpClient client = null;
        HttpGet get = new HttpGet(url);
        String result = "";
        try {
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            get.setConfig(customReqConf.build());

            HttpResponse res = null;

            if (url.startsWith("https")) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(get);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(get);
            }

            result = IOUtils.toString(res.getEntity().getContent(), charset);
        } finally {
            get.releaseConnection();
            if (url.startsWith("https") && client != null && client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
        return result;
    }


    /**
     * 从 response 里获取 charset
     *
     * @param ressponse
     * @return
     */
    @SuppressWarnings("unused")
    private static String getCharsetFromResponse(HttpResponse ressponse) {
        // Content-Type:text/html; charset=GBK
        if (ressponse.getEntity() != null  && ressponse.getEntity().getContentType() != null && ressponse.getEntity().getContentType().getValue() != null) {
            String contentType = ressponse.getEntity().getContentType().getValue();
            if (contentType.contains("charset=")) {
                return contentType.substring(contentType.indexOf("charset=") + 8);
            }
        }
        return null;
    }



    /**
     * 创建 SSL连接
     * @return
     * @throws GeneralSecurityException
     */
    private static CloseableHttpClient createSSLInsecureClient() throws GeneralSecurityException {
        try {
            SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
                public boolean isTrusted(X509Certificate[] chain,String authType) throws CertificateException {
                    return true;
                }
            }).build();

            SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, new X509HostnameVerifier() {

                @Override
                public boolean verify(String arg0, SSLSession arg1) {
                    return true;
                }

                @Override
                public void verify(String host, SSLSocket ssl)
                        throws IOException {
                }

                @Override
                public void verify(String host, X509Certificate cert)
                        throws SSLException {
                }

                @Override
                public void verify(String host, String[] cns,
                                   String[] subjectAlts) throws SSLException {
                }

            });

            return HttpClients.custom().setSSLSocketFactory(sslsf).build();

        } catch (GeneralSecurityException e) {
            throw e;
        }
    }

    public static void main(String[] args) {
        try {
            String str= post("https://localhost:443/ssl/test.shtml","name=12&page=34","application/x-www-form-urlencoded", "UTF-8", 10000, 10000);
            //String str= get("https://localhost:443/ssl/test.shtml?name=12&page=34","GBK");
            /*Map<String,String> map = new HashMap<String,String>();
            map.put("name", "111");
            map.put("page", "222");
            String str= postForm("https://localhost:443/ssl/test.shtml",map,null, 10000, 10000);*/
            System.out.println(str);
        } catch (ConnectTimeoutException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SocketTimeoutException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

创建第三个工具类（JWT，将json数据转化为Token令牌）：JwtUtils.java

package cn.luocome.commonutils;

import io.jsonwebtoken.Claims;
import io.jsonwebtoken.Jws;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;

/**
 * @author 微风
 * @version 1.0
 * @date 2021/7/20 15:11
 */
public class JwtUtils {


    public static final long EXPIRE = 1000 * 60 * 60 * 24; // 设置Token过期时间
    public static final String APP_SECRET = "ukc8BDbRigUDaY6pZFfWus2jZWLPHO";// 密钥，根据这个密钥进行后期的加密（自己谁便写一个）

    /**
     * 生成Token字符串的方法
     * @param id 用户id
     * @param nickname 用户昵称
     * @return
     */
    public static String getJwtToken(String id, String nickname){
        String JwtToken = Jwts.builder()
                // 设置JWT头信息
                .setHeaderParam("typ", "JWT")
                .setHeaderParam("alg", "HS256")
                // 设置Token的过期时间
                .setSubject("luocome-user")
                .setIssuedAt(new Date())
                .setExpiration(new Date(System.currentTimeMillis() + EXPIRE))
                // 设置Token主体部分
                .claim("id", id)
                .claim("nickname", nickname)
                // 签名哈希
                .signWith(SignatureAlgorithm.HS256, APP_SECRET)
                .compact();
        // 返回Token字符串
        return JwtToken;
    }

    /**
     * 判断token是否存在与有效
     * @param jwtToken
     * @return
     */
    public static boolean checkToken(String jwtToken) {
        if(StringUtils.isEmpty(jwtToken)) return false;
        try {
            Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    /**
     * 判断token是否存在与有效
     * @param request
     * @return
     */
    public static boolean checkToken(HttpServletRequest request) {
        try {
            String jwtToken = request.getHeader("token");
            if(StringUtils.isEmpty(jwtToken)) return false;
            Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

    /**
     * 根据token获取会员id
     * @param request
     * @return
     */
    public static String getMemberIdByJwtToken(HttpServletRequest request) {
        String jwtToken = request.getHeader("token");
        if(StringUtils.isEmpty(jwtToken)) return "";
        Jws<Claims> claimsJws = Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
        Claims claims = claimsJws.getBody();
        return (String)claims.get("id");
    }
}

控制层实现逻辑

package cn.luocome.educenter.controller;

import cn.luocome.baseservice.exceptionhandler.MyException;
import cn.luocome.commonutils.JwtUtils;
import cn.luocome.educenter.entity.UcenterMember;
import cn.luocome.educenter.service.UcenterMemberService;
import cn.luocome.educenter.utils.ConstantWxUtils;
import cn.luocome.educenter.utils.HttpClientUtils;
import com.google.gson.Gson;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;

/**
 * @author 罗裕锋
 * @version 1.0
 * @date 2021/8/14 15:21
 */

@CrossOrigin
@Controller
@RequestMapping("/api/ucenter/wx")
public class WxApiController {

    @Autowired
    private UcenterMemberService ucenterMemberService;

    // 生成微信扫描的二维码
    @GetMapping("login")
    public String getWxCode(){
        // 微信开放平台授权baseUrl  %s相当于占位符
        String baseUrl = "https://open.weixin.qq.com/connect/qrconnect" +
                "?appid=%s" +
                "&redirect_uri=%s" +
                "&response_type=code" +
                "&scope=snsapi_login" +
                "&state=%s" +
                "#wechat_redirect";

        // 对redirect_url进行URLEncoder编码
        String redirectUrl = ConstantWxUtils.WX_OPEN_REDIRECT_URL;
        try {
            redirectUrl = URLEncoder.encode(redirectUrl, "utf-8");
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        // 给占位符赋值
        String qrcodeUrl = String.format(
                baseUrl,
                ConstantWxUtils.WX_OPEN_APP_ID,
                redirectUrl,
                "luocome"
        );

        // 请求微信地址（重定向到二维码生成地址中）
        return "redirect:" + qrcodeUrl;
    }

    // 获取扫描人信息，添加数据
    @GetMapping("callback")
    public String callback(String code,String state){
        // 获取code值
        String tempCode = code;
        // 通过code值请求微信固定地址，得到accsess_token 和 openid
        String baseAccessTokenUrl = "https://api.weixin.qq.com/sns/oauth2/access_token" +
                "?appid=%s" +
                "&secret=%s" +
                "&code=%s" +
                "&grant_type=authorization_code";
        // 拼接三个参数（id，密钥和code）
        String accessTokenUrl = String.format(baseAccessTokenUrl,
                ConstantWxUtils.WX_OPEN_APP_ID,
                ConstantWxUtils.WX_OPEN_APP_SECRET,
                tempCode);
        // 请求拼接好的地址，得到accsess_token 和 openid
        // 使用Httpclient发送请求，得到返回的结果
        String accessTokenInfo = "";
        try {
            accessTokenInfo = HttpClientUtils.get(accessTokenUrl);
        } catch (Exception e) {
            e.printStackTrace();
            throw new MyException(20001,"登录失败");
        }
        // 从accessTokenInfo字符串中获取accsess_token 和 openid
        // 将accessTokenInfo字符串转换成map集合，通过map里面的key获取对应的值(使用Json转换工具)
        Gson gson = new Gson();
        HashMap<String,String> mapAccessToken = gson.fromJson(accessTokenInfo, HashMap.class);
        String accessToken = (String)mapAccessToken.get("access_token");
        String openId = (String)mapAccessToken.get("openid");
        // 将扫码人信息添加到数据库中
        // 判断数据库表中是否存在相同的微信信息（根据openid进行判断）
        UcenterMember member = ucenterMemberService.getOpenIdMember(openId);
        if (member == null) { // 表里没有该用户，进行添加数据
            // 根据accessToken和openId再去请求微信固定地址
            // 访问微信的资源服务器，获取用户信息
            String baseUserInfoUrl = "https://api.weixin.qq.com/sns/userinfo" +
                    "?access_token=%s" +
                    "&openid=%s";
            String userInfoUrl = String.format(baseUserInfoUrl, accessToken, openId);
            // 发送请求
            String userInfo = "";
            try {
                userInfo = HttpClientUtils.get(userInfoUrl);
            } catch (Exception e) {
                e.printStackTrace();
                throw new MyException(20001,"登录失败");
            }
            // 获取扫码人的信息
            HashMap<String,String> userInfoMap = gson.fromJson(userInfo, HashMap.class);
            // 获取昵称
            String nikename = (String) userInfoMap.get("nickname");
            // 获取头像
            String headimgurl = (String) userInfoMap.get("headimgurl");
            // 获取性别
            Integer sex = (int)Double.parseDouble(String.valueOf(userInfoMap.get("sex")));
            member = new UcenterMember();
            member.setOpenid(openId);
            member.setNickname(nikename);
            member.setAvatar(headimgurl);
            member.setSex(sex);
            ucenterMemberService.save(member);
        }
        // 使用JWT根据member对象生成token字符串，
        String jwtToken = JwtUtils.getJwtToken(member.getId(), member.getNickname());
        // 返回首页面，通过路径传递token字符串
        return "redirect:http://localhost:3000?token=" + jwtToken;
    }
}

Servise层还有一个逻辑

// 判断数据库表中是否存在相同的微信信息（根据openid进行判断）
    @Override
    public UcenterMember getOpenIdMember(String openId) {
        QueryWrapper<UcenterMember> wrapper = new QueryWrapper<>();
        wrapper.eq("openid",openId);
        UcenterMember member = baseMapper.selectOne(wrapper);
        return member;
    }

最后修改：2021 年 08 月 15 日

如果觉得我的文章对你有用，请随意赞赏

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

今日已经过去小时

这周已经过去天

本月已经过去天

今年已经过去个月

SpringBoot整合微信登录

微风 • 2021 年 08 月 14 日

<blockquote>最终效果演示</blockquote><video src="https://www.luocome.cn/temp/QQ20210814-175335-HD.mp4" style="background-image:url();background-size: cover;"></video><blockquote>首先在pom文件中导入相关依赖</blockquote><pre><code class="lang-xml">&lt;dependencies&gt;
 &lt;!--httpclient--&gt;
 &lt;dependency&gt;
 &lt;groupId&gt;org.apache.httpcomponents&lt;/groupId&gt;
 &lt;artifactId&gt;httpclient&lt;/artifactId&gt;
 &lt;/dependency&gt;
 &lt;!--commons-io--&gt;
 &lt;dependency&gt;
 &lt;groupId&gt;commons-io&lt;/groupId&gt;
 &lt;artifactId&gt;commons-io&lt;/artifactId&gt;
 &lt;/dependency&gt;
 &lt;!--gson--&gt;
 &lt;dependency&gt;
 &lt;groupId&gt;com.google.code.gson&lt;/groupId&gt;
 &lt;artifactId&gt;gson&lt;/artifactId&gt;
 &lt;/dependency&gt;
 &lt;/dependencies&gt;</code></pre><blockquote>在配置文件中（application.properties或application.yml），对其进行配置，我这里使用的是application.properties</blockquote><pre><code class="lang-properties"># 微信开放平台
# 开放平台appid
wx.open.app_id=你的应用id
# 开放平台密匙
wx.open.app_secret=你的应用密匙
# 微信开放平台 重定向url
wx.open.redirect_url=重定向地址</code></pre><blockquote>创建第一个工具类（主要用于获取配置文件中的数据）：ConstantWxUtils.java</blockquote><pre><code class="lang-java">package cn.luocome.educenter.utils;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @author 微风
 * @version 1.0
 * @date 2021/8/14 15:17
 */
@Component
public class ConstantWxUtils implements InitializingBean {

@Value(&quot;${wx.open.app_id}&quot;)
    private String appId;

@Value(&quot;${wx.open.app_secret}&quot;)
    private String appSecret;

@Value(&quot;${wx.open.redirect_url}&quot;)
    private String redirectUrl;

public static String WX_OPEN_APP_ID;
    public static String WX_OPEN_APP_SECRET;
    public static String WX_OPEN_REDIRECT_URL;

@Override
 public void afterPropertiesSet() throws Exception {
 WX_OPEN_APP_ID = appId;
 WX_OPEN_APP_SECRET = appSecret;
 WX_OPEN_REDIRECT_URL = redirectUrl;
 }
}
</code></pre><blockquote>创建第二个工具类（用于网络请求）：HttpClientUtils.java</blockquote><pre><code class="lang-java">package cn.luocome.educenter.utils;

import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.config.RequestConfig.Builder;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContextBuilder;
import org.apache.http.conn.ssl.TrustStrategy;
import org.apache.http.conn.ssl.X509HostnameVerifier;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;

import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
import java.io.IOException;
import java.net.SocketTimeoutException;
import java.security.GeneralSecurityException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

/**
 *  依赖的jar包有：commons-lang-2.6.jar、httpclient-4.3.2.jar、httpcore-4.3.1.jar、commons-io-2.4.jar
 *
 */
public class HttpClientUtils {

public static final int connTimeout=10000;
    public static final int readTimeout=10000;
    public static final String charset=&quot;UTF-8&quot;;
    private static HttpClient client = null;

static {
        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
        cm.setMaxTotal(128);
        cm.setDefaultMaxPerRoute(128);
        client = HttpClients.custom().setConnectionManager(cm).build();
    }

public static String postParameters(String url, String parameterStr) throws ConnectTimeoutException, SocketTimeoutException, Exception{
        return post(url,parameterStr,&quot;application/x-www-form-urlencoded&quot;,charset,connTimeout,readTimeout);
    }

public static String postParameters(String url, String parameterStr,String charset, Integer connTimeout, Integer readTimeout) throws ConnectTimeoutException, SocketTimeoutException, Exception{
        return post(url,parameterStr,&quot;application/x-www-form-urlencoded&quot;,charset,connTimeout,readTimeout);
    }

public static String postParameters(String url, Map&lt;String, String&gt; params) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {
        return postForm(url, params, null, connTimeout, readTimeout);
    }

public static String postParameters(String url, Map&lt;String, String&gt; params, Integer connTimeout,Integer readTimeout) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {
        return postForm(url, params, null, connTimeout, readTimeout);
    }

public static String get(String url) throws Exception {
        return get(url, charset, null, null);
    }

public static String get(String url, String charset) throws Exception {
        return get(url, charset, connTimeout, readTimeout);
    }

/**
     * 发送一个 Post 请求, 使用指定的字符集编码.
     *
     * @param url
     * @param body RequestBody
     * @param mimeType 例如 application/xml &quot;application/x-www-form-urlencoded&quot; a=1&amp;b=2&amp;c=3
     * @param charset 编码
     * @param connTimeout 建立链接超时时间,毫秒.
     * @param readTimeout 响应超时时间,毫秒.
     * @return ResponseBody, 使用指定的字符集编码.
     * @throws ConnectTimeoutException 建立链接超时异常
     * @throws SocketTimeoutException  响应超时
     * @throws Exception
     */
    public static String post(String url, String body, String mimeType,String charset, Integer connTimeout, Integer readTimeout)
            throws ConnectTimeoutException, SocketTimeoutException, Exception {
        HttpClient client = null;
        HttpPost post = new HttpPost(url);
        String result = &quot;&quot;;
        try {
            if (StringUtils.isNotBlank(body)) {
                HttpEntity entity = new StringEntity(body, ContentType.create(mimeType, charset));
                post.setEntity(entity);
            }
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            post.setConfig(customReqConf.build());

HttpResponse res;
            if (url.startsWith(&quot;https&quot;)) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(post);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(post);
            }
            result = IOUtils.toString(res.getEntity().getContent(), charset);
        } finally {
            post.releaseConnection();
            if (url.startsWith(&quot;https&quot;) &amp;&amp; client != null&amp;&amp; client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
        return result;
    }

/**
     * 提交form表单
     *
     * @param url
     * @param params
     * @param connTimeout
     * @param readTimeout
     * @return
     * @throws ConnectTimeoutException
     * @throws SocketTimeoutException
     * @throws Exception
     */
    public static String postForm(String url, Map&lt;String, String&gt; params, Map&lt;String, String&gt; headers, Integer connTimeout,Integer readTimeout) throws ConnectTimeoutException,
            SocketTimeoutException, Exception {

HttpClient client = null;
        HttpPost post = new HttpPost(url);
        try {
            if (params != null &amp;&amp; !params.isEmpty()) {
                List&lt;NameValuePair&gt; formParams = new ArrayList&lt;NameValuePair&gt;();
                Set&lt;Entry&lt;String, String&gt;&gt; entrySet = params.entrySet();
                for (Entry&lt;String, String&gt; entry : entrySet) {
                    formParams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
                }
                UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formParams, Consts.UTF_8);
                post.setEntity(entity);
            }

if (headers != null &amp;&amp; !headers.isEmpty()) {
                for (Entry&lt;String, String&gt; entry : headers.entrySet()) {
                    post.addHeader(entry.getKey(), entry.getValue());
                }
            }
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            post.setConfig(customReqConf.build());
            HttpResponse res = null;
            if (url.startsWith(&quot;https&quot;)) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(post);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(post);
            }
            return IOUtils.toString(res.getEntity().getContent(), &quot;UTF-8&quot;);
        } finally {
            post.releaseConnection();
            if (url.startsWith(&quot;https&quot;) &amp;&amp; client != null
                    &amp;&amp; client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
    }

/**
     * 发送一个 GET 请求
     *
     * @param url
     * @param charset
     * @param connTimeout  建立链接超时时间,毫秒.
     * @param readTimeout  响应超时时间,毫秒.
     * @return
     * @throws ConnectTimeoutException   建立链接超时
     * @throws SocketTimeoutException   响应超时
     * @throws Exception
     */
    public static String get(String url, String charset, Integer connTimeout,Integer readTimeout)
            throws ConnectTimeoutException,SocketTimeoutException, Exception {

HttpClient client = null;
        HttpGet get = new HttpGet(url);
        String result = &quot;&quot;;
        try {
            // 设置参数
            Builder customReqConf = RequestConfig.custom();
            if (connTimeout != null) {
                customReqConf.setConnectTimeout(connTimeout);
            }
            if (readTimeout != null) {
                customReqConf.setSocketTimeout(readTimeout);
            }
            get.setConfig(customReqConf.build());

HttpResponse res = null;

if (url.startsWith(&quot;https&quot;)) {
                // 执行 Https 请求.
                client = createSSLInsecureClient();
                res = client.execute(get);
            } else {
                // 执行 Http 请求.
                client = HttpClientUtils.client;
                res = client.execute(get);
            }

result = IOUtils.toString(res.getEntity().getContent(), charset);
        } finally {
            get.releaseConnection();
            if (url.startsWith(&quot;https&quot;) &amp;&amp; client != null &amp;&amp; client instanceof CloseableHttpClient) {
                ((CloseableHttpClient) client).close();
            }
        }
        return result;
    }

/**
     * 从 response 里获取 charset
     *
     * @param ressponse
     * @return
     */
    @SuppressWarnings(&quot;unused&quot;)
    private static String getCharsetFromResponse(HttpResponse ressponse) {
        // Content-Type:text/html; charset=GBK
        if (ressponse.getEntity() != null  &amp;&amp; ressponse.getEntity().getContentType() != null &amp;&amp; ressponse.getEntity().getContentType().getValue() != null) {
            String contentType = ressponse.getEntity().getContentType().getValue();
            if (contentType.contains(&quot;charset=&quot;)) {
                return contentType.substring(contentType.indexOf(&quot;charset=&quot;) + 8);
            }
        }
        return null;
    }

/**
     * 创建 SSL连接
     * @return
     * @throws GeneralSecurityException
     */
    private static CloseableHttpClient createSSLInsecureClient() throws GeneralSecurityException {
        try {
            SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
                public boolean isTrusted(X509Certificate[] chain,String authType) throws CertificateException {
                    return true;
                }
            }).build();

SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, new X509HostnameVerifier() {

@Override
                public boolean verify(String arg0, SSLSession arg1) {
                    return true;
                }

@Override
                public void verify(String host, SSLSocket ssl)
                        throws IOException {
                }

@Override
                public void verify(String host, X509Certificate cert)
                        throws SSLException {
                }

@Override
                public void verify(String host, String[] cns,
                                   String[] subjectAlts) throws SSLException {
                }

});

return HttpClients.custom().setSSLSocketFactory(sslsf).build();

} catch (GeneralSecurityException e) {
            throw e;
        }
    }

public static void main(String[] args) {
        try {
            String str= post(&quot;https://localhost:443/ssl/test.shtml&quot;,&quot;name=12&amp;page=34&quot;,&quot;application/x-www-form-urlencoded&quot;, &quot;UTF-8&quot;, 10000, 10000);
            //String str= get(&quot;https://localhost:443/ssl/test.shtml?name=12&amp;page=34&quot;,&quot;GBK&quot;);
            /*Map&lt;String,String&gt; map = new HashMap&lt;String,String&gt;();
            map.put(&quot;name&quot;, &quot;111&quot;);
            map.put(&quot;page&quot;, &quot;222&quot;);
            String str= postForm(&quot;https://localhost:443/ssl/test.shtml&quot;,map,null, 10000, 10000);*/
            System.out.println(str);
        } catch (ConnectTimeoutException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SocketTimeoutException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}</code></pre><blockquote>创建第三个工具类（JWT，将json数据转化为Token令牌）：JwtUtils.java</blockquote><pre><code class="lang-java">package cn.luocome.commonutils;

import io.jsonwebtoken.Claims;
import io.jsonwebtoken.Jws;
import io.jsonwebtoken.Jwts;
import io.jsonwebtoken.SignatureAlgorithm;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;

/**
 * @author 微风
 * @version 1.0
 * @date 2021/7/20 15:11
 */
public class JwtUtils {

public static final long EXPIRE = 1000 * 60 * 60 * 24; // 设置Token过期时间
    public static final String APP_SECRET = &quot;ukc8BDbRigUDaY6pZFfWus2jZWLPHO&quot;;// 密钥，根据这个密钥进行后期的加密（自己谁便写一个）

/**
     * 生成Token字符串的方法
     * @param id 用户id
     * @param nickname 用户昵称
     * @return
     */
    public static String getJwtToken(String id, String nickname){
        String JwtToken = Jwts.builder()
                // 设置JWT头信息
                .setHeaderParam(&quot;typ&quot;, &quot;JWT&quot;)
                .setHeaderParam(&quot;alg&quot;, &quot;HS256&quot;)
                // 设置Token的过期时间
                .setSubject(&quot;luocome-user&quot;)
                .setIssuedAt(new Date())
                .setExpiration(new Date(System.currentTimeMillis() + EXPIRE))
                // 设置Token主体部分
                .claim(&quot;id&quot;, id)
                .claim(&quot;nickname&quot;, nickname)
                // 签名哈希
                .signWith(SignatureAlgorithm.HS256, APP_SECRET)
                .compact();
        // 返回Token字符串
        return JwtToken;
    }

/**
     * 判断token是否存在与有效
     * @param jwtToken
     * @return
     */
    public static boolean checkToken(String jwtToken) {
        if(StringUtils.isEmpty(jwtToken)) return false;
        try {
            Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

/**
     * 判断token是否存在与有效
     * @param request
     * @return
     */
    public static boolean checkToken(HttpServletRequest request) {
        try {
            String jwtToken = request.getHeader(&quot;token&quot;);
            if(StringUtils.isEmpty(jwtToken)) return false;
            Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

/**
 * 根据token获取会员id
 * @param request
 * @return
 */
 public static String getMemberIdByJwtToken(HttpServletRequest request) {
 String jwtToken = request.getHeader(&quot;token&quot;);
 if(StringUtils.isEmpty(jwtToken)) return &quot;&quot;;
 Jws&lt;Claims&gt; claimsJws = Jwts.parser().setSigningKey(APP_SECRET).parseClaimsJws(jwtToken);
 Claims claims = claimsJws.getBody();
 return (String)claims.get(&quot;id&quot;);
 }
}
</code></pre><blockquote>控制层实现逻辑</blockquote><pre><code class="lang-java">package cn.luocome.educenter.controller;

import cn.luocome.baseservice.exceptionhandler.MyException;
import cn.luocome.commonutils.JwtUtils;
import cn.luocome.educenter.entity.UcenterMember;
import cn.luocome.educenter.service.UcenterMemberService;
import cn.luocome.educenter.utils.ConstantWxUtils;
import cn.luocome.educenter.utils.HttpClientUtils;
import com.google.gson.Gson;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Map;

/**
 * @author 罗裕锋
 * @version 1.0
 * @date 2021/8/14 15:21
 */

@CrossOrigin
@Controller
@RequestMapping(&quot;/api/ucenter/wx&quot;)
public class WxApiController {

@Autowired
    private UcenterMemberService ucenterMemberService;

// 生成微信扫描的二维码
    @GetMapping(&quot;login&quot;)
    public String getWxCode(){
        // 微信开放平台授权baseUrl  %s相当于占位符
        String baseUrl = &quot;https://open.weixin.qq.com/connect/qrconnect&quot; +
                &quot;?appid=%s&quot; +
                &quot;&amp;redirect_uri=%s&quot; +
                &quot;&amp;response_type=code&quot; +
                &quot;&amp;scope=snsapi_login&quot; +
                &quot;&amp;state=%s&quot; +
                &quot;#wechat_redirect&quot;;

// 对redirect_url进行URLEncoder编码
        String redirectUrl = ConstantWxUtils.WX_OPEN_REDIRECT_URL;
        try {
            redirectUrl = URLEncoder.encode(redirectUrl, &quot;utf-8&quot;);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        // 给占位符赋值
        String qrcodeUrl = String.format(
                baseUrl,
                ConstantWxUtils.WX_OPEN_APP_ID,
                redirectUrl,
                &quot;luocome&quot;
        );

// 请求微信地址（重定向到二维码生成地址中）
        return &quot;redirect:&quot; + qrcodeUrl;
    }

// 获取扫描人信息，添加数据
 @GetMapping(&quot;callback&quot;)
 public String callback(String code,String state){
 // 获取code值
 String tempCode = code;
 // 通过code值请求微信固定地址，得到accsess_token 和 openid
 String baseAccessTokenUrl = &quot;https://api.weixin.qq.com/sns/oauth2/access_token&quot; +
 &quot;?appid=%s&quot; +
 &quot;&amp;secret=%s&quot; +
 &quot;&amp;code=%s&quot; +
 &quot;&amp;grant_type=authorization_code&quot;;
 // 拼接三个参数（id，密钥和code）
 String accessTokenUrl = String.format(baseAccessTokenUrl,
 ConstantWxUtils.WX_OPEN_APP_ID,
 ConstantWxUtils.WX_OPEN_APP_SECRET,
 tempCode);
 // 请求拼接好的地址，得到accsess_token 和 openid
 // 使用Httpclient发送请求，得到返回的结果
 String accessTokenInfo = &quot;&quot;;
 try {
 accessTokenInfo = HttpClientUtils.get(accessTokenUrl);
 } catch (Exception e) {
 e.printStackTrace();
 throw new MyException(20001,&quot;登录失败&quot;);
 }
 // 从accessTokenInfo字符串中获取accsess_token 和 openid
 // 将accessTokenInfo字符串转换成map集合，通过map里面的key获取对应的值(使用Json转换工具)
 Gson gson = new Gson();
 HashMap&lt;String,String&gt; mapAccessToken = gson.fromJson(accessTokenInfo, HashMap.class);
 String accessToken = (String)mapAccessToken.get(&quot;access_token&quot;);
 String openId = (String)mapAccessToken.get(&quot;openid&quot;);
 // 将扫码人信息添加到数据库中
 // 判断数据库表中是否存在相同的微信信息（根据openid进行判断）
 UcenterMember member = ucenterMemberService.getOpenIdMember(openId);
 if (member == null) { // 表里没有该用户，进行添加数据
 // 根据accessToken和openId再去请求微信固定地址
 // 访问微信的资源服务器，获取用户信息
 String baseUserInfoUrl = &quot;https://api.weixin.qq.com/sns/userinfo&quot; +
 &quot;?access_token=%s&quot; +
 &quot;&amp;openid=%s&quot;;
 String userInfoUrl = String.format(baseUserInfoUrl, accessToken, openId);
 // 发送请求
 String userInfo = &quot;&quot;;
 try {
 userInfo = HttpClientUtils.get(userInfoUrl);
 } catch (Exception e) {
 e.printStackTrace();
 throw new MyException(20001,&quot;登录失败&quot;);
 }
 // 获取扫码人的信息
 HashMap&lt;String,String&gt; userInfoMap = gson.fromJson(userInfo, HashMap.class);
 // 获取昵称
 String nikename = (String) userInfoMap.get(&quot;nickname&quot;);
 // 获取头像
 String headimgurl = (String) userInfoMap.get(&quot;headimgurl&quot;);
 // 获取性别
 Integer sex = (int)Double.parseDouble(String.valueOf(userInfoMap.get(&quot;sex&quot;)));
 member = new UcenterMember();
 member.setOpenid(openId);
 member.setNickname(nikename);
 member.setAvatar(headimgurl);
 member.setSex(sex);
 ucenterMemberService.save(member);
 }
 // 使用JWT根据member对象生成token字符串，
 String jwtToken = JwtUtils.getJwtToken(member.getId(), member.getNickname());
 // 返回首页面，通过路径传递token字符串
 return &quot;redirect:http://localhost:3000?token=&quot; + jwtToken;
 }
}
</code></pre><blockquote>Servise层还有一个逻辑</blockquote><pre><code class="lang-java">// 判断数据库表中是否存在相同的微信信息（根据openid进行判断）
 @Override
 public UcenterMember getOpenIdMember(String openId) {
 QueryWrapper&lt;UcenterMember&gt; wrapper = new QueryWrapper&lt;&gt;();
 wrapper.eq(&quot;openid&quot;,openId);
 UcenterMember member = baseMapper.selectOne(wrapper);
 return member;
 }</code></pre>

SpringBoot整合微信登录

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

educoder-Spark机器学习

educoder-当HBase遇上MapReduce

educoder-Hbase开发批量操作

educoder-MongoDB 数据库基本操作

educoder-罗斯福国家森林树木类型识别

微风小屋安全架构升级

educoder-初识 MongoDB

记录一个关于数据库between...and语句的小问题

在Windows下Nacos服务器启动不起来，解决办法

Redis学习笔记-Bitmaps

SpringBoot整合微信登录

发表评论 取消回复 使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

SpringBoot整合微信登录

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款