java微信开发之上传下载多媒体文件的示例-古蔺大橙子建站
RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
java微信开发之上传下载多媒体文件的示例

这篇文章将为大家详细讲解有关java微信开发之上传下载多媒体文件的示例,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

在梁河等地区,都构建了全面的区域性战略布局,加强发展的系统性、市场前瞻性、产品创新能力,以专注、极致的服务理念,为客户提供成都网站制作、成都网站设计 网站设计制作按需网站建设,公司网站建设,企业网站建设,成都品牌网站建设,成都营销网站建设,成都外贸网站建设,梁河网站建设费用合理。

回复图片、音频、视频消息都是需要media_id的,这个是需要将多媒体文件上传到微信服务器才有的。

上传下载多媒体文件的方法还是写到WeixinUtil.java中。

代码如下:

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.NoSuchProviderException;
import java.security.SecureRandom;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
 
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
 
import net.sf.json.JSONObject;
 
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
 
import com.company.project.model.menu.AccessToken;
import com.company.project.model.menu.Menu;
 
public class WeixinUtil {
 private static Logger log = Logger.getLogger(WeixinUtil.class);
 public final static String APPID = "wxb927d4280e6db674";
 public final static String APP_SECRET = "21441e9f3226eee81e14380a768b6d1e";
 // 获取access_token的接口地址(GET) 限200(次/天)
 public final static String access_token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";
 // 创建菜单
 public final static String create_menu_url = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN";
 // 存放:1.token,2:获取token的时间,3.过期时间
 public final static Map accessTokenMap = new HashMap();
 /**
 * 发起https请求并获取结果
 * 
 * @param requestUrl 请求地址
 * @param requestMethod 请求方式(GET、POST)
 * @param outputStr 提交的数据
 * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
 */
 public static JSONObject handleRequest(String requestUrl,String requestMethod,String outputStr) {
 JSONObject jsonObject = null;
  
 try {
  URL url = new URL(requestUrl);
  HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
  SSLContext ctx = SSLContext.getInstance("SSL", "SunJSSE");
  TrustManager[] tm = {new MyX509TrustManager()};
  ctx.init(null, tm, new SecureRandom());
  SSLSocketFactory sf = ctx.getSocketFactory();
  conn.setSSLSocketFactory(sf);
  conn.setDoInput(true);
  conn.setDoOutput(true);
  conn.setRequestMethod(requestMethod);
  conn.setUseCaches(false);
   
  if ("GET".equalsIgnoreCase(requestMethod)) {
  conn.connect();
  }
   
  if (StringUtils.isNotEmpty(outputStr)) {
  OutputStream out = conn.getOutputStream();
  out.write(outputStr.getBytes("utf-8"));
  out.close();
  }
   
  InputStream in = conn.getInputStream();
  BufferedReader br = new BufferedReader(new InputStreamReader(in,"utf-8"));
  StringBuffer buffer = new StringBuffer();
  String line = null;
   
  while ((line = br.readLine()) != null) {
  buffer.append(line);
  }
   
  in.close();
  conn.disconnect();
   
  jsonObject = JSONObject.fromObject(buffer.toString());
 } catch (MalformedURLException e) {
  e.printStackTrace();
  log.error("URL错误!");
 } catch (IOException e) {
  e.printStackTrace();
 } catch (NoSuchAlgorithmException e) {
  e.printStackTrace();
 } catch (NoSuchProviderException e) {
  e.printStackTrace();
 } catch (KeyManagementException e) {
  e.printStackTrace();
 }
 return jsonObject;
 }
  
