微服务拆分-远程调用

我们在查询购物车列表的时候，它有一个需求，就是不仅仅要查出购物车当中的这些商品信息，同时还要去查到购物车当中这些商品的最新的价格和状态信息，跟购物车当中的快照进行一个对比，从而去提醒用户。

现在我们已经做了服务的拆分，购物车功能和商品服务功能分别拆分到了两个独立的微服务当中，也就是说代码上面它们是隔离开的，不仅如此，每个微服务将来还会有自己独立的数据库，数据上也是隔离开的。一旦微服务进行了拆分，数据产生了隔离，服务之间也产生了隔离，这个时候没有办法像以前那样去做本地调用了。如果要做数据查询，查别人的数据，就必须通过网络调用。

问题的关键是我们该怎么样通过java代码，从一个服务向另一个服务发起网络请求查询数据。

 @RequiredArgsConstructor 必备参数的构造函数，那么这样一来这个注解的作用其实就是给加final的成员变量生成构造函数（常量必须初始化）。

new ParameterizedTypeReference<List<ItemDTO>>() {
},

字节码泛型会擦除，但是new的对象它的泛型是还在的，这个时候就可以利用反射拿到这个对象上的这个泛型，从而就知道了我们想要的返回值类型。也就是泛型的引用利用这个对象把泛型传过去。

CollUtil.join(itemIds,",")自动把这个id集合以逗号拼接变成字符串。

 

private void handleCartItems(List<CartVO> vos) {//TODO 1.获取商品idSet<Long> itemIds = vos.stream().map(CartVO::getItemId).collect(Collectors.toSet());// 2.查询商品
//        List<ItemDTO> items = itemService.queryItemByIds(itemIds);//2.1.利用RestTemplate发起http请求，得到http的响应ResponseEntity<List<ItemDTO>> response = restTemplate.exchange("http://localhost:8081/items?ids={ids}",HttpMethod.GET,null,new ParameterizedTypeReference<List<ItemDTO>>() {},Map.of("ids", CollUtil.join(itemIds,",")));//2.2解析响应if (!response.getStatusCode().is2xxSuccessful()){//查询失败，直接结束return;}List<ItemDTO> items = response.getBody();if (CollUtils.isEmpty(items)) {return;}// 3.转为 id 到 item的mapMap<Long, ItemDTO> itemMap = items.stream().collect(Collectors.toMap(ItemDTO::getId, Function.identity()));// 4.写入vofor (CartVO v : vos) {ItemDTO item = itemMap.get(v.getItemId());if (item == null) {continue;}v.setNewPrice(item.getPrice());v.setStatus(item.getStatus());v.setStock(item.getStock());}}

 

已经实现了从购物车服务到商品服务的远程查询。