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

灰太狼 2022-09-06 14:25 145阅读 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 条评论，145人围观）

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

相关阅读

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

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

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

相关 Goroutine之间如何通信？

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

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

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

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

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

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

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

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

相关多线程之间是如何通信的

一.多线程之间通信场景 1.有两个线程，线程1和线程2； 2.线程1向一个集合里面依次添加元素"abc"字符串，一共添加十次，当添加到第五次的时候，希望线程2能够收到线

忘是亡心i/ 2023年10月04日 23:32/ 0 赞/ 50 阅读

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

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

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

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

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

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

相关 JAVA线程之间如何通信

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

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

相关微服务之间的通信

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

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

相关进程之间的通信

进程之间的通信: 进程是指运行中的程序，进程的任务就是执行程序中的代码，如下面程序EchoPlayer类是一个独立的java程序，他可以在任意一条安装了JDK的主机上

青旅半醒/ 2021年09月15日 08:00/ 0 赞/ 516 阅读