如何解决服务之间的通信问题？

灰太狼 2022-09-06 14:25 169阅读 0赞

### 文章目录 ###

*  1、如何解决服务之间的通信问题？
 *  2、如何在java代码中发起http方式请求？
 *  3、实现服务间通信的小案例
 *   *  3.1 使用两个测试服务 用户服务users和订单服务orders
     *  3.2 用户服务和订单服务都是两个独立的SpringBoot应用
     *  3.3 两个服务都引入consul client依赖和健康检查依赖
     *  3.4 配置两个服务的application.properties
     *  3.5 在两个服务的入口类中加入服务注册client注解
     *  3.6 控制器开发(这里进行服务提供者和服务消费者开发)
     *   *  3.6.1 服务提供者(订单服务)
         *  3.6.2 服务消费者(用户服务)
     *  3.7 测试服务调用
 *  4、现有RestTemplate方式通信存在的问题？
 *  5、解决RestTemplate负载均衡问题

# 1、如何解决服务之间的通信问题？ #

\[1\]**HTTP REST方式** 使用http协议进行数据传递 json格式数据  
\[2\]**RPC方式** 远程过程调用 二进制数据  
从**OSI七层结构**来讲，即**物理层、数据链路层、网络层、运输层、会话层、表示层、应用层**。**http属于应用层协议，而RPC属于传输层，所以RPC方式的传输效率比http高**。**SpringCloud使用的是HTTP协议传递数据**。

# 2、如何在java代码中发起http方式请求？ #

spring框架提供HttpClient对象 使用RestTemplate发起一个http请求。

# 3、实现服务间通信的小案例 #

## 3.1 使用两个测试服务 用户服务users和订单服务orders ##

## 3.2 用户服务和订单服务都是两个独立的SpringBoot应用 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70]

## 3.3 两个服务都引入consul client依赖和健康检查依赖 ##

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</artifactId>
            </dependency>

## 3.4 配置两个服务的application.properties ##

用户服务：（默认的服务名称就是Spring.application.name,所以可以不用指定）

server.port=8888
    spring.application.name=USERS
    
    #consul server
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 1]  
订单服务：

server.port=9999
    spring.application.name=ORDERS
    
    #consul server
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 2]

## 3.5 在两个服务的入口类中加入服务注册client注解 ##

用户服务  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 3]  
订单服务  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 4]

## 3.6 控制器开发(这里进行服务提供者和服务消费者开发) ##

### 3.6.1 服务提供者(订单服务) ###

OrderController.java

package com.baizhi.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @Slf4j
    public class OrderController { 
    
        @GetMapping("order")
        public String demo(){ 
           log.info("order demo...");
            return "order demo OK!!!";
        }
    }

### 3.6.2 服务消费者(用户服务) ###

UserController.java

package com.baizhi.controller;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    @Slf4j
    public class UserController { 
    
        @GetMapping("user")
        public String invokeDemo(){ 
             log.info("user demo...");
            //1、调用订单服务 服务地址：http://localhost:9999/order 必须是get方式 接收返回值String
            RestTemplate restTemplate = new RestTemplate();
            String orderResult = restTemplate.getForObject("http://localhost:9999/order", String.class);
    
            log.info("调用订单服务成功:{}",orderResult);
    
            return "调用order服务成功，结果为:"+orderResult;
        }
    }

## 3.7 测试服务调用 ##

在服务启动之后查看consul服务注册中心，可以看到用户服务和订单服务都注册成功了。关于consul服务注册与发现请看这篇文章：[https://blog.csdn.net/qq\_43753724/article/details/119820664?spm=1001.2014.3001.5501][https_blog.csdn.net_qq_43753724_article_details_119820664_spm_1001.2014.3001.5501]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 5]  
访问`http://localhost:9999/order`测试订单服务：  
![在这里插入图片描述][a500055938574fb3b6c631e056f78643.png]  
访问用户服务(用户服务中会调用订单服务)  
![在这里插入图片描述][c843b9fce6c747c59f4700187aba78b8.png]  
订单服务日志：(这里的第二次输出是因为被用户服务调用)  
![在这里插入图片描述][f739725373ea4384bc2ddadd4c83b64d.png]

用户服务日志：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 6]

# 4、现有RestTemplate方式通信存在的问题？ #

*  调用服务的路径主机和服务端口直接写死在url中无法实现服务集群时请求负载均衡
 *  调用服务的请求路径写死在代码中，日后提供服务路径发生变化时不利于后续维护工作。

# 5、解决RestTemplate负载均衡问题 #

