从一个天气预报系统讲起

本节通过Spring Boot技术快速实现一个天气预报系统。

通过这个系统，一方面可以了解Spring Boot的全面用法，为后续创建微服务应用打下基础;另一方面，该系统会作为本节进行微服务架构改造的非常好的起点。

下面以前面创建的hello-world应用作为基础进行改造，成为新的应用micro-weather-basic。

开发环境

为了演示本例，需要采用如下开发环境。

. JDK8。

.Gradle 4.0。

. Spring Boot Web Starter 2.0.0.M4。

Apache HttpClient 4.5.3。

数据来源

天气的数据是天气预报的实现基础。本应用与实际的天气数据无关，理论上可以兼容多种数据来源。但为求简单，我们在网上找了一个免费、可用的天气数据接口。

·天气数据来源为中华万年历。例如以下两种方式。

通过城市名称获得天气数据: 深圳。

通过城市ID获得天气数据: 。

·城市ID列表。每个城市都有一个唯一的ID作为标识，见https:/waylau.com/data/citylist.xml。

调用天气服务接口示例，这里以“深圳”城市为例，可看到如下天气数据返回。

{"data":{"yesterday":{"date" :"1日星期五"，"high" :"高温33℃","fx":"无持续风向"，"low" :"低温26℃","fl":"<![CDATA[<3级]]>","type":"多云"}，"city":"深圳"，"aqi" : "72","forecast":["date":"2日星期六"，"high":"高温32℃","fengli":"<![CDATA[<3级]1>"，"low" :"低温26℃","fengxiang":"无持续风向"，"type" :"阵雨"},"date":"3日星期天"，"high":"高温 29℃","fengli":"<![CDATA[5-6级]1>","low" :"低温26℃","fengxiang":"无持续风向"，"type":"大雨""date":"4日星期一"，"high":"高温29℃","fengli":"<![CDATA[3-4级]1>","low":"低温26℃"，"fengxiang" :"西南风"，"type":"暴雨"},"date":"5日星期二"，"high":"高温31℃","fengli":"<![CDATA[<3级]]>","low":"低温27℃"，"fengxiang":"无持续风向"，"type":"阵雨""date" :"6日星期三"，"high":"高温32℃","fengli":"<![CDATA[<3级]l>","low":"低温27℃","fengxiang" :"无持续风向"，"type":"阵雨" }"ganmao":"风较大，阴冷潮湿，较易发生感冒，体质较弱的朋友请注意适当防护。" wendu":"29"},"status": 1000,"desc":"OK"}

通过观察以上数据，来理解每个返回字段的含义。

“city”:城市名称。"aqi”:空气指数。“wendu”:实时温度。“date”:日期，包含未来5天。“high”:最高温度。“low”:最低温度。“fengli”:风力。“fengxiang”:风向。“type”:天气类型。

以上数据是需要的天气数据的核心数据，但是，同时也要关注下面两个字段。

“status”:接口调用的返回状态，返回值“1000”，意味着数据接口正常。·“desc”:接口状态的描述，“OK”代表接口正常。

重点关注返回值不是“1000”的情况，这说明这个接口调用异常。

初始化一个Spring Boot项目

初始化一个Spring Boot项目“micro-weather-basic”，该项目可以直接以之前的“hello-world"应用作为基础进行修改。

添加Apache HttpClient的依赖，来作为Web请求的客户端。完整的依赖情况如下。

//依赖关系dependencies {//该依赖用于编译阶段compile('org.springframework.boot:spring-boot-starter-web')/添加Apache HttpClient依赖compile('org.apache.httpcomponents:httpclient:4.5.3')//该依赖用于测试阶段testCompile('org.springframework.boot:spring-boot-starter-test')}

创建天气信息相关的值对象

创建com.waylau.spring.cloud.weather.vo包，用于存放相关值对象。这些对象都是POJO对象，没有复杂的业务逻辑

创建天气信息类 Weather:

public class Weather implements Serializable {private static final long serialVersionUID - 1L;private string city;private String aqi;private String wendu;private string ganmao;private Yesterday yesterday;private List<Forecast>forecast;1/省略getter/setter方法}

昨日天气信息类Yesterday :

