java中GET方式提交的示例：
/**
* 获取关注列表;
* @return
*/
@SuppressWarnings("unchecked")
public static ArrayList<String> getUserList() {
StringBuffer bufferRes = new StringBuffer();
ArrayList<String> users = null;
try {
URL realUrl = new URL("https://api.weixin.qq.com/cgi-bin/user/get?access_token=" + TokenProxys.accessTokens());
//URL realUrl = new URL("https://api.weixin.qq.com/cgi-bin/user/tag/get?access_token=" + TokenProxys.accessTokens());
HttpURLConnection conn = (HttpURLConnection)realUrl.openConnection();
// 请求方式
conn.setDoOutput(true);
conn.setDoInput(true);
conn.setRequestMethod("GET");
conn.setUseCaches(false);
conn.setInstanceFollowRedirects(true);
conn.setRequestProperty("Content-Type","application/json");
conn.connect();
// 获取URLConnection对象对应的输入流
InputStream in =conn.getInputStream();
BufferedReader read =new BufferedReader(new InputStreamReader(in,"UTF-8"));
String valueString =null;
while ((valueString=read.readLine())!=null){
bufferRes.append(valueString);
}
System.out.println(bufferRes);
in.close();
if (conn !=null){
// 关闭连接
conn.disconnect();
}
} catch (Exception e) {
e.printStackTrace();
}
//将返回的字符串转换成json
JSONObject jsonObject = JSONObject.fromObject(bufferRes.toString());
//解析json中表示openid的列表
JSONObject data = (JSONObject)jsonObject.get("data");
if(data!=null){
//将openid列表转化成数组保存
users = new ArrayList<String>(data.getJSONArray("openid"));
//获取关注者总数
int count = Integer.parseInt(jsonObject.get("total").toString());
if(count>1000){
JSONObject object = jsonObject;
String next_openid = null;
JSONObject ob_data = null;
ArrayList<String> ob_user = null;
//大于1000需要多次获取，或许次数为count/1000
for(int i=0;i<count/1000;i++){
//解析出下次获取的启示openid
next_openid = object.get("next_openid").toString();
object = getUserJson(next_openid);
ob_data = (JSONObject)object.get("data");
ob_user = new ArrayList<String>(ob_data.getJSONArray("openid"));
for(String open_id : ob_user){
//将多次获取的openid添加到同一个数组
users.add(open_id);
}
}
}
}
return users;
}
java中POST方式提交的示例1：
public static void main(String[] args) { try { String pathUrl = "https://api.weixin.qq.com/cgi-bin/user/tag/get?access_token=zN6OKXWAdBKdwPUc1CFXIW-czck3W1CURoKr38Xy7jjDpyIxrpmSyfglAY1Bnvq3FePZbFVUzpeLfWC9lml7ENeApBJhSDXE-BRrHCmBsTk4gUI6DxxDgrGekrdkUSDkETAhAGAZOV"; // 建立连接 URL url = new URL(pathUrl); HttpURLConnection httpConn = (HttpURLConnection) url.openConnection(); // //设置连接属性 httpConn.setDoOutput(true);// 使用 URL 连接进行输出 httpConn.setDoInput(true);// 使用 URL 连接进行输入 httpConn.setUseCaches(false);// 忽略缓存 httpConn.setRequestMethod("POST");// 设置URL请求方法 //POST请求设置所需要的JSON数据格式{"tagid" : 134,"next_openid":""//第一个拉取的OPENID，不填默认从头开始拉取} List<Map<String,Object>> list = new ArrayList<Map<String,Object>>(); Map<String, Object> map = new HashMap<String, Object>(); map.put("tagid", 104); map.put("next_openid",""); list.add(map); JSONArray arry=JSONArray.fromObject(map); String requestString = arry.toString().replace("[", "").replace("]", ""); // 设置请求属性 // 获得数据字节数据，请求数据流的编码，必须和下面服务器端处理请求流的编码一致 byte[] requestStringBytes = requestString.getBytes("utf-8"); httpConn.setRequestProperty("Content-length", "" + requestStringBytes.length); httpConn.setRequestProperty("Content-Type", "application/octet-stream"); httpConn.setRequestProperty("Connection", "Keep-Alive");// 维持长连接 httpConn.setRequestProperty("Charset", "UTF-8"); // 建立输出流，并写入数据，此方法是同样适用于参数中有文字的方法 OutputStream outputStream = httpConn.getOutputStream(); outputStream.write(requestStringBytes); outputStream.close(); // 获得响应状态 int responseCode = httpConn.getResponseCode(); if (HttpURLConnection.HTTP_OK == responseCode) {// 连接成功 // 当正确响应时处理数据 StringBuffer sb = new StringBuffer(); String readLine; BufferedReader responseReader; // 处理响应流，必须与服务器响应流输出的编码一致 responseReader = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), "utf-8")); while ((readLine = responseReader.readLine()) != null) { sb.append(readLine).append(" "); } responseReader.close(); System.err.println(sb.toString()); } } catch (Exception ex) { ex.printStackTrace(); } }
post请求向服务器传递参数的另外一种形式，示例2：
服务器端接受参数：String datas= request.getParameter("datas");
public static void sendPost() throws IOException{ List<Map<String,Object>> list = new ArrayList<Map<String,Object>>(); Map<String, Object> map = new HashMap<String, Object>(); map.put("phone", "phone"); list.add(map); JSONArray arry=JSONArray.fromObject(map); String requestString = arry.toString(); String result=""; PrintWriter out = null; BufferedReader in = null; String pathUrl = "http://shuilangyizu.iask.in/app/appWechatDataController/wchatInfo.do"; URL url=null; try { url = new URL(pathUrl); URLConnection connect = url.openConnection(); connect.setRequestProperty("content-type","application/x-www-form-urlencoded;charset=utf-8"); connect.setRequestProperty("method","POST"); byte[] bytes= requestString.getBytes("utf-8") ; connect.setDoOutput(true); connect.setDoInput(true); out = new PrintWriter(connect.getOutputStream()); // 发送请求参数：此方式遇到中文容易乱码，所以如果参数中有中文建议用上一种方式 out.print("datas="+requestString); out.flush();
// 定义BufferedReader输入流来读取URL的响应 in = new BufferedReader(new InputStreamReader(connect.getInputStream())); String line; while ((line = in.readLine()) != null) { result += line; } System.out.println(result);
in.close();
out.close();
} catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } }
接收数据服务器上接收数据的方式，示例1：
@RequestMapping(value = "/synSystemData") public void synSystemData(HttpServletRequest request, HttpServletResponse response) throws Exception { boolean isGet = request.getMethod().toLowerCase().equals("get"); if (!isGet) { String inputLine; String notityJson = ""; try { while ((inputLine = request.getReader().readLine()) != null) { notityJson += inputLine; } request.getReader().close(); } catch (Exception e) { e.printStackTrace(); } if(StringUtil.isEmpty(notityJson )){ notityJson = request.getParameter("content"); } String json= java.net.URLDecoder.decode(notityJson , "UTF-8"); if(StringUtils.isNotEmpty(json)){ StringBuffer sb = new StringBuffer();
sb.append("ok");
response.getWriter().write(sb.toString()); } }
wirte.flush();
wirte.close(); }
接收数据服务器上接收数据的方式，示例2：
/** * 接收从发送数据服务器传过来的json串 * @param request * @param response * @throws Exception */ @RequestMapping(value = "/synSystemData") public void synSystemData(HttpServletRequest request, HttpServletResponse response) throws Exception{ String result = "error"; boolean isPost = request.getMethod().toLowerCase().equals("post"); PrintWriter wirte = null; wirte = response.getWriter(); response.setCharacterEncoding("utf-8"); response.setContentType("text/html;charset=utf-8"); if (isPost) { String json = request.getParameter("datas"); System.out.println(json); wirte.print(result); }else{ wirte.print(""); } wirte.flush(); wirte.close(); }