1.创建common文件夹，里面放WeixinUtil:

public class WeixinUtil {private static Logger log = LoggerFactory.getLogger(WeixinUtil.class);/*** 开发者id*/private static final String APPID = "****";/*** 开发者秘钥*/private static final String APPSECRET="****";// 获取access_token的接口地址（GET） 限200（次/天）//        https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRETpublic 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 ACCESS_TOKEN_URL = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=APPSECRET&code=CODE&grant_type=authorization_code";/*** 发起https请求并获取结果** @param requestUrl 请求地址* @param requestMethod 请求方式（GET、POST）* @param outputStr 提交的数据* @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)*/public static JSONObject httpRequest(String requestUrl, String requestMethod, String outputStr) {JSONObject jsonObject = null;StringBuffer buffer = new StringBuffer();try {// 创建SSLContext对象，并使用我们指定的信任管理器初始化TrustManager[] tm = { new MyX509TrustManager() };SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");sslContext.init(null, tm, new java.security.SecureRandom());// 从上述SSLContext对象中得到SSLSocketFactory对象SSLSocketFactory ssf = sslContext.getSocketFactory();URL url = new URL(requestUrl);HttpsURLConnection httpUrlConn = (HttpsURLConnection) url.openConnection();httpUrlConn.setSSLSocketFactory(ssf);httpUrlConn.setDoOutput(true);httpUrlConn.setDoInput(true);httpUrlConn.setUseCaches(false);// 设置请求方式（GET/POST）httpUrlConn.setRequestMethod(requestMethod);if ("GET".equalsIgnoreCase(requestMethod))httpUrlConn.connect();// 当有数据需要提交时if (null != outputStr) {OutputStream outputStream = httpUrlConn.getOutputStream();// 注意编码格式，防止中文乱码outputStream.write(outputStr.getBytes("UTF-8"));outputStream.close();}// 将返回的输入流转换成字符串InputStream inputStream = httpUrlConn.getInputStream();InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");BufferedReader bufferedReader = new BufferedReader(inputStreamReader);String str = null;while ((str = bufferedReader.readLine()) != null) {buffer.append(str);}bufferedReader.close();inputStreamReader.close();// 释放资源inputStream.close();inputStream = null;httpUrlConn.disconnect();jsonObject = JSONObject.fromObject(buffer.toString());} catch (ConnectException ce) {log.error("Weixin server connection timed out.");} catch (Exception e) {log.error("https request error:{}", e);}return jsonObject;}/*** 获取access_token** @param appid 凭证* @param appsecret 密钥* @return*/public static AccessToken getAccessToken(String appid, String appsecret) {AccessToken accessToken = null;String requestUrl = ACCESS_TOKEN_URL.replace("APPID", appid).replace("APPSECRET", appsecret);JSONObject jsonObject = httpRequest(requestUrl, "GET", null);// 如果请求成功if (null != jsonObject) {accessToken = new AccessToken();accessToken.setToken(jsonObject.getString("access_token"));accessToken.setExpiresIn(jsonObject.getInt("expires_in"));}return accessToken;}/*** 处理doget请求* @param url* @return*/public static JSONObject doGetstr(String url){CloseableHttpClient httpclient = HttpClients.createDefault();HttpGet httpGet = new HttpGet(url);JSONObject jsonObject = null;try {CloseableHttpResponse response = httpclient.execute(httpGet);HttpEntity entity = response.getEntity();if(entity!=null){String result = EntityUtils.toString(entity);jsonObject = JSONObject.fromObject(result);}} catch (IOException e) {e.printStackTrace();}return jsonObject;}/*** 处理post请求* @param url* @return*/public static JSONObject doPoststr(String url,String outStr){CloseableHttpClient httpclient = HttpClients.createDefault();HttpPost httpPost = new HttpPost(url);JSONObject jsonObject = null;try {httpPost.setEntity(new StringEntity(outStr, "utf-8"));CloseableHttpResponse response = httpclient.execute(httpPost);String result = EntityUtils.toString(response.getEntity(),"utf-8");jsonObject =JSONObject.fromObject(result);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}return jsonObject;}public static AccessToken getAccessToken(HttpSession session){System.out.println("从接口中获取");
//        Jedis jedis  = RedisUtil.getJedis();AccessToken token = new AccessToken();String url = ACCESS_TOKEN_URL.replace("APPID", APPID).replace("APPSECRET", APPSECRET);JSONObject json = doGetstr(url);System.out.println("存储的json："+json.toString());if(json!=null){token.setToken(json.getString("access_token"));token.setExpiresIn(json.getInt("expires_in"));/*  jedis.set("access_token", json.getString("access_token"));jedis.expire("access_token", 60*60*2);*/session.setAttribute("access_token",json.getString("access_token"));System.out.println("存储的access_token："+json.getString("access_token"));}
//        RedisUtil.returnResource(jedis);return token;}public static String  getAccess_Token(HttpSession session,HttpServletRequest request){System.out.println("从缓存中读取");
//        Jedis jedis  = RedisUtil.getJedis();
//        String access_token = jedis.get("access_token");Object access_token = request.getSession().getAttribute("access_token");System.out.println("SESSION里的access_token是否获取到："+access_token);if(access_token==null){AccessToken token = getAccessToken(session);access_token = token.getToken();}
//        RedisUtil.returnResource(jedis);return access_token.toString();}}

2.创建一个uploadUtil:

package com.naruto.huo.common;import net.sf.json.JSONObject;import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.NoSuchProviderException;public class UploadUtil {private static final String UPLOAD_URL ="https://api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE";/*** 文件上传* @param filePath* @param accessToken* @param type* @return* @throws IOException* @throws NoSuchAlgorithmException* @throws NoSuchProviderException* @throws KeyManagementException*/public static String upload(String filePath, String accessToken,String type) throws IOException, NoSuchAlgorithmException, NoSuchProviderException, KeyManagementException {File file = new File(filePath);if (!file.exists() || !file.isFile()) {throw new IOException("文件不存在");}String url = UPLOAD_URL.replace("ACCESS_TOKEN", accessToken).replace("TYPE",type);URL urlObj = new URL(url);//连接HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();con.setRequestMethod("POST");con.setDoInput(true);con.setDoOutput(true);con.setUseCaches(false);//设置请求头信息con.setRequestProperty("Connection", "Keep-Alive");con.setRequestProperty("Charset", "UTF-8");//设置边界String BOUNDARY = "----------" + System.currentTimeMillis();con.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(con.getOutputStream());//输出表头out.write(head);//文件正文部分//把文件已流文件的方式 推入到url中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();StringBuffer buffer = new StringBuffer();BufferedReader reader = null;String result = null;try {//定义BufferedReader输入流来读取URL的响应reader = new BufferedReader(new InputStreamReader(con.getInputStream()));String line = null;while ((line = reader.readLine()) != null) {buffer.append(line);}if (result == null) {result = buffer.toString();}} catch (IOException e) {e.printStackTrace();} finally {if (reader != null) {reader.close();}}JSONObject jsonObj = JSONObject.fromObject(result);String typeName = "media_id";if("thumb".equals(type)){typeName = type + "_media_id";}String mediaId = jsonObj.getString(typeName);return mediaId;}
}

3.在之前(一)的controller加一个图片判断:

@Component
public class MessageDispatcher {public static String processMessage(Map<String, String> map, HttpSession session, HttpServletRequest request) throws FileNotFoundException {String openid = map.get("FromUserName"); //用户 openidString mpid = map.get("ToUserName");   //公众号原始 IDString content = map.get("Content");if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {//普通文本消息TextMessage txtmsg = new TextMessage();txtmsg.setToUserName(openid);txtmsg.setFromUserName(mpid);txtmsg.setCreateTime(new Date().getTime());txtmsg.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);if("接收".equals(content)){txtmsg.setContent("接收到了!没错~");}else if("图片".equals(content)){MessageUtil util = new MessageUtil();return util.initMessage(openid, mpid,session,request);}else{txtmsg.setContent("您输入的是:"+content);}return MessageUtil.textMessageToXml(txtmsg);}/*    else if (map.get("MsgType").equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {// 图片消息respContent = "您发送的是图片消息！";respXml = WeChatUtil.sendTextMsg(requestMap, respContent);}*/return null;}public String processEvent(Map<String, String> map) {//在这里处理事件return "123";}
}

4.在(一)的messageUtil里面加代码:

/*处理图片*//*** 将信息转为xml格式*/public String messageToxml(ImageMessage imageMessage) {XStream xtream = new XStream();xtream.alias("xml", imageMessage.getClass());xtream.alias("Image", new Image().getClass());System.out.println("xtream.toString():"+xtream.toString());return xtream.toXML(imageMessage);}/*** 封装信息*/public String initMessage(String FromUserName, String ToUserName,HttpSession session, HttpServletRequest request) throws FileNotFoundException {Image image = new Image();image.setMediaId(getmediaId(session,request));log.info("MediaId:"+image.getMediaId());ImageMessage message = new ImageMessage();message.setFromUserName(ToUserName);message.setToUserName(FromUserName);message.setCreateTime(new Date().getTime());message.setImage(image);log.info("ToUserName:"+ToUserName);log.info("FromUserName:"+FromUserName);message.setMsgType("image");log.info("message:"+message.toString());return messageToxml(message);}@Value("${config.extPath}")private String extPath;/*** 获取Media* @return*/public String getmediaId(HttpSession session, HttpServletRequest request) throws FileNotFoundException {//获取classes目录绝对路径//ResourceUtils.getURL("classpath:").getPath();//String path = request.getSession().getServletContext().getRealPath("/static/pic/feng.png");//String path = ClassUtils.getDefaultClassLoader().getResource("").getPath()+"static/images/feng.png";String path = request.getServletContext().getRealPath("/")  + "WEB-INF/classes/static/images/feng.png";log.info("path:"+path);String accessToken = WeixinUtil.getAccess_Token(session,request);String mediaId = null;try {mediaId = UploadUtil.upload(path, accessToken.toString(), "image");} catch (KeyManagementException | NoSuchAlgorithmException| NoSuchProviderException | IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}return mediaId;}/*处理结束*/

5.最后成功之后则为