当前位置: 首页 > article >正文

springcloud间通信的方式

在 Spring Cloud 中,主要有以下几种通信方式:

一、基于 HTTP 的 RESTful API
  1. 工作原理:

    • 这是一种常见的通信方式,各个微服务通过发送 HTTP 请求来相互调用。服务提供者暴露 RESTful API 接口,服务消费者通过 HTTP 客户端(如RestTemplateFeign等)发送请求。

    • 例如,一个订单服务需要查询商品信息,它可以通过 HTTP 请求调用商品服务提供的 API 接口。

  2. 优点:

    • 简单易用,基于广泛使用的 HTTP 协议,开发人员熟悉度高。

    • 与语言无关,不同语言实现的微服务可以方便地进行通信。

    • 可以利用 HTTP 的各种特性,如缓存、认证、授权等。

  3. 缺点:

    • 相对来说性能可能不如其他通信方式,因为 HTTP 协议有一定的开销。

    • 对于高性能、低延迟的场景可能不太适合。

二、基于 RPC(Remote Procedure Call)的通信
  1. 以 Dubbo 在 Spring Cloud 中的应用为例:

    • Dubbo 是一个高性能的 RPC 框架,可以与 Spring Cloud 集成。通过 Dubbo,服务提供者和服务消费者之间可以进行高效的远程方法调用。

    • 例如,使用 Dubbo 时,服务提供者将服务注册到注册中心,服务消费者从注册中心获取服务提供者的地址列表,然后通过 RPC 调用服务提供者的方法。

  2. 优点:

    • 性能高,通常比基于 HTTP 的通信方式更快。

    • 可以支持多种序列化方式,如 Hessian、JSON、Protobuf 等,满足不同场景的需求。

  3. 缺点:

    • 相对复杂,需要引入额外的框架和依赖。

    • 与特定的 RPC 框架绑定,可能会限制技术选型的灵活性。

三、消息队列(Message Queue)
  1. 工作原理:

    • 各个微服务通过发送和接收消息来进行通信。服务生产者将消息发送到消息队列,服务消费者从消息队列中获取消息并进行处理。

    • 例如,一个订单服务在订单创建成功后,将订单信息发送到消息队列,库存服务从消息队列中获取订单信息并进行库存扣减操作。

  2. 优点:

    • 解耦服务之间的直接依赖,提高系统的可扩展性和容错性。

    • 可以实现异步通信,提高系统的响应速度和吞吐量。

  3. 缺点:

    • 引入了额外的中间件,增加了系统的复杂性。

    • 需要处理消息的顺序性、重复消费等问题。

总之,Spring Cloud 中可以根据具体的业务需求和场景选择合适的通信方式。HTTP 的 RESTful API 简单易用,适合大多数场景;RPC 通信性能高,适合对性能要求较高的场景;消息队列适合解耦和异步通信的场景。

四、基于 HTTP 的 RESTful API的实现
一、主要有两种
  • RestTemplate 方式

  • Feign 的方式

二、RestTemplate 方式

RestTemplate 中也分为三种方式 简单来演示一下吧

  1. 第一种方式 直接使用 RestTemplate ,url 写死

    服务端编写

    /**

    • 用来测试与 order 服务的连接

    • @author ccyang

    • @date 2018/7/1 16:06 */ @RestController public class serverController { @GetMapping(“/getMsg”) public String getMsg(){ return “this is product’ msg”; } }

客户端编写

 /**
  * @author ccyang
  * @date 2018/7/1 16:13
  */
 @RestController
 @Slf4j
 public class clientController {
 ​
     @GetMapping("/getProductMsg")
     public String getProductMsg(){
 ​
         RestTemplate restTemplate = new RestTemplate();
         String response = restTemplate.getForObject("http://localhost:8080/getMsg",String.class);
         log.info("response = {}" , response);
         return response;
     }
 ​
 }
 ​

然后去访问 http://localhost:8080/getMsg 即可。

