SpringBoot整合SpringCloud的過程詳解

更新時(shí)間：2021年09月16日 08:35:35 作者：Tttori

SpringCloud專注于為典型的用例和擴(kuò)展機(jī)制提供良好的開箱即用體驗(yàn)，在介紹SpringCloud默認(rèn)使用的注冊中心前，先給大家介紹下分布式系統(tǒng)的三個(gè)指標(biāo)，具體內(nèi)容詳情跟隨小編一起看看吧

1. SpringCloud特點(diǎn)

SpringCloud專注于為典型的用例和擴(kuò)展機(jī)制提供良好的開箱即用體驗(yàn)，以涵蓋其他情況：

分布式/版本化配置
服務(wù)注冊和發(fā)現(xiàn) Eureka
路由 Zuul
服務(wù)到服務(wù)的呼叫
負(fù)載均衡 Ribbon
斷路器 Hystrix
分布式消息傳遞

2. 分布式系統(tǒng)的三個(gè)指標(biāo)CAP

在介紹SpringCloud默認(rèn)使用的注冊中心前，先介紹分布式系統(tǒng)的三個(gè)指標(biāo)，分別是：

Consistency：一致性，在分布式系統(tǒng)中，更新操作執(zhí)行成功后所有的用戶的讀操作必須返回最新值；client寫入，server同步至整個(gè)系統(tǒng)；
Availability：可用性，只要收到用戶的請求，在一定的時(shí)間內(nèi)服務(wù)器就必須給出回應(yīng)，回應(yīng)的結(jié)果可以是成功或是失敗；
Partition tolerance：分區(qū)容錯(cuò)，即區(qū)間通信可能失敗，在網(wǎng)絡(luò)中斷，消息丟失的情況下，仍對外提供服務(wù)；一般無法避免，可以認(rèn)為CAP中的P總是成立

CAP定律說的是，在一個(gè)分布式計(jì)算機(jī)系統(tǒng)中，一致性C，可用性A，分區(qū)容錯(cuò)性P這三種保證無法同時(shí)得到滿足，最多滿足兩個(gè)：

1.放棄P

為了避免分區(qū)容錯(cuò)性問題的發(fā)生，一種做法是將所有與事務(wù)相關(guān)的數(shù)據(jù)都放在一臺服務(wù)器上，雖然不能保證100%系統(tǒng)不會出錯(cuò)，但是不會碰到由分區(qū)帶來的負(fù)面效果，這樣的做法會嚴(yán)重影響系統(tǒng)的擴(kuò)展性。

2.放棄A

放棄可用性，一旦遇到分區(qū)容錯(cuò)故障，受到影響的服務(wù)器需要等待一定的時(shí)間，因此會導(dǎo)致在等待期間系統(tǒng)無法對外提供服務(wù)。

3.放棄C

這兒說的放棄一致性，并不是完全放棄數(shù)據(jù)的一致性，而是放棄數(shù)據(jù)的強(qiáng)一致性，而保留數(shù)據(jù)的最終一致性。以網(wǎng)絡(luò)購物為例，對只剩下一件庫存的商品，如果同時(shí)接受到了兩份訂單，那么較晚的訂單將被告知商品告罄。

文中部分CAP理論摘自：https://www.cnblogs.com/hxsyl/p/4381980.html

3. Eureka

基本介紹

Eureka是SpringCloud官方推薦用于服務(wù)注冊和發(fā)現(xiàn)，一個(gè)基于REST的服務(wù)

SpringBoot實(shí)現(xiàn)了Netflix OSS的集成，使用Eureka的原因之一是因?yàn)槠淇梢岳肧pring Cloud Netflix的其他組件：智能路由(Zuul)、客戶端負(fù)載均衡(Ribbon)等

基本組成

Eureka由多個(gè)Instance(服務(wù)實(shí)例)組成，分為Eureka Server和Eureka Client

其中Eureka Client又可細(xì)分為：Service Provider、Service Consumer

Eureka Server：服務(wù)端，提供服務(wù)的注冊和發(fā)現(xiàn)；
Eureka Client：客戶端

