|
package com.test.util;
import java.io.InputStream;
import java.io.Writer;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http. HttpServletRequest;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import com.test.message.resp.Article;
import com.test.message.resp.MusicMessage;
import com.test.message.resp.NewsMessage;
import com.test.message.resp.TextMessage;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.core.util.QuickWriter ;
import com.thoughtworks.xstream.io.HierarchicalStreamWriter;
import com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
import com.thoughtworks.xstream. io.xml.XppDriver;
/**
* Nachrichtentoolklasse
*/
public class MessageUtil {
/**
* Art der Antwortnachricht: Text
*/
public static final String RESP_MESSAGE_TYPE_TEXT = "text";
/**
* Art der Antwortnachricht: Musik
*/
public static final String RESP_MESSAGE_TYPE_MUSIC = "music";
/**
* Art der Rückmeldung: Grafik
*/
public static final String RESP_MESSAGE_TYPE_NEWS = "news";
/**
* Anforderungsnachrichtentyp: Text
*/
public static final String REQ_MESSAGE_TYPE_TEXT = "text";
/**
* Anforderungsnachrichtentyp: Bild
*/
public static final String REQ_MESSAGE_TYPE_IMAGE = "image";
/**
* Anforderungsnachrichtentyp: Link
*/
public static final String REQ_MESSAGE_TYPE_LINK = "link";
/**
* Art der Anforderungsnachricht: geografischer Standort
*/
public static final String REQ_MESSAGE_TYPE_LOCATION = "location";
/**
* Anforderungsnachrichtentyp: Audio
*/
public static final String REQ_MESSAGE_TYPE_VOICE = "voice";
/**
* Anforderungsnachrichtentyp: Push
*/
public static final String REQ_MESSAGE_TYPE_EVENT = "event";
/**
* Veranstaltungstyp: Abonnieren
*/
public static final String EVENT_TYPE_SUBSCRIBE = "subscribe";
/**
* Ereignistyp: Abmelden (Abonnement kündigen)
*/
public static final String EVENT_TYPE_UNSUBSCRIBE = "unsubscribe";
/**
* Ereignistyp: KLICK ( Benutzerdefiniertes Menü Klickereignis)
*/
public static final String EVENT_TYPE_CLICK = "CLICK";
/**
* 解析微信发来的请求（XML）
*
* @param request
* @return
* @throws Ausnahme
*/
@SuppressWarnings("unchecked")
public static Map parseXml(HttpServletRequest request) throws Exception {
// Wird analysiert Das Ergebnis wird in HashMap gespeichert
Map map = new HashMap();
// Holen Sie sich den Eingabestream aus der Anfrage
InputStream inputStream = request.getInputStream();
//Eingabestream lesen
SAXReader reader = new SAXReader();
Document document = reader.read(inputStream) ;
// Holen Sie sich das XML-Stammelement
Element root = document.getRootElement();
// Holen Sie sich alle untergeordneten Knoten des Stammelements
List elementList = root.elements();
// Alle untergeordneten Knoten durchlaufen
für (Element e : elementList) {
map.put( e.getName( ), e.getText());
}
// Ressourcen freigeben
inputStream.close();
inputStream = null;
return map;
}
/**
* Textnachrichtenobjekt in XML umgewandelt
* @param textMessage Textnachrichtenobjekt
* @return xml
*/
public static String textMessageToXml(TextMessage textMessage) { xstream .alias("xml", textMessage.getClass());
return xstream.toXML(textMessage);
}
/**
* Musiknachrichtenobjekt in XML umgewandelt
* @param musicMessage Musiknachrichtenobjekt
* @return xml
*/
public static String musicMessageToXml(MusicMessage musicMessage) {
xstream.alias("xml", musicMessage.getClass());
return xstream.toXML( musicMessage);
}
/**
* Grafisches Nachrichtenobjekt in XML konvertieren
* @param newsMessage Grafisches Nachrichtenobjekt
* @return xml
*/
public static String newsMessageToXml(NewsMessage newsMessage) {
xstream.alias(" xml", newsMessage .getClass());
xstream.alias("item", new Article().getClass());
return xstream.toXML(newsMessage);
}
/**
* xstream erweitern, um CDATA-Blöcke zu unterstützen
* @date
*/
private static XStream xstream = new XStream(new XppDriver() {
public HierarchicalStreamWriter createWriter(Writer out ) {
return new PrettyPrintWriter(out) {
// 对所有xml节点的转换都增加CDATA标记
boolean cdata = true;
@SuppressWarnings("unchecked")
public void startNode(String Name, Klasse Clazz) Autor, String Text) {
if (cdata) {
writer.write("
writer.write(text);
writer.write(" ]] & gt; "); } else { writer.write (text); ;
}
});
}
TextMessage代码
| package com.test.message.resp;public class TextMessage extends BaseMessage { | // 回复的消息内容 Content = content;
}|
package com.test.message.resp;
public class TextMessage extends BaseMessage {
// 回复的消息内容
private String Content;
public String getContent() {
return Content;
}
public void setContent(String content) {
Content = content;
}
}
|
}
BaseMessage代码
|
package com.test.message.resp;
/**
* 消息基类（公众帐号 -> 普通用户）
*/
public class BaseMessage {
// 接收方帐号（收到的OpenID）
private String ToUserName;
// 开发者微信号
private String FromUserName;
// 消息创建时间 （整型）
private long CreateTime;
// 消息类型（text/music/news）
private String MsgType;
// 位0x0001被标志时，星标刚收到的消息
private int FuncFlag;
public String getToUserName() {
return ToUserName;
}
public void setToUserName(String toUserName) {
ToUserName = toUserName;
}
public String getFromUserName() {
return FromUserName;
}
public void setFromUserName(String fromUserName) {
FromUserName = fromUserName;
}
public long getCreateTime() {
return CreateTime;
}
public void setCreateTime(long createTime) {
CreateTime = createTime;
}
public String getMsgType() {
return MsgType;
}
public void setMsgType(String msgType) {
MsgType = msgType;
}
public int getFuncFlag() {
return FuncFlag;
}
public void setFuncFlag(int funcFlag) {
FuncFlag = funcFlag;
}
}
|
Die Wirkung ist wie folgt:
| 
