高德地图web端笔记；发送http请求的工具类

1.查询所有电子围栏

package com.skjd.util;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;

public class HttpUtils {

// 代理服务器的HTTP请求协议，客户端真实IP字段名称
public static final String X_REAL_IP = "x-forwarded-for";

public static String get(final String url) throws Exception {
String result = null;
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpGet httpGet = new HttpGet(url);
CloseableHttpResponse response = httpclient.execute(httpGet);
try {
System.out.println(response.getStatusLine());
HttpEntity entity = response.getEntity();
// do something useful with the response body
// and ensure it is fully consumed
result = org.apache.http.util.EntityUtils.toString(entity);
org.apache.http.util.EntityUtils.consume(entity);
} finally {
response.close();
}
} finally {
httpclient.close();
}

return result;
}

public static String post(final String url, final Map<String, String> param) throws Exception {
String result = null;
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpPost httpPost = new HttpPost("http://httpbin.org/post");
List<NameValuePair> nvps = new ArrayList<NameValuePair>();

for (String key : param.keySet()) {
nvps.add(new BasicNameValuePair(key, param.get(key)));
}

httpPost.setEntity(new UrlEncodedFormEntity(nvps));
CloseableHttpResponse response = httpclient.execute(httpPost);

try {
System.out.println(response.getStatusLine());
HttpEntity entity = response.getEntity();
// do something useful with the response body
// and ensure it is fully consumed
result = org.apache.http.util.EntityUtils.toString(entity);
org.apache.http.util.EntityUtils.consume(entity);
} finally {
response.close();
}
} finally {
httpclient.close();
}
return result;
}

/**
* 发送POST请求的方法
*/
public static String sendPostRequest(String url,String param){
HttpURLConnection httpURLConnection = null;
OutputStream out = null; //写
InputStream in = null;   //读
int responseCode = 0;    //远程主机响应的HTTP状态码
String result="";
try{
URL sendUrl = new URL(url);
httpURLConnection = (HttpURLConnection)sendUrl.openConnection();
//post方式请求
httpURLConnection.setRequestMethod("POST");
//设置头部信息
httpURLConnection.setRequestProperty("headerdata", "ceshiyongde");
//一定要设置 Content-Type 要不然服务端接收不到参数
httpURLConnection.setRequestProperty("Content-Type", "application/Json; charset=UTF-8");
//指示应用程序要将数据写入URL连接,其值默认为false（是否传参）
httpURLConnection.setDoOutput(true);
//httpURLConnection.setDoInput(true);
httpURLConnection.setUseCaches(false);
httpURLConnection.setConnectTimeout(30000); //30秒连接超时
httpURLConnection.setReadTimeout(30000);    //30秒读取超时
//获取输出流
out = httpURLConnection.getOutputStream();
//输出流里写入POST参数
out.write(param.getBytes());
out.flush();
out.close();
responseCode = httpURLConnection.getResponseCode();
BufferedReader br = new BufferedReader(new InputStreamReader(httpURLConnection.getInputStream(),"UTF-8"));
result =br.readLine();
}catch(Exception e) {
e.printStackTrace();
}
return result;

}

/**
* 发送GET请求的方法
*/
public static String sendPostRequestGet(String url){
HttpURLConnection httpURLConnection = null;
OutputStream out = null; //写
InputStream in = null;   //读
int responseCode = 0;    //远程主机响应的HTTP状态码
String result="";
try{
URL sendUrl = new URL(url);
httpURLConnection = (HttpURLConnection)sendUrl.openConnection();
//post方式请求
httpURLConnection.setRequestMethod("GET");
//设置头部信息
httpURLConnection.setRequestProperty("headerdata", "ceshiyongde");
//一定要设置 Content-Type 要不然服务端接收不到参数
httpURLConnection.setRequestProperty("Content-Type", "application/Json; charset=UTF-8");
//指示应用程序要将数据写入URL连接,其值默认为false（是否传参）
httpURLConnection.setDoOutput(true);
//httpURLConnection.setDoInput(true);

httpURLConnection.setUseCaches(false);
httpURLConnection.setConnectTimeout(30000); //30秒连接超时
httpURLConnection.setReadTimeout(30000);    //30秒读取超时
responseCode = httpURLConnection.getResponseCode();
BufferedReader br = new BufferedReader(new InputStreamReader(httpURLConnection.getInputStream(),"UTF-8"));
result =br.readLine();
}catch(Exception e) {
e.printStackTrace();
}
return result;

}

