在微服務中最基本最基本的兩個角色是服務提供者與服務消費者。

之前所有程式碼都在同一個框架的時候，比如Controller呼叫Service的，直接注入Service bean即可進行呼叫了。現在做成微服務之後，那麼我們就需要有一個工程專門提供相應的服務功能，對應的有相應的工程消費這個功能，這就是服務提供者和服務消費者最基本的概念。

目錄大綱：

（1）服務提供者與服務消費者概念
（2）編碼思路
（3）服務提供者編碼
（4）服務消費者編碼
（5）存在問題

接下來看下具體的內容：

（1）服務提供者與服務消費者概念

服務提供者：服務的被呼叫方（即，為其他服務提供服務的服務）；

服務消費者：服務的呼叫方（即，依賴其他服務的服務）；

（2）編碼思路

這裡我們使用最基本的方式實現服務提供者和服務消費者。

（1）兩個專案，一個服務提供者，一個是服務消費者；

（2）服務提供者從記憶體資料庫H2中查詢資料,Controller進行呼叫獲取；

（3）服務消費者呼叫服務提供者的Controller進行獲取資料，然後返回給瀏覽器。

（3）服務提供者編碼

新建工程

新建一個提供使用者資訊的工程，取名為：microservie-provider-user

在pom.xml新增依賴包

Xml程式碼 

<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">  
    <modelVersion>4.0.0</modelVersion>  
   
    <groupId>com.kfit</groupId>  
    <artifactId>ms-provider-user</artifactId>  
    <version>0.0.1-SNAPSHOT</version>  
    <packaging>jar</packaging>  
   
    <name>ms-provider-user</name>  
    <url>http://maven.apache.org</url>  
   
    <!-- spring boot parent節點，引入這個之後，在下面和spring boot相關的就不需要引入版本了; -->  
    <parent>  
       <groupId>org.springframework.boot</groupId>  
       <artifactId>spring-boot-starter-parent</artifactId>  
       <version>1.4.1.RELEASE</version>  
    </parent>  
   
    <properties>  
       <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
    </properties>  
   
    <dependencies>  
       <!-- web支援: 1、web mvc; 2、restful; 3、jackjson支援; 4、aop ........ -->  
       <dependency>  
           <groupId>org.springframework.boot</groupId>  
           <artifactId>spring-boot-starter-web</artifactId>  
       </dependency>  
   
       <!-- 記憶體資料庫h2 -->  
       <dependency>  
           <groupId>com.h2database</groupId>  
           <artifactId>h2</artifactId>  
           <scope>runtime</scope>  
       </dependency>  
   
       <!-- spring data jpa -->  
       <dependency>  
           <groupId>org.springframework.boot</groupId>  
           <artifactId>spring-boot-starter-data-jpa</artifactId>  
       </dependency>  
    </dependencies>  
</project>

在src/main/resources下新建schema.sql新增建表語句

建立了一張User表：

Sql程式碼  

drop table user if exists;  
create table user(  
    id bigint generated bydefaultas identity,  
    username varchar(40),  
    name varchar(20),  
    age int(3),  
    balance decimal(10,2),  
    primarykey(id)  
);

在src/main/resources/新建data.sql插入資料

在User表插入幾條資料進行測試：

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);

建立實體類User

Java程式碼  

@JsonIgnoreProperties({"hibernateLazyInitializer", "handler"})  
@Entity  
public class User implements Serializable{  
    private static final long serialVersionUID = 1L;  
    @[email protected]  
    private long id; //主鍵.  
    private String username;//使用者名稱.  
    private String name; //姓名  
    private int age; //年齡.  
    private BigDecimal balance;//餘額.  
     
}

為什麼要加@JsonIgnoreProperties呢？

問題在於，使用load方法，您只需要一個代理，而不是真正的物件。代理物件沒有已經載入的屬性，所以當序列化發生時，沒有要序列化的屬性。使用get方法，您實際上可以獲得真正的物件，這個物件實際上可以被序列化。

建立Dao類UserRepository

Java程式碼  

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

建立Service類UserService

Java程式碼

@Service  
public class UserService {  
     
