瀏覽器向service consumer請求某個資料,service consumer會去向service provider請求資料,然後將service provider返回的資料返回給瀏覽器。
新增資料同理。
步驟同上一篇的2.3.1
(1)建立Module:member-service-consumer-80
(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>E-Commerce-Center</artifactId>
<groupId>com.li.springcloud</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>member-service-consumer-80</artifactId>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
<!--引入相關的依賴,版本都使用父專案宣告的版本-->
<dependencies>
<!--web-starter-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--actuator-starter 是 springboot程式的監控系統,可以實現系統的健康監測
可以通過http://localhost:10000/actuator看到相關的連線和資訊-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
</project>
(3)建立resources/application.yml
server:
port: 80
spring:
application:
name: member-service-consumer-80
(4)建立啟動類
package com.li.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author 李
* @version 1.0
*/
@SpringBootApplication
public class MemberConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(MemberConsumerApplication.class,args);
}
}
測試,啟動成功:
建立工具類Result.java(略,見2.3.3.1)
Member.java
package com.li.springcloud.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author 李
* @version 1.0
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
//因為物件在網路中以流的形式傳遞,這裡最好實現Serializable介面
public class Member implements Serializable{
private Long id;
private String name;
private String pwd;
private String mobile;
private String email;
private Integer gender;
}
RestTemplate 基本介紹:RestTemplate 是 Spring 提供的用於存取Rest服務的模板類,它提供來了許多便捷存取遠端 Http 服務的方法。
通過 RestTemplate,我們可以向另一個微服務模組發出 Http 請求(支援 Restful 風格),去呼叫該模組的 Controller 提供的 API 介面,就像瀏覽器發出請求呼叫該 API 介面一樣。
RestTemplate 官網:RestTemplate (Spring Framework 5.2.2.RELEASE API)
建立設定類,注入RestTemplate物件:
package com.li.springcloud.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
/**
* @author 李
* @version 1.0
* 注入RestTemplate Bean
*/
@Configuration
public class CustomInitBean {
@Bean
public RestTemplate getRestTemplate() {
return new RestTemplate();
}
}
MemberConsumerController.java:
package com.li.springcloud.controller;
import com.li.springcloud.entity.Member;
import com.li.springcloud.utils.Result;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
/**
* @author 李
* @version 1.0
*/
@RestController
@Slf4j
public class MemberConsumerController {
@Resource
private RestTemplate restTemplate;
//定義一個基礎的url
public static final String MEMBER_SERVICE_PROVIDER_URL =
"http://localhost:10000";
//新增物件到資料庫表中
@PostMapping("/member/consumer/save")
public Result<Member> save(Member member) {
log.info("service-consumer member={}", member);
/**
* MEMBER_SERVICE_PROVIDER_URL + "/member/save":就是向對應子模組發出的完整url請求
* member:就是通過 restTemplate 發出的 post 請求攜帶的資料(物件)
* Result.class:就是返回的物件型別
*/
return restTemplate.postForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/save",
member,
Result.class);
}
//根據id呼叫服務介面,返回member物件資訊
@GetMapping("/member/consumer/get/{id}")
public Result<Member> getMemberById(@PathVariable("id") Integer id) {
return restTemplate.getForObject
(MEMBER_SERVICE_PROVIDER_URL + "/member/get/" + id,
Result.class);
}
}
分別啟動兩個子模組(service consumer、service provider)
(1)測試save方法:postman以表單形式發出資料:
結果顯示新增成功,但是我們在資料庫中看到的確是空值:
原因是因為使用RestTemplate,它會將資料以json格式傳送。解決方法是在服務模組對應方法引數中使用@RequestBody註解,將接收的json格式資料轉換成物件。
最好實體類實現Serializable,支援可序列化
重新啟動模組,使用postman傳送資料:資料庫新增成功。
(2)瀏覽器測試getMemberById方法:
測試通過。
當SpringCloud的服務有多個時,管理多個服務的啟動使用右上角的run會不好管理,我們可以使用Run Dashboard:idea中如何開啟Dashboard
我們在 consumer 和 provider 模組都使用到了 Member 和 Result 類,我們可以將它們抽取到共用模組(e_commerce_center_common-api),使用Maven 打包成 jar包,其他模組需要使用直接引入依賴即可。
(1)建立Module--e_commerce_center_common-api
(2)在本模組的pom.xml引入公共的依賴
<!--引入公共模組需要的依賴-->
<dependencies>
<!--lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<!--<optional>true</optional>:防止將該依賴傳遞到其他模組中
1. true 表示兩個專案之間依賴不傳遞
比如 a 模組依賴了本專案,那麼本專案不會把 lombok 的jar包給 a 模組
意義在於繼承依賴時,防止jar發生版本衝突(如,a模組可以自定義需要的Lombok版本)
2. 不設定optional或optional=預設值false,都表示傳遞依賴
-->
<optional>true</optional>
</dependency>
</dependencies>
建立多個子模組都要使用的公共類,注意路徑要和其他模組的路徑相同。
(1)按如下步驟進行打包:
(2)成功後會在target目錄下生成對應的jar包:
並且maven-archiver下的pom.properties中生成了專案對應的座標:
#Generated by Maven
#Tue Apr 04 19:38:29 CST 2023
version=1.0-SNAPSHOT
groupId=com.li.springcloud
artifactId=e_commerce_center_common-api
(1)在 member-service-provider-10000 模組刪除當前模組的 entity 包和 utils 包
(2)在 member-service-provider-10000 的 pom.xml 引入公共模組:
<dependency>
<groupId>com.li.springcloud</groupId>
<artifactId>e_commerce_center_common-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
然後點選重新整理Maven,這樣就可以引入之前打包好的jar包程式碼了。
(3)同理,在 member-service-consumer-80 模組中也刪除 entity 和 utils 包,然後在本模組的 pom.xml 檔案中也引入公共模組,然後重新整理。
分別啟動 member-service-provider-10000 和 member-service-consumer-80 兩個子模組,在瀏覽器中傳送請求進行測試:
如下,測試成功,工程進行重構之後沒有問題,公共模組引入各個模組之後依然可以工作。
之後如果多個模組還有公共的類,依然可以通過這種方式來抽取共用的API/類,然後通過引入公共模組的方式來簡化程式碼。