基于springboot微信公众号开发(微信自动回复)

效果图

1.准备工作

申请微信订阅号(个人只能申请订阅号,而且没什么功能,也无法认证),申请完毕,点击开发=>基本配置,如下图:

服务器配置需要有域名 80端口,我猜你没有,这里推荐个实用工具,pagekite,下载链接,

这个工具需要 python2.7以上环境,还有邮箱一个,一个邮箱一个月,邮箱这东西大家懂得,

用pagekite申请完域名,就可以用自己的电脑做订阅号服务器了.

2.服务器代码

创建个springboot工程

pom.xml


    UTF-8
    UTF-8
    1.8
  
  
    org.springframework.boot
    spring-boot-starter-parent
    1.5.9.RELEASE
  


  
    
      org.springframework.boot
      spring-boot-starter-web
    
    
    
      org.springframework.boot
      spring-boot-starter-thymeleaf
    
    
    
      net.sourceforge.nekohtml
      nekohtml
      1.9.22
    
　　　　
			　　　　　　dom4j
			　　　　　　dom4j
			　　　　　　1.6.1
		　　　　
  
  
    
      
 org.springframework.boot
 spring-boot-maven-plugin

入口类

@SpringBootApplication
public class WeChatApplication {

  public static void main(String[] args) {
    SpringApplication.run(WeChatApplication.class, args);
    System.out.println("====启动成功====");
  }

}

application.properties,配置server.port=80

Controller,这个是处理微信请求,get方法就是微信公众平台服务器配置url请求的路径,post是处理用户事件

@RestController
public class WeChatController {
  @Autowired
  private WeChatService weChatService;
  
  @GetMapping(value = "wechat")
  public String validate(@RequestParam(value = "signature") String signature,
      @RequestParam(value = "timestamp") String timestamp, 
      @RequestParam(value = "nonce") String nonce,
      @RequestParam(value = "echostr") String echostr) {
    return WeChatUtil.checkSignature(signature, timestamp, nonce) ? echostr : null;

  }
  
  @PostMapping(value = "wechat")
  public String processMsg(HttpServletRequest request) {
    // 调用核心服务类接收处理请求
    return weChatService.processRequest(request);    
  }
}

Service,处理post请求


@Service
public class WeChatServiceImpl implements WeChatService{
  @Autowired
  private FeignUtil feignUtil;
  @Autowired
  private RedisUtils redisUtils;
  public String processRequest(HttpServletRequest request) {
    // xml格式的消息数据
    String respXml = null;
    // 默认返回的文本消息内容
    String respContent;
    try {
      // 调用parseXml方法解析请求消息
      Map requestMap = WeChatUtil.parseXml(request);
// 消息类型
      String msgType = (String) requestMap.get(WeChatContant.MsgType);
      String mes = null;
      // 文本消息
      if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_TEXT)) {
 mes =requestMap.get(WeChatContant.Content).toString();
 if(mes!=null&&mes.length()<2){
   List items = new ArrayList<>();
   ArticleItem item = new ArticleItem();
   item.setTitle("照片墙");
   item.setDescription("阿狸照片墙");
   item.setPicUrl("http://changhaiwx.pagekite.me/photo-wall/a/iali11.jpg");
   item.setUrl("http://changhaiwx.pagekite.me/page/photowall");
   items.add(item);
   
   item = new ArticleItem();
   item.setTitle("哈哈");
   item.setDescription("一张照片");
   item.setPicUrl("http://changhaiwx.pagekite.me/images/me.jpg");
   item.setUrl("http://changhaiwx.pagekite.me/page/index");
   items.add(item);
   
   item = new ArticleItem();
   item.setTitle("小游戏2048");
   item.setDescription("小游戏2048");
   item.setPicUrl("http://changhaiwx.pagekite.me/images/2048.jpg");
   item.setUrl("http://changhaiwx.pagekite.me/page/game2048");
   items.add(item);
   
   item = new ArticleItem();
   item.setTitle("百度");
   item.setDescription("百度一下");
   item.setPicUrl("https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1505100912368&di=69c2ba796aa2afd9a4608e213bf695fb&imgtype=0&src=http%3A%2F%2Ftx.haiqq.com%2Fuploads%2Fallimg%2F170510%2F0634355517-9.jpg");
   item.setUrl("http://www.baidu.com");
   items.add(item);
   
   respXml = WeChatUtil.sendArticleMsg(requestMap, items);
 }else if("我的信息".equals(mes)){
   Map userInfo = getUserInfo(requestMap.get(WeChatContant.FromUserName));
   System.out.println(userInfo.toString());
   String nickname = userInfo.get("nickname");
   String city = userInfo.get("city");
   String province = userInfo.get("province");
   String country = userInfo.get("country");
   String headimgurl = userInfo.get("headimgurl");
   List items = new ArrayList<>();
   ArticleItem item = new ArticleItem();
   item.setTitle("你的信息");
   item.setDescription("昵称:"+nickname+" 地址:"+country+" "+province+" "+city);
   item.setPicUrl(headimgurl);
   item.setUrl("http://www.baidu.com");
   items.add(item);
   
   respXml = WeChatUtil.sendArticleMsg(requestMap, items);
 }
      }
      // 图片消息
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_IMAGE)) {
 respContent = "您发送的是图片消息！";
 respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
      }
      // 语音消息
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_VOICE)) {
 respContent = "您发送的是语音消息！";
 respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
      }
      // 视频消息
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_VIDEO)) {
 respContent = "您发送的是视频消息！";
 respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
      }
      // 地理位置消息
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_LOCATION)) {
 respContent = "您发送的是地理位置消息！";
 respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
      }
      // 链接消息
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_link)) {
 respContent = "您发送的是链接消息！";
 respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
      }
      // 事件推送
      else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_EVENT)) {
 // 事件类型
 String eventType = (String) requestMap.get(WeChatContant.Event);
 // 关注
 if (eventType.equals(WeChatContant.EVENT_TYPE_SUBSCRIBE)) {
   respContent = "谢谢您的关注！";
   respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
 }
 // 取消关注
 else if (eventType.equals(WeChatContant.EVENT_TYPE_UNSUBSCRIBE)) {
   // TODO 取消订阅后用户不会再收到公众账号发送的消息，因此不需要回复
 }
 // 扫描带参数二维码
 else if (eventType.equals(WeChatContant.EVENT_TYPE_SCAN)) {
   // TODO 处理扫描带参数二维码事件
 }
 // 上报地理位置
 else if (eventType.equals(WeChatContant.EVENT_TYPE_LOCATION)) {
   // TODO 处理上报地理位置事件
 }
 // 自定义菜单
 else if (eventType.equals(WeChatContant.EVENT_TYPE_CLICK)) {
   // TODO 处理菜单点击事件
 }
      }
      mes = mes == null ? "不知道你在干嘛" : mes;
      if(respXml == null)
 respXml = WeChatUtil.sendTextMsg(requestMap, mes);
      System.out.println(respXml);
      return respXml;
    } catch (Exception e) {
      e.printStackTrace();
    }
    return "";
    
  }
}

