14 微服務電商【黑馬樂優商城】：day02-springcloud(理論篇二：知道什麼是SpringCloud)

時間 2019-11-09

標籤微服黑馬樂優商城 day02 day springcloud 理論知道什麼简体版

原文原文鏈接

本項目的筆記和資料的Download，請點擊這一句話自行獲取。html

day01-springboot（理論篇）；day01-springboot（實踐篇）java

day02-springcloud（理論篇一：HttpClient的簡單使用 ) ；day02-springcloud(理論篇二：知道什麼是SpringCloud) ；day02-springcloud(理論篇三：搭建Eureka註冊中心)mysql

14 微服務電商【黑馬樂優商城】：day02-springcloud

0.學習目標

瞭解系統架構的演變
瞭解RPC與Http的區別
掌握HttpClient的簡單使用
知道什麼是SpringCloud
獨立搭建Eureka註冊中心
獨立配置Robbin負載均衡

4.初識SpringCloud

微服務是一種架構方式，最終確定須要技術架構去實施。程序員

微服務的實現方式不少，可是最火的莫過於Spring Cloud了。爲何？web

後臺硬：做爲Spring家族的一員，有整個Spring全家桶靠山，背景十分強大。
技術強：Spring做爲Java領域的前輩，能夠說是功力深厚。有強力的技術團隊支撐，通常人還真比不了。
羣衆基礎好：能夠說大多數程序員的成長都伴隨着Spring框架，試問：如今有幾家公司開發不用Spring？SpringCloud與Spring的各個框架無縫整合，對你們來講一切都是熟悉的感受。
使用方便：相信你們都體會到了SpringBoot給咱們開發帶來的便利，而SpringCloud徹底支持SpringBoot的開發，用不多的配置就能完成微服務框架的搭建。

4.1.簡介

SpringCloud是Spring旗下的項目之一，官網地址：http://projects.spring.io/spring-cloud/spring

Spring最擅長的就是集成，把世界上最好的框架拿過來，集成到本身的項目中。sql

SpringCloud也是同樣，它將如今很是流行的一些技術整合到一塊兒，實現了諸如：配置管理，服務發現，智能路由，負載均衡，熔斷器，控制總線，集羣狀態等等功能。其主要涉及的組件包括：數據庫

netflixapache

Eureka：註冊中心
Zuul：服務網關
Ribbon：負載均衡
Feign：服務調用
Hystix：熔斷器

以上只是其中一部分，架構圖：tomcat

4.2.版本

SpringCloud的版本命名比較特殊，由於它不是一個組件，而是許多組件的集合，它的命名是以A到Z的爲首字母的一些單詞組成

咱們在項目中，會是以Finchley的版本。

其中包含的組件，也都有各自的版本。

Greenwich builds and works with Spring Boot 2.1.x, and is not expected to work with Spring Boot 1.5.x.

接下來，咱們就一一學習SpringCloud中的重要組件。

5.微服務場景模擬

首先，咱們須要模擬一個服務調用的場景。方便後面學習微服務架構

5.1.服務提供者

咱們新建一個項目，對外提供查詢用戶的服務。

5.1.1.Spring腳手架建立工程

藉助於Spring提供的快速搭建工具：

填寫項目信息：

添加web依賴：

添加mybatis依賴：

Spring Boot 的版本能夠在自動搭建生成後，手動在pom.xml裏修改未顯示的低版本！

填寫項目位置：

生成的項目結構：

依賴也已經所有自動引入：

固然，由於要使用通用mapper，因此咱們須要手動加一條依賴：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.leyou.demo</groupId>
    <artifactId>user-service-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>user-service-demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--springboot測試的起步依賴-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--SpringBoot熱部署開發模式啓動器-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <!--DAO層相關數據庫驅動的啓動器-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- 啓用了通用Mapper，下面的mybatis和jdbc就能夠自動繼承依賴，所以註釋掉-->
        <!--<dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.1.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>-->
        <!-- 通用mapper的啓動器 -->
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper-spring-boot-starter</artifactId>
            <version>2.1.5</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.6</version>
        </dependency>
        <!-- Druid鏈接池啓動器 -->
        <!--<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>-->
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

使用spring initializr很是快捷啊！

5.1.2.編寫代碼

添加一個對外查詢（微服務架構的）接口：

Controller層

@RestController  //等同於@Controller+@ResponseBody
@RequestMapping("user")
public class UserController {

    @Autowired
    private IUserService userService;

