04.服务间的通信方式之RestTemplate

逃离我推掉我的手 2022-10-17 04:23 166阅读 0赞

### 服务间的通信方式之RestTemplate ###

*   *  前言
     *  服务间的通信方式
     *  HTTP Rest方式实现服务间通信
     *   *  准备工作
         *  USER
         *   *  1.新建module
             *  2.pom.xml
             *  3.application.properties
             *  4.UserApplication
             *  5.UserController
         *  ORDER
         *   *  1.新建module
             *  2.pom.xml
             *  3.application.properties
             *  4.OrderApplication
             *  5.OrderController
         *  启动consul
         *  启动服务
         *  测试

## 前言 ##

前面我们说了**微服务**是基于单体应用围绕业务进行的服务拆分，拆分出来的每个服务都是一个独立的应用（独立部署、运行、独自的进程）。这些独立的应用之间相互调用的过程就是我们本节学习的重点–**微服务间的通信**

## 服务间的通信方式 ##

总的来说，目前有两种方式可以实现服务间的通信

*  **HTTP Rest**：使用http协议传输JSON格式的数据，它是基于OSI七层参考模型中的应用层进行通信的，效率较之于RPC要低。springcloud中使用的是spring提供的**RestTemplate**
 *  **RPC**(远程过程调用)：使用RPC协议传输对象序列化后的二进制数据，它是基于OSI七层参考模型中的传输层进行通信的，效率较之于HTTP Rest要高。代表是阿里的**dubbo**

下面我们主要学习使用**HTTP Rest**的方式来进行服务间的通信

## HTTP Rest方式实现服务间通信 ##

### 准备工作 ###

我们上面说了，springcloud使用的是spring提供的**RestTemplate**来实现服务间的通信的。所以我们这里需要准备两个服务**USER**和**ORDER**，这两个服务不做具体业务逻辑，只负责演示服务间的通信。开发完这两个服务后将其注册到我们的**consul**中进行演示。

### USER ###

#### 1.新建module ####

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

#### 2.pom.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>03.springcloud_httprest_users</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <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>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
        </dependencies>
    </project>

#### 3.application.properties ####

server.port=8881
    spring.application.name=CONSUL-USER
    # 注册consul服务的主机
    spring.cloud.consul.host=localhost
    # 注册consul服务的端口号
    spring.cloud.consul.port=8500

#### 4.UserApplication ####

package com.christy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /** * @Author Christy * @Date 2021/6/1 17:02 **/
    @SpringBootApplication
    @EnableDiscoveryClient
    public class UserApplication { 
        public static void main(String[] args){ 
            SpringApplication.run(UserApplication.class, args);
        }
    }

#### 5.UserController ####

package com.christy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    /** * @Author Christy * @Date 2021/6/1 17:04 **/
    @RestController
    @RequestMapping("/user")
    public class UserController { 
    
        @GetMapping("/orders")
        public String getUserOrders() { 
            System.out.println("开始获取用户的所有运单");
    
            // 调用订单服务的接口
            RestTemplate restTemplate = new RestTemplate();
            String result = restTemplate.getForObject("http://localhost:8882/order/all", String.class);
            System.out.println("获取用户所有的运单成功，结果是：" + result);
            return "获取用户所有的运单成功!!!";
        }
    }

### ORDER ###

#### 1.新建module ####

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

#### 2.pom.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>03.springcloud_httprest_orders</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <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>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
        </dependencies>
    
    </project>

#### 3.application.properties ####

server.port=8882
    spring.application.name=CONSUL-ORDER
    # 注册consul服务的主机
    spring.cloud.consul.host=localhost
    # 注册consul服务的端口号
    spring.cloud.consul.port=8500

#### 4.OrderApplication ####

package com.christy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /** * @Author Christy * @Date 2021/6/1 17:22 **/
    @SpringBootApplication
    @EnableDiscoveryClient
    public class OrderApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(OrderApplication.class, args);
        }
    }

#### 5.OrderController ####

package com.christy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /** * @Author Christy * @Date 2021/6/1 17:29 **/
    @RestController
    @RequestMapping("/order")
    public class OrderController { 
    
        @GetMapping("/all")
        public String all(){ 
            System.out.println("开始获取所有订单");
    
            return "所有运单获取成功！！！";
        }
    }

### 启动consul ###

上述工作准备完毕后，我们在命令行输入`consul agent -dev`启动我们的服务注册中心consul，然后浏览器输入`http://localhost:8500`，如下图

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

### 启动服务 ###

consul启动成功后我们依次启动上面的两个服务**USER**和**ORDER**

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

服务启动后我们在回到consul的管理界面，此时可以发现我们的两个服务都已经注册成功了

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

### 测试 ###

我们上面是在User中调用了Order中的服务，所以我们在浏览器直接输入UserController中获取订单的方法`http://localhost:8882/user/order`，如下图

![在这里插入图片描述][20210601174351571.png]  
我们回到IDEA，可以看到user服务和order服务中都输出了相应的信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70]: /images/20221014/0b4fbcef69ad4b7a81ffc4d8e0bda06d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 1]: /images/20221014/5be602564bae4f1ca8e8a646514f825c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center]: /images/20221014/1d607397d42842448479d22d1ca589bc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 2]: /images/20221014/2591bdf3fc264d1cbaff96ea7a4127f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 3]: /images/20221014/a458990d23934b5591c8e3b5271c04f6.png
[20210601174351571.png]: /images/20221014/4dd248d9c9fd4dbf84c2d4ec6804c7db.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]: /images/20221014/6e81a58bda854fae9c918340a8762145.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]: /images/20221014/9aff176e38a84c049a28e1791a4e1815.png