// build.gradle
dependencies{
    compile('org.springframework.cloud:spring-cloud-config-server')
}
// Application
@SpringBootApplication
@EnableDiscoveryClient
@EnableConfigServer
public class ConfigApplication{
    public static void main(String[] args){
        SpringApplication.run(ConfigApplication.class,args);
    }
}
// application.properties
# config server
server.port=8888
spring.application.name=micro-weather-config-server
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
spring.cloud.config.server.git.uri=https:...
spring.cloud.config.server.git.search-paths=...

// build.gradle
dependencies{
    compile('org.springframework.cloud:spring-cloud-config-client')
}
// Application
@SpringBootApplication
@EnableDiscoveryClient
public class ConfigClientApplication{
    public static void main(String[] args){
        SpringApplication.run(ConfigClientApplication.class,args);
    }
}
// application.properties
# config server
spring.application.name=micro-weather-config-client
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
spring.cloud.config.profile=dev
spring.cloud.config.uri=http://localhost:8888

/{application}/{profile}/[/{label}]
/{application}-{profile}.yml
/{label}/{application}-{profile}.yml
/{application}-{profile}.properties
/{label}/{application}-{profile}.properties

// 创建新的DataClient替换原本的CityClient以及WeatherDataServer
@FeignClient("micro-weather-eureka-client-zuul")
public interface DataClient {
	@GetMapping("/city/cities")
	List<City> listCity() throws Exception;
	@GetMapping("/data/weather/cityId/{cityId}")
	WeatherResponse getDataByCityId(@PathVariable("cityId")String cityId);
}

// 依赖
dependenies{
    compile('org.apache.httpcomponents:httpclient:4.5.3')
}
// 注入
@Configuration
public clas RestConfiguration{
    @Autowired
    private RestTemplateBuilder builder;
    @Bean
    public RestTemplate restTemplate(){
        return builder.build();
    }
}
// 使用
@Service
public class WeatherDataServiceImpl implements WeatherDataService{
    @Autowired
    private RestTemplate restTemplate;
    private WeatherResponse doGetWeatherData(String uri){
        ResponseEntity<String> response = restTemplate.getForEntity(uri,String.class);
        // ...
    }
}

// 依赖
dependenies{
    compile('org.springframework.cloud:spring-cloud-starter-netflix-ribbon')
}
// 注入
@Configuration
@RibbonClient(name="ribbon-client",configuration=RibbonConfiguration.class)
public clas RestConfiguration{
    @Autowired
    private RestTemplateBuilder builder;
    @Bean
    public RestTemplate restTemplate(){
        return builder.build();
    }
}
// 配置
@Configuration
public class RibbonConfiguration{
    @Bean
    public ZonePreferenceServerListFilter serverListFilter(){
        ZonePreferenceServerListFilter filter = new ZonePreferenceServerListFilter();
        filter.setZone("myZone");
        return filter;
    }
    @Bean
    public IPing ribbonPing(){
        return new PingUrl();
    }
}
// application.properties
spring.application.name=micro-weather-eureka-client-ribbon
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

// 使用
@RestController
public class CityController{
    @Autowired
    private RestTemplate restTemplate;
    @GetMapping("/cities")
    public String listCity(){
        // 通过服务应用名称查找
        String body = restTemplate.getForEntity("http://msa-weather-city-server/cities",Strign.class);
        return body;
    }
}

// build.gradle
dependencies {
	// Eureka Client
	compile('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client')
	// Feign
	compile('org.springframework.cloud:spring-cloud-starter-openfeign')
	// Test
	testCompile('org.springframework.boot:spring-boot-starter-test')
}

// application.properties
spring.application.name= micro-weather-eureka-client-feign
eureka.client.serviceUrl.defaultZone= http://localhost:8761/eureka/
feign.client.config.feignName.connectTimeout= 5000
feign.client.config.feignName.readTimeout= 5000
    
// CityClient.java
@FeignClient("micro-weather-city-eureka")
public interface CityClient {

	@GetMapping("/cities")
	String listCity();
}
// CityController.java
@RestController
public class CityController {
	@Autowired
	private CityClient cityClient;

	@GetMapping("/cities")
	public String listCity() {
		// 通过Feign客户端来查找
		String body = cityClient.listCity();
		return body;
	}
}