    @Autowired  
    private UserRepository userRepository;  
     
    public User getById(longid){  
       return userRepository.getOne(id);  
    }  
}

建立Controller類UserController

Java程式碼  

@RestController  
public class UserController {  
    @Autowired  
    private UserService userService;  
     
    @GetMapping("/user/{id}")  
    public User getById(@PathVariablelongid){  
       User user = userService.getById(id);  
       System.out.println(user);  
       return user;  
    }  
}

在src/main/resources新建application.properties

主要是配置埠號和jpa配置：

Properties程式碼  

server.port=7900  
   
spring.jpa.generate-ddl=false  
spring.jpa.show-sql=true  
spring.jpa.hibernate.ddl-auto=none  
spring.datasource.platform=h2  
spring.datasource.schema=classpath:schema.sql  
spring.datasource.data=classpath:data.sql  
   
logging.level.root=INFO  
logging.level.org.hibernate=INFO

編寫啟動類

Java程式碼  

@SpringBootApplication  
public class App {  
    public staticv oid main(String[] args) {  
       SpringApplication.run(App.class, args);  
    }  
}

啟動App測試

{"id":1,"username":"user1","name":"張三","age":20,"balance":100.00}

到此服務提供者就編寫完畢了，這個程式碼沒有什麼特別之處，和我們常規程式碼編寫是一樣的！。

（4）服務消費者編碼

新建工程

新建一個服務消費者專案，取名為：microservice-consumer-movice

在pom.xml新增依賴包

Xml程式碼  

<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">  
  <modelVersion>4.0.0</modelVersion>  
   
  <groupId>com.kfit</groupId>  
  <artifactId>ms-consumer-movice</artifactId>  
  <version>0.0.1-SNAPSHOT</version>  
  <packaging>jar</packaging>  
   
  <name>ms-consumer-movice</name>  
  <url>http://maven.apache.org</url>  
   
    <!-- spring boot parent節點，引入這個之後，在下面和spring boot相關的就不需要引入版本了; -->  
    <parent>  
       <groupId>org.springframework.boot</groupId>  
       <artifactId>spring-boot-starter-parent</artifactId>  
       <version>1.5.8.RELEASE</version>  
    </parent>  
   
   
  <properties>  
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
  </properties>  
   
  <dependencies>  
     <!-- web支援: 1、web mvc; 2、restful; 3、jackjson支援; 4、aop ........ -->  
    <dependency>  
       <groupId>org.springframework.boot</groupId>  
       <artifactId>spring-boot-starter-web</artifactId>  
    </dependency>  
  </dependencies>  
</project>

新建實體類User

Java程式碼  

public class User implements Serializable{  
    private static final longserialVersionUID = 1L;  
    private long id; //主鍵.  
    private String username;//使用者名稱.  
    private String name; //姓名  
    private int age; //年齡.  
    private BigDecimal balance;//餘額.  
     
}

新建Controller類MoviceController

Java程式碼  

@RestController  
public class MoviceController {  
     
    @Autowired  
    private RestTemplate restTemplate;  
     
    @GetMapping("/user/{id}")  
    public User getById(longid){  
       String url = "http://127.0.0.1:7900/user/"+id;  
       return restTemplate.getForObject(url, User.class);  
    }  
}

在src/main/resources新建application.properties

這裡只配置了埠號:

server.port=7901

新建啟動類App.java

Java程式碼  

@SpringBootApplication  
public class App {  
     
    @Bean  
    public RestTemplate restTemplate(){  
       returnnew RestTemplate();  
    }  
     
    publicstaticvoid main(String[] args) {  
       SpringApplication.run(App.class, args);  
    }  
}

這裡將RestTemplate進行初始化，交給Spring進行管理。

啟動測試

{"id":2,"username":"user2","name":"李四","age":20,"balance":100.00}

（5）存在問題

 該例子簡單易理解，但是存在很多的問題，比如：

（1）請求地址（http://127.0.0.1:7900/user/）硬編碼了；

（2）當有多個提供者節點的時候，怎麼進行負載，基本想法可以在提供者和消費者中間加一個反向代理，但是服務太多的時候不利於管理。