调用微信的内容安全接口（java实现）

以你之姓@ 2022-12-29 14:18 180阅读 0赞

# 调用微信的内容安全接口（java实现） #

文本内容安全接口参考链接：[https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/sec-check/security.msgSecCheck.html ][https_developers.weixin.qq.com_miniprogram_dev_api-backend_open-api_sec-check_security.msgSecCheck.html]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70_pic_center]

> 小程序出于安全考虑，api.weixin.qq.com 不能被配置为服务器域名，相关API也不能在小程序内调用。 开发者应将AppSecret保存到后台服务器中，通过服务器使用 getAccessToken 接口获取access\_token，并调用相关 API。

在微信小程序的request合法域名不包括https://api.weixin.qq.com，含有输入文本的小程序通过审核的前提是要调用文本内容安全接口，由于不能直接在小程序调用，所以需要自己发布到云服务器中运行。下面来看看具体步骤：

*  在调用文本内容安全接口首先要获取access\_token（接口调用凭证）。  
    接口调用凭证参考链接：[https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/access-token/auth.getAccessToken.html][https_developers.weixin.qq.com_miniprogram_dev_api-backend_open-api_access-token_auth.getAccessToken.html]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70_pic_center 1]
 *  access\_token的请求地址含有三个必填参数，其中的grant\_type为client\_credential，appid和secret在开发管理→开发设置中查看。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70]
 *  通过https://api.weixin.qq.com/cgi-bin/token?grant\_type=client\_credential&appid=APPID&secret=APPSECRET  
    获取到access\_token（接口调用凭证）后注意：access\_token（接口调用凭证）会过期，应动态获取access\_token（接口调用凭证）。调用内容安全接口使用过期的access\_token（接口调用凭证）会返回errcode（错误码）42001。  
    ![在这里插入图片描述][20201223144901482.png]

### Java实现： ###

package com.zxx.web;
    
    import java.io.UnsupportedEncodingException;
    
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import com.zxx.util.HttpUtil;
    import com.alibaba.fastjson.JSONObject;
    
    @Controller
    @RequestMapping("/app/wxqqapi")
    public class WxQqApiController { 
    	private String url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token=";
    	
    	@ResponseBody
    	@RequestMapping(value = "/getData", produces = "application/json;charset=UTF-8")
    	public Object getData(String content) throws UnsupportedEncodingException{ 
            JSONObject json = new JSONObject();
            json.put("content", content);
            String result = HttpUtil.doPost(url, json.toJSONString());
    		String errcode = result.toString().split(",")[0].split(":")[1];
    		//过期access_token（42001）；没有access_token（41001）；无效access_token（40001）
    		if(Integer.parseInt(errcode) == 42001 || Integer.parseInt(errcode) == 41001 || Integer.parseInt(errcode) == 40001) { 
    			//重新获取access_token(接口调用凭证)
    			System.out.println("重新获取access_token(接口调用凭证)");
    			Object access = HttpUtil.doGet("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=开发设置中的AppID&secret=开发设置中的AppSecret");//
    			String access_token = access.toString().split(",")[0].split(":")[1];
    			access_token = access_token.substring(1,access_token.length()-1);
    			url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token="+access_token;
    			result = HttpUtil.doPost(url,json.toJSONString());
    		}
    	    return result;
    	}
    }

### http请求公共类： ###