// Application.java
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class FeignApplication {

	public static void main(String[] args) {
		SpringApplication.run(FeignApplication.class, args);
	}
}

// build.gradle
buildscript {
    ext {
        springBootVersion = '2.0.3.RELEASE'
    }
    repositories {
		mavenCentral()
    }
    dependencies {
        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
    }
}
ext {
    springCloudVersion = 'Finchley.SR1'
}

dependencies {
    // Eureka Server
    compile('org.springframework.cloud:spring-cloud-starter-netflix-eureka-server')
    testCompile('org.springframework.boot:spring-boot-starter-test')
}

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

// application.properties
# Eureka
server.port=8761
eureka.instance.hostname=localhost
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.service-url.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka/

// Application.java
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
	public static void main(String[] args) {
		SpringApplication.run(EurekaApplication.class, args);
	}
}

// build.gradle
buildscript {
    ext {
        springBootVersion = '2.0.3.RELEASE'
    }
    repositories {
		mavenCentral()
    }
    dependencies {
        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
    }
}
ext {
    springCloudVersion = 'Finchley.SR1'
}

dependencies {
    // Eureka Server
    compile('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client')
    testCompile('org.springframework.boot:spring-boot-starter-test')
}

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

// application.properties
# eureka client
spring.application.name=micro-weather-eureka-client
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

// Application.java
@SpringBootApplication
@EnableEurekaClient
public class MicroWeatherEurekaClientApplication {
	public static void main(String[] args) {
		SpringApplication.run(MicroWeatherEurekaClientApplication.class, args);
	}
}

// 对四个微服务的build.gradle 配置文件进行修改
// 添加如下配置,类eureka client
buildscript {
    ext {
        springBootVersion = '2.0.3.RELEASE'
    }
    ...
}
...
ext {
    springCloudVersion = 'Finchley.SR1'
}

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

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

// 四个微服务的Application.java文件进行修改
@SpringBootApplication
@EnableDiscoveryClient
public class ...Application {
	public static void main(String[] args) {
		SpringApplication.run(...Application.class, args);
	}
}
// 四个微服务的application.properties
# ... eureka server
server.pory=808x
spring.application.name=micro-weather-...-eureka
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/

// config 	QuartzConfiguration RestConfiguration
// job 		WeatherDataSyncJob
// service 	WeatherDataCollectionService & Impl
// vo 		City

// controller 	WeatherReportController
// service 		WeatherReportService
// vo			City Forecast Weather WeatherResponse Yesterday
// UI

// controller 	WeatherReportController
// service 		WeatherReportService
// vo			City Forecast Weather WeatherResponse Yesterday
// resource		citylist.xml

// controller 	WeatherController
// service 		WeatherDataService
// vo			Forecast Weather WeatherResponse Yesterday

