java版微信机器人代码

来源：http://www.open-open.com/code/view/1430907127288

1. 
   
2.   
   
3. import java.io.IOException;
   
4. import java.io.PrintWriter;
   
5. import java.util.Date;
   
6.   
   
7. import javax.servlet.ServletException;
   
8. import javax.servlet.http.HttpServlet;
   
9. import javax.servlet.http.HttpServletRequest;
   
10. import javax.servlet.http.HttpServletResponse;
    
11.   
    
12. import com.eiyoung.wechat.web.utils.Message;
    
13. import com.eiyoung.wechat.web.utils.ReplyMessage;
    
14. import org.apache.commons.io.IOUtils;
    
15.   
    
16. import com.thoughtworks.xstream.XStream;
    
17. import com.thoughtworks.xstream.io.xml.DomDriver;
    
18.   
    
19.   
    
20. public class WeChat extends HttpServlet {
    
21.     private static final long serialVersionUID = 1L;
    
22.   
    
23.   
    
24.     public WeChat() {
    
25.         super();
    
26.     }
    
27.   
    
28.     /**
    
29.      * 验证
    
30.      * @param request
    
31.      * @param response
    
32.      * @throws ServletException
    
33.      * @throws IOException
    
34.      */
    
35.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    
36.         response.setContentType("text/html;charset=UTF-8");
    
37.         PrintWriter pw = response.getWriter();
    
38.         String echo = request.getParameter("echostr");
    
39.         System.out.print(echo);
    
40.         echo = new String(echo.getBytes("ISO-8859-1"),"UTF-8");
    
41.         pw.println(echo);
    
42.     }
    
43.   
    
44.   
    
45.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    
46.        response.setContentType("text/html;charset=UTF-8");
    
47.         PrintWriter pw = response.getWriter();
    
48.         String wxMsgXml = IOUtils.toString(request.getInputStream(),"utf-8");
    
49.         Message textMsg = null;
    
50.         try {
    
51.             textMsg = getMessage(wxMsgXml);
    
52.         } catch (Exception e) {
    
53.             e.printStackTrace();
    
54.         }
    
55.         StringBuffer replyMsg = new StringBuffer();
    
56.         if(textMsg != null){
    
57.             //增加你所需要的处理逻辑，这里只是简单重复消息
    
58.             replyMsg.append("您给我的消息是：");
    
59.             replyMsg.append(textMsg.getContent());
    
60.         }
    
61.         else{
    
62.             replyMsg.append(":)不是文本的消息，我暂时看不懂");
    
63.         }
    
64.         String returnXml = getReplyMessage(replyMsg.toString(), textMsg.getFromUserName(),textMsg.getToUserName());
    
65.         System.out.print(textMsg.toString());
    
66.         System.out.print(returnXml.toString());
    
67.         pw.println(returnXml);
    
68.     }
    
69.   
    
70.     private Message getMessage(String xml){
    
71.         XStream xstream = new XStream(new DomDriver());
    
72.         xstream.alias("xml", Message.class);
    
73.         xstream.aliasField("ToUserName", Message.class, "toUserName");
    
74.         xstream.aliasField("FromUserName", Message.class, "fromUserName");
    
75.         xstream.aliasField("CreateTime", Message.class, "createTime");
    
76.         xstream.aliasField("MsgType", Message.class, "messageType");
    
77.         xstream.aliasField("Content", Message.class, "content");
    
78.         xstream.aliasField("MsgId", Message.class, "msgId");
    
79.         Message Message = (Message)xstream.fromXML(xml);
    
80.         return Message;
    
81.     }
    
82.   
    
83.     private String getReplyMessage(String replyMsg,String toUserName,String fromUserName){
    
84.         ReplyMessage we = new ReplyMessage();
    
85.         we.setMessageType("text");
    
86.         we.setFuncFlag("0");
    
87.         we.setCreateTime(new Long(new Date().getTime()).toString());
    
88.         we.setContent(replyMsg);
    
89.         we.setToUserName(toUserName);
    
90.         we.setFromUserName(fromUserName);
    
91.         XStream xstream = new XStream(new DomDriver());
    
92.         xstream.alias("xml", ReplyMessage.class);
    
93.         xstream.aliasField("ToUserName", ReplyMessage.class, "toUserName");
    
94.         xstream.aliasField("FromUserName", ReplyMessage.class, "fromUserName");
    
95.         xstream.aliasField("CreateTime", ReplyMessage.class, "createTime");
    
96.         xstream.aliasField("MsgType", ReplyMessage.class, "messageType");
    
97.         xstream.aliasField("Content", ReplyMessage.class, "content");
    
98.         xstream.aliasField("FuncFlag", ReplyMessage.class, "funcFlag");
    
99.         String xml =xstream.toXML(we);
    
100.         return xml;
     
101.     }
     
102.   
     
103.   
     
104. }
     
105.   
     
106. ===========================================================================
     
107. package com.eiyoung.wechat.web.utils;
     
108.   
     
109. /**
     
110. * Created with IntelliJ IDEA.
     
111. * User: sb
     
112. * Date: 8/1/13
     
113. * Time: 10:37 PM
     
114. * To change this template use File | Settings | File Templates.
     
115. */
     
