摘要：本章主要講解天氣數(shù)據(jù)微服務的實現(xiàn)。在我們拆分成微服務架構之后調(diào)用第三方接口的行為由天氣數(shù)據(jù)采集微服務中的定時任務進行。因此在天氣數(shù)據(jù)微服務中我們的天氣數(shù)據(jù)直接從緩存中進行獲取，若在緩存中獲取不到對應城市的數(shù)據(jù)，則直接拋出錯誤。

照例附上項目github鏈接

本項目實現(xiàn)的是將一個簡單的天氣預報系統(tǒng)一步一步改造成一個SpringCloud微服務系統(tǒng)的過程，本節(jié)主要講的是單塊架構改造成微服務架構的過程，最終將原來單塊架構的天氣預報服務拆分為四個微服務：城市數(shù)據(jù)API微服務，天氣數(shù)據(jù)采集微服務，天氣數(shù)據(jù)API微服務，天氣預報微服務。

本章主要講解天氣數(shù)據(jù)API微服務的實現(xiàn)。

對原來單塊架構的天氣預報服務進行改進，去除多余的依賴，最終的pom文件如下：

    4.0.0



    com.demo

    sifoudemo02

    0.0.1-SNAPSHOT

    jar



    sifoudemo02

    Demo project for Spring Boot



    

        org.springframework.boot

        spring-boot-starter-parent

        2.0.5.RELEASE

         

    



    

        UTF-8

        UTF-8

        1.8

    



    

        

            org.springframework.boot

            spring-boot-devtools

            true

        

     

        

            org.springframework.boot

            spring-boot-starter-web

        



        

            org.springframework.boot

            spring-boot-starter-test

            test

        

        

        

            org.slf4j

            slf4j-jdk14

            1.7.7

            

        

        

            org.springframework.boot

            spring-boot-starter-data-redis

        

    



    

        

            

                org.springframework.boot

                spring-boot-maven-plugin

                

                    true

                

                

            

        

     

在service中保留如下接口：

（1）根據(jù)城市Id查詢天氣的接口getDataByCityId

（2）根據(jù)城市名稱查詢天氣的接口getDataByCityName

注意：原來我們的天氣數(shù)據(jù)是先從緩存中獲取的，若查詢不到則調(diào)用第三方接口獲取天氣信息，并將其保存到緩存中。

在我們拆分成微服務架構之后調(diào)用第三方接口的行為由天氣數(shù)據(jù)采集微服務中的定時任務進行。

因此在天氣數(shù)據(jù)API微服務中我們的天氣數(shù)據(jù)直接從緩存中進行獲取，若在緩存中獲取不到對應城市的數(shù)據(jù)，則直接拋出錯誤。

@Service
public class WeatherDataServiceImpl implements WeatherDataService {
    private final static Logger logger = LoggerFactory.getLogger(WeatherDataServiceImpl.class);  
    
    private static final String WEATHER_URI = "http://wthrcdn.etouch.cn/weather_mini?";
    
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    
    @Override
    public WeatherResponse getDataByCityId(String cityId) {
        String uri = WEATHER_URI + "citykey=" + cityId;
        return this.doGetWeahter(uri);
    }

    @Override
    public WeatherResponse getDataByCityName(String cityName) {
        String uri = WEATHER_URI + "city=" + cityName;
        return this.doGetWeahter(uri);
    }
    
    private WeatherResponse doGetWeahter(String uri) {
        String key = uri;
        String strBody = null;
        ObjectMapper mapper = new ObjectMapper();
        WeatherResponse resp = null;
        ValueOperations  ops = stringRedisTemplate.opsForValue();
        // 先查緩存，緩存有的取緩存中的數(shù)據(jù)
        if (stringRedisTemplate.hasKey(key)) {
            logger.info("Redis has data");
            strBody = ops.get(key);
        } else {
            logger.info("Redis don"t has data");
            // 緩存沒有，拋出異常
            throw new RuntimeException("Don"t has data!");
        }

        try {
            resp = mapper.readValue(strBody, WeatherResponse.class);
        } catch (IOException e) {
            //e.printStackTrace();
            logger.error("Error!",e);
        }
        
        return resp;
    }

}

在controller中提供根據(jù)城市Id和名稱獲取天氣數(shù)據(jù)的接口。

@RestController
@RequestMapping("/weather")
public class WeatherController {
    @Autowired
    private WeatherDataService weatherDataService;
    
    @GetMapping("/cityId/{cityId}")
    public WeatherResponse getWeatherByCityId(@PathVariable("cityId") String cityId) {
        return weatherDataService.getDataByCityId(cityId);
    }
    
    @GetMapping("/cityName/{cityName}")
    public WeatherResponse getWeatherByCityName(@PathVariable("cityName") String cityName) {
        return weatherDataService.getDataByCityName(cityName);
    }
}