springcloud入門篇Demo

微服務的概述

• 什么是微服務？

現今微服務界沒有一個統一的、標准的定義

微服務化的核心就是將統一的一站式應用，根據業務拆分成一個一個的服務，徹底的去耦合，每一個微服務提供單個業務功能的服務,一個服務做一件事, 從技術角度看就是一種小而獨立的處理過程,類似進程概念,能夠自行單獨啟動 或銷毀,擁有自己獨立的數據庫

• 微服務的架構

微服務架構是一種架構模式,它提倡將單一應用程序划分成一組小的服務,服務之間互相協調、互相配合,為用戶提供最終價值.每個服務運行在其獨立的進程中,服務與服務間采用輕量級的通信機制互相協作(通常是基於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)

在父工程下創建一個子工程的方式：

　　   

• 使用同樣的方式分別創建子工程：txservicecloud-provider-dept-8001、txservicecloud-consumer-dep-80.
• 在父工程中的pom.xml文件中導入坐標

   <dependencyManagement>
          <dependencies>
              <dependency>
                  <groupId>org.springframework.cloud</groupId>
                  <artifactId>spring-cloud-dependencies</artifactId>
                  <version>Finchley.SR1</version>
                  <type>pom</type>
                  <scope>import</scope>
              </dependency>
              <dependency>
                  <groupId>org.springframework.boot</groupId>
                  <artifactId>spring-boot-dependencies</artifactId>
                  <version>2.0.1.RELEASE</version>
                  <type>pom</type>
                  <scope>import</scope>
              </dependency>
              <dependency>
                  <groupId>mysql</groupId>
                  <artifactId>mysql-connector-java</artifactId>
                  <version>5.0.4</version>
              </dependency>
              <dependency>
                  <groupId>com.alibaba</groupId>
                  <artifactId>druid</artifactId>
                  <version>1.0.31</version>
              </dependency>
              <dependency>
                  <groupId>org.mybatis.spring.boot</groupId>
                  <artifactId>mybatis-spring-boot-starter</artifactId>
                  <version>1.3.0</version>
              </dependency>
              <dependency>
                  <groupId>ch.qos.logback</groupId>
                  <artifactId>logback-core</artifactId>
                  <version>1.2.3</version>
              </dependency>
              <dependency>
                  <groupId>junit</groupId>
                  <artifactId>junit</artifactId>
                  <version>${junit.version}</version>
                  <scope>test</scope>
              </dependency>
              <dependency>
                  <groupId>log4j</groupId>
                  <artifactId>log4j</artifactId>
                  <version>${log4j.version}</version>
              </dependency>
          </dependencies>
      </dependencyManagement>

• 在MySQL的數據庫中創建一個dept的表結構，並插入數據：

