java根據經緯度獲取地址(百度地圖)
阿新 • • 發佈：2018-11-26
先建立HttpClientUtils工具類
package cn.crenative.lockinlife.util; import com.google.common.base.Function; import com.google.common.collect.FluentIterable; import com.google.common.collect.Lists; import org.apache.commons.httpclient.HttpStatus; import org.apache.commons.httpclient.NoHttpResponseException; import org.apache.commons.lang3.StringUtils; import org.apache.http.*; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpRequestRetryHandler; import org.apache.http.client.ResponseHandler; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.client.protocol.HttpClientContext; import org.apache.http.client.utils.URLEncodedUtils; import org.apache.http.config.ConnectionConfig; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.config.SocketConfig; import org.apache.http.conn.ConnectTimeoutException; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.entity.ContentType; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.message.BasicNameValuePair; import org.apache.http.protocol.HttpContext; import org.apache.http.ssl.SSLContexts; import org.apache.http.util.EntityUtils; import javax.net.ssl.SSLException; import javax.net.ssl.SSLHandshakeException; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.InterruptedIOException; import java.net.HttpURLConnection; import java.net.URL; import java.net.UnknownHostException; import java.nio.charset.CodingErrorAction; import java.util.List; import java.util.Map; /** * HttpClient工具類 */ public class HttpClientUtils { /** * 連線池最大連線數 */ private static final int MAX_TOTAL_CONNECTIONS = 4000; /** * 設定每個路由上的預設連線個數 */ private static final int DEFAULT_MAX_PER_ROUTE = 200; /** * 請求的請求超時時間 單位：毫秒 */ private static final int REQUEST_CONNECTION_TIMEOUT = 8 * 1000; /** * 請求的等待資料超時時間 單位：毫秒 */ private static final int REQUEST_SOCKET_TIMEOUT = 8 * 1000; /** * 請求的連線超時時間 單位：毫秒 */ private static final int REQUEST_CONNECTION_REQUEST_TIMEOUT = 5 * 1000; /** * 連線閒置多久後需要重新檢測 單位：毫秒 */ private static final int VALIDATE_AFTER_IN_ACTIVITY = 2 * 1000; /** * 關閉Socket時，要麼傳送完所有資料，要麼等待多少秒後，就關閉連線，此時socket.close()是阻塞的 單位秒 */ private static final int SOCKET_CONFIG_SO_LINGER = 60; /** * 接收資料的等待超時時間,即讀超時時間，單位ms */ private static final int SOCKET_CONFIG_SO_TIMEOUT = 5 * 1000; /** * 重試次數 */ private static int RETRY_COUNT = 5; /** * 宣告為 static volatile,會迫使執行緒每次讀取時作為一個全域性變數讀取 */ private static volatile CloseableHttpClient httpClient = null; /** * @param uri * @return String * @description get請求方式 * @author: long.he01 */ public static String doGet(String uri) { StringBuilder result = new StringBuilder(); try { String res = ""; URL url = new URL(uri); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8")); String line; while ((line = in.readLine()) != null) { res += line+"\n"; } in.close(); return res; }catch (Exception e) { e.printStackTrace(); return null; } } /** * @param uri * @param params * @return string * @description 帶map引數get請求, 此方法會將map引數拼接到連線地址上。 */ public static String doGet(String uri, Map<String, String> params) { return doGet(getGetUrlFromParams(uri, params)); } /** * @param uri * @param params * @return String * @description 根據map引數拼接完整的url地址 */ private static String getGetUrlFromParams(String uri, Map<String, String> params) { List<BasicNameValuePair> resultList = FluentIterable.from(params.entrySet()).transform( new Function<Map.Entry<String, String>, BasicNameValuePair>() { @Override public BasicNameValuePair apply(Map.Entry<String, String> innerEntry) { return new BasicNameValuePair(innerEntry.getKey(), innerEntry.getValue()); } }).toList(); String paramSectionOfUrl = URLEncodedUtils.format(resultList, Consts.UTF_8); StringBuffer resultUrl = new StringBuffer(uri); if (StringUtils.isEmpty(uri)) { return uri; } else { if (!StringUtils.isEmpty(paramSectionOfUrl)) { if (uri.endsWith("?")) { resultUrl.append(paramSectionOfUrl); } else { resultUrl.append("?").append(paramSectionOfUrl); } } return resultUrl.toString(); } } /** * @param uri * @param params * @return String * @description 帶map引數的post請求方法 */ public static String doPost(String uri, Map<String, String> params) { String responseBody; HttpPost httpPost = new HttpPost(uri); try { List<NameValuePair> nvps = Lists.newArrayList(); for (Map.Entry<String, String> entry : params.entrySet()) { String key = entry.getKey(); String value = entry.getValue(); nvps.add(new BasicNameValuePair(key, value)); } httpPost.setEntity(new UrlEncodedFormEntity(nvps, Consts.UTF_8)); httpPost.setConfig(getRequestConfig()); responseBody = executeRequest(httpPost); } catch (Exception e) { throw new RuntimeException("httpclient doPost方法異常 ", e); } finally { httpPost.releaseConnection(); } return responseBody; } /** * @param uri * @param param * @param contentType 根據具體請求情況指定,比如json可以是 ContentType.APPLICATION_JSON * @return String * @description 帶單string引數執行post方法 */ public static String doPost(String uri, String param, ContentType contentType) { String responseBody; HttpPost httpPost = new HttpPost(uri); try { StringEntity reqEntity = new StringEntity(param, contentType); httpPost.setEntity(reqEntity); httpPost.setConfig(getRequestConfig()); responseBody = executeRequest(httpPost); } catch (IOException e) { throw new RuntimeException("httpclient doPost方法異常 ", e); } finally { httpPost.releaseConnection(); } return responseBody; } /** * @return RequestConfig * @description: 獲得請求配置資訊 */ private static RequestConfig getRequestConfig() { RequestConfig defaultRequestConfig = RequestConfig.custom() //.setCookieSpec(CookieSpecs.DEFAULT) .setExpectContinueEnabled(true) //.setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM, AuthSchemes.DIGEST)) //.setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)) .build(); return RequestConfig.copy(defaultRequestConfig) .setSocketTimeout(REQUEST_CONNECTION_TIMEOUT) .setConnectTimeout(REQUEST_SOCKET_TIMEOUT) .setConnectionRequestTimeout(REQUEST_CONNECTION_REQUEST_TIMEOUT) .build(); } /** * @param method * @return String * @throws IOException * @description 通用執行請求方法 */ private static String executeRequest(HttpUriRequest method) throws IOException { ResponseHandler<String> responseHandler = new ResponseHandler<String>() { @Override public String handleResponse(final HttpResponse response) throws IOException { int status = response.getStatusLine().getStatusCode(); String result; if (status >= HttpStatus.SC_OK && status < HttpStatus.SC_MULTIPLE_CHOICES) { HttpEntity entity = response.getEntity(); result = entity != null ? EntityUtils.toString(entity) : null; EntityUtils.consume(entity); return result; } else { throw new ClientProtocolException("Unexpected response status: " + status); } } }; String result = getHttpClientInstance().execute(method, responseHandler); return result; } /** * @return CloseableHttpClient * @description 單例獲取httpclient例項 */ private static CloseableHttpClient getHttpClientInstance() { if (httpClient == null) { synchronized (CloseableHttpClient.class) { if (httpClient == null) { httpClient = HttpClients.custom().setConnectionManager(initConfig()).setRetryHandler(getRetryHandler()).build(); } } } return httpClient; } /** * @return HttpRequestRetryHandler * @description :獲取重試handler */ private static HttpRequestRetryHandler getRetryHandler() { // 請求重試處理 return new HttpRequestRetryHandler() { @Override public boolean retryRequest(IOException exception, int executionCount, HttpContext context) { if (executionCount >= RETRY_COUNT) { // 假設已經重試了5次，就放棄 return false; } if (exception instanceof NoHttpResponseException) { // 假設server丟掉了連線。那麼就重試 return true; } if (exception instanceof SSLHandshakeException) { // 不要重試SSL握手異常 return false; } if (exception instanceof InterruptedIOException) { // 超時 return false; } if (exception instanceof UnknownHostException) { // 目標server不可達 return false; } if (exception instanceof ConnectTimeoutException) { // 連線被拒絕 return false; } if (exception instanceof SSLException) { // SSL握手異常 return false; } HttpRequest request = HttpClientContext.adapt(context).getRequest(); // 假設請求是冪等的，就再次嘗試 return !(request instanceof HttpEntityEnclosingRequest); } }; } /** * @return PoolingHttpClientConnectionManager * @description 初始化連線池等配置資訊 */ private static PoolingHttpClientConnectionManager initConfig() { Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create() .register("http", PlainConnectionSocketFactory.INSTANCE) .register("https", new SSLConnectionSocketFactory(SSLContexts.createSystemDefault())) .build(); PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry); /** * 以下引數設定含義分別為: * 1 是否立即傳送資料，設定為true會關閉Socket緩衝，預設為false * 2 是否可以在一個程序關閉Socket後，即使它還沒有釋放埠，其它程序還可以立即重用埠 * 3 接收資料的等待超時時間，單位ms * 4 關閉Socket時，要麼傳送完所有資料，要麼等待多少秒後，就關閉連線，此時socket.close()是阻塞的 * 5 開啟監視TCP連線是否有效 * 其中setTcpNoDelay(true)設定是否啟用Nagle演算法，設定true後禁用Nagle演算法，預設為false（即預設啟用Nagle演算法）。 * Nagle演算法試圖通過減少分片的數量來節省頻寬。當應用程式希望降低網路延遲並提高效能時， * 它們可以關閉Nagle演算法，這樣資料將會更早地發 送，但是增加了網路消耗。 單位為：毫秒 */ SocketConfig socketConfig = SocketConfig.custom() .setTcpNoDelay(true) .setSoReuseAddress(true) .setSoTimeout(SOCKET_CONFIG_SO_TIMEOUT) //.setSoLinger(SOCKET_CONFIG_SO_LINGER) //.setSoKeepAlive(true) .build(); connManager.setDefaultSocketConfig(socketConfig); connManager.setValidateAfterInactivity(VALIDATE_AFTER_IN_ACTIVITY); ConnectionConfig connectionConfig = ConnectionConfig.custom() .setMalformedInputAction(CodingErrorAction.IGNORE) .setUnmappableInputAction(CodingErrorAction.IGNORE) .setCharset(Consts.UTF_8) .build(); connManager.setDefaultConnectionConfig(connectionConfig); connManager.setDefaultMaxPerRoute(DEFAULT_MAX_PER_ROUTE); connManager.setMaxTotal(MAX_TOTAL_CONNECTIONS); return connManager; } }
然後建立MapUtil工具類，根據經緯度獲取詳細地址
package cn.crenative.lockinlife.util; import com.alibaba.fastjson.JSONObject; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.math.BigDecimal; import java.math.RoundingMode; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.util.HashMap; import java.util.Map; import java.util.Set; /** * @author: SQJ * @data: 2018/8/31 17:58 * @version: */ public class MapUtil { /** * 百度地圖請求祕鑰 */ private static final String KEY = "填入自己的ak"; /** * 返回值型別 */ private static final String OUTPUT = "json"; /** * 根據地名獲取經緯度 */ private static final String GET_LNG_LAT_URL = "http://api.map.baidu.com/geocoder/v2/"; /** * 根據經緯度獲取地名 */ private static final String GET_ADDRESS_URL = "http://api.map.baidu.com/geocoder/v2/"; /** * 根據經緯度獲得省市區資訊 * @param lon 緯度 * @param lat 經度 * @param coordtype 經緯度座標系 * @return */ public static Map<String, String> getCityByLonLat(double lng, double lat, String coordtype) { String location = lat + "," + lng; Map<String, String> params = new HashMap<>(); params.put("location", location); params.put("coordtype", coordtype); try { //拼裝url String url = joinUrl(params, OUTPUT, KEY, GET_ADDRESS_URL); JSONObject result = JSONObject.parseObject(JSONObject.parseObject(JSONObject.parseObject(HttpClientUtils.doGet(url)). getString("result")).getString("addressComponent")); Map<String, String> area = new HashMap<>(); area.put("province", result.getString("province")); area.put("city", result.getString("city")); area.put("district", result.getString("district")); return area; }catch (Exception e) { e.printStackTrace(); } return null; } /** * 拼接url字串 * @param params * @param output * @param key * @param url * @return * @throws IOException */ private static String joinUrl(Map<String, String> params, String output, String key, String url) throws IOException { StringBuilder baseUrl = new StringBuilder(); baseUrl.append(url); int index = 0; Set<Map.Entry<String, String>> entrys = params.entrySet(); for (Map.Entry<String, String> param : entrys) { // 判斷是否是第一個引數 if (index == 0) { baseUrl.append("?"); } else { baseUrl.append("&"); } baseUrl.append(param.getKey()).append("=").append(URLEncoder.encode(param.getValue(), "utf-8")); index++; } baseUrl.append("&output=").append(output).append("&ak=").append(key); return baseUrl.toString(); } }