JAVA微信开发-新手接入指南

准备工作

 1.  下载 Jdk1.7  安装

 2.  下载 Tomcat 7.0

 3.  下载 Myeclipse 6.5

 4.  下载 Json-lib第三方jar .

1.      申请一个公网IP地址，发布自己的应用。

例如： 192.168.1.102

2.      打开myeclipse 创建一个工程

如下图所示：

3.  创建一个微信应用接入Servlet类

JAVA实现类 ：WeixinServlet 

[java] view plain copy

1. package com.wx.servlet;  
2. import java.io.IOException;  
3. import java.io.InputStream;  
4. import java.io.OutputStream;  
5. import java.security.MessageDigest;  
6. import java.security.NoSuchAlgorithmException;  
7. import java.util.Arrays;  
8. import java.util.logging.Logger;  
9. import javax.servlet.ServletException;  
10. import javax.servlet.http.HttpServlet;  
11. import javax.servlet.http.HttpServletRequest;  
12. import javax.servlet.http.HttpServletResponse;  
13. import net.sf.json.JSONObject;  
14. import net.sf.json.xml.XMLSerializer;  
15. public class WeixinServlet extends HttpServlet{  
16.     private Logger log =Logger.getLogger(this.getClass().getName());  
17.     private static final long serialVersionUID = 1L;  
18.     private   String Token;  
19.     private   String echostr;  
20.     @Override  
21.     protected void doGet(HttpServletRequest request, HttpServletResponse response)  
22.             throws ServletException, IOException {  
23.          connect(request,response);  
24.     }  
25.     @Override  
26.     protected void doPost(HttpServletRequest request, HttpServletResponse response)  
27.             throws ServletException, IOException {  
28.         message(request,response);  
29.     }  
30.     private void connect(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException{  
31.         log.info("RemoteAddr: "+ request.getRemoteAddr());  
32.         log.info("QueryString: "+ request.getQueryString());  
33.          if(!accessing(request, response)){  
34.              log.info("服务器接入失败.......");  
35.              return ;  
36.          }  
37.         String echostr=getEchostr();  
38.         if(echostr!=null && !"".equals(echostr)){  
39.                 log.info("服务器接入生效..........");  
40.                 response.getWriter().print(echostr);//完成相互认证  
41.         }  
42.     }  
43.     private boolean accessing(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {  
44.         String signature = request.getParameter("signature");  
45.         String timestamp = request.getParameter("timestamp");  
46.         String nonce = request.getParameter("nonce");  
47.         String echostr = request.getParameter("echostr");  
48.         if( isEmpty(signature)){  
49.             return false;  
50.         }  
51.         if(isEmpty(timestamp)){  
52.             return false;  
53.         }  
54.         if(isEmpty(nonce)){  
55.             return false;  
56.         }  
57.         if(isEmpty(echostr)){  
58.             return false;  
59.         }  
60.         String[] ArrTmp = { Token, timestamp, nonce };  
61.         Arrays.sort(ArrTmp);  
62.         StringBuffer sb = new StringBuffer();  
63.         for (int i = 0; i < ArrTmp.length; i++) {  
64.             sb.append(ArrTmp[i]);  
65.         }  
66.         String pwd = Encrypt(sb.toString());  
67.         log.info("signature:"+signature+"timestamp:"+timestamp+"nonce:"+nonce+"pwd:"+pwd+"echostr:"+echostr);  
68.         if(trim(pwd).equals(trim(signature))){  
69.             this.echostr =echostr;  
70.             return true;  
71.         }else{  
72.             return false;  
73.         }  
74.     }  
75.     private String Encrypt(String strSrc) {  
76.         MessageDigest md = null;  
77.         String strDes = null;  
78.         byte[] bt = strSrc.getBytes();  
79.         try {  
80.             md = MessageDigest.getInstance("SHA-1");  
81.             md.update(bt);  
82.             strDes = bytes2Hex(md.digest()); //to HexString  
83.         } catch (NoSuchAlgorithmException e) {  
84.             System.out.println("Invalid algorithm.");  
85.             return null;  
86.         }  
87.         return strDes;  
88.     }  
89.     public String bytes2Hex(byte[] bts) {  
90.         String des = "";  
91.         String tmp = null;  
92.         for (int i = 0; i < bts.length; i++) {  
93.             tmp = (Integer.toHexString(bts[i] & 0xFF));  
94.             if (tmp.length() == 1) {  
95.                 des += "0";  
96.             }  
97.             des += tmp;  
98.         }  
99.         return des;  
100.     }  
101.     public String getEchostr(){  
102.         return echostr;  
103.     }  
104.      private void message(HttpServletRequest request,HttpServletResponse response) throws ServletException, IOException{  
105.             InputStream is = request.getInputStream();  
106.             // 取HTTP请求流长度  
107.             int size = request.getContentLength();  
108.             // 用于缓存每次读取的数据  
109.             byte[] buffer = new byte[size];  
110.             // 用于存放结果的数组  
111.             byte[] xmldataByte = new byte[size];  
112.             int count = 0;  
113.             int rbyte = 0;  
114.             // 循环读取  
115.             while (count < size) {   
116.                 // 每次实际读取长度存于rbyte中  
117.                 rbyte = is.read(buffer);   
118.                 for(int i=0;i<rbyte;i++) {  
119.                     xmldataByte[count + i] = buffer[i];  
120.                 }  
121.                 count += rbyte;  
122.             }  
123.             is.close();  
124.             String requestStr = new String(xmldataByte, "UTF-8");  
125.             try{  
126.                 manageMessage(requestStr,request,response);  
127.             }catch(Exception e){  
128.                 e.printStackTrace();  
129.             }  
130.         }  
131.       private void  manageMessage(String requestStr,HttpServletRequest request,HttpServletResponse response)throws ServletException,IOException{  
132.             String responseStr;  
133.             try {  
134.                  XMLSerializer xmlSerializer=new XMLSerializer();  
135.                  JSONObject jsonObject =(JSONObject) xmlSerializer.read(requestStr);  
136.                  String event =jsonObject.getString("Event");  
137.                  String msgtype =jsonObject.getString("MsgType");  
138.                  if("CLICK".equals(event) && "event".equals(msgtype)){ //菜单click事件  
139.                      String eventkey =jsonObject.getString("EventKey");  
140.                      if("hytd_001".equals(eventkey)){ // hytd_001 这是好友团队按钮的标志值  
141.                          jsonObject.put("Content", "欢迎使用好友团队菜单click按钮.");  
142.                      }  
143.                  }  
144.                  responseStr =creatRevertText(jsonObject);//创建XML  
145.                  log.info("responseStr:"+responseStr);  
146.                  OutputStream os =response.getOutputStream();  
147.                  os.write(responseStr.getBytes("UTF-8"));  
148.             }   catch (Exception e) {  
149.                 e.printStackTrace();  
150.             }  
151.     }  
152.     private String creatRevertText(JSONObject jsonObject){  
153.             StringBuffer revert =new StringBuffer();  
154.             revert.append("<xml>");  
155.             revert.append("<ToUserName><![CDATA["+jsonObject.get("ToUserName")+"]]></ToUserName>");  
156.             revert.append("<FromUserName><![CDATA["+jsonObject.get("FromUserName")+"]]></FromUserName>");  
157.             revert.append("<CreateTime>"+jsonObject.get("CreateTime")+"</CreateTime>");  
158.             revert.append("<MsgType><![CDATA[text]]></MsgType>");  
159.             revert.append("<Content><![CDATA["+jsonObject.get("Content")+"]]></Content>");  
160.             revert.append("<FuncFlag>0</FuncFlag>");  
161.             revert.append("</xml>");  
162.             return revert.toString();  
163.         }  
164.     @Override  
165.     public void init() throws ServletException {  
166.         Token="test123";  
167.     }  
168.     private boolean isEmpty(String str){  
169.         return null ==str || "".equals(str) ? true :false;  
170.     }  
171.     private String trim(String str){  
172.         return null !=str  ? str.trim() : str;  
173.     }  
174. }  

 4.   本地部署应用  访问http://localhost:端口号/上下文/wenxin 

5  .申请成为开发者

访问 http://mp.weixin.qq.com   ，开启开发者模式。填入URL和taken，申请成功，如下所示：

填入URL：http://外网IP/TestWeixin/weixin 【必须80端】

填入token :  test123【需要与代码中的token保持一致，Token的长度是有限制的，根据笔者的经验最好不超过10个字符。】