SpringCloud学习之旅09--weather项目collection-eureka-feign

目录结构：

该项目是通过上篇博文获取的cityId去获取该城市的天气情况。

build.gradle文件：

// buildscript 代码块中脚本优先执行
buildscript {

// ext 用于定义动态属性
ext {
springBootVersion = '2.0.0.M3'
}

// 使用了Maven的中央仓库及Spring自己的仓库（也可以指定其他仓库）
repositories {
// mavenCentral()
maven { url "https://repo.spring.io/snapshot" }
maven { url "https://repo.spring.io/milestone" }
maven { url "http://maven.aliyun.com/nexus/content/groups/public/" }
}

// 依赖关系
dependencies {

// classpath 声明了在执行其余的脚本时，ClassLoader 可以使用这些依赖项
classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
}
}

// 使用插件
apply plugin: 'java'
apply plugin: 'eclipse'
apply plugin: 'org.springframework.boot'
apply plugin: 'io.spring.dependency-management'

// 指定了生成的编译文件的版本，默认是打成了 jar 包
group = 'com.waylau.spring.cloud'
version = '1.0.0'

// 指定编译 .java 文件的 JDK 版本
sourceCompatibility = 1.8

// 使用了Maven的中央仓库及Spring自己的仓库（也可以指定其他仓库）
repositories {
//mavenCentral()
maven { url "https://repo.spring.io/snapshot" }
maven { url "https://repo.spring.io/milestone" }
maven { url "http://maven.aliyun.com/nexus/content/groups/public/" }
}

ext {
springCloudVersion = 'Finchley.M2'
}

// 依赖关系
dependencies {

// 该依赖用于编译阶段
compile('org.springframework.boot:spring-boot-starter-web')

// HttpClient
compile('org.apache.httpcomponents:httpclient:4.5.3')

// Redis
compile('org.springframework.boot:spring-boot-starter-data-redis')

// Quartz
compile('org.springframework.boot:spring-boot-starter-quartz')

// Eureka Client
compile('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client')

// Feign
//compile('org.springframework.cloud:spring-cloud-starter-openfeign')

// https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-openfeign
compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-openfeign', version: '1.4.4.RELEASE'

// https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-feign
compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-feign', version: '1.0.3.RELEASE'

// 该依赖用于测试阶段
testCompile('org.springframework.boot:spring-boot-starter-test')
}

dependencyManagement {
imports {
mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
}

}

application.properties文件：

spring.application.name: msa-weather-collection-eureka-feign

eureka.client.serviceUrl.defaultZone: http://localhost:8761/eureka/

feign.client.config.feignName.connectTimeout: 5000
feign.client.config.feignName.readTimeout: 5000

server.port=8016

package com.waylau.spring.cloud.weather.vo;

/**
* City.
*
* @since 1.0.0 2017年11月23日
* @author <a href="https://waylau.com">Way Lau</a>
*/
public class City {
private String cityId;

private String cityName;

private String cityCode;

private String province;

public String getCityId() {
return cityId;
}

public void setCityId(String cityId) {
this.cityId = cityId;
}

public String getCityName() {
return cityName;
}

public void setCityName(String cityName) {
this.cityName = cityName;
}

public String getCityCode() {
return cityCode;
}

public void setCityCode(String cityCode) {
this.cityCode = cityCode;
}

public String getProvince() {
return province;
}

public void setProvince(String province) {
this.province = province;
}

}

package com.waylau.spring.cloud.weather.service;

import java.util.List;

import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;

import com.waylau.spring.cloud.weather.vo.City;

/**
* City Client.
*
* @since 1.0.0 2017年11月28日
* @author <a href="https://waylau.com">Way Lau</a>

//这是注册到eureka的另外一个服务

@FeignClient("msa-weather-city-eureka")
public interface CityClient {

@GetMapping("/cities")
List<City> listCity() throws Exception;

}

package com.waylau.spring.cloud.weather.service;

/**
* Weather Data Collection Service.
*
* @since 1.0.0 2017年11月26日
* @author <a href="https://waylau.com">Way Lau</a>
*/
public interface WeatherDataCollectionService {

/**
* 根据城市ID同步天气
* @param cityId
*/
void syncDateByCityId(String cityId);

}

