Spring Cloud（Greenwich版）-01-服务生产者与服务消费者

ゝ一纸荒年。 2021-11-15 13:16 253阅读 0赞

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

#### 概念 ####

服务生产者：服务的被调用方（即：为其他服务提供服务的服务）
    服务消费者：服务的调用方（即：依赖其他服务的服务）

以微商城系统为例：用户发起购买商品请求，调用商品信息微服务是否满足购买条件，如果满足那就去查用户信息，如下图所示：  
![微商城系统][aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTM0Y2U5MDBmZWNkNmRlMDEuanBn]

**商品微服务**是服务消费者，**用户微服务**就是服务生产者。  
接下来以“微商城”系统为例，编写服务生产者和消费者。

#### 编写一个服务生产者 ####

##### 第一步：通过start.spring.io构建服务生产者项目 #####

打开地址：https://start.spring.io  
如下图所示，选择相应信息：  
![构建生产者服务][aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTBiNGViOWY2YzIzYmZkNjUuanBn]  
增加Dependencies模块支持：  
1、web  
2、jpa 访问持久层  
3、h2 内嵌数据库（可以做一些数据的展示）  
可以直接搜索添加即可，添加完成后点击**Generate the project**，将会生产代码的压缩包，解压导入idea开发工具即可。

##### 第二步：编写sql脚本 #####

由于用的是内嵌h2数据库，所以这里编写创建用户表的sql脚本和数据：  
schema.sql

drop table user if exists;
    create table user(
      id bigint generated by default as identity,
      user_name varchar(40),
      name varchar(20),
      age int(3),
      balance decimal(10,2),
      primary key(id)
    )

data.sql

insert into user(id,user_name,name,age,balance) values (1,'tangseng','唐僧',20,98.00);
    insert into user(id,user_name,name,age,balance) values (2,'wukong','齐天大圣',18,10000.00);
    insert into user(id,user_name,name,age,balance) values (3,'bajie','二师兄',25,898.00);
    insert into user(id,user_name,name,age,balance) values (4,'wujing','三师弟',35,998.00);

##### 第三步：application.ml配置文件 #####

server:
      port: 8080
    spring:
      spa:
        generate-ddl: false
        show-sql: true
        hibernate:
          ddl-auto: none
      datasource:
        platform: h2
        schema: classpath:schema.sql
        data: classpath:data.sql
    logging:
      level:
        root: INFO
        org.hibernate: INFO
        org.hibernate.type.descriptor.sql.BasicBinder: TRACE
        org.hibernate.type.descriptor.sql.BasicExtractor: TRACE
        com.itunion: DEBUG

##### 第三步：编写User实体类 #####

@Entity
    @JsonIgnoreProperties(value = { "hibernateLazyInitializer", "handler" })
    public class User {
        @Id
        @GeneratedValue(strategy = GenerationType.AUTO)
        private Long id;
        @Column
        private String userName;
        @Column
        private String name;
        @Column
        private int age;
        @Column
        private BigDecimal balance;
       ......省略get/set方法
    }

##### 第四步：编写UserRepository #####

@Repository
    public interface UserRepository extends JpaRepository<User,Long> {
    }

这里继承了JpaRepository。

##### 第五步：编写UserController #####

@RestController
    public class UserController {
        @Autowired
        private UserRepository userRepository;
        @GetMapping("/simple/{id}")
        public User findById(@PathVariable Long id){
            User user = this.userRepository.getOne(id);
            System.out.println(user.toString());
            return user;
        }
    }

##### 第六步：测试 #####