*  自定义负载均衡解决策略，但是这样无法实现服务健康检查切负载均衡策略过于单一
 *  使用SpringCloud提供的组件 推荐使用Ribbon来解决负载均衡的调用问题

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 7]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70]: /images/20220829/d26a50746092426bab9c8a3afdb0c22a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 1]: /images/20220829/106b31390f94405fad4ef89cd22a7c34.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 2]: /images/20220829/e57828fb8c7a4053b94d1644a2b95e83.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 3]: /images/20220829/654fc6290d1c4974a8a82c11c6ae2884.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 4]: /images/20220829/7494480cc3444c539d2bb2ce459aeea2.png
[https_blog.csdn.net_qq_43753724_article_details_119820664_spm_1001.2014.3001.5501]: https://blog.csdn.net/qq_43753724/article/details/119820664?spm=1001.2014.3001.5501
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 5]: /images/20220829/baad3ded60084c9aa7d6f497e8133d89.png
[a500055938574fb3b6c631e056f78643.png]: /images/20220829/16cc2ddbfc654e8b84f82816a8bdbcc3.png
[c843b9fce6c747c59f4700187aba78b8.png]: /images/20220829/b4280b6acaa648bc8f56a6a78d8e5ba0.png
[f739725373ea4384bc2ddadd4c83b64d.png]: /images/20220829/0976d4c164e14798b276613e6797fcb6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 6]: /images/20220829/72d0c4f63e6940c5be2ac870abb01bc9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNzUzNzI0_size_16_color_FFFFFF_t_70 7]: /images/20220829/7619092f94894f75a45902de9beb2241.png

发表评论取消回复

表情：

评论列表（有 0 条评论，169人围观）

还没有评论，来说两句吧...

相关阅读

相关在大型分布式系统中，如何解决Java服务间的通信问题

在大型分布式系统中，Java服务间通常采用以下几种方式进行通信： 1. **TCP/IP**：最常用的通信方式，基于IP协议进行数据传输。例如，使用Socket API实现客

刺骨的言语ヽ痛彻心扉/ 2024年09月05日 17:03/ 0 赞/ 68 阅读

相关在大型分布式系统中，如何解决Java服务间的通信问题

在大型分布式系统中，Java服务间通常采用以下几种方式进行通信： 1. **TCP/IP**：最常用的通信方式，基于IP协议进行数据传输。例如，使用Socket API实现客

拼搏现实的明天。/ 2024年09月05日 17:03/ 0 赞/ 67 阅读

相关 Goroutine之间如何通信？

goroutine通信机制在Go语言中，goroutine之间通过通道（channel）进行通信。通道是一种特殊的数据结构，用于在不同的goroutine之间传递数据和

布满荆棘的人生/ 2023年10月12日 13:06/ 0 赞/ 42 阅读

相关微服务之间的数据依赖问题，该如何解决？

微服务，顾名思义，就是将我们程序拆分为最小化单元来提供服务。在一体化系统中，各个微服务也是不可能独立存在的，那么微服务之间涉及到的数据依赖问题，应该怎么处理呢？我们从场景入手来

ゝ一世哀愁。/ 2023年10月10日 22:08/ 0 赞/ 24 阅读

相关 Dubbo 在服务消费者和服务提供者之间如何建立通信

Dubbo 在服务消费者和服务提供者之间如何建立通信当服务消费者（Consumer）调用服务提供者（Provider）的服务时，Dubbo 底层主要通过以下几个步骤来找

分手后的思念是犯贱/ 2023年10月10日 17:13/ 0 赞/ 85 阅读

相关 Vue之组件之间如何通信

Vue之组件之间如何通信以下包括父子组件之间的通信和兄弟组件之间的通信父子组件之间的数据传递：父组件通过属性传递给子组件，子组件通过事件触发的方式去传递给父组

Dear 丶/ 2023年07月07日 05:52/ 0 赞/ 49 阅读

相关如何解决服务之间的通信问题？

文章目录 1、如何解决服务之间的通信问题？ 2、如何在java代码中发起http方式请求？ 3、实现服务间通信的小案例 3.1 使用两个测试

灰太狼/ 2022年09月06日 14:25/ 0 赞/ 170 阅读

相关 SpringCloud(三)微服务之间的通信Restful

目录一.RestTemplateto通信 1.第一种调用方式 2.第二种调用方式 3.第三种调用方式(使用server\_id) 二.Feign 1.介绍

叁歲伎倆/ 2022年01月31日 03:17/ 0 赞/ 344 阅读

相关 JAVA线程之间如何通信

两种： 1.共享内存（共享内存模型：线程之间共享程序的公共状态，线程之间通过写-读内存中的公共状态来隐式进行通信，例如可以使用volatile 修饰变量） 2.消息

朱雀/ 2021年09月24日 13:58/ 0 赞/ 402 阅读

相关微服务之间的通信

在monolithic单体应用程序中，不同的组件之间通过编程语言级别的方法或函数调用相互调用。相反，基于微服务的应用程序是在多台计算机上运行的分布式系统。每个服务实例通常是

系统管理员/ 2021年09月21日 05:54/ 0 赞/ 495 阅读