Service Provider：服務(wù)提供方，將自身服務(wù)注冊到Eureka，讓消費(fèi)方找到Service Consumer：服務(wù)消費(fèi)方，從Eureka獲取注冊服務(wù)列表，從而消費(fèi)服務(wù)

Eureka和Zookeeper

1）由CAP理論的角度來看

Zookeeper：ZK保證CP，突出強(qiáng)一致性，但無法保證每次訪問服務(wù)可用性，比如ZK會出現(xiàn)這樣一種情況：當(dāng)master節(jié)點(diǎn)因?yàn)榫W(wǎng)絡(luò)故障與其他節(jié)點(diǎn)失去聯(lián)系時(shí)，剩余節(jié)點(diǎn)會重新進(jìn)行l(wèi)eader選舉，在ZK選舉leader期間整個(gè)ZK集群都是不可用的，這就導(dǎo)致了在選舉期間注冊服務(wù)癱瘓。在云部署的環(huán)境下，因網(wǎng)絡(luò)問題使得ZK集群失去master節(jié)點(diǎn)是較大概率會發(fā)生的事兒，雖然服務(wù)最終會恢復(fù)，但是漫長的選舉時(shí)間導(dǎo)致的注冊長期不可用是難以容忍的。

Eureka：Eureka保證AP，Eureka在設(shè)計(jì)時(shí)就優(yōu)先保證可用性。對于Eureka中的節(jié)點(diǎn)，每個(gè)節(jié)點(diǎn)都是平等的，幾個(gè)節(jié)點(diǎn)掛掉也不會影響正常節(jié)點(diǎn)的工作，剩余的節(jié)點(diǎn)依然可以提供注冊和查詢服務(wù)。但Eureka不保證強(qiáng)一致性，即查到的信息可能不是最新的。此外Eureka還有一種自我保護(hù)機(jī)制，如果在15分鐘內(nèi)超過85%的節(jié)點(diǎn)都沒有正常的心跳，那么Eureka就會認(rèn)為客戶端和注冊中心出現(xiàn)了網(wǎng)絡(luò)故障，但會保證當(dāng)前節(jié)點(diǎn)依然可用，不會像ZK導(dǎo)致整個(gè)注冊服務(wù)癱瘓。

2）由節(jié)點(diǎn)分工的角度來看

Zookeeper：ZK集群中節(jié)點(diǎn)分為三類，承擔(dān)不同的任務(wù)

Leader：事務(wù)請求唯一的調(diào)度者和處理者（除了查詢請求）
Follower：處理非事務(wù)請求，參與Leader選舉投票
Observer：處理非事務(wù)請求，但不參與Leader選舉投票

Eureka：在Eureka集群中每個(gè)節(jié)點(diǎn)都是平等的，每個(gè)節(jié)點(diǎn)扮演相同的角色，它們通過相互注冊的方式來感知對方的存在，當(dāng)由注冊消息時(shí)，它們會同步給集群內(nèi)的其他節(jié)點(diǎn)

中文文檔：https://www.springcloud.cc/spring-cloud-greenwich.html

4. SpringCloud Demo

Demo整體結(jié)構(gòu)(父子項(xiàng)目)

api：Bean、DTO、POJO等以及Service接口
controller：服務(wù)消費(fèi)方，前端交互
provider：服務(wù)提供方，服務(wù)實(shí)現(xiàn)
registry：服務(wù)注冊中心

4.1 registry

1）pom.xml

關(guān)鍵點(diǎn)在于導(dǎo)入eureka服務(wù)端依賴以及SpringCloud依賴

<dependencies>
        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-server -->
        <!-- eureka服務(wù)端 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR6</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

2）application.properties

進(jìn)行Eureka服務(wù)端的相關(guān)配置

spring.application.name=SpringCloudDemoRegistry

# server端口，自己喜歡
server.port=8888

# Eureka Server服務(wù)url以及默認(rèn)zone，結(jié)尾必須eureka
eureka.client.service-url.defaultZone= http://127.0.0.1:8888/eureka/

# eureka的自我保護(hù)機(jī)制，k8s環(huán)境下建議false
eureka.server.enable-self-preservation=false

# false表示自己端就是注冊中心，我的功能就是維護(hù)服務(wù)實(shí)例，不需要從server獲取注冊的服務(wù)信息
eureka.client.fetch-registry=false