package com.waylau.spring.cloud.weather.service;

import java.util.concurrent.TimeUnit;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

/**
* Weather Data Collection Service.
*
* @since 1.0.0 2017年11月26日
* @author <a href="https://waylau.com">Way Lau</a>
*/
@Service
public class WeatherDataCollectionServiceImpl implements WeatherDataCollectionService {
private static final String WEATHER_URI = "http://wthrcdn.etouch.cn/weather_mini?";

private static final long TIME_OUT = 1800L; // 1800s

@Autowired
private RestTemplate restTemplate;

@Autowired
private StringRedisTemplate stringRedisTemplate;

@Override
public void syncDateByCityId(String cityId) {
String uri = WEATHER_URI + "citykey=" + cityId;
this.saveWeatherData(uri);
}

/**
* 把天气数据放在缓存
* @param uri
*/
private void saveWeatherData(String uri) {
String key = uri;
String strBody = null;
ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();

// 调用服务接口来获取
ResponseEntity<String> respString = restTemplate.getForEntity(uri, String.class);

if (respString.getStatusCodeValue() == 200) {
strBody = respString.getBody();
}

// 数据写入缓存
ops.set(key, strBody, TIME_OUT, TimeUnit.SECONDS);

}

}

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 Configuration.
*
* @since 1.0.0 2017年11月22日
* @author <a href="https://waylau.com">Way Lau</a>
*/
@Configuration
public class RestConfiguration {

@Autowired
private RestTemplateBuilder builder;

@Bean
public RestTemplate restTemplate() {
return builder.build();
}

}

package com.waylau.spring.cloud.weather.config;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.waylau.spring.cloud.weather.job.WeatherDataSyncJob;

/**
* Quartz Configuration.
*
* @since 1.0.0 2017年11月23日
* @author <a href="https://waylau.com">Way Lau</a>
*/
@Configuration
public class QuartzConfiguration {

private static final int TIME = 1800; // 更新频率 s

// JobDetail
@Bean
public JobDetail weatherDataSyncJobDetail() {
return JobBuilder.newJob(WeatherDataSyncJob.class).withIdentity("weatherDataSyncJob")
.storeDurably().build();
}

// Trigger
@Bean
public Trigger weatherDataSyncTrigger() {

SimpleScheduleBuilder schedBuilder = SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(TIME).repeatForever();

return TriggerBuilder.newTrigger().forJob(weatherDataSyncJobDetail())
.withIdentity("weatherDataSyncTrigger").withSchedule(schedBuilder).build();
}

}

package com.waylau.spring.cloud.weather.job;

import java.util.List;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;

import com.waylau.spring.cloud.weather.service.CityClient;
import com.waylau.spring.cloud.weather.service.WeatherDataCollectionService;
import com.waylau.spring.cloud.weather.vo.City;

/**
* Weather Data Sync Job.
*
* @since 1.0.0 2017年11月23日
* @author <a href="https://waylau.com">Way Lau</a>
*/
public class WeatherDataSyncJob extends QuartzJobBean {

private final static Logger logger = LoggerFactory.getLogger(WeatherDataSyncJob.class);

@Autowired
private WeatherDataCollectionService weatherDataCollectionService;

@Autowired
private CityClient cityClient;

@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
logger.info("Weather Data Sync Job. Start！");
// 获取城市ID列表
List<City> cityList = null;

try {

// 由城市数据API微服务提供数据
cityList = cityClient.listCity();
} catch (Exception e) {
logger.error("Exception!", e);
}

// 遍历城市ID获取天气
for (City city : cityList) {
String cityId = city.getCityId();
logger.info("Weather Data Sync Job, cityId:" + cityId);

weatherDataCollectionService.syncDateByCityId(cityId);
}

logger.info("Weather Data Sync Job. End！");
}

}

这里就把根据cityId获取天气的信息服务注册到了eureka服务中去了。

该博文是根据cityId获取天气的信息将信息存入Redis缓存中。

SpringCloud学习之旅09--weather项目collection-eureka-feign

猜你喜欢