请求的Controller

import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.*;

@PostMapping(value = "/notifyMsg", produces = "text/plain;charset=utf-8")

public Object notify(@RequestBody String xml) {

log.info("后台接收到公众号发来的数据是:\n{}", xml);

// 把微信发送给后端的xml消息转成WechatNotifyRequestVO对象start

WechatNotifyRequestVO wechatNotifyRequestVO = XmlUtil.fromXML(xml, WechatNotifyRequestVO.class);

// 把微信发送给后端的xml消息转成WechatNotifyRequestVO对象end

if (StringUtils.equals(wechatNotifyRequestVO.getEvent(), "subscribe")) {

log.info("用户关注了微信公众号, 这里写自己的业务逻辑.....");

}

if (StringUtils.equals(wechatNotifyRequestVO.getEvent(), "unsubscribe")) {

log.info("用户取消关注公众号, 这里写自己的业务逻辑......");

}

return StringUtils.EMPTY;

}

}

WechatNotifyRequestVO类:

import com.thoughtworks.xstream.annotations.XStreamAlias;

import io.swagger.annotations.ApiModelProperty;

import lombok.Data;

import lombok.experimental.Accessors;

/**

* 详情见微信官方文档

* https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Receiving_event_pushes.html

*/

@Data

@Accessors(chain = true)

@XStreamAlias(value = "xml")

public class WechatNotifyRequestVO {

@ApiModelProperty("开发者微信号")

@XStreamAlias(value = "ToUserName")

private String toUserName;

@ApiModelProperty("发送方帐号(一个OpenID)")

@XStreamAlias(value = "FromUserName")

private String fromUserName;

@ApiModelProperty("消息创建时间 (整型)")

@XStreamAlias(value = "CreateTime")

private Integer createTime;

@ApiModelProperty("消息类型，event")

@XStreamAlias(value = "MsgType")

private String messageType;

@ApiModelProperty("事件类型，subscribe(订阅)、unsubscribe(取消订阅)")

@XStreamAlias(value = "Event")

private String event;

}

XmlUtil工具类

import com.thoughtworks.xstream.XStream;

import com.thoughtworks.xstream.io.xml.XmlFriendlyNameCoder;

import com.thoughtworks.xstream.io.xml.XppDriver;

public class XmlUtil {

private XmlUtil() {

}

/**

* xml文档解析为对象

*

* @param xml xml文档

* @param clazz 要转换的类

* @return 对象

*/

public static T fromXML(String xml, Class clazz, Class... childClazz) {

XStream xmlStream = new XStream(new XppDriver(new XmlFriendlyNameCoder("_-", "_")));

XStream.setupDefaultSecurity(xmlStream);

xmlStream.processAnnotations(new Class[]{clazz});

xmlStream.processAnnotations(childClazz);

xmlStream.allowTypes(new Class[]{clazz});

xmlStream.allowTypes(childClazz);

xmlStream.ignoreUnknownElements();

Object result = xmlStream.fromXML(xml);

return (T) result;

}

/**

* 对象组装成xml

*

* @param object 要转换的对象

* @return xml文档

*/

public static String toXML(Object object) {

//转换成XML

XStream xmlStream = new XStream(new XppDriver(new XmlFriendlyNameCoder("_-", "_")));

XStream.setupDefaultSecurity(xmlStream);

xmlStream.processAnnotations(new Class[]{object.getClass()});

xmlStream.allowTypes(new Class[]{object.getClass()});

return xmlStream.toXML(object);

}

}