Java微信二次開發（九）

多媒體文件上傳與下載

第一步：找到包com.wtz.vo，新建類WeixinMedia.java

package com.wtz.vo;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月25日 上午11:10:31
 *  <p>version:1.0</p>
 *     <p>description:媒體文件信息</p>
 */
public class WeixinMedia {
    // 媒體文件類型
    private String type;
    // 媒體文件標識或縮略圖的媒體文件標識
    private String mediaId;
    // 媒體文件上傳的時間
    private int createdAt;

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getMediaId() {
        return mediaId;
    }

    public void setMediaId(String mediaId) {
        this.mediaId = mediaId;
    }

    public int getCreatedAt() {
        return createdAt;
    }

    public void setCreatedAt(int createdAt) {
        this.createdAt = createdAt;
    }
}

?

?

第二步，找到包com.wtz.util，修改類AdvancedUtil.java

package com.wtz.util;

import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.wtz.vo.UserInfo;
import com.wtz.vo.UserList;
import com.wtz.vo.WeixinMedia;

/**
 *     @author wangtianze QQ:864620012
 *    @date 2017年4月24日 下午7:36:03
 *  <p>version:1.0</p>
 *     <p>description:高級接口工具類</p>
 */
public class AdvancedUtil {
    private static Logger log = LoggerFactory.getLogger(AdvancedUtil.class);
    
    /**
     * 獲取用戶信息
     * 
     * @param accessToken 接口訪問憑證
     * @param openId 用戶憑證
     * @return WeixinUserInfo
     */
    public static UserInfo getUserInfo(String accessToken,String openId){
        UserInfo weixinUserInfo = null;
        //拼接請求地址
        String requestUrl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid=OPENID";
        requestUrl = requestUrl.replace("ACCESS_TOKEN",accessToken).replace("OPENID",openId);
        //獲取用戶信息
        JSONObject jsonObject = WeixinUtil.httpsRequest(requestUrl, "GET", null);
        
        if(null != jsonObject){
            try{
                weixinUserInfo = new UserInfo();
                
                //用戶的標識
                weixinUserInfo.setOpenId(jsonObject.getString("openid"));
                
                //關注狀態（1是關注，0是未關注），未關注時獲取不到其余信息
                weixinUserInfo.setSubscribe(jsonObject.getInt("subscribe"));
                
                //用戶關注時間
                weixinUserInfo.setSubscribeTime(jsonObject.getString("subscribe_time"));
                
                //昵稱
                weixinUserInfo.setNickname(jsonObject.getString("nickname"));
                
                //用戶的性別（1是男性，2是女性，0是未知）
                weixinUserInfo.setSex(jsonObject.getInt("sex"));
                
                //用戶所在的國家
                weixinUserInfo.setCountry(jsonObject.getString("country"));
                
                //用戶所在的省份
                weixinUserInfo.setProvince(jsonObject.getString("province"));
                
                //用戶所在的城市
                weixinUserInfo.setCity(jsonObject.getString("city"));
                
                //用戶的語言，簡體中文為zh_CN
                weixinUserInfo.setLanguage(jsonObject.getString("language"));
                
                //用戶頭像
                weixinUserInfo.setHeadImgUrl(jsonObject.getString("headimgurl"));
                
                //uninonid
                weixinUserInfo.setUnionid(jsonObject.getString("unionid"));
            }catch(Exception e){
                if(0 == weixinUserInfo.getSubscribe()){
                    log.error("用戶{}已取消關注",weixinUserInfo.getOpenId());
                }else{
                    int errorCode = jsonObject.getInt("errcode");
                    String errorMsg = jsonObject.getString("errmsg");
                    log.error("獲取用戶信息失敗 errorcode:{} errormsg:{}",errorCode,errorMsg);
                }
            }
        }
        return weixinUserInfo;
    } 
    
    /**
     * 獲取關注者列表
     * 
     * @param accessToken 調用接口憑證
     * @param nextOpenId 第一個拉取nextOpenId，不填默認從頭開始拉取
     * @return WeixinUserList
     */
    @SuppressWarnings({ "deprecation", "unchecked" })
    public static UserList getUserList(String accessToken,String nextOpenId){
        UserList weixinUserList = null;
        if(null == nextOpenId){
            nextOpenId = "";
        }
        //拼接請求地址
        String requestUrl = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN&next_openid=NEXT_OPENID";
        
        requestUrl.replace("ACCESS_TOKEN", accessToken).replace("NEXT_OPENID",nextOpenId);
        
        //獲取關注者列表
        JSONObject jsonObject = WeixinUtil.httpsRequest(requestUrl, "GET", null);
        
        //如果請求成功
        if(null != jsonObject){
            weixinUserList = new UserList();
            weixinUserList.setTotal(jsonObject.getInt("total"));
            weixinUserList.setCount(jsonObject.getInt("count"));
            weixinUserList.setNextOpenId(jsonObject.getString("next_openid"));
            JSONObject dataObject = (JSONObject)jsonObject.get("data");
            weixinUserList.setOpenIdList(JSONArray.toList(dataObject.getJSONArray("openid"),List.class));    
        }

        return weixinUserList;
    }
    