 /**
 * 获取access_token
 *
 * @author qincd
 * @date Nov 6, 2014 9:56:43 AM
 */
 public static AccessToken getAccessToken(String appid,String appSecret) {
 AccessToken at = new AccessToken();
 // 每次获取access_token时,先从accessTokenMap获取,如果过期了就重新从微信获取
 // 没有过期直接返回
 // 从微信获取的token的有效期为2个小时
 if (!accessTokenMap.isEmpty()) {
  Date getTokenTime = (Date) accessTokenMap.get("getTokenTime");
  Calendar c = Calendar.getInstance();
  c.setTime(getTokenTime);
  c.add(Calendar.HOUR_OF_DAY, 2);
   
  getTokenTime = c.getTime();
  if (getTokenTime.after(new Date())) {
  log.info("缓存中发现token未过期,直接从缓存中获取access_token");
  // token未过期,直接从缓存获取返回
  String token = (String) accessTokenMap.get("token");
  Integer expire = (Integer) accessTokenMap.get("expire");
  at.setToken(token);
  at.setExpiresIn(expire);
  return at;
  }
 }
 String requestUrl = access_token_url.replace("APPID", appid).replace("APPSECRET", appSecret);
  
 JSONObject object = handleRequest(requestUrl, "GET", null);
 String access_token = object.getString("access_token");
 int expires_in = object.getInt("expires_in");
  
 log.info("\naccess_token:" + access_token);
 log.info("\nexpires_in:" + expires_in);
  
 at.setToken(access_token);
 at.setExpiresIn(expires_in);
  
 // 每次获取access_token后,存入accessTokenMap
 // 下次获取时,如果没有过期直接从accessTokenMap取。
 accessTokenMap.put("getTokenTime", new Date());
 accessTokenMap.put("token", access_token);
 accessTokenMap.put("expire", expires_in);
  
 return at;
 }
  
 /**
 * 创建菜单
 *
 * @author qincd
 * @date Nov 6, 2014 9:56:36 AM
 */
 public static boolean createMenu(Menu menu,String accessToken) {
 String requestUrl = create_menu_url.replace("ACCESS_TOKEN", accessToken);
 String menuJsonString = JSONObject.fromObject(menu).toString();
 JSONObject jsonObject = handleRequest(requestUrl, "POST", menuJsonString);
 String errorCode = jsonObject.getString("errcode");
 if (!"0".equals(errorCode)) {
  log.error(String.format("菜单创建失败!errorCode:%d,errorMsg:%s",jsonObject.getInt("errcode"),jsonObject.getString("errmsg")));
  return false;
 }
  
 log.info("菜单创建成功!");
  
 return true;
 }
  
