微服务Spring Cloud | 2.1 创建一个服务提供者和消费者

叁歲伎倆 2022-05-27 13:54 183阅读 0赞

## 微服务Spring Cloud | 2.1 创建一个服务提供者和消费者 ##

## 一、 概念 ##

服务提供者：是指服务的被调用方（即：为其它服务提供服务的服务）
       服务消费者：是指服务的调用方（即：依赖其它服务的服务）

## 二、 业务场景 ##

1 查询者A需要根据id查询User的信息，调用consumer的查询服务；  
2 consumer程序调用microservier（服务提供者）的查询接口进行查询；  
3 consumer将查询结果反馈给查询者A；  
业务场景如图：  
![这里写图片描述][70]

## 三、 服务提供者 ##

首先，我们需要访问[http://start.spring.io][http_start.spring.io]，并在页面内添加项目信息，即可生成一个maven项目。如下图：  
![这里写图片描述][70 1]  
将生成的压缩包解压并以maven项目的形式导入eclipse中。（我用的是eclipse，也可以导入到ide中）  
下面开始做服务接口：根据id，查询user信息。（比较简单，我给出调用关系），如图：  
![\*\*这里写图片描述\*\*][70 2]

项目需要添加的部分如下：  
![这里写图片描述][70 3]  
开始码代码了：  
（1） User类：注意点是理解一个其中的注解

package com.aerotop.cloud.entity;
    
    import java.math.BigDecimal;
    
    import javax.persistence.Column;
    import javax.persistence.Entity;
    import javax.persistence.GeneratedValue;
    import javax.persistence.GenerationType;
    import javax.persistence.Id;
    
    @Entity
    public class User { 
      @Id
      @GeneratedValue(strategy = GenerationType.AUTO)
      private Long id;
    
      @Column
      private String username;
    
      @Column
      private String name;
    
      @Column
      private Short age;
    
      @Column
      private BigDecimal balance;
    
      public Long getId() {
        return this.id;
      }
    
      public void setId(Long id) {
        this.id = id;
      }
    
      public String getUsername() {
        return this.username;
      }
    
      public void setUsername(String username) {
        this.username = username;
      }
    
      public String getName() {
        return this.name;
      }
    
      public void setName(String name) {
        this.name = name;
      }
    
      public Short getAge() {
        return this.age;
      }
    
      public void setAge(Short age) {
        this.age = age;
      }
    
      public BigDecimal getBalance() {
        return this.balance;
      }
    
      public void setBalance(BigDecimal balance) {
        this.balance = balance;
      }
    }

（2） UserRepository类：需要继承JpaRepository类，（这个是知识点：JpaRepository支持接口规范方法名查询）

package com.aerotop.cloud.repository;
    
    import org.springframework.data.jpa.repository.JpaRepository;
    import org.springframework.stereotype.Repository;
    
    import com.aerotop.cloud.entity.User;
    
    @Repository
    public interface UserRepository extends JpaRepository<User, Long> {
    
    }

（3） UserController类：在findById方法中的调用方式为springboot的新版本调用方式，记住即可。

package com.aerotop.cloud.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.domain.Example;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.aerotop.cloud.entity.User;
    import com.aerotop.cloud.repository.UserRepository;
    
    @RestController
    public class UserController {
    
        @Autowired
        private UserRepository userRepository;
    
        @GetMapping("/simple/{id}")
        public User findById(@PathVariable Long id) {
            User user = new User();
            user.setId(id);
            Example<User> userExample = Example.of(user);
            return userRepository.findOne(userExample).orElse(null); 
        }
    }

（4） Application文件：首先将此文件后缀改为yml格式，原因是这种文件格式支持结构化的书写，会很直观。

server:
      port: 7900
    spring:
      jpa:
        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.itmuch: DEBUG

（5） Sql文件：  
schema.sql

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

data.sql

insert into user(id,username,name,age,balance) values(1,'user1','张三',20,100.00);
    insert into user(id,username,name,age,balance) values(2,'user2','李三',20,100.00);
    insert into user(id,username,name,age,balance) values(3,'user3','王三',20,100.00);
    insert into user(id,username,name,age,balance) values(4,'user4','赵三',20,100.00);

好了，项目已经创建完成。启动项目工程后，在页面访问接口地址，如果能查询出结果则说明项目成功。  
![这里写图片描述][70 4]

## 四、 服务消费者 ##

首先，我们需要访问[http://start.spring.io][http_start.spring.io]，并在页面内添加项目信息，即可生成一个maven项目。如下图：  
![这里写图片描述][70 5]  
将生成的压缩包解压并以maven项目的形式导入eclipse中。  
下面开始做服务接口：根据id，查询user信息。（比较简单，我给出调用关系），如图：

项目需要添加的部分如下：  
![这里写图片描述][70 6]

给出代码：  
（1） Moviecontroller

package com.aerotop.cloud.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.itmuch.cloud.entity.User;
    
    @RestController
    public class MovieController {
    
        @Autowired
        private RestTemplate restTemplate;
    
        @Value("${user.userServicePath}")
        private String userServicePath;
    
        @GetMapping("/movie/{id}")
        public User findById(@PathVariable Long id) {
            return this.restTemplate.getForObject(this.userServicePath + id, User.class);
        }
    }

（2） User：只用来接收，所以把注释去掉

package com.itmuch.cloud.entity;
    
    import java.math.BigDecimal;
    
    public class User { 
      private Long id;
    
      private String username;
    
      private String name;
    
      private Short age;
    
      private BigDecimal balance;
    
      public Long getId() {
        return this.id;
      }
    
      public void setId(Long id) {
        this.id = id;
      }
    
      public String getUsername() {
        return this.username;
      }
    
      public void setUsername(String username) {
        this.username = username;
      }
    
      public String getName() {
        return this.name;
      }
    
      public void setName(String name) {
        this.name = name;
      }
    
      public Short getAge() {
        return this.age;
      }
    
      public void setAge(Short age) {
        this.age = age;
      }
    
      public BigDecimal getBalance() {
        return this.balance;
      }
    
      public void setBalance(BigDecimal balance) {
        this.balance = balance;
      }
    
    }

（3） MicroserviceConsumerMovieApplication：需要注入RestTemplate类；

package com.aerotop.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    public class MicroserviceConsumerMovieApplication { 
    
        @Bean
        public RestTemplate restTemplate() {
            return new RestTemplate();
        }
    
        public static void main(String[] args) {
            SpringApplication.run(MicroserviceConsumerMovieApplication.class, args);
        }
    }

（4） Application文件

server:
      port: 7901
    user: 
      userServicePath: http://localhost:7900/simple/

启动项目，如果在页面调用地址可以看到如下则说明成功。  
![这里写图片描述][70 7]  
至此，则服务提供者和消费者项目创建完成。并且服务消费者可以调用到服务提供者提供的接口；  
项目源码下载地址：

> [https://download.csdn.net/download/mengmengdastyle/10361669][https_download.csdn.net_download_mengmengdastyle_10361669]

## 五、 问题来了 ##

这样我们虽然创建了一个简单服务提供者和消费者。但是存在一些问题：  
1. 服务提供者的IP及端口应该是可以随时变动的。  
2. 服务的注册机制还是没有满足。

[70]: /images/20220527/888a9ae14907440e8c601cd1d7f78307.png
[http_start.spring.io]: http://start.spring.io
[70 1]: /images/20220527/bb69484533a449cdb84b2786b4001a52.png
[70 2]: /images/20220527/8e4913aba98b45b593c37e8a53b8d366.png
[70 3]: /images/20220527/69e6ab95156d455483ff60c577d40d72.png
[70 4]: /images/20220527/2cc746b6fd934d69a4d3a14f7117cae7.png
[70 5]: /images/20220527/d5f2f42c19e04965b7060fd664e76509.png
[70 6]: /images/20220527/d71c052ca3844be286fe39859715419e.png
[70 7]: /images/20220527/c25f626fdba24d5184364ff6099b0e8e.png
[https_download.csdn.net_download_mengmengdastyle_10361669]: https://download.csdn.net/download/mengmengdastyle/10361669