116. public class ReplyMessage {
     
117.   
     
118.     private String FuncFlag;//消息编号
     
119.     private String fromUserName;//发送人
     
120.     private String toUserName;//接收人
     
121.     private String content;//内容
     
122.     private String messageType;//消息类型
     
123.     private String createTime;//创建日期
     
124.   
     
125.   
     
126.     public String getContent() {
     
127.         return content;
     
128.     }
     
129.   
     
130.     public void setContent(String content) {
     
131.         this.content = content;
     
132.     }
     
133.   
     
134.     public String getMessageType() {
     
135.         return messageType;
     
136.     }
     
137.   
     
138.     public void setMessageType(String messageType) {
     
139.         this.messageType = messageType;
     
140.     }
     
141.   
     
142.     public String getFromUserName() {
     
143.         return fromUserName;
     
144.     }
     
145.   
     
146.     public void setFromUserName(String fromUserName) {
     
147.         this.fromUserName = fromUserName;
     
148.     }
     
149.   
     
150.     public String getToUserName() {
     
151.         return toUserName;
     
152.     }
     
153.   
     
154.     public void setToUserName(String toUserName) {
     
155.         this.toUserName = toUserName;
     
156.     }
     
157.   
     
158.     public String getCreateTime() {
     
159.         return createTime;
     
160.     }
     
161.   
     
162.     public void setCreateTime(String createTime) {
     
163.         this.createTime = createTime;
     
164.     }
     
165.   
     
166.     public String getFuncFlag() {
     
167.         return FuncFlag;
     
168.     }
     
169.   
     
170.     public void setFuncFlag(String funcFlag) {
     
171.         FuncFlag = funcFlag;
     
172.     }
     
173.   
     
174.     public String toString(){
     
175.         return "createTime:"+getCreateTime()+"\\ntoUserName:"+getToUserName()+"\\n FromUserName:"+getFromUserName()+"\\nmessageType:"+getMessageType()+"\\ncontent:"+getContent();
     
176.     }
     
177. }
     
178.   
     
179. ===============================================================================
     
180. package com.eiyoung.wechat.web.utils;
     
181.   
     
182. import java.util.Date;
     
183.   
     
184. /**
     
185. * Created with IntelliJ IDEA.
     
186. * User: sb
     
187. * Date: 8/1/13
     
188. * Time: 10:37 PM
     
189. * To change this template use File | Settings | File Templates.
     
190. */
     
191. public class Message {
     
192.   
     
193.     private String msgId;//消息编号
     
194.     private String fromUserName;//发送人
     
195.     private String toUserName;//接收人
     
196.     private String content;//内容
     
197.     private String messageType;//消息类型
     
198.     private String createTime;//创建日期
     
199.   
     
200.   
     
201.     public String getContent() {
     
202.         return content;
     
203.     }
     
204.   
     
205.     public void setContent(String content) {
     
206.         this.content = content;
     
207.     }
     
208.   
     
209.     public String getMessageType() {
     
210.         return messageType;
     
211.     }
     
212.   
     
213.     public void setMessageType(String messageType) {
     
214.         this.messageType = messageType;
     
215.     }
     
216.   
     
217.     public String getFromUserName() {
     
218.         return fromUserName;
     
219.     }
     
220.   
     
221.     public void setFromUserName(String fromUserName) {
     
222.         this.fromUserName = fromUserName;
     
223.     }
     
224.   
     
225.     public String getToUserName() {
     
226.         return toUserName;
     
227.     }
     
228.   
     
229.     public void setToUserName(String toUserName) {
     
230.         this.toUserName = toUserName;
     
231.     }
     
232.   
     
233.     public String getCreateTime() {
     
234.         return createTime;
     
235.     }
     
236.   
     
237.     public void setCreateTime(String createTime) {
     
238.         this.createTime = createTime;
     
239.     }
     
240.   
     
241.     public String getMsgId() {
     
242.         return msgId;
     
243.     }
     
244.   
     
245.     public void setMsgId(String msgId) {
     
246.         this.msgId = msgId;
     
247.     }
     
248.   
     
249.     public String toString(){
     
250.         return "msgId:"+getMsgId()+"\\ncreateTime:"+getCreateTime()+"\\ntoUserName:"+getToUserName()+"\\n FromUserName:"+getFromUserName()+"\\nmessageType:"+getMessageType()+"\\ncontent:"+getContent();
     
251.     }
     
252. }
     
253. ==============================================================================
     
254. maven
     
255. <dependencies>
     
256.     <dependency>
     
257.       <groupId>junit</groupId>
     
258.       <artifactId>junit</artifactId>
     
259.       <version>3.8.1</version>
     
260.       <scope>test</scope>
     
261.     </dependency>
     
262.     <dependency>
     
263.       <groupId>javax.servlet</groupId>
     
264.       <artifactId>servlet-api</artifactId>
     
265.       <version>3.0-alpha-1</version>
     
266.     </dependency>
     
267.       <dependency>
     
268.           <groupId>joda-time</groupId>
     
269.           <artifactId>joda-time</artifactId>
     
270.           <version>2.2</version>
     
271.       </dependency>
     
272.       <dependency>
     
273.           <groupId>org.apache.commons</groupId>
     
274.           <artifactId>commons-io</artifactId>
     
275.           <version>1.3.2</version>
     
276.       </dependency>
     
277.       <dependency>
     
278.           <groupId>com.thoughtworks.xstream</groupId>
     
279.           <artifactId>xstream</artifactId>
     
280.           <version>1.4.3</version>
     
281.       </dependency>
     
282.   </dependencies>
     
283. 
     

复制代码