# false表示不將自己注冊到Eureka Server
eureka.client.register-with-eureka=false

3）EurekaregistryApplication

使用@EnableEurekaServer激活相關(guān)配置，使registry模塊作為注冊中心Server

@EnableEurekaServer //聲明為注冊中心服務(wù)端
@SpringBootApplication
public class EurekaregistryApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaregistryApplication.class, args);
    }
}

4.2 api

1）entity

實(shí)體類以部門和用戶信息為例，由于演示使用了Lombok省點(diǎn)代碼，用于實(shí)現(xiàn)基本的CRUD

Department.class

@Data
@ToString
@NoArgsConstructor
@AllArgsConstructor
public class Department {
    private Long id;
    private Integer dId;
    private String dName;
    private Date updateTime;
}

UserInfo.class

@Data
@ToString
@NoArgsConstructor
@AllArgsConstructor
public class UserInfo {
    private Long id;
    private Integer uId;
    private Integer dId;
    private String uName;
    private String uPhone;
    @Email(message = "非法郵件格式") //Validator格式校驗(yàn)
    private String uEmail;
    private String uAddress;
    private Date updateTime;
    private Department department;
}

2）UserService

UserService為服務(wù)接口，聲明需要提供和消費(fèi)的方法，寫了幾個(gè)簡單查詢

public interface UserService {

    /**
     * 判斷用戶是否存在，0為不存在，返回值與uId相等則存在
     * @param uId
     * @return
     */
    Integer userExist(Integer uId);

    /**
     * 獲取用戶個(gè)人基本信息
     * @param uId
     * @return
     */
    UserInfo getUserInfo(Integer uId);

    /**
     * 獲取用戶個(gè)人詳情信息
     * @param uId
     * @return
     */
    UserInfo getUserDetailsInfo(Integer uId);
}

4.3 provider

1）pom.xml

關(guān)鍵點(diǎn)是引入eureka客戶端依賴、openfeign依賴、SpringCloud依賴

<dependencies>
    	<!-- Springboot的依賴省略... -->
		<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
</dependencies>

<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR6</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
</dependencyManagement>

2）application.properties

配置Eureka、Mybatis以及DataSource數(shù)據(jù)源等信息

spring.application.name=SpringCloudDemoProvider

# Server端口
server.port=9999

# Eureka服務(wù)url
eureka.client.service-url.defaultZone= http://127.0.0.1:8888/eureka/
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true

