在配置好开发者配置后,本人第一个想要实现的是自动回复消息的功能,说明以下几点:
1. url 仍然不变,还是开发配置里的url
2. 微信采用 xml 格式传输数据
3.微信服务器传给我们的参数主要有(如图):
附上解析xml类的依赖:
<!-- dom对象读取写入xml文件 -->
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.0.0</version>
</dependency>
<dependency>
<groupId>com.thoughtworks.xstream</groupId>
<artifactId>xstream</artifactId>
<version>1.4.9</version>
</dependency>
第一步:建立model 类接收参数(基本信息类,子类,子类包括文本信息类,图片信息类,语音信息类等,本人暂时只写了文本的信息类)
基类:
package com.encore.model; import lombok.*; /**
* 微信公众号消息的基类
*/ @Setter
@Getter
@ToString
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class WxMessage {
// 开发者微信号
private String ToUserName;
// 发送方帐号(一个OpenID)
private String FromUserName;
// 消息创建时间 (整型)
private long CreateTime;
// 消息类型(text/image/location/link)
private String MsgType;
// 消息id,64位整型
private long MsgId;
}
文本信息类 继承自基类:
package com.encore.model; import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import org.springframework.beans.BeanUtils; /**
* 文本消息
*/ @Getter
@Setter
@NoArgsConstructor
public class TextMessage extends WxMessage { private String Content;// 文本消息内容 //用来把基类的属性值复制给子类
public static TextMessage adapt(WxMessage msg){
TextMessage textMessage = new TextMessage();
BeanUtils.copyProperties(msg, textMessage);
return textMessage;
}
}
第二步: controller post接收方式,中间会涉及到读取和写入xml,util类会在最后附上
@RequestMapping(value = "/view.json", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
@ResponseBody
public String receiveMessage(HttpServletRequest request){ //1. 获取微信服务器发送的消息,转换成map对象
Map<String, String> map = MessageUtil.parseXmlToMap(request);
// 2. 获取详细的信息
// 发送方帐号(open_id)
String fromUserName = map.get("FromUserName");
// 公众帐号
String toUserName = map.get("ToUserName");
// 消息类型
String msgType = map.get("MsgType");
// 消息内容
String content = map.get("Content");
// 消息id
String msgId = map.get("MsgId"); //3. 定义回复消息对象
String respMsg = ""; // 也可以用new,然后一个属性一个属性的set
// 微信消息的基类
//set属性值的时候,注意:ToUserName 和 FromUserName的值要反过来!是坑!是坑!是坑!
WxMessage msg = WxMessage.builder().FromUserName(toUserName).ToUserName(fromUserName).MsgType(msgType).MsgId(Long.parseLong(msgId))
.CreateTime(new Date().getTime()).build(); if (RESP_MESSAGE_TYPE_TEXT.equals(msgType)){//文本消息
//要回复的消息内容
String resultContent = "";
if ("python".equals(content)){
resultContent = "人生苦短,我用python";
}else if ("php".equals(content) || "PHP".equals(content)){
resultContent = "PHP是世界上最好的语言";
}else if ("java".equals(content) || "JAVA".equals(content)){
resultContent = "JAVA太特么复杂了";
}else if ("js".equals(content) || "javascript".equals(content)){
resultContent = "老子是脚本!跟java没半毛钱关系!";
}else {
resultContent = "您的开发语言是:"+content;
}
TextMessage textMessage = TextMessage.adapt(msg);
textMessage.setContent(resultContent);
respMsg = MessageUtil.parseMsgToXml(textMessage, TextMessage.class);
} return respMsg;
}
最后附上读取和写入xml的工具类:
package com.encore.util; import com.encore.model.WxMessage;
import com.thoughtworks.xstream.XStream;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader; import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map; public class MessageUtil { /**
* 接收request对象,读取xml内容,转换成map对象
* @param request
* @return
*/
public static Map<String, String> parseXmlToMap(HttpServletRequest request){
Map<String, String> map = new HashMap<>();
SAXReader reader = new SAXReader();
InputStream ins = null;
try {
ins = request.getInputStream();
} catch (IOException e1) {
e1.printStackTrace();
}
Document doc = null;
try {
doc = reader.read(ins);
Element root = doc.getRootElement();
List<Element> list = root.elements();
for (Element e : list) {
map.put(e.getName(), e.getText());
}
return map;
} catch (DocumentException e1) {
e1.printStackTrace();
}finally{
try {
if (null != ins){
ins.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
return null;
} /**
* 将消息转换成xml格式的字符串
* @param msg 各种信息类,如文本信息类,图片信息类,音频信息类等。(都是WxMessage的子类)
* @param child 用来确定到底是哪一种子类
* @return
*/
public static String parseMsgToXml(WxMessage msg, Class child){
XStream xstream = new XStream();
xstream.alias("xml", child);
return xstream.toXML(msg);
}
}
至此基本步骤已经完成,具体什么关键字回复什么内容全屏自己设置。
补充:如果想让公众号除了自己设定的几个关键字以外不进行任何回复,则直接返回空字符串""即可,避免出现 “该公众号提供的服务出现故障,请稍后重试” 错误!