?
?
?接入微信? 使用 ngrok
?http://knight-black-bob.iteye.com/blog/2244830
?
接受普通消息
?
WeichatServlet.java
package com.curiousby.cn;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.curiousby.cn.entity.TextMessage;
import com.curiousby.cn.util.CommonUtils;
import com.curiousby.cn.util.MessageUtil;
import com.curiousby.cn.util.WeichatCheckUtils;
/**
* @author baoyou E-mail:curiousby@163.com
* @version 创建时间：2015年9月20日 下午2:06:42
* des:
*/
public class WeichatServlet extends HttpServlet{
private static final long serialVersionUID = 1L;
private String signature; //微信加密签名，signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。
private String timestamp; // 时间戳
private String nonce; //随机数
private String echostr; //随机字符串
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
signature = req.getParameter("signature");
timestamp = req.getParameter("timestamp");
nonce = req.getParameter("nonce");
echostr = req.getParameter("echostr");
System.out.println("signature timestamp nonce echostr " + signature +" " + timestamp +" " + nonce + " " + echostr );
PrintWriter out = resp.getWriter();
if (WeichatCheckUtils.checkSignature(signature, timestamp, nonce)) {
out.print(echostr);
}
}
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
req.setCharacterEncoding("UTF-8");
resp.setCharacterEncoding("UTF-8");
PrintWriter out = resp.getWriter();
try {
Map<String,String> map = MessageUtil.xmlToString(req);
System.out.println(CommonUtils.mapToString(map));
String toUserName = map .get("ToUserName");
String fromUserName = map .get("FromUserName");
String createTime = map .get("CreateTime");
String msgType = map .get("MsgType");
String content = map .get("Content");
String msgId = map .get("MsgId");
String message ="";
if ("text".equals(msgType)) {
TextMessage text = new TextMessage();
text.setFromUserName(toUserName);
text.setToUserName(fromUserName);
text.setMsgType("text");
text.setCreateTime(new Date().getTime());
String recontent ="";
try{
int aint = Integer.parseInt(content);
recontent=" 您好，我是包包大人.\r\n 您发送的内容是 :"+(aint+1);
}catch(Exception e){
recontent =" 您好，我是包包大人.\r\n 您发送的内容是 :"+content;
}
text.setContent(recontent);
message = MessageUtil.textMessageToXml(text);
}
System.out.println(message);
out.print(message);
} catch (Exception e) {
e.printStackTrace();
}finally{
out.close();
}
}
}
?
CommonUtils.java
package com.curiousby.cn.util;
import java.util.Map;
/**
* @author baoyou E-mail:curiousby@163.com
* @version 创建时间：2015年9月20日 下午2:24:27
* des:
*/
public class CommonUtils {
public static String arrayToString (String [] arr){
StringBuffer sb = new StringBuffer();
for (int i = 0; i < arr.length; i++) {
sb.append(arr[i]);
}
return sb.toString();
}
public static String mapToString(Map<String,String> map){
StringBuffer sb = new StringBuffer();
sb.append("{");
for (String key : map.keySet() ) {
sb.append(key+":"+map.get(key)+",");
}
sb.substring(0, sb.length()-1);
sb.append("}");
return sb.toString();
}
}
?
?MessageUtil.java
package com.curiousby.cn.util;
import java.io.InputStream;
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.curiousby.cn.entity.TextMessage;
import com.thoughtworks.xstream.XStream;
/**
* @author baoyou E-mail:curiousby@163.com
* @version 创建时间：2015年9月20日 下午4:18:35
* des:
*/
public class MessageUtil {
public static Map <String,String> xmlToString(HttpServletRequest request) throws Exception{
Map <String,String> map = new HashMap<String,String>();
SAXReader reader = new SAXReader();
InputStream is = request.getInputStream();
Document doc = reader.read(is);
Element root = doc.getRootElement();
List<Element> llist = root.elements();
for (Element e : llist) {
map.put(e.getName(), e.getText());
}
is.close();
return map;
}
public static String textMessageToXml(TextMessage textMessage){
XStream xStream = new XStream();
xStream.alias("xml", textMessage.getClass());
return xStream.toXML(textMessage);
}
}
?
?
ShaUtils.java
package com.curiousby.cn.util;
import java.security.MessageDigest;
/**
* @author baoyou E-mail:curiousby@163.com
* @version 创建时间：2015年9月20日 下午2:36:04
* des:
*/
public class ShaUtils {
private static final char[] HEX_DIGITS = { ‘0‘, ‘1‘, ‘2‘, ‘3‘, ‘4‘, ‘5‘,
‘6‘, ‘7‘, ‘8‘, ‘9‘, ‘a‘, ‘b‘, ‘c‘, ‘d‘, ‘e‘, ‘f‘ };
public static String getSha1(String str){
if (str == null || str.length() ==0) {
return null;
}
try{
MessageDigest messageDigest = MessageDigest.getInstance("SHA1");
messageDigest.update(str.getBytes("UTF-8"));
byte[] md = messageDigest.digest();
int j = md.length;
char [] buf = new char[j*2];
int k = 0;
for (int i = 0; i < j; i++) {
byte byte0 = md[i];
buf[k++] =HEX_DIGITS[byte0 >>> 4 & 0xf ];
buf[k++] =HEX_DIGITS[byte0 & 0xf ];
}
System.out.println(" before sha1 str :"+ str +"\r\n after sha1 string : "+new String(buf));
return new String(buf);
}catch(Exception e){
return null;
}
}
}
?
?
WeichatCheckUtils.java
package com.curiousby.cn.util;
import java.util.Arrays;
/**
* @author baoyou E-mail:curiousby@163.com
* @version 创建时间：2015年9月20日 下午2:14:46
* des:
*/
public class WeichatCheckUtils {
private static final String TOKEN ="xxxxxx";
public static boolean checkSignature(String signature, String timestamp,String nonce){
String[] str = { TOKEN, timestamp, nonce };
Arrays.sort(str); // 字典序排序
String string = CommonUtils.arrayToString(str);
String temp = ShaUtils.getSha1(string);
return temp.equals(signature);
}
}
?
?
web.xml
<servlet> <servlet-name>weichatServlet</servlet-name> <servlet-class>com.curiousby.cn.WeichatServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>weichatServlet</servlet-name> <url-pattern>/weichat.do</url-pattern> </servlet-mapping>
?
?
?