# Mybatis
mybatis.mapper-locations= classpath:com.maziyao.provider.mapper/*.xml
mybatis.type-aliases-package= com.maziyao.common.entity

# DataSource數(shù)據(jù)源配置
spring.datasource.type=com.zaxxer.hikari.HikariDataSource

# DataSource
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/boot-demo?serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=root

3）EurekaproviderApplication

provider啟動類使用@EnableEurekaClient聲明為EurekaClient客戶端，作為ServiceProvider

@EnableEurekaClient
@SpringBootApplication
@EnableAspectJAutoProxy
@MapperScan("com.maziyao.provider.mapper")
@ComponentScan(basePackages = {
        "com.maziyao.provider.rest",
        "com.maziyao.provider.redis",
        "com.maziyao.provider.service",
        "com.maziyao.provider.config"
})
public class EurekaproviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaproviderApplication.class, args);
    }
}

4）service

UserServiceImpl作為UserService接口實(shí)現(xiàn)類，@Service用于標(biāo)注業(yè)務(wù)層組件

自動注入mapper層的mapper接口并調(diào)用，mapper的SQL語句下面就略了，很簡單

需要注意的是，對于數(shù)據(jù)訪問層組件mapper，使用@Repository進(jìn)行標(biāo)注

@Service("userService")
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public Integer userExist(Integer uId) {
        return userMapper.userExist(uId);
    }

    @Override
    public UserInfo getUserInfo(Integer uId) {
        return userMapper.getUserInfo(uId);
    }

    @Override
    public UserInfo getUserDetailsInfo(Integer uId) {
        return userMapper.getUserDetailsInfo(uId);
    }
}

5）rest

重點(diǎn)是rest包下的UserServer，要知道Eureka是一個(gè)基于REST的服務(wù)

使用@RestController標(biāo)注并聲明為userServer，這個(gè)是SpringBoot注解，用于標(biāo)注控制層組件

@RestController("userServer")
public class UserServer {

    public static final Logger logger = LoggerFactory.getLogger(UserServer.class);

    @Autowired
    private UserService userService;

    @ResponseBody
    @RequestMapping(value = "/exist",method = RequestMethod.GET)
    public Integer existUserByUid(@RequestParam("uId")Integer uId){
        return userService.userExist(uId);
    }

    @ResponseBody
    @RequestMapping(value = "/userInfo",method = RequestMethod.GET)
    public UserInfo getUserInfo(@RequestParam("uId")Integer uId){
        return userService.getUserInfo(uId);
    }

    @ResponseBody
    @RequestMapping(value="/userDetailsInfo",method = RequestMethod.GET)
    public UserInfo getUserDetailsInfo(@RequestParam("uId")Integer uId){
        return userService.getUserDetailsInfo(uId);
    }
}

4.4 consumer

1）pom.xml

在Controller的pom.xml中也需要導(dǎo)入EurekaClient的依賴，對于Provider和Controller都為Client

<dependencies>
    	<!-- SpringBoot依賴省略... -->
		<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>
</dependencies>

2）application.properties

在application.properties中配置Eureka相關(guān)信息

spring.application.name=springCloudDemoController

# Server端口
server.port=8899

# 注冊中心url
eureka.client.service-url.defaultZone= http://127.0.0.1:8888/eureka/
eureka.client.register-with-eureka=true
eureka.client.fetch-registry=true

3）EurekacontrollerApplication

與Provider的啟動類一致，聲明啟動類為Eureka的客戶端

并使用@EnableFeignClients開啟Feign，聲明性的web服務(wù)客戶端

@EnableEurekaClient
@EnableFeignClients
@SpringBootApplication
@EnableAspectJAutoProxy
@ComponentScan({
        "com.maziyao.controller.config",
        "com.maziyao.controller.controller",
        "com.maziyao.controller.rest"
})
public class EurekacontrollerApplication {

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

}

4）rest

controller作為前端交互層，即控制層，此處UserClient聲明調(diào)用方法

使用@FeignClient聲明服務(wù)提供方在application.properties中配置的spring.application.name

以及綁定服務(wù)提供方對應(yīng)rest包下的UserServer類的@RestController("userServer")

@FeignClient(name = "springCloudDemoProvider",contextId = "userServer")
public interface UserClient {

    @ResponseBody
    @RequestMapping(value = "/exist",method = RequestMethod.GET)
    public Integer existUserByUid(@RequestParam("uId")Integer uId);

    @ResponseBody
    @RequestMapping(value = "/userInfo",method = RequestMethod.GET)
    public UserInfo getUserInfo(@RequestParam("uId")Integer uId);

    @ResponseBody
    @RequestMapping(value="/userDetailsInfo",method = RequestMethod.GET)
    public UserInfo getUserDetailsInfo(@RequestParam("uId")Integer uId);

}

5）UserController

控制層，使用@RestController標(biāo)注，并注入U(xiǎn)serClient進(jìn)行調(diào)用

@RestController
public class UserController {

    private static final Logger logger = LoggerFactory.getLogger(UserController.class);

    @Autowired
    private UserClient userClient;

    @ResponseBody
    @RequestMapping(value = "/exist",method = RequestMethod.GET)
    public Integer existUserByUid(@RequestParam("uId") Integer uId){
        return userClient.existUserByUid(uId);
    }

    @ResponseBody
    @RequestMapping(value = "/userInfo",method = RequestMethod.GET)
    public UserInfo getUserInfoByUid(@RequestParam("uId")Integer uId){
        return userClient.getUserInfo(uId);
    }

    @ResponseBody
    @RequestMapping(value = "/userDetailsInfo",method = RequestMethod.GET)
    public UserInfo getUserDetailsInfoByUid(@RequestParam("uId")Integer uId){
        return userClient.getUserDetailsInfo(uId);
    }

}