SpringBoot整合⾼德地图天⽓查询的全过程⽬录
申请key
相关代码
启动服务
总结
申请key
登录⾼德，注册，添加应⽤，创建key
官⽹api：
调⽤步骤:
第⼀步，申请”web服务 API”密钥（Key）；
第⼆步，拼接HTTP请求URL，第⼀步申请的Key需作为必填参数⼀同发送；
第三步，接收HTTP请求返回的数据（JSON或XML格式），解析数据。
如⽆特殊声明，接⼝的输⼊参数和输出数据编码全部统⼀为UTF-8。
最主要的也是获取到key
相关代码
<!--httpclient-->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.4</version>
</dependency>
<!-- mvnrepository/artifact/com.alibaba/fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.78</version>
</dependency>
<dependency>
<groupId>org.apachemons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.4</version>
</dependency>
application.properties
server.port=2080
#The config for HttpClient
http.maxTotal=300
http.defaultMaxPerRoute=50
http.socketTimeout=5000
http.staleConnectionCheckEnabled=true
gaode.key = 申请的key
HttpClientConfig
package com.fig;
import lombok.Data;
import org.apache.http.client.HttpClient;
import org.apache.fig.RequestConfig;
import org.HttpClientConnectionManager;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.PoolingHttpClientConnectionManager;
import org.t.properties.ConfigurationProperties;
import t.annotation.Bean;
import t.annotation.Configuration;
import org.springframework.http.client.ClientHttpRequestFactory;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.verter.HttpMessageConverter;
import org.verter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;
import java.nio.charset.Charset;
import java.util.List;
@Data
@Configuration
@ConfigurationProperties(prefix = "http", ignoreUnknownFields = true)
public class HttpClientConfig {
private Integer maxTotal;// 最⼤连接
private Integer defaultMaxPerRoute;// 每个host的最⼤连接
private Integer connectTimeout;// 连接超时时间
private Integer connectionRequestTimeout;// 请求超时时间
private Integer socketTimeout;// 响应超时时间
/**
* HttpClient连接池
* @return
*/
@Bean
public HttpClientConnectionManager httpClientConnectionManager() {
PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(); connectionManager.setMaxTotal(maxTotal);
connectionManager.setDefaultMaxPerRoute(defaultMaxPerRoute);
return connectionManager;
}
/**
* 注册RequestConfig
* @return
*/
@Bean
public RequestConfig requestConfig() {
return RequestConfig.custom().setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectionRequestTimeout).setSocketTimeout(socketTimeout) .build();
}
/**
* 注册HttpClient
* @param manager
* @param config
* @return
*/
@Bean
public HttpClient httpClient(HttpClientConnectionManager manager, RequestConfig config) {
ate().setConnectionManager(manager).setDefaultRequestConfig(config)
.build();
}
@Bean
public ClientHttpRequestFactory requestFactory(HttpClient httpClient) {
return new HttpComponentsClientHttpRequestFactory(httpClient);
}
/**
* 使⽤HttpClient来初始化⼀个RestTemplate
* @param requestFactory
* @return
*/
@Bean
public RestTemplate restTemplate(ClientHttpRequestFactory requestFactory) {
RestTemplate template = new RestTemplate(requestFactory);
List<HttpMessageConverter<?>> list = MessageConverters();
for (HttpMessageConverter<?> mc : list) {
if (mc instanceof StringHttpMessageConverter) {
((StringHttpMessageConverter) mc).setDefaultCharset(Charset.forName("UTF-8"));
}
}
return template;
}
}
WeatherUtils
package com.zjy.map.utils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
cityofspring怎么读import org.apache.hods.CloseableHttpResponse;
import org.apache.hods.HttpGet;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.URI;
import java.util.Map;
@Component
public class WeatherUtils {
/
**⽇志对象*/
private static final Logger logger = Logger(WeatherUtils.class);
@Value("${gaode.key}")
private String KEY;
public final String WEATHER_URL = "restapi.amap/v3/weather/weatherInfo?";
/**
* 发送get请求
* @return
*/
public JSONObject getCurrent(Map<String, String> params){
JSONObject jsonObject = null;
CloseableHttpClient httpclient = ateDefault();
// 创建URI对象，并且设置请求参数
try {
URI uri = getBuilderCurrent(WEATHER_URL, params);
// 创建http GET请求
HttpGet httpGet = new HttpGet(uri);
CloseableHttpResponse response = ute(httpGet);
// 判断返回状态是否为200
jsonObject = getRouteCurrent(response);
httpclient.close();
} catch (Exception e) {
e.printStackTrace();
}
return jsonObject;
}
/**
* 根据不同的路径规划获取距离
* @param response
* @return
*/
private static JSONObject getRouteCurrent(CloseableHttpResponse response) throws Exception{ JSONObject live = null;
// 判断返回状态是否为200
if (StatusLine().getStatusCode() == 200) {
String content = Entity(), "UTF-8");
logger.info("调⽤⾼德地图接⼝返回的结果为:{}",content);
JSONObject jsonObject = (JSONObject) JSONObject.parse(content);
JSONArray lives = (JSONArray) ("lives");
live = (JSONObject) (0);
logger.info("返回的结果为:{}",JSONString(live));
}
return live;
}
/**
* 封装URI
* @param url
* @param params
* @return
* @throws Exception
*/
private URI getBuilderCurrent(String url, Map<String, String> params) throws Exception{
// 城市编码，⾼德地图提供
String adcode = ("adcode");
URIBuilder uriBuilder = new URIBuilder(url);
// 公共参数
uriBuilder.setParameter("key", KEY);
uriBuilder.setParameter("city", adcode);
logger.info("请求的参数key为:{}, cityCode为:{}", KEY, adcode);
URI uri = uriBuilder.build();
return uri;
}
/**
* 查询未来的
* 发送get请求
* @return
*/
public JSONObject sendGetFuture(Map<String, String> params){
JSONObject jsonObject = null;
CloseableHttpClient httpclient = ateDefault();
// 创建URI对象，并且设置请求参数
try {
URI uri = getBuilderFuture(WEATHER_URL, params);
// 创建http GET请求
HttpGet httpGet = new HttpGet(uri);
CloseableHttpResponse response = ute(httpGet);
// 判断返回状态是否为200
jsonObject = getRouteFuture(response);
httpclient.close();
} catch (Exception e) {
e.printStackTrace();
}
return jsonObject;
}
/**
* 封装URI
* @param url
* @param params
* @return
* @throws Exception
*/
private URI getBuilderFuture(String url, Map<String, String> params) throws Exception{
// 城市编码，⾼德地图提供
String adcode = ("adcode");
URIBuilder uriBuilder = new URIBuilder(url);
// 公共参数
uriBuilder.setParameter("key", KEY);
uriBuilder.setParameter("city", adcode);
uriBuilder.setParameter("extensions", "all");
logger.info("请求的参数key为:{}, cityCode为:{}", KEY, adcode);
URI uri = uriBuilder.build();
return uri;
}
/**
* 根据不同的路径规划获取距离
* @param response
* @return
*/
private static JSONObject getRouteFuture(CloseableHttpResponse response) throws Exception{ JSONObject live = null;
// 判断返回状态是否为200
if (StatusLine().getStatusCode() == 200) {
String content = Entity(), "UTF-8");
logger.info("调⽤⾼德地图接⼝返回的结果为:{}",content);
JSONObject jsonObject = (JSONObject) JSONObject.parse(content);
JSONArray forecast = (JSONArray) ("forecasts");
live = (JSONObject) (0);
logger.info("返回的结果为:{}",JSONString(live));
}
return live;
}
}
WeatherController
package com.ller;
import com.alibaba.fastjson.JSONObject;
import com.zjy.map.utils.WeatherUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.Map;
/**
* ⾼德天⽓
*/
@RestController
@RequestMapping("/weather")
public class WeatherController {
@Autowired
private WeatherUtils weatherUtils;
/**⽇志对象*/
private static final Logger logger = Logger(WeatherController.class); /**
* localhost:2080/weather/getCurrent?adcode=140200
* 获取当前的天⽓预报
* @param adcode
* @return
*/
@GetMapping("/getCurrent")
public JSONObject getWeather(@RequestParam String adcode){
Map<String, String> params = new HashMap<>();
params.put("adcode", adcode);
logger.info("获取当前的天⽓预报，请求的参数为:{}", params);
JSONObject map = Current(params);
logger.info("获取当前的天⽓预报，返回的请求结果为:{}", map);
return map;
}
/**
* localhost:2080/weather/getFuture?adcode=140200
* 获取未来的天⽓预报
* @param adcode
* @return
*/
@GetMapping("/getFuture")
public JSONObject getFuture(@RequestParam String adcode){
Map<String, String> params = new HashMap<>();
params.put("adcode", adcode);
logger.info("获取未来的天⽓预报，请求的参数为:{}", params);
JSONObject map = weatherUtils.sendGetFuture(params);
logger.info("获取未来的天⽓预报，返回的请求结果为:{}", map);
return map;
}
}
代码贴完了。开始测试
启动服务
城市编号
官⽹提供下载地址：
这⾥获取当前时间的天⽓情况与未来天⽓情况返回数据不⼀样，所在写了2个⽅法，参数只有⼀个，城市编码.
1.获取当前天⽓
2.获取未来天⽓
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论