    /** 
     * 上傳媒體文件 
     * @param accessToken 接口訪問憑證 
     * @param type 媒體文件類型，分別有圖片（image）、語音（voice）、視頻（video），普通文件(file) 
     * @param media form-data中媒體文件標識，有filename、filelength、content-type等信息 
     * @param mediaFileUrl 媒體文件的url 
     * 上傳的媒體文件限制 
        * 圖片（image）:1MB，支持JPG格式 
        * 語音（voice）：2MB，播放長度不超過60s，支持AMR格式 
        * 視頻（video）：10MB，支持MP4格式 
        * 普通文件（file）：10MB 
     * */  
    public static WeixinMedia uploadMedia(String accessToken, String type, String mediaFileUrl) {  
        WeixinMedia weixinMedia = null;  
        // 拼裝請求地址  
        String uploadMediaUrl = "https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE";  
        uploadMediaUrl = uploadMediaUrl.replace("ACCESS_TOKEN", accessToken).replace("TYPE", type);  
      
        // 定義數據分隔符  
        String boundary = "------------7da2e536604c8";  
        try {  
            URL uploadUrl = new URL(uploadMediaUrl);  
            HttpURLConnection uploadConn = (HttpURLConnection) uploadUrl.openConnection();  
            uploadConn.setDoOutput(true);  
            uploadConn.setDoInput(true);  
            uploadConn.setRequestMethod("POST");  
            // 設置請求頭Content-Type  
            uploadConn.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary);  
            // 獲取媒體文件上傳的輸出流（往微信服務器寫數據）  
            OutputStream outputStream = uploadConn.getOutputStream();  
      
            URL mediaUrl = new URL(mediaFileUrl);  
            HttpURLConnection meidaConn = (HttpURLConnection) mediaUrl.openConnection();  
            meidaConn.setDoOutput(true);  
            meidaConn.setRequestMethod("GET");  
      
            // 從請求頭中獲取內容類型  
            String contentType = meidaConn.getHeaderField("Content-Type");  
            // 根據內容類型判斷文件擴展名  
            String fileExt = WeixinUtil.getFileExt(contentType);  
            // 請求體開始  
            outputStream.write(("--" + boundary + "\r\n").getBytes());  
            outputStream.write(String.format("Content-Disposition: form-data; name=\"media\"; filename=\"file1%s\"\r\n", fileExt).getBytes());  
            outputStream.write(String.format("Content-Type: %s\r\n\r\n", contentType).getBytes());  
      
            // 獲取媒體文件的輸入流（讀取文件）  
            BufferedInputStream bis = new BufferedInputStream(meidaConn.getInputStream());  
            byte[] buf = new byte[8096];  
            int size = 0;  
            while ((size = bis.read(buf)) != -1) {  
                // 將媒體文件寫到輸出流（往微信服務器寫數據）  
                outputStream.write(buf, 0, size);  
            }  
            // 請求體結束  
            outputStream.write(("\r\n--" + boundary + "--\r\n").getBytes());  
            outputStream.close();  
            bis.close();  
            meidaConn.disconnect();  
      
            // 獲取媒體文件上傳的輸入流（從微信服務器讀數據）  
            InputStream inputStream = uploadConn.getInputStream();  
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");  
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);  
            StringBuffer buffer = new StringBuffer();  
            String str = null;  
            while ((str = bufferedReader.readLine()) != null) {  
                buffer.append(str);  
            }  
            bufferedReader.close();  
            inputStreamReader.close();  
            // 釋放資源  
            inputStream.close();  
            inputStream = null;  
            uploadConn.disconnect();  
      