因为服务端的 api 被硬编码在客户端,因此有两个缺点: – 当注册中心有很多服务时,我们可能不知道我们需要的服务由谁提供、api是多少,因此就可能无法调用到服务。 –当某个服务部署了多个,例如 api 是: “localhost:9080/getMsg,localhost:9081/getMsg “,那么此时就需要负载均衡,这种硬编码显然不符合场景。

  1. 第二种方式: service端代码依旧,客户端通过 LoadBalancerClient 来获取应用名,进而获取地址和端口,在格式化拼接地址,从而调用 product服务。如下:

    /**

    • 测试获取 product服务的msg

    • @author ccyang

    • @date 2018/7/1 16:13 */ @RestController @Slf4j public class clientController {

      @Autowired private LoadBalancerClient loadBalancerClient;

      @GetMapping(“/getProductMsg”) public String getProductMsg(){

        RestTemplate restTemplate = new RestTemplate();
        ServiceInstance serviceInstance = loadBalancerClient.choose("PRODUCT");  // serviceId 为提供服务的应用名
        String url = String.format("http://%s:%s",serviceInstance.getHost(),serviceInstance.getPort() + "/getMsg");
        String response = restTemplate.getForObject( url, String.class);
        log.info("response = {}" , response);
        return response;
       123456

      } }

缺点是每次调用服务都要这样写,编码很麻烦。

  1. 第三种方式 通过 @LoadBalanced,可在restTemplate 直接使用应用名字。

    @Component public class RestTemplateConfig { @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }

    @RestController @Slf4j public class clientController {

     @Autowired
     private RestTemplate restTemplate;
     ​
     @GetMapping("/getProductMsg")
     public String getProductMsg(){
     ​
         String response = restTemplate.getForObject( "http://PRODUCT/getMsg", String.class);  // 通过应用名进行访问
         log.info("response = {}" , response);
         return response;
     }
     12345678910

    }

三、使用 Feign 的方式进行通信
  • 声明式 REST客户端(伪 RPC)

  • 采用了基于接口的注解

先看看如何使用 Feign: \1. 添加依赖

 <!-- add feign , note: must add version -->
     <dependency>
         <groupId>org.springframework.cloud</groupId >
         <artifactId>spring-cloud-starter-feign</artifactId>
         <version>1.4.4.RELEASE</version>
     </dependency>
 ​
 2. 添加注解到主类上
 ​
 ​
 @EnableFeignClients
 ​
 3. 定义要调用的接口
 ​
 ​
 @FeignClient(name = "product")  // 服务名
 public interface ProductClient {
 ​
     @GetMapping("/getMsg")  // 这里要和 Product服务提供的接口一致
     String productMsg();
 ​
 }
 ​
 ​
 4. 在该使用的地方使用注解中提供的方法
 ​
 ​
 @RestController
 @Slf4j
 public class clientController {
 ​
     @Autowired
     private ProductClient productClient;  // 有报错,不影响
     @GetMapping("/getProductMsg")
     public String getProductMsg(){
 ​
         String response = productClient.productMsg();
         log.info("response = {}" , response);
         return response;
     }
 }
 ​

Feign 可以看做是一个伪 RPC,而且HTTP远程调用对开发者完全透明。

RestTemplate 内部使用 Ribbon做负载均衡 Feign 内部也是使用的Ribbon做负载均衡

参考:springCloud 服务间的两种通信方式_springcloud项目之间是如何通信的-CSDN博客


http://www.kler.cn/a/297167.html

相关文章:

  • 非标金属零件加工的质量与效率是如何体现的?
  • Figma如何给设计的UI套样机
  • RK3562 NPU供电要求
  • wordpress做后台的资讯类小程序源码
  • Anaconda Prompt 安装paddle2.6报错
  • 线程池实现服务端
  • Linux Runtime PM(运行时电源管理)框架API
  • 97.游戏的启动与多开-共享内存多开检测
  • 九,自定义转换器详细操作(附+详细源码解析)
  • c语言--力扣简单题目(移除链表元素)讲解
  • UE4_后期处理_后期处理材质及后期处理体积一
  • 从Milvus迁移DashVector
  • 久久派安装启用USB摄像头(基于mjpg-streamer)
  • TCP 拥塞控制
  • 本地服务器部署Text generation并添加code llama实现远程多人协作
  • C#复习之内部类和分布类
  • 2024年CCPC网络赛A题题解 —— 军训Ⅰ(gym105336A)
  • 无人机之报警器的工作原理
  • CH9114 USB转四串口替换FT4232H系列芯片
  • 基于Flink的流式计算可视化开发实践之配置->任务生成->任务部署过程