浏览器输入地址：[http://127.0.0.1:8080/simple/2][http_127.0.0.1_8080_simple_2]

{"id":2,"userName":"wukong","name":"齐天大圣","age":18,"balance":10000.00}

好了，到这里一个简单的微服务服务生产者已经编写完成。  
**备注：代码结构如下**  
![服务生产者代码结构][aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTY2Njk3Y2NjNmNjM2FhNjMuanBn]

#### 编写一个服务消费者 ####

##### 第一步：通过start.spring.io构建服务消费者项目 #####

和上面步骤一样，Artifact需要修改，如下图所示：  
![构建消费者服务][aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTVhODRmOTg2NDc4OGZkZjIuanBn]  
增加Dependencies模块支持：  
1、web  
只需要web就可以了，添加完成后点击Generate the project，将会生产代码的压缩包，解压导入idea开发工具。

##### 第二步：编写User实体类 #####

@JsonIgnoreProperties(value = { "hibernateLazyInitializer", "handler" })
    public class User {
        private Long id;
        private String userName;
        private String name;
        private int age;
        private BigDecimal balance;
        ......省略其他get/set方法
    }

这里只是做一个接收数据的映射，不需要jpa的注解。

##### 第三步：编写GoodsController #####

@RestController
    public class GoodsController {
        @Autowired
        private RestTemplate restTemplate;
        @GetMapping("/goods/{id}")
        public User findById(@PathVariable Long id){
            return this.restTemplate.getForObject("http://127.0.0.1:8080/simple/"+id,User.class);
        }
    }

根据传入的id通过restTemplate的方式去查询服务生产者获取用户信息。

##### 第四步：配置application.yml文件 #####

server:
      port: 8081

##### 第五步：启动测试 #####

服务生产者和消费者都需要启动。  
访问服务消费者地址：[http://127.0.0.1:8081/goods/2][http_127.0.0.1_8081_goods_2]  
报错信息：

Description:
    Field restTemplate in com.itunion.cloud.web.controller.GoodsController required a bean of type 'org.springframework.web.client.RestTemplate' that could not be found.
    The injection point has the following annotations:
    	- @org.springframework.beans.factory.annotation.Autowired(required=true)
    Action:
    Consider defining a bean of type 'org.springframework.web.client.RestTemplate' in your configuration.

错误原因：RestTemplate 未实例化，MicroserviceSimpleConsumerGoodsApplication增加RestTemplate实例化代码

@Bean
    	public RestTemplate restTemplate(){
    		return new RestTemplate();
    	};

再次启动并访问：[http://127.0.0.1:8081/goods/2][http_127.0.0.1_8081_goods_2]  
返回结果

{"id":2,"userName":"wukong","name":"齐天大圣","age":18,"balance":10000.00}

#### 总结 ####

简单的服务生产者和服务消费者已经实现了，用户在购买商品的时候调用**服务消费者的goods**接口，然后服务消费者通过RestTemplate调用**服务生产者simple**查询用户信息。  
文中为了快速实现生产者和消费者的关系，采取了一些硬编码的方式，在实际分布式架构中是不行的，不过没关系后面我们慢慢来使项目更加健壮。

#### 问题 ####

1、生产者和消费者应用如何进行监控？并且也没有画板，啥指标都没得。没办法监控系统压力、QPS、内存、CPU和日活的可视化面板，是不是很low？  
2、上面提到的硬编码问题，微服务地址和端口都是固定的，在实际项目场景中每次地址发生变更都需要去修改代码（如果用Docker容器化部署那就更酸爽了）。  
3、负载均衡怎么办？  
4、服务直接的容错机制如何处理？  
5、用户的认证和授权呢？  
6、应用发生故障，如何能够进行问题追踪快速定位？

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poZW5naGhneg_size_16_color_FFFFFF_t_70]: /images/20211115/0ab614e3e1af4a63a191cfe858237822.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTM0Y2U5MDBmZWNkNmRlMDEuanBn]: /images/20211115/f201a76da6684ee18670336e213c86f8.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTBiNGViOWY2YzIzYmZkNjUuanBn]: /images/20211115/c134b90bb2224cc5804a1d3d7a5da9ec.png
[http_127.0.0.1_8080_simple_2]: http://127.0.0.1:8080/simple/2
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTY2Njk3Y2NjNmNjM2FhNjMuanBn]: /images/20211115/7bccafb8071946909d41e69e8be3a995.png
[aHR0cHM6Ly91cGxvYWQtaW1hZ2VzLmppYW5zaHUuaW8vdXBsb2FkX2ltYWdlcy84MTIyNzcyLTVhODRmOTg2NDc4OGZkZjIuanBn]: /images/20211115/e42deea96d344784ad96d3aab1d0d394.png
[http_127.0.0.1_8081_goods_2]: http://127.0.0.1:8081/goods/2