@Data
public class WeatherResponse implements Serializable{
   private Weather data;
   private Integer status;
   private String desc;
}
@Data
public class Weather implements Serializable{
	// 城市
	private String city;
	// ...属性根据JSON返回数据编写
}
// 天气数据接口
public interface WeatherDataService {
	// 根据城市ID查询天气数据
	WeatherResponse getDataByCityId(String cityId);
	// 根据城市名称查询天气数据
	WeatherResponse getDataByCityName(String cityName);
}
// 实现
@Service
public class WeatherDataServiceImpl implements WeatherDataService {
	private static final String WEATHER_URL = "http://wthrcdn.etouch.cn/weather_mini?";
	@Autowired
	private RestTemplate restTemplate;
	@Override
	public WeatherResponse getDataByCityId(String cityId) {
		String url = WEATHER_URL + "citykey=" + cityId;
		return this.doGetWeather(url);
	}
	private WeatherResponse doGetWeather(String url) {
		ResponseEntity<String> respString = restTemplate.getForEntity(url, String.class);
		// JSON数据转化为对应类
		ObjectMapper mapper = new ObjectMapper();
		WeatherResponse resp = null;
		String strBody = null;
		if (respString.getStatusCodeValue() == 200) {
			strBody = respString.getBody();
		}
		try {
			resp = mapper.readValue(strBody, WeatherResponse.class);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return resp;
	}
}
// config（见附录）
@Configuration
public class RestConfiguration {
	@Autowired
	private RestTemplateBuilder builder;
	@Bean
	public RestTemplate restTemplate(){
		return builder.build();
	}
}

private final static Logger logger = LoggerFactory.getLogger(WeatherDataServiceImpl.class);
private static final long TIME_OUT = 1800L;
@Autowired
private StringRedisTemplate stringRedisTemplate;

// 修改WeaterDataServiceImpl中的doGetWeather()
private WeatherResponse doGetWeather(String url) {
    String key = url;
    String strBody = null;
    // JSON数据转化为对应类
    ObjectMapper mapper = new ObjectMapper();
    WeatherResponse resp = null;
    ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
    // 先查询Redis缓存
    if (stringRedisTemplate.hasKey(key)) {
        logger.info("REDIS HAS DATA");
        strBody = ops.get(key);
    } else {
        logger.info("REDIS DOESN'T HAS DATA");
        // 缓存不存在，调用接口
        ResponseEntity<String> respString = restTemplate.getForEntity(url, String.class);
        if (respString.getStatusCodeValue() == 200) {
            strBody = respString.getBody();
        }
        // 数据写入缓存
        ops.set(url, strBody, TIME_OUT, TimeUnit.SECONDS);
    }
    // 类型返回
    try {
        resp = mapper.readValue(strBody, WeatherResponse.class);
    } catch (IOException e) {
        logger.error("ERROR:" + e.toString());
    }    
    return resp;
}

@Configuration
public class QuartzConfiguration {
   // JobDetail
   @Bean
   public JobDetail weatherDataSyncJobDetail(){
      return JobBuilder.newJob(WeatherDataSyncJob.class)
            .withDescription("WeatherDataSyncJob").storeDurably().build();
   }
   // Trigger
   @Bean
   public Trigger weatherDataSyncTrigger(){
      SimpleScheduleBuilder schedBuilder = SimpleScheduleBuilder.simpleSchedule()
            .withIntervalInSeconds(1800).repeatForever();
      return TriggerBuilder.newTrigger().forJob(weatherDataSyncJobDetail())
            .withDescription("WeatherDataSyncTrigger").withSchedule(schedBuilder).build();
   }
}

public class WeatherDataSyncJob extends QuartzJobBean {
private final static Logger logger = LoggerFactory.getLogger(WeatherDataSyncJob.class);
@Override
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
    logger.info("Weather Data Sync Job");
}
}

// CityList.java
@XmlRootElement(name = "c")
@XmlAccessorType(XmlAccessType.FIELD) // 通过字段访问
public class CityList {
	@XmlElement(name = "d")
	private List<City> cityList;
}

// City.java
@XmlRootElement(name = "d")
@XmlAccessorType(XmlAccessType.FIELD) // 通过字段访问
public class City {
   @XmlAttribute(name = "d1")
   private String cityId;
   @XmlAttribute(name = "d2")
   private String cityName;
   @XmlAttribute(name = "d3")
   private String cityCode;
   @XmlAttribute(name = "d4")
   private String province;
   // ...GETTER SETTER
}

// Util
public class XmlBuilder {
	// 将XML数据转换成JAVA对应的POJO
	public static Object xmlStrToObject(Class<?> clazz, String xmlStr) throws Exception {
		Object xmlObject = null;
		Reader reader = null;
		JAXBContext context = JAXBContext.newInstance(clazz);
		// XML转为对象的接口
		Unmarshaller unmarshaller = context.createUnmarshaller();
		reader = new StringReader(xmlStr);
		xmlObject = unmarshaller.unmarshal(reader);
		if (reader != null) {
			reader.close();
		}
		return xmlObject;
	}
}

// Service
@Service
public class CityDataServiceImpl implements CityDataService {
	@Override
	public List<City> listCity() throws Exception {
		// 读取XML文件
		Resource resource = new ClassPathResource("citylist.xml");
		BufferedReader br = new BufferedReader(new InputStreamReader(resource.getInputStream(), "utf-8"));
		StringBuffer buffer = new StringBuffer();
		String line = "";
		while ((line = br.readLine()) != null) {
			buffer.append(line);
		}
		br.close();
		// XML转化为JAVA对象
		CityList cityList = (CityList) XmlBuilder.xmlStrToObject(CityList.class,buffer.toString());
		return cityList.getCityList();
	}
}