public class Yesterday implements Serializable {private static final long serialversionUID = 1L;private string date;private string high;private String fx;private String low;private String fl;private String type;//省略getter/setter方法}

未来天气信息类Forecast:

public class Forecast implements Serializable private static final long serialVersionUID =1L;private string date;private string high;private string fengxiang;private string low;private String fengli;private String type;//省略getter/setter方法}

WeatherResponse作为整个消息的返回对象:

public class WeatherResponse implements Serializable{private static final long serialversionUID =1L;private Weather data;1/消息数据private String status;//消息状态private string desc;/l消息描述//省略getter/setter方法}

创建com.waylau.spring.cloud.weather.service包，用于存放服务接口及其实现。

下面是定义服务的两个接口方法，一个是根据城市的ID来查询天气数据，另一个是根据城市名称来查询天气数据。

package com.waylau.spring.cloud.weather.service;import com.waylau.spring.cloud.weather.vo.WeatherResponse;/*★*天气数据服务．大csince 1.0.o 2017年10月18日*  @author <a href=";>Way Lau</a>*/public interface weatherDataservice {/**根据城市ID来查询天气数据**@param city工d*return*/WeatherResponse getDataByCityId(String cityId);/***根据城市名称来查询天气数据**@param cityId*@return*/WeatherResponse getDataByCityName(String cityName);}

其服务实现WeatherDataServiceImpl为:

package com.waylau.spring.cloud.weather.service;import java.io.IOException;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.http.ResponseEntity;import org.springframework.stereotype.Service;import org.springframework.web.client.RestTemplate;import com.fasterxml.jackson.databind.0bjectMapper;import com.waylau.spring.cloud.weather.vo.WeatherResponse;/***天气数据服务．** @since 1.0.0 2017年10月18日* @author <a href=";>Way Lau</a>*/@servicepublic class WeatherDataServiceImpl implements WeatherDataService {Autowiredprivate RestTemplate restTemplate;private final string WEATHER_API = " mini";@overridepublic WeatherResponse getDataByCityId(string cityId){String uri = WEATHER_API + "?citykey=" + cityId;return this.doGetweatherData(uri);}@overridepublic WeatherResponse getDataByCityName(String cityName){String uri = WEATHER_API +"?city=" + cityName;return this.doGetWeatherData (uri);private WeatherResponse doGetWeatherData(String uri){ResponseEntity<String> response = restTemplate.getForEntity(uri,String.class);String strBody = null;if(response.getstatusCodevalue()==200）{strBody= response.getBody(;}objectMapper mapper = new objectMapper();WeatherResponse weather = null;try{weather = mapper.readValue (strBody,WeatherResponse.class);}catch (工OException e）{e.printStackTrace();return weather;

其中:

. RestTemplate是一个REST客户端，默认采用Apache HttpClient来实现;

·返回的天气信息采用了Jackson来进行反序列化，使其成为WeatherResponse对象。

控制器层

创建com.waylau.spring.cloud.weather.service包，用于存放控制器层代码。控制器层暴露了RESTful API接口。

package com.waylau.spring.cloud.weather.controller;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping:import org.springframework.web.bind.annotation.RestController;import com.waylau.spring.cloud.weather.service.WeatherDataService;import com.waylau.spring.cloud.weather.vo.WeatherResponse;/★大*天气AP工.** @since 1.0.0 2017年10月18日* author <a href=";>Way Lau</a>*/@RestControllerRequestMapping("/weather")public class WeatherController {@Autowiredprivate WeatherDataService weatherDataService;@GetMapping("/cityId/{cityId}")public WeatherResponse getReportByCityId(CPathVariable("cityId")string cityId){return weatherDataService.getDataByCityId(cityId);}GetMapping("/cityName/{cityName}")public WeatherResponse getReportByCityName (CPathVariable ("cityName")string cityName){return weatherDataService.getDataByCityName(cityName);}

其中，@RestController会自动将返回的数据进行序列化，使其成为JSON数据格式。

配置类

创建com.waylau.spring.cloud.weather.config包，用于存放配置相关的代码。创建RestConfiguration

类，该类是RestTemplate 的配置类。

package com.waylau.spring.cloud.weather.config;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.web.client.RestTemplateBuilder;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.web.client.RestTemplate;/***REST 配置类.**@since 1.0.02017年10月18日* @author <a href="; >Way Lau</a>*/Configurationpublic class RestConfiguration {Autowiredprivate RestTemplateBuilder builder;@Beanpublic RestTemplate restTemplate({return builder .build(）;}}

运行项目之后，访问以下API来进行测试。

. 。惠州。

能看到如图6-1所示的天气API返回的数据。

本篇内容给大家讲解的是：通过SpringBoot技术快速实现一个天气预报系统下篇文章给大家介绍使用Redis提升应用的并发访问能力；觉得文章不错的朋友可以转发此文关注小编；感谢大家的支持！！