微信开发的消息接口

感觉微信开发就是要调用微信的接口，所以在没安排工作的时候看和试着调用微信接口，调用微信接口需要发送http的get和post请求，所以最好先写个httputil类，专门发送get和post请求，然而我的java网络编程学的并不好，于是百度一些代码，然后自己封装一些，可以正常使用就行了，代码如下

import java.io.BufferedReader;import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.PrintWriter;import java.net.HttpURLConnection;import java.net.URL;import java.net.URLConnection;import java.util.Iterator;import java.util.Map;import javax.activation.MimetypesFileTypeMap;/** *  * @author luolei * */public class HttpUtil {        public static String httpGet(String httpUrl){        StringBuffer buffer = null;         try{            URL url = new URL(httpUrl);            HttpURLConnection httpUrlConn = (HttpURLConnection) url.openConnection();              httpUrlConn.setDoInput(true);              httpUrlConn.setRequestMethod("GET");          // 获取输入流              InputStream inputStream = httpUrlConn.getInputStream();              InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");              BufferedReader bufferedReader = new BufferedReader(inputStreamReader);              // 读取返回结果              buffer = new StringBuffer();              String str = null;              while ((str = bufferedReader.readLine()) != null) {                  buffer.append(str);              }              // 释放资源              bufferedReader.close();              inputStreamReader.close();              inputStream.close();              httpUrlConn.disconnect();         }catch(Exception e){            e.printStackTrace();        }        return buffer.toString();            }        /**     *      * 发 post 请求，     */    public static String httpPost(String httpUrl,String data){        PrintWriter out = null;        BufferedReader in = null;        String result = "";        try {            URL realUrl = new URL(httpUrl);            // 打开和URL之间的连接            URLConnection conn = realUrl.openConnection();            // 设置通用的请求属性            conn.setRequestProperty("accept", "*/*");            conn.setRequestProperty("connection", "Keep-Alive");            conn.setRequestProperty("user-agent",                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");            // 发送POST请求必须设置如下两行            conn.setDoOutput(true);            conn.setDoInput(true);            // 获取URLConnection对象对应的输出流            out = new PrintWriter(conn.getOutputStream());            // 发送请求参数            out.print(data);            // flush输出流的缓冲            out.flush();            // 定义BufferedReader输入流来读取URL的响应            in = new BufferedReader(                    new InputStreamReader(conn.getInputStream()));            String line;            while ((line = in.readLine()) != null) {                result += line;            }        } catch (Exception e) {            System.out.println("发送 POST 请求出现异常！"+e);            e.printStackTrace();        }        //使用finally块来关闭输出流、输入流        finally{            try{                if(out!=null){                    out.close();                }                if(in!=null){                    in.close();                }            }            catch(IOException ex){                ex.printStackTrace();            }        }        return result;    }        /**     * 上传图片     *      * @param urlStr     * @param textMap     * @param fileMap     * @return     */    public static String formUpload(String urlStr, Map<String, String> textMap,            Map<String, String> fileMap) {        String res = "";        HttpURLConnection conn = null;        String BOUNDARY = "---------------------------123821742118716"; //boundary就是request头和上传文件内容的分隔符        try {            URL url = new URL(urlStr);            conn = (HttpURLConnection) url.openConnection();//            System.out.println(conn);            conn.setConnectTimeout(5000);            conn.setReadTimeout(30000);            conn.setDoOutput(true);            conn.setDoInput(true);            conn.setUseCaches(false);            conn.setRequestMethod("POST");            conn.setRequestProperty("Connection", "Keep-Alive");            conn                    .setRequestProperty("User-Agent",                            "Mozilla/5.0 (Windows; U; Windows NT 6.1; zh-CN; rv:1.9.2.6)");            conn.setRequestProperty("Content-Type",                    "multipart/form-data; boundary=" + BOUNDARY);            OutputStream out = new DataOutputStream(conn.getOutputStream());            // text            if (textMap != null) {                StringBuffer strBuf = new StringBuffer();                Iterator iter = textMap.entrySet().iterator();                while (iter.hasNext()) {                    Map.Entry entry = (Map.Entry) iter.next();                    String inputName = (String) entry.getKey();                    String inputValue = (String) entry.getValue();                    if (inputValue == null) {                        continue;                    }                    strBuf.append("/r/n").append("--").append(BOUNDARY).append(                            "/r/n");                    strBuf.append("Content-Disposition: form-data; name=/""                            + inputName + "/"/r/n/r/n");                    strBuf.append(inputValue);                }                out.write(strBuf.toString().getBytes());            }            // file            if (fileMap != null) {                Iterator iter = fileMap.entrySet().iterator();                while (iter.hasNext()) {                    Map.Entry entry = (Map.Entry) iter.next();                    String inputName = (String) entry.getKey();                    String inputValue = (String) entry.getValue();                    if (inputValue == null) {                        continue;                    }                    File file = new File(inputValue);                    String filename = file.getName();                    String contentType = new MimetypesFileTypeMap()                            .getContentType(file);                    if (filename.endsWith(".png")) {                        contentType = "image/png";                    }                    if (contentType == null || contentType.equals("")) {                        contentType = "application/octet-stream";                    }                    StringBuffer strBuf = new StringBuffer();                    strBuf.append("/r/n").append("--").append(BOUNDARY).append(                            "/r/n");                    strBuf.append("Content-Disposition: form-data; name=/""                            + inputName + "/"; filename=/"" + filename                            + "/"/r/n");                    strBuf.append("Content-Type:" + contentType + "/r/n/r/n");                    out.write(strBuf.toString().getBytes());                    DataInputStream in = new DataInputStream(                            new FileInputStream(file));                    int bytes = 0;                    byte[] bufferOut = new byte[1024];                    while ((bytes = in.read(bufferOut)) != -1) {                        out.write(bufferOut, 0, bytes);                    }                    in.close();                }            }            byte[] endData = ("/r/n--" + BOUNDARY + "--/r/n").getBytes();            out.write(endData);            out.flush();            out.close();            // 读取返回数据            StringBuffer strBuf = new StringBuffer();            BufferedReader reader = new BufferedReader(new InputStreamReader(                    conn.getInputStream()));            String line = null;            while ((line = reader.readLine()) != null) {                strBuf.append(line).append("/n");            }            res = strBuf.toString();            reader.close();            reader = null;        } catch (Exception e) {            System.out.println("发送POST请求出错。" + urlStr);            e.printStackTrace();        } finally {            if (conn != null) {                conn.disconnect();                conn = null;            }        }        return res;    }    }

其中的httpGet 和httpPost 用来发送get,和post请求，微信开发里面，消息接口一般是xml格式的，其他的接口上传和返回的数据一般是json，所以需要一个解析json的包，我用的是fastjson，当然也可以用gson

现在开始消息接口的测试，首先要了解请求过程：

微信服务器会根据填写的url发送get请求进行验证，当验证成功，还是根据url发送post请求，消息格式为xml格式

消息类型开发文档上有，主要有文本，图片，语音等消息，还有一些事件，如关注，点击，和跳转。

这些消息和事件是xml格式，所以要对xml格式的消息进行解析，我用的dom4j解析，

在之前验证接入的servlet的doPost方法解析消息，

我是按照柳峰的博客里面写的方法，写了个MessageUtil,里面封装了解析xml的方法，并把解析出来的结果放在map<string,string>中，具体代码如下：

public static Map<String, String> parseXml(HttpServletRequest request) throws Exception {          // 将解析结果存储在HashMap中          Map<String, String> map = new HashMap<String, String>();            // 从request中取得输入流          InputStream inputStream = request.getInputStream();          // 读取输入流          SAXReader reader = new SAXReader();          Document document = reader.read(inputStream);          // 得到xml根元素          Element root = document.getRootElement();          // 得到根元素的所有子节点          List<Element> elementList = root.elements();            // 遍历所有子节点          for (Element e : elementList)              map.put(e.getName(), e.getText());            // 释放资源          inputStream.close();          inputStream = null;            return map;      }

那么经过解析后的xml会按照 标签名 - 内容 保存在map中

然后可以从中取出消息类型msgType

String msgType = requestMap.get("MsgType");

然后判断消息的类型，不同的消息类型，让不同的servlet去处理，

// 文本消息            if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {                request.getRequestDispatcher("TextMessage").forward(request, response);            }            // 图片消息            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {                request.getRequestDispatcher("ImageServlet").forward(request, response);            }            // 地理位置消息            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {                request.getRequestDispatcher("LocationServlet").forward(request, response);            }            // 链接消息            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {                request.getRequestDispatcher("LinkServlet").forward(request, response);            }            // 音频消息            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {                request.getRequestDispatcher("VedioServlet").forward(request, response);            }            // 事件推送            else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {                // 事件类型                String eventType = requestMap.get("Event");                // 订阅                if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {                    request.getRequestDispatcher("SubServlet").forward(request, response);                }                // 取消订阅                else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {                    // TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息                                    }                // 自定义菜单点击事件                else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {                    // TODO 自定义菜单权没有开放，暂不处理该类消息                    request.getRequestDispatcher("ClickServlet").forward(request, response);                }            }

不同的servlet里面处理不同的消息，可以根据需要返回不同的消息，返回消息的格式也是xml格式的，返回消息类型跟接受的消息类型基本类似，可以对这些返回的消息进行封装，每个xml标签对应字段名，内容就是字段的内容

例子：

public class BaseMessageResp {    // 接收方帐号（收到的OpenID）      private String ToUserName;      // 开发者微信号      private String FromUserName;      // 消息创建时间 （整型）      private long CreateTime;      // 消息类型（text/music/news）      private String MsgType;      // 位0x0001被标志时，星标刚收到的消息      private int FuncFlag;

省略了set,get方法

public class TextMessage extends BaseMessageResp {    // 回复的消息内容      private String Content;        public String getContent() {          return Content;      }        public void setContent(String content) {          Content = content;      }}

因为不同的消息有相同的字段，因此写了通用的基类。

现在离返回消息给用户还差一步，技术将这些pojo类转化为xml字符串

用的是xstream

/**      * 文本消息对象转换成xml      *       * @param textMessage 文本消息对象      * @return xml      */      public static String textMessageToXml(TextMessage textMessage) {          xstream.alias("xml", textMessage.getClass());          return xstream.toXML(textMessage);      }

这里只是简单的描述，具体的可以以看柳峰的博客，链接我忘记了，应该可以百度的到

最后将得到的string 返回给微信服务器就可以回复用户了。

只用这些消息接口就可以写一个简单的订阅号了，应该，一般公司的公众号好像是通过view类型的button跳到自己的网站里面去。

现在用上面的接口可以接受用户发送的各种消息，然后提前消息，可以自己进行处理，或者调用一些api，如天气，笑话，文章等api，得到结果，解析后，按照自己希望的格式返回给用户，可以实习一个生活助手之类的订阅号，但是个人申请的订阅号的权限有限，不知道能不能够胜任。

以上就是微信开发的消息接口的详细内容，更多请关注php中文网其它相关文章！