// Modify WeatherService
@Override
public void syncDataByCityId(String cityId) {
    String url = WEATHER_URL + "citykey=" + cityId;
    this.saveWeatherData(url);
}
private void saveWeatherData(String url) {
    String key = url;
    String strBody = null;
    ValueOperations<String, String> ops = stringRedisTemplate.opsForValue();
    // 缓存不存在，调用接口
    ResponseEntity<String> respString = restTemplate.getForEntity(url, String.class);
    if (respString.getStatusCodeValue() == 200) {
        strBody = respString.getBody();
    }
    // 数据写入缓存
    ops.set(url, strBody, TIME_OUT, TimeUnit.SECONDS);
}

mockMvc.perform(MockMvcRequestBuilders.get("/hello").accept(MediaType.APPLICATION_JSON))
				.andExpect(status().isOk())
				.andExpect(content().string(equalTo("Hello World")));

import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
import static org.hamcrest.Matchers.equalTo;

// 文档类型的EsBlog实体
@Document(indexName = "blog",type = "blog")
public class EsBlog implements Serializable{
    @Id
	private String id;

	// Blog实体的ID
	@Field(index = FieldIndex.not_analyzed)
	private Long blogId;
	private String title;
	private String summary;
	private String content;
	// 不使用全文检索字段
	@Field(index = FieldIndex.not_analyzed)
	private String username;
	...
	private String tags;
}

// EsBlogRepository
public interface EsBlogRepository extends ElasticsearchRepository<EsBlog,String> {
    // 模糊搜索查询
	Page<EsBlog> findDistinctEsBlogByTitleContainingOrSummaryContainingOrContentContainingOrTagsContaining(String title,String summary,String content,String tags,Pageable pageable);
}

// EsBlogService
public interface EsBlogService {
	// 最新博客列表
	Page<EsBlog> listNewestEsBlogs(String keyword, Pageable pageable);
	...
}

// Impl
@Override
public List<TagVO> listTop30Tags() {
    List<TagVO> list = new ArrayList<>();
    // given
    SearchQuery searchQuery = new NativeSearchQueryBuilder()
        .withQuery(matchAllQuery())
        .withSearchType(SearchType.QUERY_THEN_FETCH)
        .withIndices("blog").withTypes("blog")
        .addAggregation(terms("tags").field("tags").order(Terms.Order.count(false)).size(30))
        .build();
    // when
    Aggregations aggregations = elasticsearchTemplate.query(searchQuery, new ResultsExtractor<Aggregations>() {
        @Override
        public Aggregations extract(SearchResponse response) {
            return response.getAggregations();
        }
    });
    
    StringTerms modelTerms = (StringTerms)aggregations.asMap().get("tags");
    Iterator<Terms.Bucket> modelBucketIt = modelTerms.getBuckets().iterator();
    while (modelBucketIt.hasNext()){
        Terms.Bucket actiontypeBucket = modelBucketIt.next();
        list.add(new TagVO(actiontypeBucket.getKey().toString(),actiontypeBucket.getDocCount()));
    }
    return list;
}

// BlogController
@Controller
@RequestMapping("/blogs")
public class BlogController {
	@Autowired
	private EsBlogService esBlogService;

	/**
	 * 博客列表
	 */
	@GetMapping
	public String listBlogs(@RequestParam(value = "order", required = false, defaultValue = "new") String order,
							@RequestParam(value = "keyword", required = false, defaultValue = "") String keyword,
							@RequestParam(value = "async", required = false) boolean async,
							@RequestParam(value = "pageIndex", required = false, defaultValue = "0") int pageIndex,
							@RequestParam(value = "pageSize", required = false, defaultValue = "10") int pageSize,
							Model model) {
		Page<EsBlog> page = null;
		List<EsBlog> list = null;
		// 系统初始化时，没有博客数据
		boolean isEmpty = true;
		try {
			// 热门查询
			if (order.equals("hot")) {
				...
			} else if (order.equals("new")) {
				...
			}
			isEmpty = false;
		} catch (Exception e) {
		...
		}
		// 所在页面数据列表
		list = page.getContent();
		model.addAttribute("order", order);
		...
		// 首次访问页面才加载
		if (!async && !isEmpty) {
			List<EsBlog> newest = esBlogService.listTop5NewestEsBlogs();
			model.addAttribute("newest", newest);
			...
		}
		return (async == true ? "/index :: #mainContainerRepleace" : "/index");
	}
}