java实现微信小程序服务端(登录)

系统管理员 2021-01-10 06:32 761阅读 0赞

微信小程序如今被广泛使用，微信小程序按照微信官网的定义来说就是：

微信小程序是一种全新的连接用户与服务的方式，它可以在微信内被便捷地获取和传播，同时具有出色的使用体验。

这就是微信小程序的魅力所在，有的时候我们不需要去下载过多的app，只要打开微信，就可以应用每一个服务，甚至连注册都变得简单起来，具有特别贴近人心的用户体验。

最近在做一个微信小程序的服务端，主要就是实现登录、业务账号和微信号绑定的基本功能，接下来总结一下如何实现微信小程序的服务端代码。

要去实现服务端的代码，就要先去了解客户端的请求。

微信小程序开发平台开发了很全面、功能很强大的开发API供我们使用：

[https://developers.weixin.qq.com/miniprogram/dev/api/][https_developers.weixin.qq.com_miniprogram_dev_api]

我们来看下api中的登录功能：

![1372758-20180713111904664-364330231.png][]

这个是微信小程序登录的时序图，非常明显地告知了我们微信小程序登录的请求服务调用的过程

**1.添加微信小程序固定信息**

在注册的时候，这个小程序的appId和appSecret已经知道了，还有固定的url，然后我们可以将其做为配置文件放入后台的代码中去：

![1372758-20180713112137870-1020744254.png][]

**2.根据小程序信息和code获取openId和session\_key**

在前端代码中，每当我们刚进入小程序的时候，都会去调用wx.login()方法，会得到一个code，然后发送给我们，然后，我们通过code和这些已知的参数，去调用微信的接口，去获取openId和session\_key，作为登录态的标识

/**
         * 获取微信小程序的session_key和openid
         *
         * @author hengyang4
         * @param code 微信前端login()方法返回的code
         * @return jsonObject
         *
         * */
        public JSONObject getSessionKeyAndOpenId(String code)throws Exception{
            //微信登录的code值
            String wxCode = code;
            //读取属性文件
            ResourceBundle resourceBundle = ResourceBundle.getBundle("weixin");
            //服务器端调用接口的url
            String requestUrl = resourceBundle.getString("url");
            //封装需要的参数信息
            Map<String,String> requestUrlParam = new HashMap<String,String>();
            //开发者设置中的appId
            requestUrlParam.put("appid",resourceBundle.getString("appId"));
            //开发者设置中的appSecret
            requestUrlParam.put("secret",resourceBundle.getString("appSecret"));
            //小程序调用wx.login返回的code
            requestUrlParam.put("js_code", wxCode);
            //默认参数
            requestUrlParam.put("grant_type", "authorization_code");
    
            JSONObject jsonObject = JSON.parseObject(sendPost(requestUrl,requestUrlParam));
            return jsonObject;
        }
    
        /**
         * 向指定 URL 发送POST方法的请求
         *
         * @param url 发送请求的 URL
         * @return 所代表远程资源的响应结果
         */
        public String sendPost(String url, Map<String, ?> paramMap) {
            PrintWriter out = null;
            BufferedReader in = null;
            String result = "";
    
            String param = "";
            Iterator<String> it = paramMap.keySet().iterator();
    
            while(it.hasNext()) {
                String key = it.next();
                param += key + "=" + paramMap.get(key) + "&";
            }
    
            try {
                URL realUrl = new URL(url);
                // 打开和URL之间的连接
                URLConnection conn = realUrl.openConnection();
                // 设置通用的请求属性
                conn.setRequestProperty("accept", "*/*");
                conn.setRequestProperty("connection", "Keep-Alive");
                conn.setRequestProperty("Accept-Charset", "utf-8");
                conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
                // 发送POST请求必须设置如下两行
                conn.setDoOutput(true);
                conn.setDoInput(true);
                // 获取URLConnection对象对应的输出流
                out = new PrintWriter(conn.getOutputStream());
                // 发送请求参数
                out.print(param);
                // flush输出流的缓冲
                out.flush();
                // 定义BufferedReader输入流来读取URL的响应
                in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
                String line;
                while ((line = in.readLine()) != null) {
                    result += line;
                }
            } catch (Exception e) {
                log.error(e.getMessage(),e);
            }
            //使用finally块来关闭输出流、输入流
            finally{
                try{
                    if(out!=null){
                        out.close();
                    }
                    if(in!=null){
                        in.close();
                    }
                }
                catch(IOException ex){
                    ex.printStackTrace();
                }
            }
            return result;
        }

**3. 将openId和session\_key生成sessionId返回客户端**

第三方服务器端拿到请求回来的session\_key和openid，先留着，不能给客户端；然后用操作系统提供的真正随机数算法生成一个新的session，叫session\_id

·　所以，每次前端wx.login()后调用的服务端的controller我们就应该这样写：

@RequestMapping(value = "/loginByWeixin", produces = "application/json;charset=UTF-8")
        public String loginByWeixin(@RequestParam("code") String code) throws Exception{
            //得到用户的openId + sessionKey
            JSONObject jsonObject = getSessionKeyAndOpenId(code);
            log.info(jsonObject.toString());
            System.out.println(jsonObject);
            String openId = jsonObject.getString("openid");
    
            String sessionKey = jsonObject.getString("session_key");
            //组装结果
            Map<String,Object> resMap = new HashMap<String,Object>();
            //判断openId是否存在用户表中
            UserInfo userInfo = userInfoMapper.selectByUserName(openId);
            if(ValidateUtil.isEmpty(userInfo)){
                //不存在该用户关联关系
                log.info("验证是否绑定微信","未登录");
                resMap.put("code",ErrorCode.ERR_WEIXIN_USER_EMPTY.getErrorCode());
                resMap.put("desc",ErrorCode.ERR_WEIXIN_USER_EMPTY.getErrorMessage());
            }else {
                //组装结果
                log.info("验证是否绑定微信", "用户查询成功");
                //0:操作成功
                resMap.put("code", ErrorCode.ERR_SUCCEED.getErrorCode());
                resMap.put("desc", ErrorCode.ERR_SUCCEED.getErrorMessage());
                resMap.put("userInfo", userInfo);
            }
            //将通过md5生成sessionId（一般是用个操作系统提供的真正随机数算法生成新的session）
            String sessionId = MD5.EncodeByMd5(openId+sessionKey+ DateUtil.getNowTime());
            jedisCache.hashSet(sessionId,"ses",openId);
            resMap.put("sessionId",sessionId);
            return JSONConvertor.toJSON(resMap);
    
        }

**4. 使用过滤器过滤请求头中含有session\_id的请求**

然后我们将session\_id为key，微信服务端返回的openId为值，保存起来，这里我们用了redis去缓存这个session信息，openId为我们系统用户与微信绑定的标识

接下来，我们每次请求的时候，都会将session\_id放入请求头中去，然后判断在redis中是否有key为该值得键值对，从而判断用户session是否失效

我们这里使用了过滤器来拦截用户请求

public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)throws IOException,ServletException{
            //设置跨域请求
            HttpServletResponse resp = (HttpServletResponse)response;
            resp.setHeader("Access-Control-Allow-Origin", "*");
    
            HttpServletRequest req = (HttpServletRequest)request;
            //获取请求时的sessionId
            String sessionId = req.getHeader("sessionId");
            if(StrUtil.IsNullOrEmpty(sessionId)){
                //该请求不需要验证session,直接通过
                log.info("sessionId过滤","该请求不需要过滤，通过");
                chain.doFilter(request,response);
                return;
            }else {
                //只有在缓存中存在该sessionId才能进行请求
                if (!jedisCache.existKey(sessionId)) {
                    // 登录信息已过期，请重新登录
                    log.info("sessionId过滤", "登录信息失效，请重新登录");
                    response.getWriter().write("登录信息失效，请重新登录");
                    return;
                }
    
                log.info("sessionId过滤", "session验证成功");
                chain.doFilter(request, response);
            }
        }

**5. 在数据库中建立用户与微信用户唯一标识的关联关系**

每当用户注册或者登陆时，请求中都会含有session\_id，然后我们将session\_id作为key去redis中查找，得到value值，也就是我们之前存的openId，然后我们将openId和用户信息进行数据库表中的关联，之后，我们调用登陆方法的时候，如果该openId有关联的用户信息，则不需要去登录，直接给前端返回用户信息即可，就是我们之前的那段代码：

![1372758-20180713115000407-910463471.png][]

**在这里，我们的微信小程序服务端代码就基本实现了，可以用于微信小程序与业务系统的登录，微信小程序的功能还有很多，之后我们有机会多去试一下其他功能，感受小程序的强大和快捷。**

[https_developers.weixin.qq.com_miniprogram_dev_api]: https://developers.weixin.qq.com/miniprogram/dev/api/
[1372758-20180713111904664-364330231.png]: /images/1610260344913.png
[1372758-20180713112137870-1020744254.png]: /images/1610260324842.png
[1372758-20180713115000407-910463471.png]: /images/1610260305174.png