微服務的概述
- 什麼是微服務？
現今微服務界沒有一個統一的、标準的定義
微服務化的核心就是将統一的一站式應用，根據業務拆分成一個一個的服務，徹底的去耦合，每一個微服務提供單個業務功能的服務,一個服務做一件事, 從技術角度看就是一種小而獨立的處理過程,類似程序概念,能夠自行單獨啟動 或銷毀,擁有自己獨立的資料庫
- 微服務的架構
微服務架構是一種架構模式,它提倡将單一應用程式劃分成一組小的服務,服務之間互相協調、互相配合,為使用者提供最終價值.每個服務運作在其獨立的程序中,服務與服務間采用輕量級的通信機制互相協作(通常是基于HTTP協定的RESTful API).每個服務都圍繞着具體業務進行建構,并且能夠被獨立的部署到生産環境、生産環境等.另外,應當盡量避免統一的、集中式的服務管理機制,對具體的一個服務而言,應根據業務上下文,選擇合适的語言、工具對其進行建構.
有哪些優點？
- 每個服務足夠内聚,足夠小,代碼容易了解這樣能聚焦一個指定的業務功能或業務需求
- 開發簡單、開發效率提高,一個服務可能就是專一的隻幹一件事.
- 微服務是松耦合的,是有功能意義的服務,無論是在開發階段或部署階段都是獨立的.
- 微服務能試用不同的語言開發
- 易于和第三方內建,微服務允許容易且靈活的方式內建自動部署,通過持續內建工具,如Jenkins,Hudson
- 微服務易于被一個開發人員了解,修改和維護,這樣小團隊能夠更關注自己的工作成果.無需通過合作才能展現價值
- 微服務允許你利用融合最新技術
微服務隻是業務邏輯的代碼,不會和HTML,CSS或其他界面元件混合.
每個微服務都有自己的存儲能力,可以有自己的資料庫.也可以有統一的資料庫
有哪些缺點：
- 開發人員要處理分布式系統的複雜性
- 多服務運維難度,随着服務的增加,運維的壓力也在增大
- 系統部署依賴
- 服務間通信成本
- 資料一緻性
- 系統內建測試
- 性能監控
SpringBoot和SpringCloud那點事？
SpringBoot專注于快速友善的開發單個個體微服務。
SpringCloud是關注于全局微服務協調治理架構，他将Springboot開發的一個個單體微服務整合并管理起來，為各個微服務質檢提供配置管理，服務發現，斷路器，路由，微代理，事件總線，全局鎖，決策競選，分布式會話等內建服務。
Springboot可以離開SpringCloud單獨的使用開發項目，但是SpringCloud不能離開Springboot，屬于依賴的關系。
Springboot專注于快速、友善的開發單個微服務個體。
SpringCloud關注全局的服務治理架構。
SpringCloud中文網：https://springcloud.cc/
參考資料：https://www.springcloud.cc/spring-cloud-netflix.html
使用springcloud做一個簡單的查詢操作搭建項目的開發環境：
- 建立一個普通的maven工程（不用勾選任何選項），此時建立的是一個父工程
(以上建立一個普通的maven工程如果有哪裡不清晰，可以檢視MyBatis入門的第一天，裡面有講解：https://www.cnblogs.com/LBJLAKERS/p/11324234.html)
在pom.xml檔案夾中更改他的打包的方式，添加一句。
項目的打包類型：pom、jar、war
packing預設是jar類型，
<packaging>pom</packaging> ---------> 父類型都為pom類型
<packaging>jar</packaging> ---------> 内部調用或者是作服務使用
<packaging>war</packaging> ---------> 需要部署的項目
<packaging>pom</packaging>
在建立一個子工程，建立方式，如圖：（名稱為：zhservicecloud-common)
在父工程下建立一個子工程的方式：
- 使用同樣的方式分别建立子工程：zhservicecloud-provider-dept-8001、zhservicecloud-consumer-dep-80.
- 在父工程中的pom.xml檔案中導入坐标
1 <dependencyManagement> 2 <dependencies> 3 <dependency> 4 <groupId>org.springframework.cloud</groupId> 5 <artifactId>spring-cloud-dependencies</artifactId> 6 <version>Finchley.SR1</version> 7 <type>pom</type> 8 <scope>import</scope> 9 </dependency> 10 <dependency> 11 <groupId>org.springframework.boot</groupId> 12 <artifactId>spring-boot-dependencies</artifactId> 13 <version>2.0.1.RELEASE</version> 14 <type>pom</type> 15 <scope>import</scope> 16 </dependency> 17 <dependency> 18 <groupId>mysql</groupId> 19 <artifactId>mysql-connector-java</artifactId> 20 <version>5.0.4</version> 21 </dependency> 22 <dependency> 23 <groupId>com.alibaba</groupId> 24 <artifactId>druid</artifactId> 25 <version>1.0.31</version> 26 </dependency> 27 <dependency> 28 <groupId>org.mybatis.spring.boot</groupId> 29 <artifactId>mybatis-spring-boot-starter</artifactId> 30 <version>1.3.0</version> 31 </dependency> 32 <dependency> 33 <groupId>ch.qos.logback</groupId> 34 <artifactId>logback-core</artifactId> 35 <version>1.2.3</version> 36 </dependency> 37 <dependency> 38 <groupId>junit</groupId> 39 <artifactId>junit</artifactId> 40 <version>${junit.version}</version> 41 <scope>test</scope> 42 </dependency> 43 <dependency> 44 <groupId>log4j</groupId> 45 <artifactId>log4j</artifactId> 46 <version>${log4j.version}</version> 47 </dependency> 48 </dependencies> 49 </dependencyManagement> - 在MySQL的資料庫中建立一個dept的表結構，并插入資料：
1 DROP DATABASE IF EXISTS cloudDB01;
2 CREATE DATABASE cloudDB01 CHARACTER SET UTF8;
3 USE cloudDB01;
4 CREATE TABLE dept
5 (
6 deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,
7 dname VARCHAR(60),
8 db_source VARCHAR(60)
9 );
10 INSERT INTO dept(dname,db_source) VALUES('開發部',DATABASE());
11 INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());
12 INSERT INTO dept(dname,db_source) VALUES('财務部',DATABASE());
13 INSERT INTO dept(dname,db_source) VALUES('市場部',DATABASE());
14 INSERT INTO dept(dname,db_source) VALUES('運維部',DATABASE());
15
16 SELECT * FROM dept;
- 建立一個applicatioon.xml檔案。用來配置資料庫的基本配置
1 server: 2 port: 8001 3 mybatis: 4 config-location: classpath:mybatis/mybatis.cfg.xml #mybatis配置檔案所在路徑 5 type-aliases-package: zh.stu.service.model #所有Entity别名類所在包 6 mapper-locations: 7 - classpath:mybatis/mapper/**/*.xml #mapper映射檔案 8 spring: 9 application: 10 name: zhservicecloud-dept 11 datasource: 12 type: com.alibaba.druid.pool.DruidDataSource #目前資料源操作類型 13 driver-class-name: com.mysql.jdbc.Driver #mysql驅動包 14 url: jdbc:mysql://localhost:3306/cloudDB01 #資料庫名稱 15 username: root 16 password: zhanghao22333 17 dbcp2: 18 min-idle: 5 #資料庫連接配接池的最小維持連接配接數 19 initial-size: 5 #初始化連接配接數 20 max-total: 5 #最大連接配接數 21 max-wait-millis: 200 #等待連接配接擷取的最大逾時時間 - 因為在applicatioon.xml檔案中mybatis.cfg.xml的檔案配置，是以在建立一個此檔案即可
- 建立一個部門的model，并要實作序列化的接口
1 public class Dep implements Serializable{
2 private Long deptno; // 主鍵
3 private String dname; // 部門名稱
4 private String db_source;// 來自那個資料庫，因為微服務架構可以一個服務對應一個資料庫，同一個資訊被存儲到不同資料庫
5
6 public Long getDeptno() {
7 return deptno;
8 }
9
10 public void setDeptno(Long deptno) {
11 this.deptno = deptno;
12 }
13
14 public String getDname() {
15 return dname;
16 }
17
18 public void setDname(String dname) {
19 this.dname = dname;
20 }
21
22 public String getDb_source() {
23 return db_source;
24 }
25
26 public void setDb_source(String db_source) {
27 this.db_source = db_source;
28 }
29 }
- 其中建立的子工程txservicecloud-provider-dept-8001，是服務的提供者。在他的pom.xml檔案中導入坐标
1 <dependencies> 2 <dependency> 3 <groupId>junit</groupId> 4 <artifactId>junit</artifactId> 5 </dependency> 6 <dependency> 7 <groupId>mysql</groupId> 8 <artifactId>mysql-connector-java</artifactId> 9 </dependency> 10 <dependency> 11 <groupId>com.alibaba</groupId> 12 <artifactId>druid</artifactId> 13 </dependency> 14 <dependency> 15 <groupId>ch.qos.logback</groupId> 16 <artifactId>logback-core</artifactId> 17 </dependency> 18 <dependency> 19 <groupId>org.mybatis.spring.boot</groupId> 20 <artifactId>mybatis-spring-boot-starter</artifactId> 21 </dependency> 22 <dependency> 23 <groupId>org.springframework.boot</groupId> 24 <artifactId>spring-boot-starter-jetty</artifactId> 25 </dependency> 26 <dependency> 27 <groupId>org.springframework.boot</groupId> 28 <artifactId>spring-boot-starter-web</artifactId> 29 </dependency> 30 <dependency> 31 <groupId>org.springframework.boot</groupId> 32 <artifactId>spring-boot-starter-test</artifactId> 33 </dependency> 34 <!-- 修改後立即生效，熱部署 --> 35 <dependency> 36 <groupId>org.springframework</groupId> 37 <artifactId>springloaded</artifactId> 38 </dependency> 39 <dependency> 40 <groupId>org.springframework.boot</groupId> 41 <artifactId>spring-boot-devtools</artifactId> 42 </dependency> 43 <dependency> 44 <groupId>cn.tx.springcloud1</groupId> 45 <artifactId>txservicecloud-common</artifactId> 46 <version>1.0-SNAPSHOT</version> 47 </dependency> 48 </dependencies> - 在provider的工程下建立一個deptdao的接口。
1 package zh.stu.dao; 2 3 import org.apache.ibatis.annotations.Mapper; 4 import zh.stu.service.model.Dept; 5 6 import java.util.List; 7 8 @Mapper 9 public interface DeptDao { 10 11 boolean addDept (Dept dept); 12 13 Dept findById(Long id); 14 15 List<Dept> findAll(); 16 } - 建立一個service接口：DeptService
1 package zh.stu.service; 2 3 import org.springframework.transaction.annotation.Transactional; 4 import zh.stu.service.model.Dept; 5 6 import java.util.List; 7 8 @Transactional 9 public interface DeptService { 10 // 添加資料 11 boolean addDept (Dept dept); 12 // 根據條件查詢 13 Dept findById(Long id); 14 // 查詢資料庫表中的所有資料 15 List<Dept> findAll(); 16 } - 在resource目錄下建立一個mapper.xml檔案
1 <?xml version="1.0" encoding="UTF-8" ?> 2 <!DOCTYPE mapper 3 PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 4 "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> 5 <mapper namespace="zh.stu.dao.DeptDao"> 6 <select id="findById" resultType="dept" parameterType="Long"> 7 SELECT d.deptno,d.dname,d.db_source FROM dept d WHERE d.deptno=#{deptno} 8 </select> 9 <select id="findAll" resultType="dept"> 10 SELECT d.deptno,d.dname,d.db_source FROM dept d 11 </select> 12 <insert id="addDept" parameterType="dept"> 13 INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE()); 14 </insert> 15 </mapper>
- 實作該service接口
1 package zh.stu.service.ServiceImpl; 2 3 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.stereotype.Service; 5 import zh.stu.dao.DeptDao; 6 import zh.stu.service.DeptService; 7 import zh.stu.service.model.Dept; 8 9 import java.util.List; 10 11 @Service 12 public class DeptServiceImpl implements DeptService { 13 14 @Autowired 15 private DeptDao deptDao; 16 17 @Override 18 public boolean addDept(Dept dept) { 19 return deptDao.addDept(dept); 20 } 21 22 @Override 23 public Dept findById(Long id) { 24 return deptDao.findById(id); 25 } 26 27 @Override 28 public List<Dept> findAll() { 29 return deptDao.findAll(); 30 } 31 } - 建立一個controller
1 package zh.stu.controller; 2 3 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.web.bind.annotation.*; 5 import zh.stu.service.DeptService; 6 import zh.stu.service.model.Dept; 7 8 import java.util.List; 9 10 @RestController 11 public class DeptController { 12 13 @Autowired 14 private DeptService deptService; 15 16 @RequestMapping(value = "/dept/add",method = RequestMethod.POST) 17 public boolean add(@RequestBody Dept dept) 18 { 19 return deptService.addDept(dept); 20 } 21 22 @RequestMapping(value = "/dept/get/{id}",method = RequestMethod.GET) 23 public Dept dept (@PathVariable("id") Long id){ 24 return deptService.findById(id); 25 } 26 27 @RequestMapping(value = "/dept/list",method = RequestMethod.GET) 28 public List<Dept> dept() 29 { 30 return deptService.findAll(); 31 } 32 } - 添加一個SpringApplicationTx類，運作此類，在控制台輸入控制器中添加的路徑：http://localhost:8001/dept/list
結果：1 package zh.stu; 2 3 import org.springframework.boot.SpringApplication; 4 import org.springframework.boot.autoconfigure.SpringBootApplication; 5 6 @SpringBootApplication 7 public class SpringApplicationTx { 8 public static void main(String[] args) { 9 SpringApplication.run(SpringApplicationTx.class,args); 10 } 11 }
附一張項目結構圖
- 以上是服務的提供端
- 在consumer和provider之間的的調用，在consummer端對provider的調用
- 同樣是在resource的目錄下新添加一個application.xml的檔案：制定端口号80
server: port: 80 - 在新加一個RestConfigBean的類，将RestTemplate交給容器
1 package zh.stu; 2 3 import org.springframework.context.annotation.Bean; 4 import org.springframework.context.annotation.Configuration; 5 import org.springframework.web.client.RestTemplate; 6 7 @Configuration 8 public class RestConfigBean { 9 @Bean 10 public RestTemplate restTemplate() { 11 return new RestTemplate(); 12 } 13 } - 添加控制器，對兩不同條件的查詢做測試
1 package zh.stu.controller; 2 3 import org.springframework.beans.factory.annotation.Autowired; 4 import org.springframework.web.bind.annotation.PathVariable; 5 import org.springframework.web.bind.annotation.RequestMapping; 6 import org.springframework.web.bind.annotation.RestController; 7 import org.springframework.web.client.RestTemplate; 8 import zh.stu.service.model.Dept; 9 10 import java.util.List; 11 12 @RestController 13 public class DeptController { 14 15 private String REST_URL_PREFIX="http://localhost:8001/"; 16 17 @Autowired 18 private RestTemplate restTemplate; 19 20 @RequestMapping("/consumer/dept/getdept/{id}") 21 public Dept getDept(@PathVariable("id") Long id){ 22 return restTemplate.getForObject(REST_URL_PREFIX+"dept/get/"+id,Dept.class); 23 } 24 25 @RequestMapping("/consumer/dept/findall") 26 public List<Dept> findAll(){ 27 return restTemplate.getForObject(REST_URL_PREFIX+"dept/list",List.class); 28 } 29 } - 建立SpringAppConsumerTx類檔案
啟動之後在位址欄根據在控制器中添加的路徑輸位址，可查詢出相應的資料。1 package zh.stu; 2 3 4 import org.springframework.boot.SpringApplication; 5 import org.springframework.boot.autoconfigure.SpringBootApplication; 6 7 @SpringBootApplication 8 public class SpringAppConsumerTx { 9 public static void main(String[] args) { 10 SpringApplication.run(SpringAppConsumerTx.class,args); 11 } 12 }
注意：在啟動consumer端的SpringAppConsumerTx之前，就應該把provider端啟動起來，因為在consumer端要通路provider。