微信工具类(只写了回复文本消息,和图文消息,其他的都是大同小异)

package com.wechat.util;

import java.io.InputStream;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import org.dom4j.document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

import com.wechat.bean.ArticleItem;


public class WeChatUtil {  

  
  public static boolean checkSignature(String signature, String timestamp, String nonce) {
    String[] arr = new String[] { WeChatContant.TOKEN, timestamp, nonce };
    // 将token、timestamp、nonce三个参数进行字典序排序
    // Arrays.sort(arr);
    sort(arr);
    StringBuilder content = new StringBuilder();
    for (int i = 0; i < arr.length; i++) {
      content.append(arr[i]);
    }
    MessageDigest md = null;
    String tmpStr = null;

    try {
      md = MessageDigest.getInstance("SHA-1");
      // 将三个参数字符串拼接成一个字符串进行sha1加密
      byte[] digest = md.digest(content.toString().getBytes());
      tmpStr = byteToStr(digest);
    } catch (NoSuchAlgorithmException e) {
      e.printStackTrace();
    }

    content = null;
    // 将sha1加密后的字符串可与signature对比，标识该请求来源于微信
    return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;
  }

  
  private static String byteToStr(byte[] byteArray) {
    String strDigest = "";
    for (int i = 0; i < byteArray.length; i++) {
      strDigest += byteToHexStr(byteArray[i]);
    }
    return strDigest;
  }

  
  private static String byteToHexStr(byte mByte) {
    char[] Digit = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };
    char[] tempArr = new char[2];
    tempArr[0] = Digit[(mByte >>> 4) & 0x0F];
    tempArr[1] = Digit[mByte & 0x0F];

