SpringCloud跨微服务的远程调用，如何发起网络请求，RestTemplate

2024-08-01 115

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

服务治理 MSE Sentinel/OpenSergo，Agent数量不受限

容器镜像服务 ACR，镜像仓库100个不限时长

可观测可视化 Grafana 版，10个用户账号 1个月

简介： SpringCloud跨微服务的远程调用，如何发起网络请求，RestTemplate

在我们的业务流程之中不一定都会是自己模块查询自己模块的信息，有些时候就需要去结合其他模块的信息来进行一些查询完成相应的业务流程，但是在SpringCloud每个模块都相对独立，数据库也有数据隔离。所以当我们需要其他微服务模块的信息的时候，就需要跨模块调用发起网络请求。

就像电商项目中，购物车模块就不得不需要像商品模块发起查询请求。购物车业务中需要查询商品信息，但商品信息查询的逻辑全部迁移到了item-service服务，导致我们无法查询。

最终结果就是查询到的购物车数据不完整，因此要想解决这个问题，我们就必须改造其中的代码，把原本本地方法调用，改造成跨微服务的远程调用（RPC，即Remote Produce Call）。

因此，现在查询购物车列表的流程变成了这样：

编辑

那么：我们该如何用Java代码发送Http的请求呢？

RestTemplate

Spring给我们提供了一个RestTemplate的API，可以方便的实现Http请求的发送。

rg.springframework.web.client public class RestTemplate

extends InterceptingHttpAccessor

implements RestOperations

----------------------------------------------------------------------------------------------------------------

同步客户端执行HTTP请求，在底层HTTP客户端库(如JDK HttpURLConnection、Apache HttpComponents等)上公开一个简单的模板方法API。RestTemplate通过HTTP方法为常见场景提供了模板，此外还提供了支持不太常见情况的通用交换和执行方法。 RestTemplate通常用作共享组件。然而，它的配置不支持并发修改，因此它的配置通常是在启动时准备的。如果需要，您可以在启动时创建多个不同配置的RestTemplate实例。如果这些实例需要共享HTTP客户端资源，它们可以使用相同的底层ClientHttpRequestFactory。注意:从5.0开始，这个类处于维护模式，只有对更改和错误的小请求才会被接受。请考虑使用org.springframework.web.react .client. webclient，它有更现代的API，支持同步、异步和流场景。

其中提供了大量的方法，方便我们发送Http请求，例如：

编辑

可以看到常见的Get、Post、Put、Delete请求都支持，如果请求参数比较复杂，还可以使用exchange方法来构造请求。

我们在需要的微服务中定义一个配置类：

编辑

在启动类中先将RestTemplate注册为一个Bean：

@SpringBootApplication
public class CartApplication {
    public static void main(String[] args) {
        SpringApplication.run(CartApplication.class, args);
    }
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

远程调用

接下来，我们修改cart-service中的实现类的handleCartItems方法，发送http请求到item-service：

// 2.查询商品
//        List<ItemDTO> items = itemService.queryItemByIds(itemIds);
        //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.解析响应
        if (!response.getStatusCode().is2xxSuccessful()){
            //查询失败，结束
            return;
        }
        List<ItemDTO> items = response.getBody();
        if (CollUtils.isEmpty(items)) {
            return;
        }

可以看到，利用RestTemplate发送http请求与前端ajax发送请求非常相似，都包含四部分信息：

① 请求方式
② 请求路径
③ 请求参数
④ 返回值类型

@RequiredArgsConstructor
public class CartServiceImpl extends ServiceImpl<CartMapper, Cart> implements ICartService {
    private final RestTemplate restTemplate;