package com.zxx.util;
    
    import org.apache.log4j.Logger;
    
    import java.io.*;
    import java.net.HttpURLConnection;
    import java.net.MalformedURLException;
    import java.net.URL;
    import java.util.*;
    
    public class HttpUtil { 
    	static Logger log = Logger.getLogger(HttpUtil.class);
    	 
        /** * 向指定URL发送GET方法的请求 * * @param httpurl * 请求参数用?拼接在url后边，请求参数应该是 name1=value1&name2=value2 的形式。 * @return result 所代表远程资源的响应结果 */
        public static String doGet(String httpurl) { 
            HttpURLConnection connection = null;
            InputStream is = null;
            BufferedReader br = null;
            String result = null;// 返回结果字符串
            try { 
                // 创建远程url连接对象
                URL url = new URL(httpurl);
                // 通过远程url连接对象打开一个连接，强转成httpURLConnection类
                connection = (HttpURLConnection) url.openConnection();
                // 设置连接方式：get
                connection.setRequestMethod("GET");
                // 设置连接主机服务器的超时时间：15000毫秒
                connection.setConnectTimeout(15000);
                // 设置读取远程返回的数据时间：60000毫秒
                connection.setReadTimeout(60000);
                // 发送请求
                connection.connect();
                // 通过connection连接，获取输入流
                if (connection.getResponseCode() == 200) { 
                    is = connection.getInputStream();
                    // 封装输入流is，并指定字符集
                    br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
                    // 存放数据
                    StringBuffer sbf = new StringBuffer();
                    String temp = null;
                    while ((temp = br.readLine()) != null) { 
                        sbf.append(temp);
                        sbf.append("\r\n");
                    }
                    result = sbf.toString();
                }
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            } finally { 
                // 关闭资源
                if (null != br) { 
                    try { 
                        br.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
     
                if (null != is) { 
                    try { 
                        is.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
     
                connection.disconnect();// 关闭远程连接
            }
     
            return result;
        }
     
        /** * 向指定 URL 发送POST方法的请求 * * @param httpUrl * 发送请求的 URL * @param param * 请求参数应该是{"key":"参数"}的形式。 * @return 所代表远程资源的响应结果 */
        public static String doPost(String httpUrl, String param) { 
     
            HttpURLConnection connection = null;
            InputStream is = null;
            OutputStream os = null;
            BufferedReader br = null;
            String result = null;
            try { 
                URL url = new URL(httpUrl);
                // 通过远程url连接对象打开连接
                connection = (HttpURLConnection) url.openConnection();
                // 设置连接请求方式
                connection.setRequestMethod("POST");
                // 设置连接主机服务器超时时间：15000毫秒
                connection.setConnectTimeout(15000);
                // 设置读取主机服务器返回数据超时时间：60000毫秒
                connection.setReadTimeout(60000);
     
                // 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true
                connection.setDoOutput(true);
                // 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无
                connection.setDoInput(true);
                // 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。
                connection.setRequestProperty("Content-Type", "application/json");
                // 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0
                //connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
                // 通过连接对象获取一个输出流
                os = connection.getOutputStream();
                // 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的
                os.write(param.getBytes());
                // 通过连接对象获取一个输入流，向远程读取
                if (connection.getResponseCode() == 200) { 
     
                    is = connection.getInputStream();
                    // 对输入流对象进行包装:charset根据工作项目组的要求来设置
                    br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
     
                    StringBuffer sbf = new StringBuffer();
                    String temp = null;
                    // 循环遍历一行一行读取数据
                    while ((temp = br.readLine()) != null) { 
                        sbf.append(temp);
                        sbf.append("\r\n");
                    }
                    result = sbf.toString();
                }
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            } finally { 
                // 关闭资源
                if (null != br) { 
                    try { 
                        br.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                if (null != os) { 
                    try { 
                        os.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                if (null != is) { 
                    try { 
                        is.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                // 断开与远程地址url的连接
                connection.disconnect();
            }
            return result;
        }
     
        /** * * @param httpUrl 请求的url * @param param form表单的参数（key,value形式） * @return */
        public static String doPostForm(String httpUrl, Map param) { 
     
            HttpURLConnection connection = null;
            InputStream is = null;
            OutputStream os = null;
            BufferedReader br = null;
            String result = null;
            try { 
                URL url = new URL(httpUrl);
                // 通过远程url连接对象打开连接
                connection = (HttpURLConnection) url.openConnection();
                // 设置连接请求方式
                connection.setRequestMethod("POST");
                // 设置连接主机服务器超时时间：15000毫秒
                connection.setConnectTimeout(15000);
                // 设置读取主机服务器返回数据超时时间：60000毫秒
                connection.setReadTimeout(60000);
     
                // 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true
                connection.setDoOutput(true);
                // 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无
                connection.setDoInput(true);
                // 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。
                connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
                // 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0
                //connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
                // 通过连接对象获取一个输出流
                os = connection.getOutputStream();
                // 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的(form表单形式的参数实质也是key,value值的拼接，类似于get请求参数的拼接)
                os.write(createLinkString(param).getBytes());
                // 通过连接对象获取一个输入流，向远程读取
                if (connection.getResponseCode() == 200) { 
     
                    is = connection.getInputStream();
                    // 对输入流对象进行包装:charset根据工作项目组的要求来设置
                    br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
     
                    StringBuffer sbf = new StringBuffer();
                    String temp = null;
                    // 循环遍历一行一行读取数据
                    while ((temp = br.readLine()) != null) { 
                        sbf.append(temp);
                        sbf.append("\r\n");
                    }
                    result = sbf.toString();
                }
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            } finally { 
                // 关闭资源
                if (null != br) { 
                    try { 
                        br.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                if (null != os) { 
                    try { 
                        os.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                if (null != is) { 
                    try { 
                        is.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                // 断开与远程地址url的连接
                connection.disconnect();
            }
            return result;
        }
        /** * 把数组所有元素排序，并按照“参数=参数值”的模式用“&”字符拼接成字符串 * @param params 需要排序并参与字符拼接的参数组 * @return 拼接后字符串 */
        public static String createLinkString(Map<String, String> params) { 
     
            List<String> keys = new ArrayList<String>(params.keySet());
            Collections.sort(keys);
     
            StringBuilder prestr = new StringBuilder();
            for (int i = 0; i < keys.size(); i++) { 
                String key = keys.get(i);
                String value = params.get(key);
                if (i == keys.size() - 1) { // 拼接时，不包括最后一个&字符
                    prestr.append(key).append("=").append(value);
                } else { 
                	prestr.append(key).append("=").append(value).append("&");
                }
            }
            return prestr.toString();
        }
    }

### 调用结果 ###

返回的errcode为0表示内容正常。  
![在这里插入图片描述][20201223153453826.png_pic_center]  
最后把代码打包放在的https服务器上运行，供小程序调用。

[https_developers.weixin.qq.com_miniprogram_dev_api-backend_open-api_sec-check_security.msgSecCheck.html]: https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/sec-check/security.msgSecCheck.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/3d0084981c474c3caae9df3e76c965dd.png
[https_developers.weixin.qq.com_miniprogram_dev_api-backend_open-api_access-token_auth.getAccessToken.html]: https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/access-token/auth.getAccessToken.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/517c3c3e2aab46a5be9ef27546b6908b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU0NzU5OQ_size_16_color_FFFFFF_t_70]: /images/20221120/01a27fb7d1454edfb5b0da56d1bf48a5.png
[20201223144901482.png]: /images/20221120/7715579fcbcd42e5bdd9ecf5c5f0a17d.png
[20201223153453826.png_pic_center]: /images/20221120/3bbe0d1acebe47549fe2807ef56b8657.png