SpringCloud极简入门-使用RestTemplate实现服务通信

简介: 目前除了Eureka Server以外我们的微服务有订单服务springcloud-order-server-1030,和用户服务springcloud-user-server-1020 , 我们就用这两个服务来演示微服务的通信,他们的调用关系应该是:浏览器 -> 订单服务 -> 用户服务,

五.使用RestTemplate实现服务通信

1.如何实现服务通信

1.1.需求说明

上一章节我们对Eureka Server做了高可用集群搭建,这一章节我们来实现简单版的服务通信。

目前除了Eureka Server以外我们的微服务有订单服务springcloud-order-server-1030,和用户服务springcloud-user-server-1020 , 我们就用这两个服务来演示微服务的通信,他们的调用关系应该是:浏览器 -> 订单服务 -> 用户服务,如下图:

这里订单服务通过RestTemplate向用户服务发起调用,目的是要获取到用户服务返回的User对象,最终是需要浏览器获取到User。

1.2.解决方案

用户服务需要提供User对象,我们需要为其编写Controller接口,编写相关方法返回User,订单服务需要从用户服务获取到User对象,而浏览器需要访问订单服务获取到User对象,所以订单服务也需要编写Controller接口供浏览器来调用。

我们发现不管是用户服务还是订单服务都需要用到User对象,那么是不是在用户服务和订单服务都需要创建User的模型?当然没必要,公共的东西就是要抽取,所以我们会把User对象封装在一个公共的模块 springcloud-user-common中然后让用户服务和订单服务都去依赖这个模块。

1.3.RestTemplate介绍

微服务的通信协议主流的有RPC,Http,SpringCloud是基于Http Restful 风格 ,在Java中发起一个Http请求的方式很多,比如 Apache的HttpClient , OKHttp等等 。Spring为我们封装了一个基于Restful的使用非常简单的Http客户端工具 RestTemplate ,我们就用它来实订单服务和用户服务的通信。需要注意的是,RestTmplate本身不具备服务发现和负载均衡器的功能,我们本章的案例只是演示在订单服务中使用RestTemplate基于ip和端口的方式向用户服务发起调用,即:不走注册中心,不使用服务发现方式。

2.服务通信实战

2.1.搭建公共User模块

创建工程模块 springcloud-user-common ,效果如下:

springcloud-parent
  springcloud-eureka-server-1010
  springcloud-order-server-1030
  springcloud-user-common //公共User模块
  springcloud-user-server-1020

在springcloud-user-common中创建User对象如下:

packagecn.itsource.springboot.domain;
publicclassUser {
privateLongid;
privateStringusername;
privateStringdesc;
publicUser() {
    }
publicUser(Longid, Stringusername, Stringdesc) {
this.id=id;
this.username=username;
this.desc=desc;
    }
publicLonggetId() {
returnid;
    }
publicvoidsetId(Longid) {
this.id=id;
    }
publicStringgetUsername() {
returnusername;
    }
publicvoidsetUsername(Stringusername) {
this.username=username;
    }
publicStringgetDesc() {
returndesc;
    }
publicvoidsetDesc(Stringdesc) {
this.desc=desc;
    }
}

2.2.用户和订单依赖User模块

修改工程springcloud-order-server-1030 , springcloud-user-server-1020在他们的pom.xml都导入springcloud-user-common 模块

<dependency><groupId>cn.itsource.springboot</groupId><artifactId>springcloud-user-common</artifactId><version>1.0-SNAPSHOT</version></dependency>

2.3.用户服务返回User

修改 springcloud-user-server-1020 工程,编写controller,返回User对象

//用户服务:暴露接口给订单访问@RestControllerpublicclassUserController {
//订单服务来调用这个方法      http://localhost:1020/user/10// @GetMapping(value = "/user/{id}" )@RequestMapping(value="/user/{id}",method=RequestMethod.GET)
publicUsergetById(@PathVariable("id")Longid){
//根据id去数据库查询UserreturnnewUser(id,"zs:"+id,"我是zs");
    }
}

2.4.订单服务获取User

在订单服务中需要使用RestTemplate调用用户服务,我们需要把RestTmplate配置成Bean方便使用(当然也可以不创建Bean,用的时候直接new对象也可以) ,修改工程springcloud-order-server-1030在主配置类配置RestTemplate如下:

/*** 订单的启动类*/@SpringBootApplication@EnableEurekaClientpublicclassOrderServerApplication1030{
//配置一个RestTemplate ,Spring封装的一个机遇Restful风格的http客户端 工具@BeanpublicRestTemplaterestTemplate(){
returnnewRestTemplate();
    }
publicstaticvoidmain( String[] args )
    {
SpringApplication.run(OrderServerApplication1030.class);
    }
}

创建controller,通过RestTemplate调用用户服务,代码如下:

//订单服务@RestControllerpublicclassOrderController {
//需要配置成Bean@AutowiredprivateRestTemplaterestTemplate ;
//浏览器调用该方法@RequestMapping(value="/order/{id}",method=RequestMethod.GET)
publicUsergetById(@PathVariable("id")Longid){
//发送http请求调用 user的服务,获取user对象 : RestTemplate//目标资源路径:user的ip,user的端口,user的Controller路径Stringurl="http://localhost:1020/user/"+id;
//发送http请求returnrestTemplate.getForObject(url, User.class);
    }
}

