Java环境下高德地图Api的使用方式-eolink官网

Java环境下高德地图Api的使用方式

java高德地图Api的使用

使用高德经纬度获取地址信息

一些准备用到的常量

/**

* 高德地图请求秘钥

private static final String KEY = "密钥,可以去高德地图免费申请";

/**

* 返回值类型

private static final String OUTPUT = "jsON";

/**

* 根据地名获取高德经纬度Api

private static final String GET_LNG_LAT_URL = "http://restapi.amap.com/v3/geocode/geo";

/**

* 根据高德经纬度获取地名Api

private static final String GET_ADDRESS_URL = http://restapi.amap.com/v3/geocode/regeo;

HttpClientUtils

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.IOException;

import java.io.InterruptedIOException;

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) {

String responseBody;

HttpGet httpGet = new HttpGet(uri);

try {

httpGet.setConfig(getRequestConfig());

responseBody = executeRequest(httpGet);

} catch (IOException e) {

throw new RuntimeException("httpclient doGet方法异常 ", e);

} finally {

httpGet.releaseConnection();

}

return responseBody;

}

/**

* @param uri

* @param params

* @return string

* @description 带map参数get请求, 此方法会将map参数拼接到连接地址上。

public static String doGet(String uri, Map params) {

return doGet(getGetUrlFromParams(uri, params));

}

/**

* @param uri

* @param params

* @return String

* @description 根据map参数拼接完整的url地址

private static String getGetUrlFromParams(String uri, Map params) {

List resultList = FluentIterable.from(params.entrySet()).transform(

new Function, BasicNameValuePair>() {

@Override

public BasicNameValuePair apply(Map.Entry 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 params) {

String responseBody;

HttpPost httpPost = new HttpPost(uri);

try {

List nvps = Lists.newArrayList();

for (Map.Entry 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 responseHandler = new ResponseHandler() {

@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;

http:// } 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 socketFactoryRegistry = RegistryBuilder.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;

}

GaoDeMapUtils

import java.io.IOException;

import java.net.URLEncoder;

import java.util.HashMap;

import java.util.Map;

import java.util.Set;

public class GaoDeMapUtils {

/**

* 高德地图请求秘钥

private static final String KEY = "密钥,可以去高德地图免费申请";

/**

* 返回值类型

private static final String OUTPUT = "JSON";

/**

* 根据地名获取高德经纬度

private static final String GET_LNG_LAT_URL = "http://restapi.amap.com/v3/geocode/geo";

/**

* 根据高德经纬度获取地名

private static final String GET_ADDRESS_URL = "http://restapi.amap.com/v3/geocode/regeo";

/**

* 根据高德经纬度获取地址信息

* @param gdLon 高德地图经度

* @param gdLat 高德地图纬度

* @return

public static String getAddressByLonLat(double gdLon, double gdLat) {

String location = gdLon + "," + gdLat;

Map params = new HashMap<>();

params.put("location", location);

// Map result = new HashMap<>();

try {

// 拼装url

String url = jointUrl(params, OUTPUT, KEY, GET_ADDRESS_URL);

// 调用高德SDK

return HttpClientUtils.doPost(url, params);

// 解析Json字符串,获取城市名称

// JSONObject jsonObject = JSON.parseObject(jsonResult);

// String regeocode = jsonObject.getString("regeocode");

// JSONObject regeocodeObj = JSON.parseObject(regeocode);

// String address = regeocodeObj.getString("formatted_address");

// 组装结果

// result.put(location, address);

} catch (Exception e) {

e.printStackTrace();

}

return null;

}

/**

* 根据地址信息获取高德经纬度

* @param address 地址信息

* @return

public static String getLonLarByAddress(String address) {

Map params = new HashMap<>();

params.put("address", address);

// Map result = new HashMap<>();

try {

// 拼装url

String url = jointUrl(params, OUTPUT, KEY, GET_LNG_LAT_URL);

// 调用高德地图SDK

return HttpClientUtils.doPost(url, params);

// 解析JSON字符串,取到高德经纬度

// JSONObject jsonObject = JSON.parseObject(jsonResult);

// JSONArray geocodes = jsonObject.getJSONArray("geocodes");

// String geocode = JSON.toJSONString(geocodes.get(0));

// JSONObject geocodeObj = JSON.parseObject(geocode);

// String lonAndLat = geocodeObj.getString("location");

// 组装结果

// result.put(address, lonAndLat);

} catch (Exception e) {

e.printStackTrace();

}

return null;

}

/**

* 拼接请求字符串

* @param params

* @param output

* @param key

* @param url

* @return

* @throws IOException

private static String jointUrl(Map params, String output, String key, String url) throws IOException {

StringBuilder baseUrl = new StringBuilder();

baseUrl.append(url);

int index = 0;

Set> entrys = params.entrySet();

for (Map.Entry 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("&key=").append(key);

return baseUrl.toString();

}

返回结果

// 这是根据高德经纬度获取的返回报文

{"status":"1","info":"OK","infocode":"10000","regeocode":{"formatted_address":"北京市东城区东华门街道天安门","addressComponent":{"country":"中国","province":"北京市","city":[],"citycode":"010","district":"东城区","adcode":"110101","township":"东华门街道","towncode":"110101001000","neighborhood":{"name":[],"type":[]},"building":{"name":"天安门","type":"风景名胜;风景名胜相关;旅游景点"},"streetNumber":{"street":"广场东侧路","number":"44号","location":"116.39795,39.9097239","direction":"北","distance":"113.709"},"businessAreas":[{"location":"116.3998109423077,39.90717459615385","name":"天安门","id":"110101"},{"location":"116.39981058278138,39.92383706953642","name":"景山","id":"110101"},{"location":"116.4118112683418,39.91461494422115","name":"王府井","id":"110101"}]}}}

// 这是根据地址名称获取的返回报文

{"status":"1","info":"OK","infocode":"10000","count":"1","geocodes":[{"formatted_address":"北京市东城区天安门","province":"北京市","citycode":"010","city":"北京市","district":"东城区","township":[],"neighborhood":{"name":[],"type":[]},"building":{"name":[],"type":[]},"adcode":"110101","street":[],"number":[],"location":"116.397573,39.908743","level":"兴趣点"}]}

Java调用高德Api获取经纬度

1.第一步使用高德api需要先注册高德账号申请Key

高德开放平台:https://lbs.amap.com/

2.第二步详细阅读高德api开发指南

指南地址:https://lbs.amap.com/api/webservice/guide/api/georegeo/#geo

3.编写业务代码

首先这里需要判断成功把值返回失败默认赋值

其次笔者是使用的map形式返回值大家也可以尝试其他方法返回得到的值

对于最终得到的值因为是六位小数这里是用的双精度型存储然后转换为数据库存储值的类型按自己数据库的类型为准

4.编写用作调用经纬度的类

将调用得到的json格式的数据进行处理得到所需要的经纬度的值封装入定义好的map参数中

标签：api

使用SpringBoot实现API接口

590 2022-10-19

Java环境下高德地图Api的使用方式

java 单机接口限流处理方案

使用SpringBoot实现API接口

Python怎么调用GPT3.5接口

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！