 // 上传多媒体文件到微信服务器
 public static final String upload_media_url = "http://file.api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE";
 /**
 * 上传多媒体文件到微信服务器
 * @see http://www.oschina.net/code/snippet_1029535_23824  * @see http://mp.weixin.qq.com/wiki/index.php?title=上传下载多媒体文件  *  * @author qincd  * @date Nov 6, 2014 4:11:22 PM  */  public static JSONObject uploadMediaToWX(String filePath,String type,String accessToken) throws IOException{  File file = new File(filePath);  if (!file.exists()) {   log.error("文件不存在!");   return null;  }     String url = upload_media_url.replace("ACCESS_TOKEN", accessToken).replace("TYPE", type);  URL urlObj = new URL(url);  HttpURLConnection conn = (HttpURLConnection) urlObj.openConnection();  conn.setDoInput(true);  conn.setDoOutput(true);  conn.setUseCaches(false);     conn.setRequestProperty("Connection", "Keep-Alive");     conn.setRequestProperty("Charset", "UTF-8");        // 设置边界     String BOUNDARY = "----------" + System.currentTimeMillis();     conn.setRequestProperty("Content-Type", "multipart/form-data; boundary="         + BOUNDARY);        // 请求正文信息        // 第一部分:     StringBuilder sb = new StringBuilder();     sb.append("--"); // ////////必须多两道线     sb.append(BOUNDARY);     sb.append("\r\n");     sb.append("Content-Disposition: form-data;name=\"file\";filename=\""         + file.getName() + "\"\r\n");     sb.append("Content-Type:application/octet-stream\r\n\r\n");        byte[] head = sb.toString().getBytes("utf-8");        // 获得输出流     OutputStream out = new DataOutputStream(conn.getOutputStream());     out.write(head);        // 文件正文部分     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[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线        out.write(foot);        out.flush();     out.close();        /**      * 读取服务器响应,必须读取,否则提交不成功      */      try {      // 定义BufferedReader输入流来读取URL的响应      StringBuffer buffer = new StringBuffer();      BufferedReader reader = new BufferedReader(new InputStreamReader(      conn.getInputStream()));      String line = null;      while ((line = reader.readLine()) != null) {       buffer.append(line);      }             reader.close();      conn.disconnect();             return JSONObject.fromObject(buffer.toString());      } catch (Exception e) {      log.error("发送POST请求出现异常!" + e);      e.printStackTrace();      }  return null;  }     public static final String download_media_url = "http://file.api.weixin.qq.com/cgi-bin/media/get?access_token=ACCESS_TOKEN&media_id=MEDIA_ID";  /**  * 从微信服务器下载多媒体文件  *  * @author qincd  * @date Nov 6, 2014 4:32:12 PM  */  public static String downloadMediaFromWx(String accessToken,String mediaId,String fileSavePath) throws IOException {  if (StringUtils.isEmpty(accessToken) || StringUtils.isEmpty(mediaId)) return null;     String requestUrl = download_media_url.replace("ACCESS_TOKEN", accessToken).replace("MEDIA_ID", mediaId);  URL url = new URL(requestUrl);  HttpURLConnection conn = (HttpURLConnection) url.openConnection();  conn.setRequestMethod("GET");  conn.setDoInput(true);  conn.setDoOutput(true);  InputStream in = conn.getInputStream();     File dir = new File(fileSavePath);  if (!dir.exists()) {   dir.mkdirs();  }  if (!fileSavePath.endsWith("/")) {   fileSavePath += "/";  }     String ContentDisposition = conn.getHeaderField("Content-disposition");  String weixinServerFileName = ContentDisposition.substring(ContentDisposition.indexOf("filename")+10, ContentDisposition.length() -1);  fileSavePath += weixinServerFileName;   BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(fileSavePath));  byte[] data = new byte[1024];  int len = -1;     while ((len = in.read(data)) != -1) {   bos.write(data,0,len);  }     bos.close();  in.close();  conn.disconnect();     return fileSavePath;  } }

测试代码:

public class WeixinUtilTest {
 
 /**
 *
 * @author qincd
 * @date Nov 6, 2014 9:57:54 AM
 */
 public static void main(String[] args) {
 // 1).获取access_token
 AccessToken accessToken = WeixinUtil.getAccessToken(WeixinUtil.APPID, WeixinUtil.APP_SECRET);
 String filePath = "C:\\Users\\qince\\Pictures\\壁纸20141029091612.jpg";
 JSONObject uploadJsonObj = testUploadMedia(filePath,"image",accessToken.getToken());
 if (uploadJsonObj == null) {
  System.out.println("上传图片失败");
  return;
 }
  
 int errcode = 0;
 if (uploadJsonObj.containsKey("errcode")) {
  errcode = uploadJsonObj.getInt("errcode");
 }
 if (errcode == 0) {
  System.out.println("图片上传成功");
   
  String mediaId = uploadJsonObj.getString("media_id");
  long createAt = uploadJsonObj.getLong("created_at");
  System.out.println("--Details:");
  System.out.println("media_id:" + mediaId);
  System.out.println("created_at:" + createAt);
 }
 else {
  System.out.println("图片上传失败!");
   
  String errmsg = uploadJsonObj.getString("errmsg");
  System.out.println("--Details:");
  System.out.println("errcode:" + errcode);
  System.out.println("errmsg:" + errmsg);
 }
  
 String mediaId = "6W-UvSrQ2hkdSdVQJJXShwtFDPLfbGI1qnbNFy8weZyb9Jac2xxxcAUwt8p4sYPH";
 String filepath = testDownloadMedia(accessToken.getToken(), mediaId, "d:/test");
 System.out.println(filepath);
 }
 
 
 /**
 * 上传多媒体文件到微信
 *
 * @author qincd
 * @date Nov 6, 2014 4:15:14 PM
 */
 public static JSONObject testUploadMedia(String filePath,String type,String accessToken) {
 try {
  return WeixinUtil.uploadMediaToWX(filePath, type, accessToken);
 } catch (IOException e) {
  e.printStackTrace();
 }
  
 return null;
 }
  
 /**
 * 从微信下载多媒体文件
 *
 * @author qincd
 * @date Nov 6, 2014 4:56:25 PM
 */
 public static String testDownloadMedia(String accessToken,String mediaId,String fileSaveDir) {
 try {
  return WeixinUtil.downloadMediaFromWx(accessToken, mediaId, fileSaveDir);
 } catch (IOException e) {
  e.printStackTrace();
 }
  
 return null;
 }
}

关于“java微信开发之上传下载多媒体文件的示例”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。


网站名称:java微信开发之上传下载多媒体文件的示例
浏览路径:http://scgulin.cn/article/jhecgs.html