基于springboot微信公眾號(hào)開(kāi)發(fā)(微信自動(dòng)回復(fù))
更新時(shí)間：2019年11月07日 15:09:50 作者：若星漢浮云
這篇文章主要介紹了基于springboot微信公眾號(hào)開(kāi)發(fā)(微信自動(dòng)回復(fù)),文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
效果圖
1.準(zhǔn)備工作
申請(qǐng)微信訂閱號(hào)(個(gè)人只能申請(qǐng)訂閱號(hào),而且沒(méi)什么功能,也無(wú)法認(rèn)證),申請(qǐng)完畢,點(diǎn)擊 開(kāi)發(fā)=>基本配置,如下圖:
服務(wù)器配置需要有 域名 80端口,我猜你沒(méi)有,這里推薦個(gè)實(shí)用工具,pagekite,下載鏈接,
這個(gè)工具需要 python2.7以上環(huán)境,還有郵箱一個(gè),一個(gè)郵箱一個(gè)月,郵箱這東西大家懂得,
用pagekite申請(qǐng)完域名,就可以用自己的電腦做訂閱號(hào)服務(wù)器了.
2.服務(wù)器代碼
創(chuàng)建個(gè)springboot工程
pom.xml
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.9.RELEASE</version>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<!-- 使thymeleaf支持h5標(biāo)簽 -->
<dependency>
<groupId>net.sourceforge.nekohtml</groupId>
<artifactId>nekohtml</artifactId>
<version>1.9.22</version>
</dependency>
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
入口類(lèi)
@SpringBootApplication
public class WeChatApplication {
public static void main(String[] args) {
SpringApplication.run(WeChatApplication.class, args);
System.out.println("====啟動(dòng)成功====");
}
}
application.properties,配置server.port=80
Controller,這個(gè)是處理微信請(qǐng)求,get方法就是微信公眾平臺(tái) 服務(wù)器配置url請(qǐng)求的路徑,post是處理用戶事件
@RestController
public class WeChatController {
@Autowired
private WeChatService weChatService;
/**
* 處理微信服務(wù)器發(fā)來(lái)的get請(qǐng)求，進(jìn)行簽名的驗(yàn)證
*
* signature 微信端發(fā)來(lái)的簽名
* timestamp 微信端發(fā)來(lái)的時(shí)間戳
* nonce 微信端發(fā)來(lái)的隨機(jī)字符串
* echostr 微信端發(fā)來(lái)的驗(yàn)證字符串
*/
@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;
}
/**
* 此處是處理微信服務(wù)器的消息轉(zhuǎn)發(fā)的
*/
@PostMapping(value = "wechat")
public String processMsg(HttpServletRequest request) {
// 調(diào)用核心服務(wù)類(lèi)接收處理請(qǐng)求
return weChatService.processRequest(request);
}
}
Service,處理post請(qǐng)求
/**
* 核心服務(wù)類(lèi)
*/
@Service
public class WeChatServiceImpl implements WeChatService{
@Autowired
private FeignUtil feignUtil;
@Autowired
private RedisUtils redisUtils;
public String processRequest(HttpServletRequest request) {
// xml格式的消息數(shù)據(jù)
String respXml = null;
// 默認(rèn)返回的文本消息內(nèi)容
String respContent;
try {
// 調(diào)用parseXml方法解析請(qǐng)求消息
Map<String,String> requestMap = WeChatUtil.parseXml(request);
// 消息類(lèi)型
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<ArticleItem> 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<String, String> 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<ArticleItem> items = new ArrayList<>();
ArticleItem item = new ArticleItem();
item.setTitle("你的信息");
item.setDescription("昵稱(chēng):"+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 = "您發(fā)送的是圖片消息！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 語(yǔ)音消息
else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_VOICE)) {
respContent = "您發(fā)送的是語(yǔ)音消息！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 視頻消息
else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_VIDEO)) {
respContent = "您發(fā)送的是視頻消息！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 地理位置消息
else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_LOCATION)) {
respContent = "您發(fā)送的是地理位置消息！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 鏈接消息
else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_LINK)) {
respContent = "您發(fā)送的是鏈接消息！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 事件推送
else if (msgType.equals(WeChatContant.REQ_MESSAGE_TYPE_EVENT)) {
// 事件類(lèi)型
String eventType = (String) requestMap.get(WeChatContant.Event);
// 關(guān)注
if (eventType.equals(WeChatContant.EVENT_TYPE_SUBSCRIBE)) {
respContent = "謝謝您的關(guān)注！";
respXml = WeChatUtil.sendTextMsg(requestMap, respContent);
}
// 取消關(guān)注
else if (eventType.equals(WeChatContant.EVENT_TYPE_UNSUBSCRIBE)) {
// TODO 取消訂閱后用戶不會(huì)再收到公眾賬號(hào)發(fā)送的消息，因此不需要回復(fù)
}
// 掃描帶參數(shù)二維碼
else if (eventType.equals(WeChatContant.EVENT_TYPE_SCAN)) {
// TODO 處理掃描帶參數(shù)二維碼事件
}
// 上報(bào)地理位置
else if (eventType.equals(WeChatContant.EVENT_TYPE_LOCATION)) {
// TODO 處理上報(bào)地理位置事件
}
// 自定義菜單
else if (eventType.equals(WeChatContant.EVENT_TYPE_CLICK)) {
// TODO 處理菜單點(diǎn)擊事件
}
}
mes = mes == null ? "不知道你在干嘛" : mes;
if(respXml == null)
respXml = WeChatUtil.sendTextMsg(requestMap, mes);
System.out.println(respXml);
return respXml;
} catch (Exception e) {
e.printStackTrace();
}
return "";
}
}
微信工具類(lèi)(只寫(xiě)了回復(fù)文本消息,和圖文消息,其他的都是大同小異)
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;
/**
* 請(qǐng)求校驗(yàn)工具類(lèi)
*
* @author 32950745
*
*/
public class WeChatUtil {
/**
* 驗(yàn)證簽名
*
* @param signature
* @param timestamp
* @param nonce
* @return
*/
public static boolean checkSignature(String signature, String timestamp, String nonce) {
String[] arr = new String[] { WeChatContant.TOKEN, timestamp, nonce };
// 將token、timestamp、nonce三個(gè)參數(shù)進(jìn)行字典序排序
// 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");
// 將三個(gè)參數(shù)字符串拼接成一個(gè)字符串進(jìn)行sha1加密
byte[] digest = md.digest(content.toString().getBytes());
tmpStr = byteToStr(digest);
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
}
content = null;
// 將sha1加密后的字符串可與signature對(duì)比，標(biāo)識(shí)該請(qǐng)求來(lái)源于微信
return tmpStr != null ? tmpStr.equals(signature.toUpperCase()) : false;
}
/**
* 將字節(jié)數(shù)組轉(zhuǎn)換為十六進(jìn)制字符串
*
* @param byteArray
* @return
*/
private static String byteToStr(byte[] byteArray) {
String strDigest = "";
for (int i = 0; i < byteArray.length; i++) {
strDigest += byteToHexStr(byteArray[i]);
}
return strDigest;
}
/**
* 將字節(jié)轉(zhuǎn)換為十六進(jìn)制字符串
*
* @param mByte
* @return
*/
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;
}
}
}
}
/**
* 解析微信發(fā)來(lái)的請(qǐng)求(xml)
*
* @param request
* @return
* @throws Exception
*/
@SuppressWarnings({ "unchecked"})
public static Map<String,String> parseXml(HttpServletRequest request) throws Exception {
// 將解析結(jié)果存儲(chǔ)在HashMap中
Map<String,String> map = new HashMap<String,String>();
// 從request中取得輸入流
InputStream inputStream = request.getInputStream();
// 讀取輸入流
SAXReader reader = new SAXReader();
Document document = reader.read(inputStream);
// 得到xml根元素
Element root = document.getRootElement();
// 得到根元素的所有子節(jié)點(diǎn)
List<Element> elementList = root.elements();
// 遍歷所有子節(jié)點(diǎn)
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("<xml>");
mapToXML2(map, sb);
sb.append("</xml>");
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("</" + key + ">");
} else {
if (value instanceof HashMap) {
sb.append("<" + key + ">");
mapToXML2((HashMap) value, sb);
sb.append("</" + key + ">");
} else {
sb.append("<" + key + "><![CDATA[" + value + "]]></" + key + ">");
}
}
}
}
/**
* 回復(fù)文本消息
* @param requestMap
* @param content
* @return
*/
public static String sendTextMsg(Map<String,String> requestMap,String content){
Map<String,Object> map=new HashMap<String, Object>();
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);
}
/**
* 回復(fù)圖文消息
* @param requestMap
* @param items
* @return
*/
public static String sendArticleMsg(Map<String,String> requestMap,List<ArticleItem> items){
if(items == null || items.size()<1){
return "";
}
Map<String,Object> map=new HashMap<String, Object>();
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<Map<String,Object>> Articles=new ArrayList<Map<String,Object>>();
for(ArticleItem itembean : items){
Map<String,Object> item=new HashMap<String, Object>();
Map<String,Object> itemContent=new HashMap<String, Object>();
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";
}
圖文消息實(shí)體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;
}
}
好了運(yùn)行項(xiàng)目,在公眾平臺(tái)配置好url,個(gè)人訂閱號(hào)完成.
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
Java多線程之同步工具類(lèi)CyclicBarrier
這篇文章主要介紹Java多線程之同步工具類(lèi)CyclicBarrier,它是一個(gè)同步工具類(lèi)，它允許一組線程互相等待，直到達(dá)到某個(gè)公共屏障點(diǎn)，支持一個(gè)可選的Runnable命令，在一組線程中的最后一個(gè)線程到達(dá)之后,該命令只在每個(gè)屏障點(diǎn)運(yùn)行一次。下面來(lái)看文章具體內(nèi)容2021-10-10
springcloud client指定注冊(cè)到eureka的ip與端口號(hào)方式
這篇文章主要介紹了springcloud client指定注冊(cè)到eureka的ip與端口號(hào)方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-03-03
SWT(JFace) 簡(jiǎn)易瀏覽器 制作實(shí)現(xiàn)代碼
SWT(JFace) 簡(jiǎn)易瀏覽器 制作實(shí)現(xiàn)代碼2009-06-06
Springboot2.6.x高版本與Swagger2版本沖突問(wèn)題解決方法
Spring Boot 2.6.x版本引入依賴(lài)?springfox-boot-starter?(Swagger?3.0) 后，啟動(dòng)容器會(huì)報(bào)錯(cuò)，本文就介紹一下Springboot2.6.x高版本與Swagger2版本沖突問(wèn)題解決方法，感興趣的可以了解一下2022-04-04
這篇文章主要介紹了Java如何利用策略模式替代if/else語(yǔ)句，幫助大家優(yōu)化自己的代碼，提高程序運(yùn)行效率，感興趣的朋友可以了解下2020-09-09
TypeHandler被稱(chēng)作類(lèi)型處理器，MyBatis在設(shè)置預(yù)處理語(yǔ)句中的參數(shù)或從結(jié)果集中取出一個(gè)值時(shí)，都會(huì)用類(lèi)型處理器將Java對(duì)象轉(zhuǎn)化為數(shù)據(jù)庫(kù)支持的類(lèi)型或者將獲取到數(shù)據(jù)庫(kù)值以合適的方式轉(zhuǎn)換成Java類(lèi)型，感興趣的同學(xué)可以參考下文2023-05-05
Java聊天室之使用Socket實(shí)現(xiàn)傳遞對(duì)象
這篇文章主要為大家詳細(xì)介紹了Java簡(jiǎn)易聊天室之使用Socket實(shí)現(xiàn)傳遞對(duì)象功能，文中的示例代碼講解詳細(xì)，具有一定的借鑒價(jià)值，需要的可以了解一下2022-10-10
fail-fast和fail-safe是兩種不同的迭代器行為,特別是在遍歷集合時(shí)遇到并發(fā)修改的情況,本文主要介紹了Java中fail-fast和fail-safe的使用,感興趣的可以了解一下2024-08-08
這篇文章主要介紹了Java實(shí)現(xiàn)洗牌發(fā)牌的方法,涉及java針對(duì)數(shù)組的遍歷與排序操作相關(guān)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-07-07
mybatis是一款優(yōu)秀的ORM開(kāi)源框架，這個(gè)框架具有極強(qiáng)的靈活性，本文再次給大家介紹Mybatis 插件原理，感興趣的朋友一起看看吧2021-10-10