/**
* for nigx返向代理构造 获取客户端IP地址
* @param request
* @return
*/
public static String getRemoteHost(HttpServletRequest request){
String ip = request.getHeader(X_REAL_IP);
if(ip == null || ip.length() == 0 || ip.equalsIgnoreCase("unknown")) {
ip = request.getRemoteAddr();
}
return ip.split(",")[0];
}

public static void main(String[] args) {
try {
System.out.println(get("http://www.baidu.com"));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

/**
* 根据key查询所有的围栏
* 返回所有围栏的信息
* @param pd
* @return
* @throws Exception
*/
public List<Map<String,Object>> select(Map<String,Object> pd) throws Exception{
Gson gson=new Gson();
String key=pd.get("key").toString();
String url="http://restapi.amap.com/v4/geofence/meta?key="
+key;
//请求返回的参数
String data=HttpUtils.sendPostRequestGet(url);
//转为对象便于获取
Map<String,Object> dataJson = gson.fromJson(data, HashMap.class);
Map<String, Object> map=(LinkedTreeMap)dataJson.get("data");
List<Map<String,Object>> list = (List)map.get("rs_list");

return list;
}

2.创建围栏

/**
* 传入对应格式的坐标区域，创建一个围栏;返回status(新增成功0，已存在返回1；失败返回2);若新增成功则返回gid;message信息
*/
public static  PageData xyUtil(PageData pd){
PageData pd2=new PageData();
pd.put("key", "be8e6c802d51a4be29c99be895d8c2c7");
//数据库读取的坐标参数
/*114.288221,30.593268#114.321866,30.580559#114.311223,30.560015#114.291278,30.602487#*/
//第三方接口要求的格式：lon1,lat1;lon2,lat2;lon3,lat3（3<=点个数<=5000）
//将#号换为;
String points = pd.getString("points").replace("#", ";");
String key=pd.getString("key");
String name=pd.getString("name1");
PageData pd3=new PageData();
pd3.put("points", points);
pd3.put("name", name);
/*pd3.put("valid_time ", DateUtil.getDay());设置过期时间、默认90天*/
pd3.put("repeat", "Mon,Tues,Wed,Thur,Fri,Sat,Sun");//可以指定每天的监控时间段和一周内监控的日期
Gson gson=new Gson();
//传入的参数
String param=gson.toJson(pd3);
String url="http://restapi.amap.com/v4/geofence/meta?key="
+ key
+ "&type=ajaxRequest";
String data=HttpUtil.sendPostRequest(url,param);
//请求回来的数据
System.out.println(data);
PageData data2 = gson.fromJson(data, pd.getClass());
PageData data3 = gson.fromJson(data2.get("data").toString(), pd.getClass());
//状态为0说明新增成功！
if(data3.get("status").toString().equals("0.0")){
pd2.put("status", "0");
pd2.put("gid", data3.get("gid").toString());
//返回状态106.0说明已存在，则查询此区域的gid
}else if(data3.get("status").toString().equals("106.0")){
pd2.put("status", "1");
}else{
pd2.put("status", "2");
}
pd2.put("message", data3.get("message").toString());
return pd2;
}

3.更新围栏

/**
* 更新围栏；传入围栏名称name；gid;传入围栏坐标点points
* @param pd
* @return 返回status
*/
public static PageData xyupdata(PageData pd){
PageData pd2=new PageData();
pd.put("key", "be8e6c802d51a4be29c99be895d8c2c7");
String key=pd.getString("key");
/*    String gid=pd.getString("gid");*/
String gid=pd.getString("gid");
pd2.put("repeat", "Mon,Tues,Wed,Thur,Fri,Sat,Sun");
pd2.put("points",pd.getString("points").replace("#", ";"));
pd2.put("name", pd.getString("name1"));

Gson gson=new Gson();
//传入的参数
String param=gson.toJson(pd2);
String url="http://restapi.amap.com/v4/geofence/meta?key="
+ key+"&gid="
+gid
+ "&type=ajaxRequest&method=patch";
String data=HttpUtil.sendPostRequest(url,param);
System.out.println(data);
PageData data2 = gson.fromJson(data, pd.getClass());
PageData data3 = gson.fromJson(data2.get("data").toString(), pd.getClass());
return data3;
}

4.删除围栏

/**
* 删除围栏；传入围栏名称gid;
* @param pd
* @return 返回status
*/
public static PageData xydel(PageData pd){
PageData pd2=new PageData();
pd.put("key", "be8e6c802d51a4be29c99be895d8c2c7");
String key=pd.getString("key");
/*    String gid=pd.getString("gid");*/
String gid=pd.getString("gid");
Gson gson=new Gson();
//传入的参数
String param=gson.toJson(pd2);
String url="http://restapi.amap.com/v4/geofence/meta?key="
+ key+"&gid="
+gid
+ "&type=ajaxRequest&method=delete";
String data=HttpUtil.sendPostRequest(url,param);
System.out.println(data);
PageData data2 = gson.fromJson(data, pd.getClass());
PageData data3 = gson.fromJson(data2.get("data").toString(), pd.getClass());
return data3;
}

5.查询一个坐标是否在围栏内；如果需要查询是否在指定的围栏内，需要做进一步处理

/**需要传入参数key;diu（唯一设备号）;时间戳;坐标点
*返回 状态status(0表示在范围内；1表示不在范围内)
*如果在范围内，则返回围栏列表，带有gid和name
* @throws Exception
*/
public Map<String,Object> xyTest(Map<String,Object> pd) throws Exception{
Map<String,Object> pd2=new HashMap();

//坐标点
String locations =pd.get("locations").toString();
//key
String key=pd.get("key").toString();
//设备唯一标识
String diu=pd.get("diu").toString();
//时间戳
String time="1484816232";
Gson gson=new Gson();
String url="http://restapi.amap.com/v4/geofence/status?"
+ "key="+key
+ "&diu="+diu
+ "&locations="+locations+","
+ time;
//请求返回的参数
String data=HttpUtils.sendPostRequestGet(url);
//转为对象便于获取
Map<String,Object> dataJson = gson.fromJson(data, HashMap.class);
Map<String, Object> map=(LinkedTreeMap)dataJson.get("data");

//获取围栏事件列表；如果为空说明不在围栏内
if(map.get("fencing_event_list")==null||((List)map.get("fencing_event_list")).size()<1){
pd2.put("status", "1");
return pd2;
}
//如果不为空，则获取里面的返回值
List<Map<String,Object>> list = (List) map.get("fencing_event_list");
List<Map<String,Object>> list2 = new ArrayList<>();
for(int i=0;i<list.size();i++){
Map<String,Object> pd3=new HashMap();
Map<String,Object> map2 = list.get(i);
//如果高德地图api返回的状态为in说明在范围内
if(map2.get("client_status").toString().equals("in")){
//围栏信息
Map<String,Object> map3 =(Map)map2.get("fence_info");

//添加全局围栏gid值;
pd3.put("fence_gid",map3.get("fence_gid").toString());
//添加围栏名称
pd3.put("fence_name", map3.get("fence_name").toString());
list2.add(pd3);
}
}
//添加状态值
pd2.put("status", "0");
pd2.put("list", list2);
return pd2;
}