    String s = new String(tempArr);
    return s;
  }

  private static void sort(String a[]) {
    for (int i = 0; i < a.length - 1; i++) {
      for (int j = i + 1; j < a.length; j++) {
 if (a[j].compareTo(a[i]) < 0) {
   String temp = a[i];
   a[i] = a[j];
   a[j] = temp;
 }
      }
    }
  }

  
  @SuppressWarnings({ "unchecked"})
  public static Map parseXml(HttpServletRequest request) throws Exception {
    // 将解析结果存储在HashMap中
    Map map = new HashMap();

    // 从request中取得输入流
    InputStream inputStream = request.getInputStream();
    // 读取输入流
    SAXReader reader = new SAXReader();
    document document = reader.read(inputStream);
    // 得到xml根元素
    Element root = document.getRootElement();
    // 得到根元素的所有子节点
    List elementList = root.elements();
    // 遍历所有子节点
    for (Element e : elementList)
      map.put(e.getName(), e.getText());

    // 释放资源
    inputStream.close();
    inputStream = null;
    return map;
  }

  public static String mapToXML(Map map) {
    StringBuffer sb = new StringBuffer();
    sb.append("");
    mapToXML2(map, sb);
    sb.append("");
    try {
      return sb.toString();
    } catch (Exception e) {
    }
    return null;
  }

  private static void mapToXML2(Map map, StringBuffer sb) {
    Set set = map.keySet();
    for (Iterator it = set.iterator(); it.hasNext();) {
      String key = (String) it.next();
      Object value = map.get(key);
      if (null == value)
 value = "";
      if (value.getClass().getName().equals("java.util.ArrayList")) {
 ArrayList list = (ArrayList) map.get(key);
 sb.append("<" + key + ">");
 for (int i = 0; i < list.size(); i++) {
   HashMap hm = (HashMap) list.get(i);
   mapToXML2(hm, sb);
 }
 sb.append("");

      } else {
 if (value instanceof HashMap) {
   sb.append("<" + key + ">");
   mapToXML2((HashMap) value, sb);
   sb.append("");
 } else {
   sb.append("<" + key + ">");
 }

      }

    }
  }
  
   public static String sendTextMsg(Map requestMap,String content){
    
    Map map=new HashMap();
    map.put("ToUserName", requestMap.get(WeChatContant.FromUserName));
    map.put("FromUserName", requestMap.get(WeChatContant.ToUserName));
    map.put("MsgType", WeChatContant.RESP_MESSAGE_TYPE_TEXT);
    map.put("CreateTime", new Date().getTime());
    map.put("Content", content);
    return mapToXML(map);
  }
   
  public static String sendArticleMsg(Map requestMap,List items){
    if(items == null || items.size()<1){
      return "";
    }
    Map map=new HashMap();
    map.put("ToUserName", requestMap.get(WeChatContant.FromUserName));
    map.put("FromUserName", requestMap.get(WeChatContant.ToUserName));
    map.put("MsgType", "news");
    map.put("CreateTime", new Date().getTime());
    List> Articles=new ArrayList>(); 
    for(ArticleItem itembean : items){
      Map item=new HashMap();
      Map itemContent=new HashMap();
      itemContent.put("Title", itembean.getTitle());
      itemContent.put("Description", itembean.getDescription());
      itemContent.put("PicUrl", itembean.getPicUrl());
      itemContent.put("Url", itembean.getUrl());
      item.put("item",itemContent);
      Articles.add(item);
    }
    map.put("Articles", Articles);
    map.put("ArticleCount", Articles.size());
    return mapToXML(map);
  }
  
}

微信常量

public class WeChatContant {
   //APPID
  public static final String appID = "appid";
  //appsecret
  public static final String appsecret = "appsecret";
  // Token
  public static final String TOKEN = "zch";
  public static final String RESP_MESSAGE_TYPE_TEXT = "text";
  public static final Object REQ_MESSAGE_TYPE_TEXT = "text";
  public static final Object REQ_MESSAGE_TYPE_IMAGE = "image";
  public static final Object REQ_MESSAGE_TYPE_VOICE = "voice";
  public static final Object REQ_MESSAGE_TYPE_VIDEO = "video";
  public static final Object REQ_MESSAGE_TYPE_LOCATION = "location";
  public static final Object REQ_MESSAGE_TYPE_link = "link";
  public static final Object REQ_MESSAGE_TYPE_EVENT = "event";
  public static final Object EVENT_TYPE_SUBSCRIBE = "SUBSCRIBE";
  public static final Object EVENT_TYPE_UNSUBSCRIBE = "UNSUBSCRIBE";
  public static final Object EVENT_TYPE_SCAN = "SCAN";
  public static final Object EVENT_TYPE_LOCATION = "LOCATION";
  public static final Object EVENT_TYPE_CLICK = "CLICK";
  
  public static final String FromUserName = "FromUserName";
  public static final String ToUserName = "ToUserName";
  public static final String MsgType = "MsgType";
  public static final String Content = "Content";
  public static final String Event = "Event";
  
}

图文消息实体bean

public class ArticleItem {
  private String Title;
  private String Description;
  private String PicUrl;
  private String Url;
  public String getTitle() {
    return Title;
  }
  public void setTitle(String title) {
    Title = title;
  }
  public String getDescription() {
    return Description;
  }
  public void setDescription(String description) {
    Description = description;
  }
  public String getPicUrl() {
    return PicUrl;
  }
  public void setPicUrl(String picUrl) {
    PicUrl = picUrl;
  }
  public String getUrl() {
    return Url;
  }
  public void setUrl(String url) {
    Url = url;
  }
  
}

好了运行项目,在公众平台配置好url,个人订阅号完成.

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。

基于springboot微信公众号开发(微信自动回复)

Java相关栏目本月热门文章