请求

摘要：本文次要剖析应用cse提供的RestTemplate的场景，其实cse提供的rpc注解（RpcReference）的形式最初的调用逻辑和RestTemplate是必由之路的。本文分享自华为云社区《我是一个申请，我该何去何从（下）》，原文作者：向昊 。 上次咱们大略理解到了服务端是怎么解决申请的，那么发送申请又是个什么样的流程了？本文次要剖析应用cse提供的RestTemplate的场景，其实cse提供的rpc注解（RpcReference）的形式最初的调用逻辑和RestTemplate是必由之路的。 应用应用cse提供的RestTemplate时候，是这样初始化的： RestTemplate restTemplate = RestTemplateBuilder.create();restTemplate.getForObject("cse://appId:serviceName/xxx", Object.class);咱们能够留神到2个怪异的中央： RestTemplate是通过RestTemplateBuilder.create()来获取的，而不是用的Spring里提供的。申请门路结尾是cse而不是咱们常见的http、https且须要加上服务所属的利用ID和服务名称。解析依据url匹配RestTemplate首先看下RestTemplateBuilder.create()，它返回的是org.apache.servicecomb.provider.springmvc.reference.RestTemplateWrapper，是cse提供的一个包装类。 // org.apache.servicecomb.provider.springmvc.reference.RestTemplateWrapper// 用于同时反对cse调用和非cse调用class RestTemplateWrapper extends RestTemplate { private final List<AcceptableRestTemplate> acceptableRestTemplates = new ArrayList<>(); final RestTemplate defaultRestTemplate = new RestTemplate(); RestTemplateWrapper() { acceptableRestTemplates.add(new CseRestTemplate()); } RestTemplate getRestTemplate(String url) { for (AcceptableRestTemplate template : acceptableRestTemplates) { if (template.isAcceptable(url)) { return template; } } return defaultRestTemplate; }}AcceptableRestTemplate：这个类是一个抽象类，也是继承RestTemplate的，目前其子类就是CseRestTemplate，咱们也能够看到在初始化的时候会默认往acceptableRestTemplates中增加一个CseRestTemplate。 回到应用的中央restTemplate.getForObject：这个办法会委托给如下办法： public <T> T getForObject(String url, Class<T> responseType, Object... urlVariables) throws RestClientException { return getRestTemplate(url).getForObject(url, responseType, urlVariables);}能够看到首先会调用getRestTemplate(url)，即会调用template.isAcceptable(url)，如果匹配到了就返回CseRestTemplate，否则就返回惯例的RestTemplate。那么再看下isAcceptable()这个办法： ...

