import org.apache.commons.lang.StringUtils;  import org.apache.log4j.Logger;  import org.springframework.beans.factory.annotation.Autowired;  import org.springframework.stereotype.Controller;  import org.springframework.web.bind.annotation.RequestMapping;  import org.springframework.web.bind.annotation.RequestMethod;      import com.company.project.service.WeixinService;  import com.company.project.util.Util;      import javacommon.base.BaseRestSpringController;      @Controller  @RequestMapping("/wxapi")  public class WeixinApiController extends BaseRestSpringController<Object, java.lang.Long>{  public static final Logger log = Logger.getLogger(WeixinApiController.class);  public static final String WX_TOKEN = "weixin";  @Autowired  private WeixinService wxService;  /** * 微信回调地址 * * @author qincd * @throws IOException  * @date Nov 3, 2014 4:01:42 PM */  @RequestMapping(method=RequestMethod.GET)  public void doGet(HttpServletRequest request,HttpServletResponse response) throws IOException {  // 微信会在配置的回调地址上加上signature,nonce,timestamp,echostr4个参数  String signature = request.getParameter("signature");  String timestamp = request.getParameter("timestamp");  String nonce = request.getParameter("nonce");  String echostr = request.getParameter("echostr");    log.info("微信传递的参数：");  log.info("signature："+signature);  log.info("timestamp："+timestamp);  log.info("nonce："+nonce);  log.info("echostr："+echostr);    if (StringUtils.isEmpty(signature)) {  return;  }  // 1).排序  String sortString = sort(WX_TOKEN, timestamp, nonce);  // 2).加密  String mytoken = Util.sha1(sortString);  // 3).校验签名  if (StringUtils.isNotEmpty(mytoken) && mytoken.equals(signature)) {  log.info("签名校验通过。");  response.getWriter().println(echostr);  }  else {  log.warn("签名校验失败。");  }  }    @RequestMapping(method=RequestMethod.POST)  public void doPost(HttpServletRequest request,HttpServletResponse response) throws IOException {  // 处理请求、响应  request.setCharacterEncoding("utf-8");  response.setCharacterEncoding("utf-8");  String message = wxService.processRequest(request);  response.getWriter().println(message);  }    /** * 将token,timestamp,nonce按字典序排序，并返回拼接的字符串 * * @author qincd * @date Nov 3, 2014 4:09:43 PM */  public static String sort(String token,String timestamp,String nonce) {  String[] strArray = {token,timestamp,nonce};  Arrays.sort(strArray);    StringBuilder sbuilder = new StringBuilder();  for (String str : strArray) {  sbuilder.append(str);  }    return sbuilder.toString();  }      }      import java.util.ArrayList;  import java.util.List;  import java.util.Map;      import javax.servlet.http.HttpServletRequest;      import org.apache.log4j.Logger;  import org.springframework.stereotype.Service;      import com.company.project.model.resp.Articles;  import com.company.project.model.resp.Music;  import com.company.project.model.resp.MusicMessage;  import com.company.project.model.resp.NewsMessage;  import com.company.project.model.resp.TextMessage;  import com.company.project.util.MessageUtil;      @Service  public class WeixinService {  public static Logger log = Logger.getLogger(WeixinService.class);    public String processRequest(HttpServletRequest req) {  // 解析微信传递的参数  String str = null;  try {  Map<String,String> xmlMap = MessageUtil.parseXml(req);  str = "请求处理异常，请稍后再试！";    String ToUserName = xmlMap.get("ToUserName");  String FromUserName = xmlMap.get("FromUserName");  String MsgType = xmlMap.get("MsgType");    if (MsgType.equals(MessageUtil.MESSAGG_TYPE_TEXT)) {  // 用户发送的文本消息  String content = xmlMap.get("Content");  log.info("用户：[" + FromUserName + "]发送的文本消息：" + content);    // 链接  if (content.contains("csdn")) {  TextMessage tm = new TextMessage();  tm.setToUserName(FromUserName);  tm.setFromUserName(ToUserName);  tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  tm.setCreateTime(System.currentTimeMillis());  tm.setContent("我的CSDN博客：<a href=http://www.mamicode.com/"http://my.csdn.net/qincidong\">我的CSDN博客</a>\n");  return MessageUtil.textMessageToXml(tm);  }    if (content.contains("图文")) {  NewsMessage nm = new NewsMessage();  nm.setFromUserName(ToUserName);  nm.setToUserName(FromUserName);  nm.setCreateTime(System.currentTimeMillis());  nm.setMsgType(MessageUtil.MESSAGG_TYPE_NEWS);  List<Articles> articles = new ArrayList<Articles>();  Articles e1 = new Articles();  e1.setTitle("马云接受外媒专访：中国的五大银行想杀了“我”");  e1.setDescription("阿里巴巴集团上市大获成功，《华尔街日报》日前就阿里巴巴集团、支付宝等话题采访了马云，马云也谈到了与苹果Apple Pay建立电子支付联盟的可能性。本文摘编自《华尔街日报》，原文标题：马云谈阿里巴巴将如何帮助美国出口商，虎嗅略有删节。");  e1.setPicUrl("http://img1.gtimg.com/finance/pics/hv1/29/53/1739/113092019.jpg");  e1.setUrl("http://finance.qq.com/a/20141105/010616.htm?pgv_ref=aio2012&ptlang=2052");    Articles e2 = new Articles();  e2.setTitle("史上最牛登机牌：姓名竟是微博名 涉事航空公司公开致歉");  e2.setDescription("世上最遥远的距离是飞机在等你登机，你却过不了安检。");  e2.setPicUrl("http://p9.qhimg.com/dmfd/328_164_100/t011946ff676981792d.png");  e2.setUrl("http://www.techweb.com.cn/column/2014-11-05/2093128.shtml");  articles.add(e1);  articles.add(e2);    nm.setArticles(articles);  nm.setArticleCount(articles.size());    String newsXml = MessageUtil.NewsMessageToXml(nm);  log.info("\n"+newsXml);  return newsXml;  }  if (content.contains("音乐")) {  MusicMessage mm =  new MusicMessage();  mm.setFromUserName(ToUserName);  mm.setToUserName(FromUserName);  mm.setMsgType(MessageUtil.MESSAGG_TYPE_MUSIC);  mm.setCreateTime(System.currentTimeMillis());  Music music = new Music();  music.setTitle("Maid with the Flaxen Hair");  music.setDescription("测试音乐");  music.setMusicUrl("http://yinyueshiting.baidu.com/data2/music/123297915/1201250291415073661128.mp3?xcode=e2edf18bbe9e452655284217cdb920a7a6a03c85c06f4409");  music.setHQMusicUrl("http://yinyueshiting.baidu.com/data2/music/123297915/1201250291415073661128.mp3?xcode=e2edf18bbe9e452655284217cdb920a7a6a03c85c06f4409");  mm.setMusic(music);    String musicXml = MessageUtil.MusicMessageToXml(mm);  log.info("musicXml:\n" + musicXml);  return musicXml;  }    // 响应  TextMessage tm = new TextMessage();  tm.setToUserName(FromUserName);  tm.setFromUserName(ToUserName);  tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  tm.setCreateTime(System.currentTimeMillis());  tm.setContent("你好，你发送的内容是：\n" + content);    String xml = MessageUtil.textMessageToXml(tm);  log.info("xml:" + xml);  return xml;  }  else if (MsgType.equals(MessageUtil.MESSAGG_TYPE_EVENT)) {  String event = xmlMap.get("Event");  if (event.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  // 订阅  TextMessage tm = new TextMessage();  tm.setToUserName(FromUserName);  tm.setFromUserName(ToUserName);  tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  tm.setCreateTime(System.currentTimeMillis());  tm.setContent("你好，欢迎关注[程序员的生活]公众号！[愉快]/呲牙/玫瑰\n目前可以回复文本消息");  return MessageUtil.textMessageToXml(tm);  }  else if (event.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  // 取消订阅  log.info("用户【" + FromUserName + "]取消关注了。");  }  }  } catch (Exception e) {  e.printStackTrace();  log.error("处理微信请求时发生异常：");  }    return str;  }  }