Java를 사용하여 WeChat 액세스 및 양식 데이터에 대한 메시지 푸시 기능 구현

public class WeChatServlet extends HttpServlet { private static final String TOKEN = "your_token"; protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { //验证请求是否来自微信服务器 String signature = request.getParameter("signature"); String timestamp = request.getParameter("timestamp"); String nonce = request.getParameter("nonce"); String echostr = request.getParameter("echostr"); String[] arr = {TOKEN, timestamp, nonce}; //字典排序 Arrays.sort(arr); StringBuilder sb = new StringBuilder(); for (String s : arr) { sb.append(s); } String tempStr = SHA1.encode(sb.toString()); //验证签名 if (tempStr.equals(signature)) { //接收并处理消息 //... } //返回验证结果 PrintWriter out = response.getWriter(); out.print(echostr); out.close(); } }

public class AccessTokenUtil { private static final String APPID = "your_appid"; private static final String APPSECRET = "your_appsecret"; private static String access_token = null; private static long expires_time = 0; public static String getAccessToken() { if (access_token == null || System.currentTimeMillis() >= expires_time) { String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + APPID + "&secret=" + APPSECRET; String result = HttpUtil.sendGet(url); JSONObject jsonObject = JSONObject.parseObject(result); access_token = jsonObject.getString("access_token"); int expires_in = jsonObject.getIntValue("expires_in"); expires_time = System.currentTimeMillis() + (expires_in - 200) * 1000; } return access_token; } }

public class MessageUtil { public static void sendMessage(String openid, String message) { String url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=" + AccessTokenUtil.getAccessToken(); JSONObject jsonObject = new JSONObject(); jsonObject.put("touser", openid); jsonObject.put("msgtype", "text"); JSONObject text = new JSONObject(); text.put("content", message); jsonObject.put("text", text); String result = HttpUtil.sendPost(url, jsonObject.toJSONString()); } }

public void handleMessage(HttpServletRequest request) { //获取用户输入的表单数据 String name = request.getParameter("name"); String email = request.getParameter("email"); String message = request.getParameter("message"); //整合表单数据 StringBuilder sb = new StringBuilder(); sb.append("姓名：").append(name).append(" "); sb.append("邮箱：").append(email).append(" "); sb.append("留言：").append(message); //将整合后的数据推送给目标 MessageUtil.sendMessage(target_openid, sb.toString()); }