起步新年目标Spring Cloud开始实施，打开慕课网。刚学了一章，大体就是调用中国天气网的api，使用Spring Boot构建自己的天气预报系统，然后使用Spring Cloud，一步一步使用微服务的思想来演进架构。小目标昨天去百度抢了新年红包，感叹百度的高并发做的也是如此优秀。阿里的双十一，百度的新年。(发现了二者的共同点，可能也是解决并发的一种思路，并发的时候只允许增加数据。)感叹归感叹，期望着学习完Spring Cloud也能设计出优秀的架构，解决并发的一些问题。遇到的问题学习时也跟着课程进行编码，讲师讲的非常好，但是本课程的重点是后面的微服务架构，所以前面的功能有一些瑕疵，特此提出自己的实现，供大家学习交流。功能描述最初的功能很简单，因为后台是没有任何数据的，所以前台有请求，就直接去天气网要数据，然后再返回去。数据序列化问题这是天气网api返回来的数据格式，乍一看没啥毛病。{ “data”: { “yesterday”: { “date”: “4日星期一”, “high”: “高温 26℃”, “fx”: “无持续风向”, “low”: “低温 18℃”, “fl”: “<![CDATA[<3级]]>”, “type”: “多云” }, “city”: “深圳”, “forecast”: [ { “date”: “5日星期二”, “high”: “高温 25℃”, “fengli”: “<![CDATA[<3级]]>”, “low”: “低温 18℃”, “fengxiang”: “无持续风向”, “type”: “多云” }, { “date”: “6日星期三”, “high”: “高温 26℃”, “fengli”: “<![CDATA[<3级]]>”, “low”: “低温 17℃”, “fengxiang”: “无持续风向”, “type”: “多云” }, { “date”: “7日星期四”, “high”: “高温 27℃”, “fengli”: “<![CDATA[<3级]]>”, “low”: “低温 18℃”, “fengxiang”: “无持续风向”, “type”: “多云” }, { “date”: “8日星期五”, “high”: “高温 26℃”, “fengli”: “<![CDATA[<3级]]>”, “low”: “低温 17℃”, “fengxiang”: “无持续风向”, “type”: “多云” }, { “date”: “9日星期六”, “high”: “高温 24℃”, “fengli”: “<![CDATA[<3级]]>”, “low”: “低温 14℃”, “fengxiang”: “无持续风向”, “type”: “小雨” } ], “ganmao”: “相对今天出现了较大幅度降温，较易发生感冒，体质较弱的朋友请注意适当防护。”, “wendu”: “23” }, “status”: 1000, “desc”: “OK”}缺点1：有拼音；ganmao、wendu。缺点2：名称不一致；理论上来说yesterday与forecast应该是同一个实体，都表示一天的天气情况，只是名称不同。但是在yesterday中，风向和风力是fx和fl，在forecast中，名称却是fengli、fengxiang。解决此问题，想到的思路就是使用jackson进行序列化与反序列化时进行配置的一些注解。最初使用此种方法实现：@JsonProperty(“wendu”)private Float temperature;一个对象中的名字，一个json数据中的名字。可以实现，但是不好。举个例子，天气api返回给我wendu，添加了@JsonProperty，然后wendu就绑定到了temperature上，但是如果我前台再返回该对象，序列化后生成的名称还是wendu。不好！目标是实现，反序列化时：从wendu能绑定到我的temperature，序列化时直接使用我的字段名。get、set尝试猜测是不是和get、set方法有关。就把@JsonProperty(“wendu”)添加到set方法上，发现并没有用。JsonAlias后来经过查询，原来是注解用错了，此种情况应使用别名。关于JsonProperty和JsonAlias的详细讲解，请参考Jackson @JsonProperty and @JsonAlias Example。@JsonAlias(“wendu”)private Float temperature;同时，可以应用多个别名：@JsonAlias({“fengli”, “fl”})private String windForce;发起请求发起请求的示例代码，供以后参考。@Autowiredprivate RestTemplate restTemplate;@Overridepublic Weather getWeatherByCityName(String cityName) { return this.getWeatherByUrl(BASE_URL + “?” + CITY_NAME + “=” + cityName) .getData();}private Response getWeatherByUrl(String url) { // 发起Get请求 ResponseEntity<String> response = restTemplate.getForEntity(url, String.class); // 如果状态码非200, 抛异常 if (response.getStatusCodeValue() != 200) { throw new YunzhiNetworkException(“数据请求失败”); } // 实例化对象映射对象 ObjectMapper mapper = new ObjectMapper(); // 初始化响应数据 Response data; // 从字符串转换为Response对象 try { data = mapper.readValue(response.getBody(), Response.class); } catch (IOException e) { throw new YunzhiIOException(“json数据转换失败”); } // 返回 return data;}RestTemplate配置这里与正常的RestTemplate构建有些不同，通常的RestTemplate是使用Spring工具类构造的，此处使用Apache的Http组件构造，以支持更多的数据格式。implementation ‘org.apache.httpcomponents:httpclient’同时去除了默认的对String的Http消息转换器，默认的转换器使用的不是UTF-8编码。讲师原文章：Spring RestTemplate 调用天气预报接口乱码的解决@Configurationpublic class BeanConfiguration { @Bean public RestTemplate restTemplate() { // 使用Apache HttpClient构建RestTemplate, 支持的比Spring自带的更多 RestTemplate restTemplate = new RestTemplate(new HttpComponentsClientHttpRequestFactory()); // 去除默认的String转换器 restTemplate.getMessageConverters().removeIf(converter -> converter instanceof StringHttpMessageConverter); // 添加自定义的String转换器, 支持UTF-8 restTemplate.getMessageConverters() .add(new StringHttpMessageConverter(StandardCharsets.UTF_8)); return restTemplate; }}更完善的单元测试同时，在编写单元测试的时候，看了一篇关于AssertJ的文章。Testing with AssertJ assertions - Tutorial之前学Junit5的时候，觉得这个东西挺好使的啊？为什么被开源社区抛弃而使用AssertJ呢？原来之前用的断言都太简单，其实AssertJ远比我们使用的更强大。@Testpublic void getWeatherByCityName() throws Exception { final String cityName = “深圳”; MvcResult mvcResult = this.mockMvc .perform(MockMvcRequestBuilders.get(BASE_URL + “/cityName/” + cityName)) .andExpect(MockMvcResultMatchers.status().isOk()) .andReturn(); String json = mvcResult.getResponse().getContentAsString(); Assertions.assertThat(json) .contains(“cityName”, “cold”, “temperature”, “windDirection”, “windForce”) .doesNotContain(“ganmao”, “wendu”, “fx”, “fl”, “fengxiang”, “fengli”);}总结多看英文文章，Tutorial写得都特别好。 ...