微信开发入门(一)

public class WeixinServlet extends HttpServlet {
 @Override
 protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
 String signature=req.getParameter("signature");
 String timestamp=req.getParameter("timestamp");
 String nonce=req.getParameter("nonce");
 String echostr=req.getParameter("echostr");
 
 PrintWriter out = resp.getWriter();
 if(CheckUtil.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 map = MessageUtil.xmlToMap(req);
 String toUserName = map.get("ToUserName");
 String fromUserName = map.get("FromUserName");
 String msgType = map.get("MsgType");
 String content = map.get("Content"); 

 String message = null;
 //文本类型
            if("text".equals(msgType))
 {
 //按关键字进行判断
                if("喜欢你".equals(content)){
 message=MessageUtil.initText(toUserName, fromUserName,MessageUtil.firstMenu());;
 }else if("很喜欢你".equals(content)){
 message=MessageUtil.initText(toUserName, fromUserName,MessageUtil.secondMenu());
 }else if("?".equals(content)||"？".equals(content)){
 message=MessageUtil.initText(toUserName, fromUserName, MessageUtil.menuText());
 }
 System.out.println(message);
 } //关注事件
            else if(MessageUtil.MESSAGE_EVENT.equals(msgType)){
 String eventType = map.get("Event");
 if(MessageUtil.EVENT_SUB.equals(eventType)){
 String mycontent = MessageUtil.menuText();
 message = MessageUtil.initText(toUserName, fromUserName, mycontent);

 }
 } 
 out.print(message);

 } catch (Exception e) {
 e.printStackTrace();
 }finally{
 out.close();
 }
 }
}
 

public class CheckUtil {
 
 private static final String token="huaweiclub";
 public static boolean checkSignature(String signature,String timestamp,String nonce){
 String[] arr=new String[]{token,timestamp,nonce};
 //排序
 Arrays.sort(arr);
 //生成字符串
        StringBuffer cOntent=new StringBuffer();
 for(int i=0;i){
 content.append(arr[i]);
 
 }
 
 //sha1加密
        String temp=getSha1(content.toString());
 return temp.equals(signature);
 } 
 
 public static String getSha1(String str){
 if(str==null||str.length()==0){
 return null;
 }
 char hexDigits[] = {'0','1','2','3','4','5','6','7','8','9',
 'a','b','c','d','e','f'};
 try {
 MessageDigest mdTemp = MessageDigest.getInstance("SHA1");
 mdTemp.update(str.getBytes("UTF-8"));

 byte[] md = mdTemp.digest();
 int j = md.length;
 char buf[] = new char[j*2];
 int k = 0;
 for (int i = 0; i ) {
 byte byte0 = md[i];
 buf[k++] = hexDigits[byte0 >>> 4 & 0xf];
 buf[k++] = hexDigits[byte0 & 0xf]; 
 }
 return new String(buf);
 } catch (Exception e) {
 // TODO: handle exception
                return null;
 }
 }

}

/*
 * xml和javabean的转换
 */
    public class MessageUtil {

 /*
 * 定义不同的消息类型
 */
        public static final String MESSAGE_TEXT = "text";
 public static final String MESSAGE_IMAGE = "image";
 public static final String MESSAGE_VOICE = "voice";
 public static final String MESSAGE_VIDEO = "video";
 public static final String MESSAGE_LINK = "link";
 public static final String MESSAGE_LOCATION = "location";
 public static final String MESSAGE_EVENT = "event";

 public static final String EVENT_SUB = "subscribe";
 public static final String EVENT_UNSUB = "unsubscribe";
 public static final String EVENT_CLICK = "CLICK";
 public static final String EVENT_VIEW = "VIEW";

 /**
 * xml转为map
 * @param request
 * @return
 * @throws DocumentException
 * @throws IOException
 */
        public static Map xmlToMap(HttpServletRequest request ) throws DocumentException, IOException
 {
 Map map = new HashMap();
 //SAXreader用于解析xml
            SAXReader reader = new SAXReader();
 InputStream ins = request.getInputStream();
 //从输入流中读取xml文档
            Document doc = reader.read(ins);
 //取得root节点
            Element root = doc.getRootElement();
 List list = root.elements();
 for (Element e : list) {
 map.put(e.getName(), e.getText());
 }
 ins.close();
 return map;

 }

 /*
 * 将文本消息转换为xml类型
 * xstream能将bean对象序列化xml
 */
        public static String textMessageToXml(TextMessage textMessage){
 XStream xstream = new XStream();
 //将序列化中的类全量名称，用别名替换
            xstream.alias("xml", textMessage.getClass());
 return xstream.toXML(textMessage);
 }

 public static String initText(String toUserName, String fromUserName, String content){
 TextMessage text = new TextMessage();
 text.setFromUserName(toUserName);
 text.setToUserName(fromUserName);
 text.setMsgType(MESSAGE_TEXT);
 text.setCreateTime(new Date().getTime());
 text.setContent(content);
 return textMessageToXml(text);
 
 }

 /*
 * 根据关键字回复内容
 */
        public static String menuText(){
 StringBuffer sb = new StringBuffer();
 sb.append("谢谢关注");
 return sb.toString(); 
 }
 
 public static String firstMenu(){
 StringBuffer sb = new StringBuffer();
 sb.append("好感+1");
 return sb.toString();
 }
 
 public static String secondMenu(){
 StringBuffer sb = new StringBuffer();
 sb.append("好感+2");
 return sb.toString();
 }
 
}

package com.xidian.bean;
/**
微信通信用的是XML，所以我们要新建一个javabean
 */
public class TextMessage {

 private String ToUserName; 
 private String FromUserName; 
 private long CreateTime; 
 private String MsgType;
 private String Content;
 private long MsgId;
 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 l) {
 CreateTime = l;
 }
 public String getMsgType() {
 return MsgType;
 }
 public void setMsgType(String msgType) {
 MsgType = msgType;
 }
 public String getContent() {
 return Content;
 }
 public void setContent(String content) {
 Content = content;
 }
 public long getMsgId() {
 return MsgId;
 }
 public void setMsgId(long msgId) {
 MsgId = msgId;
 }
}