微信小程序之无需服务端支持实现内容安全检查

Posted 2023-03-18

参考技术A

微信小程序审核未通过，原因如下：

一个平平无奇的小程序，在一次平平无奇的升级优化过程中，竟然审核未通过，很奇怪的是之前的升级过程中一直没有此问题！不过，出了问题总要解决的，好在未通过原因中给出了解决办法：“可以调用小程序内容安全API，或使用其他技术”。既然小程序提供了现成的API，那就撸TA……

首先在微信小程序开发文档中搜索关键词： 内容安全 ，可以发现微信还是很人性化的，提供了 云调用 的调用方式来进行违法违规检查，不需要服务端的支持，这样对前端的同学还是非常友好的。 内容安全文档地址

开通云开发请参考微信官方文档： 云开发 。

开通云开发，默认使用 基础版1 ，如无特殊业务要求，使用此版本即可，是免费的哦~

云开发要求创建环境，留意此处的环境ID，在小程序调用云函数的时候会用到。

在小程序项目目录下新建云函数目录 cloudfunctions ，并在 project.config.json 中注册该目录，注册后该目录会显示有云图标，如图所示：

在云函数根目录下新建云函数 msgSecCheck ，云函数新建成功后，会生成固定的目录结构，如图所示：

在云函数中调用内容安全检查的API，并对结果进行处理。

根据官方文档要求：

在云函数 msgSecCheck 目录下新建 config.json 文件，配置云调用权限，如图所示：

完成后的云函数如果不上传并部署的话，小程序是无法调用的，所以云函数有改动的话， 务必及时上传并部署 。

小程序调用云函数，此处的 env 的值就是上文中说到的环境ID， name 的值是新建的云函数的文件名。

至此，大功告成！

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

　　　　　　　　　　　　　　　　　　　　　　　　　　　　

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

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

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

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

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

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

　　　https://developers.weixin.qq.com/miniprogram/dev/api/

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

　　　

 

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

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

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

　　

 

　　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有关联的用户信息，则不需要去登录，直接给前端返回用户信息即可，就是我们之前的那段代码：

　　

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