DROP DATABASE IF EXISTS cloudDB01;
CREATE DATABASE cloudDB01 CHARACTER SET UTF8;
USE cloudDB01;
CREATE TABLE dept
(
    deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,
    dname VARCHAR(60),
    db_source VARCHAR(60)
);
INSERT INTO dept(dname,db_source) VALUES('開發部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('財務部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('市場部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('運維部',DATABASE());
 
SELECT * FROM dept;

• 創建一個applicatioon.xml文件。用來配置數據庫的基本配置

  server:
    port: 8001
  mybatis:
    config-location: classpath:mybatis/mybatis.cfg.xml    #mybatis配置文件所在路徑
    type-aliases-package: zh.stu.service.model      #所有Entity別名類所在包
    mapper-locations:
      - classpath:mybatis/mapper/**/*.xml                   #mapper映射文件
  spring:
    application:
      name: zhservicecloud-dept
    datasource:
      type: com.alibaba.druid.pool.DruidDataSource        #當前數據源操作類型
      driver-class-name: com.mysql.jdbc.Driver          #mysql驅動包
      url: jdbc:mysql://localhost:3306/cloudDB01          #數據庫名稱
      username: root
      password: zhanghao22333
      dbcp2:
        min-idle: 5                                       #數據庫連接池的最小維持連接數
        initial-size: 5                                   #初始化連接數
        max-total: 5                                      #最大連接數
        max-wait-millis: 200                              #等待連接獲取的最大超時時間

• 因為在applicatioon.xml文件中mybatis.cfg.xml的文件配置，所以在創建一個此文件即可
• 創建一個部門的model，並要實現序列化的接口

public class Dep implements Serializable{
    private Long   deptno; // 主鍵
    private String     dname; // 部門名稱
    private String     db_source;// 來自那個數據庫，因為微服務架構可以一個服務對應一個數據庫，同一個信息被存儲到不同數據庫

    public Long getDeptno() {
        return deptno;
    }

    public void setDeptno(Long deptno) {
        this.deptno = deptno;
    }

    public String getDname() {
        return dname;
    }

    public void setDname(String dname) {
        this.dname = dname;
    }

    public String getDb_source() {
        return db_source;
    }

    public void setDb_source(String db_source) {
        this.db_source = db_source;
    }
}

• 其中創建的子工程txservicecloud-provider-dept-8001，是服務的提供者。在他的pom.xml文件中導入坐標

  <dependencies>
      <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
      </dependency>
      <dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
      </dependency>
      <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>druid</artifactId>
      </dependency>
      <dependency>
          <groupId>ch.qos.logback</groupId>
          <artifactId>logback-core</artifactId>
      </dependency>
      <dependency>
          <groupId>org.mybatis.spring.boot</groupId>
          <artifactId>mybatis-spring-boot-starter</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-jetty</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-test</artifactId>
      </dependency>
      <!-- 修改后立即生效，熱部署 -->
      <dependency>
          <groupId>org.springframework</groupId>
          <artifactId>springloaded</artifactId>
      </dependency>
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-devtools</artifactId>
      </dependency>
      <dependency>
          <groupId>cn.tx.springcloud1</groupId>
          <artifactId>txservicecloud-common</artifactId>
          <version>1.0-SNAPSHOT</version>
      </dependency>
  </dependencies>

•  在provider的工程下創建一個deptdao的接口。

  package zh.stu.dao;
  
  import org.apache.ibatis.annotations.Mapper;
  import zh.stu.service.model.Dept;
  
  import java.util.List;
  
  @Mapper
  public interface DeptDao {
  
      boolean addDept (Dept dept);
  
      Dept findById(Long id);
  
      List<Dept> findAll();
  }

• 創建一個service接口：DeptService

  package zh.stu.service;
  
  import org.springframework.transaction.annotation.Transactional;
  import zh.stu.service.model.Dept;
  
  import java.util.List;
  
  @Transactional
  public interface DeptService {
  //  添加數據
      boolean addDept (Dept dept);
  //  根據條件查詢
      Dept findById(Long id);
  //  查詢數據庫表中的所有數據
      List<Dept> findAll();
  }

• 在resource目錄下創建一個mapper.xml文件

  <?xml version="1.0" encoding="UTF-8" ?>
  <!DOCTYPE mapper
          PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
          "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  <mapper namespace="zh.stu.dao.DeptDao">
      <select id="findById" resultType="dept" parameterType="Long">
          SELECT d.deptno,d.dname,d.db_source FROM dept d WHERE d.deptno=#{deptno}
      </select>
      <select id="findAll" resultType="dept">
          SELECT d.deptno,d.dname,d.db_source FROM dept d
      </select>
      <insert id="addDept" parameterType="dept">
          INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE());
      </insert>
  </mapper>

• 實現該service接口

  package zh.stu.service.ServiceImpl;
  
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.stereotype.Service;
  import zh.stu.dao.DeptDao;
  import zh.stu.service.DeptService;
  import zh.stu.service.model.Dept;
  
  import java.util.List;
  
  @Service
  public class DeptServiceImpl implements DeptService {
  
      @Autowired
      private DeptDao deptDao;
  
      @Override
      public boolean addDept(Dept dept) {
          return deptDao.addDept(dept);
      }
  
      @Override
      public Dept findById(Long id) {
          return deptDao.findById(id);
      }
  
      @Override
      public List<Dept> findAll() {
          return deptDao.findAll();
      }
  }

• 創建一個controller

  package zh.stu.controller;
  
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.web.bind.annotation.*;
  import zh.stu.service.DeptService;
  import zh.stu.service.model.Dept;
  
  import java.util.List;
  
  @RestController
  public class DeptController {
  
      @Autowired
      private DeptService deptService;
  
      @RequestMapping(value = "/dept/add",method = RequestMethod.POST)
      public boolean add(@RequestBody Dept dept)
      {
          return deptService.addDept(dept);
      }
  
      @RequestMapping(value = "/dept/get/{id}",method = RequestMethod.GET)
      public Dept dept (@PathVariable("id") Long id){
          return deptService.findById(id);
      }
  
      @RequestMapping(value = "/dept/list",method = RequestMethod.GET)
      public List<Dept> dept()
      {
          return deptService.findAll();
      }
  }

• 添加一個SpringApplicationTx類，運行此類，在控制台輸入控制器中添加的路徑：http://localhost:8001/dept/list

  package zh.stu;
  
  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;
  
  @SpringBootApplication
  public class SpringApplicationTx {
      public static void main(String[] args) {
          SpringApplication.run(SpringApplicationTx.class,args);
      }
  }

  結果：

　　附一張項目結構圖

　　　

• 以上是服務的提供端
• 在consumer和provider之間的的調用，在consummer端對provider的調用
• 同樣是在resource的目錄下新添加一個application.xml的文件：制定端口號80

  server:
    port: 80

• 在新加一個RestConfigBean的類，將RestTemplate交給容器

  package zh.stu;
  
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;
  import org.springframework.web.client.RestTemplate;
  
  @Configuration
  public class RestConfigBean {
      @Bean
      public RestTemplate restTemplate() {
          return new RestTemplate();
      }
  }

• 添加控制器，對兩不同條件的查詢做測試

  package zh.stu.controller;
  
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.web.bind.annotation.PathVariable;
  import org.springframework.web.bind.annotation.RequestMapping;
  import org.springframework.web.bind.annotation.RestController;
  import org.springframework.web.client.RestTemplate;
  import zh.stu.service.model.Dept;
  
  import java.util.List;
  
  @RestController
  public class DeptController {
  
      private String REST_URL_PREFIX="http://localhost:8001/";
  
      @Autowired
      private RestTemplate restTemplate;
  
      @RequestMapping("/consumer/dept/getdept/{id}")
      public Dept getDept(@PathVariable("id") Long id){
          return restTemplate.getForObject(REST_URL_PREFIX+"dept/get/"+id,Dept.class);
      }
  
      @RequestMapping("/consumer/dept/findall")
      public List<Dept> findAll(){
          return restTemplate.getForObject(REST_URL_PREFIX+"dept/list",List.class);
      }
  }

• 創建SpringAppConsumerTx類文件

  package zh.stu;
  
  
  import org.springframework.boot.SpringApplication;
  import org.springframework.boot.autoconfigure.SpringBootApplication;
  
  @SpringBootApplication
  public class SpringAppConsumerTx {
      public static void main(String[] args) {
          SpringApplication.run(SpringAppConsumerTx.class,args);
      }
  }

  啟動之后在地址欄根據在控制器中添加的路徑輸地址，可查詢出相應的數據。

　　　注意：在啟動consumer端的SpringAppConsumerTx之前，就應該把provider端啟動起來，因為在consumer端要訪問provider。