            // 使用JSON-lib解析返回結果  
            JSONObject jsonObject = JSONObject.fromObject(buffer.toString());  
            // 測試打印結果  
            System.out.println("打印測試結果"+jsonObject);  
            weixinMedia = new WeixinMedia();  
            weixinMedia.setType(jsonObject.getString("type"));  
            // type等于 縮略圖（thumb） 時的返回結果和其它類型不一樣  
            if ("thumb".equals(type))  
                weixinMedia.setMediaId(jsonObject.getString("thumb_media_id"));  
            else  
                weixinMedia.setMediaId(jsonObject.getString("media_id"));  
                weixinMedia.setCreatedAt(jsonObject.getInt("created_at"));  
        } catch (Exception e) {  
            weixinMedia = null;  
            String error = String.format("上傳媒體文件失敗：%s", e);  
            System.out.println(error);  
        }  
        return weixinMedia;  
    }  
    
    /** 
     * 獲取媒體文件 
     * @param accessToken 接口訪問憑證 
     * @param media_id 媒體文件id 
     * @param savePath 文件在服務器上的存儲路徑 
     * */  
    public static String downloadMedia(String accessToken, String mediaId, String savePath) {  
        String filePath = null;  
        // 拼接請求地址  
        String requestUrl = "https://qyapi.weixin.qq.com/cgi-bin/media/get?access_token=ACCESS_TOKEN&media_id=MEDIA_ID";  
        requestUrl = requestUrl.replace("ACCESS_TOKEN", accessToken).replace("MEDIA_ID", mediaId);  
        System.out.println(requestUrl);  
        try {  
            URL url = new URL(requestUrl);  
            HttpURLConnection conn = (HttpURLConnection) url.openConnection();  
            conn.setDoInput(true);  
            conn.setRequestMethod("GET");  
  
            if (!savePath.endsWith("/")) {  
                savePath += "/";  
            }  
            // 根據內容類型獲取擴展名  
            String fileExt = WeixinUtil.getFileExt(conn.getHeaderField("Content-Type"));  
            // 將mediaId作為文件名  
            filePath = savePath + mediaId + fileExt;  
  
            BufferedInputStream bis = new BufferedInputStream(conn.getInputStream());  
            FileOutputStream fos = new FileOutputStream(new File(filePath));  
            byte[] buf = new byte[8096];  
            int size = 0;  
            while ((size = bis.read(buf)) != -1)  
                fos.write(buf, 0, size);  
            fos.close();  
            bis.close();  
  
            conn.disconnect();  
            String info = String.format("下載媒體文件成功，filePath=" + filePath);  
            System.out.println(info);  
        } catch (Exception e) {  
            filePath = null;  
            String error = String.format("下載媒體文件失敗：%s", e);  
            System.out.println(error);  
        }  
        return filePath;  
    }  
    
    public static void main(String[] args){
        //獲取接口訪問憑證
        String accessToken = WeixinUtil.getToken(Parameter.appId,Parameter.appSecret).getAccessToken();
        System.out.println("accessToken:" + accessToken);
        
        //獲取關注者列表
        UserList weixinUserList = getUserList(accessToken,"");
        System.out.println("總關注用戶數：" + weixinUserList.getTotal());
        System.out.println("本次獲取用戶數：" + weixinUserList.getCount());
        System.out.println("OpenId列表：" + weixinUserList.getOpenIdList().toString());
        System.out.println("next_openid" + weixinUserList.getNextOpenId());
        
        UserInfo user = null;
        List<String> list = weixinUserList.getOpenIdList();
        for(int i = 0; i < list.size(); i++){
            //獲取用戶信息
            user = getUserInfo(accessToken,(String)list.get(i));
            System.out.println("OpenId:" + user.getOpenId());
            System.out.println("關注狀態:" + user.getSubscribe());
            System.out.println("關注時間:" + (new SimpleDateFormat("yyyy-MM-dd HH:mm-ss").format(new Date(new Long(user.getSubscribeTime())))));
            System.out.println("昵稱:" + user.getNickname());
            System.out.println("性別:" + user.getSex());
            System.out.println("國家:" + user.getCountry());
            System.out.println("省份:" + user.getProvince());
            System.out.println("城市:" + user.getCity());
            System.out.println("語言:" + user.getLanguage());
            System.out.println("頭像:" + user.getHeadImgUrl());
            System.out.println("unionid:" + user.getUnionid());
            System.out.println("=====================================");
        }
        
        /** 
         * 上傳多媒體文件 
         */  
        //地址  
        WeixinMedia weixinMedia = uploadMedia(accessToken, "image", "http://localhost:8080/weixinClient/images/a.jpg");  
        //media_id  
        System.out.println("media_id："+weixinMedia.getMediaId());  
        //類型  
        System.out.println("類型："+weixinMedia.getType());  
        //時間戳  
        System.out.println("時間戳："+weixinMedia.getCreatedAt());  
        //打印結果  
        if(null != weixinMedia){  
            System.out.println("上傳成功！");  
        } 
  
        /** 
         * 下載多媒體文件 
         */  
        String savePath = downloadMedia(accessToken, weixinMedia.getMediaId(), "C:/download");  
        System.out.println("下載成功之后保存在本地的地址為："+savePath);  
    }
}

多媒體文件上傳與下載完成