    @GetMapping("/{id}")  //
    public User queryById(@PathVariable(name = "id") Long id){
        
        User user= this.userService.queryById(id);

        return user;
    }
}

Service層的接口的實現類

@Service
@Transactional  //啓用事務的註解
public class UserServiceImpl implements IUserService {
    @Autowired
    private UserMapper userMapper;

    @Override
    public User queryById(Long id) {
        return this.userMapper.selectByPrimaryKey(id);
    }
}

DAO層提供給通用Mapper查詢的Interface

//@Mapper
//@Repository  //此處的註解做用有待測試，添加以後IDEA對Service層不報錯
public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User> {

}

數據庫對應的實體類：若是是非持久化的屬性字段要用註解@Transient聲明

@Table(name = "tb_user")
public class User implements Serializable {

//    private static final long serialVersionUID = 1L;
 @Id
    @KeySql(useGeneratedKeys = true)
    //主鍵，必須用基本類型的包裝類
    //此處用long基本類型會返回null
    private Long id;
    // 用戶名
    private String userName;
    // 密碼
    private String password;
    // 姓名
    private String name;
    // 年齡
    private Integer age;
    // 性別，1男性，2女性
    private Integer sex;
    // 出生日期
    private Date birthday;
    // 備註
    private String note;
    // 建立時間
    private Date created;
    // 更新時間
    private Date updated;

    //=====下面省略get/set方法和toString()方法=====//

屬性配置文件,這裏咱們採用了yaml語法，而不是properties：

application-demo.yml

spring:
  datasource:
    #四項鍊接配置
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/leyou?useUniode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
    username: root
    password: root
    #鏈接池類型
    type: com.zaxxer.hikari.HikariDataSource
    #鏈接池個性化配置
    hikari:
      maximum-pool-size: 20
      minimum-idle: 10


mybatis:
  #配置entity實體類的映射掃描包
  type-aliases-package: com.leyou.demo.userservice.pojo
  configuration:
    #配置下劃線轉駝峯規則
    map-underscore-to-camel-case: true


#tomcat服務器端口
server:
  port: 8081
#     servlet:
#對應的是視圖層方法上@RequestMapping註解的("/*.do")
#   path: "*.do"


#log4j日誌輸出控制
#logging:
# level:
#  cn.bjut.interceptor: debug

application.yml

spring:
  profiles:
    active: demo

5.1.3.啓動並測試：

啓動項目，訪問接口：http://localhost:8081/user/7

5.2.服務調用者

5.2.1.建立工程

與上面相似，這裏再也不贅述，須要注意的是，咱們調用user-service的功能，所以不須要mybatis相關依賴了。

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.leyou.demo</groupId>
    <artifactId>user-consumer-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>user-consumer-demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <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>
            <scope>test</scope>
        </dependency>

        <!-- 添加OkHttp支持 -->
        <dependency>
            <groupId>com.squareup.okhttp3</groupId>
            <artifactId>okhttp</artifactId>
            <version>4.2.1</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

5.2.2.編寫代碼

首先在啓動類中註冊RestTemplate：

@SpringBootApplication
public class UserConsumerDemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserConsumerDemoApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate() {
        //註冊誰，就用@Bean註解返回，誰的一個匿名對象
        // 此次咱們使用了OkHttp客戶端,只須要注入工廠便可
        return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
    }

}

而後編寫UserDao，注意，這裏不是調用mapper查數據庫，而是經過RestTemplate遠程查詢user-service-demo中的接口：

@Repository
public class UserDao {

    @Autowired
    private RestTemplate restTemplate;

    public User queryUserById(Long id){
        String url = "http://localhost:8081/user/" + id;
        //RestTemplate的.getForObject方法封裝了JSON轉實體類的過程
        return this.restTemplate.getForObject(url, User.class);
    }
}

而後編寫user-service，循環查詢UserDAO信息：

@Service
public class UserService {
    @Autowired
    private UserDao userDao;

    public List<User> querUserByIds(List<Long> ids){
        //初始化一個集合對象放查詢結果
        List<User> users = new ArrayList<>();
        for (Long id : ids) {
            User user = this.userDao.queryUserById(id);
            users.add(user);
        }
        return users;
    }

}

編寫controller：

@RestController
@RequestMapping("consume")
public class ConsumerController {

    @Autowired
    private UserService userService;

    @GetMapping
    public List<User> consume(@RequestParam("ids") List<Long> ids) {
        return this.userService.querUserByIds(ids);
    }
    
}