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

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

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

相关阅读

相关如何解决微服务架构中的雪崩问题？

记得在三年前公司因为业务发展需要，就曾经将单体应用迁移到分布式框架上来。当时就遇到了这样一个问题：系统仅有一个控制单元，它会调用多个运算单元，如果某个运算单元（作为服

水深无声/ 2023年07月02日 08:28/ 0 赞/ 37 阅读

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

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

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

相关 Fragment之间的通信

在本节中，你会学到 1、定义接口 2、实现接口 3、将消息传递给fragment 为了重用Fragment UI 组件，在设计中你应该通过定义每一个fragemnt自己

淡淡的烟草味﹌/ 2022年08月11日 16:38/ 0 赞/ 136 阅读

相关 Fragment之间的通信

在本节中，你会学到 1、定义接口 2、实现接口 3、将消息传递给fragment 为了重用Fragment UI组件，在设计中你应该通过定义每一个fragemnt自己的

喜欢ヅ旅行/ 2022年08月09日 09:24/ 0 赞/ 168 阅读

相关 activity和service之间如何进行通信？

Android的最重要的组件就是Service和Acitivity，那么在使用过程中，我们最常遇到的问题是他们之间的通信问题。首先Activity调用Service 这

系统管理员/ 2022年07月12日 02:42/ 0 赞/ 200 阅读

相关 Java并发编程---线程之间的通信问题

一.线程之间的通信 1.概念线程是操作系统中独立的个体,但这些如果不经过特殊的处理就不能成为一个整体,线程间的通信就成为整体的必用方式之一.当线程存在通信指挥,系统间

曾经终败给现在/ 2022年06月03日 10:59/ 0 赞/ 167 阅读

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

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

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

相关 JAVA线程之间如何通信

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

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

相关微服务之间的通信

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

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

相关进程之间的通信

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

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