这里的url是用户服务获取user资源的路径,通过RestTmplate发起Http调用,拿到User对象后返回给浏览器。

2.5.测试服务通信

依次启动Eureka Server注册中心(不启动也行) , 用户服务 ,订单服务 , 浏览器访问订单服务:http://localhost:1030/order/1 , 返回结果:

3.做个小结

虽然这里我们基于RestTemplate实现了订单服务和用户服务的通信,但是我们在请求用户服务的时候是使用ip地址和端口的方式,在之前的Eureka章节我们说到,Eureka的目的就是用来管理微服务的通信地址,服务之间可以使用服务名发起调用,很显然我们还咩有满足这一情况。在下一章节我们将使用Ribbon客户端负载均衡配合RestTmplate使用服务发现的方式时间服务的通信。

目录
相关文章
|
2月前
|
负载均衡 算法 Java
【SpringCloud(4)】OpenFeign客户端:OpenFeign服务绑定;调用服务接口;Feign和OpenFeign
Feign是一个WebService客户端。使用Feign能让编写WebService客户端更加简单。 它的使用方法是定义一个服务接口然后再上面添加注解。Feign也支持可拔插式的编码器和解码器。SpringCloud对Feign进行了封装,十七支持了SpringMVC标准注解和HttpMessageConverters。 Feign可用于Eureka和Ribbon组合使用以支持负载均衡
694 138
|
人工智能 Java Serverless
【MCP教程系列】搭建基于 Spring AI 的 SSE 模式 MCP 服务并自定义部署至阿里云百炼
本文详细介绍了如何基于Spring AI搭建支持SSE模式的MCP服务,并成功集成至阿里云百炼大模型平台。通过四个步骤实现从零到Agent的构建,包括项目创建、工具开发、服务测试与部署。文章还提供了具体代码示例和操作截图,帮助读者快速上手。最终,将自定义SSE MCP服务集成到百炼平台,完成智能体应用的创建与测试。适合希望了解SSE实时交互及大模型集成的开发者参考。
12642 60
|
4月前
|
监控 Java API
Spring Boot 3.2 结合 Spring Cloud 微服务架构实操指南 现代分布式应用系统构建实战教程
Spring Boot 3.2 + Spring Cloud 2023.0 微服务架构实践摘要 本文基于Spring Boot 3.2.5和Spring Cloud 2023.0.1最新稳定版本,演示现代微服务架构的构建过程。主要内容包括: 技术栈选择:采用Spring Cloud Netflix Eureka 4.1.0作为服务注册中心,Resilience4j 2.1.0替代Hystrix实现熔断机制,配合OpenFeign和Gateway等组件。 核心实操步骤: 搭建Eureka注册中心服务 构建商品
799 3
|
2月前
|
负载均衡 Java API
《深入理解Spring》Spring Cloud 构建分布式系统的微服务全家桶
Spring Cloud为微服务架构提供一站式解决方案,涵盖服务注册、配置管理、负载均衡、熔断限流等核心功能,助力开发者构建高可用、易扩展的分布式系统,并持续向云原生演进。
|
3月前
|
消息中间件 存储 Java
RabbitMQ 和 Spring Cloud Stream 实现异步通信
本文介绍了在微服务架构中,如何利用 RabbitMQ 作为消息代理,并结合 Spring Cloud Stream 实现高效的异步通信。内容涵盖异步通信的优势、RabbitMQ 的核心概念与特性、Spring Cloud Stream 的功能及其与 RabbitMQ 的集成方式。通过这种组合,开发者可以构建出具备高可用性、可扩展性和弹性的分布式系统,满足现代应用对快速响应和可靠消息传递的需求。
231 2
RabbitMQ 和 Spring Cloud Stream 实现异步通信
|
5月前
|
Prometheus 监控 Cloud Native
Docker 部署 Prometheus 和 Grafana 监控 Spring Boot 服务
Docker 部署 Prometheus 和 Grafana 监控 Spring Boot 服务实现步骤
569 0
|
9月前
|
人工智能 自然语言处理 Java
对话即服务:Spring Boot整合MCP让你的CRUD系统秒变AI助手
本文介绍了如何通过Model Context Protocol (MCP) 协议将传统Spring Boot服务改造为支持AI交互的智能系统。MCP作为“万能适配器”,让AI以统一方式与多种服务和数据源交互,降低开发复杂度。文章以图书管理服务为例,详细说明了引入依赖、配置MCP服务器、改造服务方法(注解方式或函数Bean方式)及接口测试的全流程。最终实现用户通过自然语言查询数据库的功能,展示了MCP在简化AI集成、提升系统易用性方面的价值。未来,“对话即服务”有望成为主流开发范式。
6620 7
|
9月前
|
负载均衡 Dubbo Java
Spring Cloud Alibaba与Spring Cloud区别和联系?
Spring Cloud Alibaba与Spring Cloud区别和联系?