SpringBoot整合SpringCloud

1. SpringCloud特點

SpringCloud專注于為典型的用例和擴展機制提供良好的開箱即用體驗，以涵蓋其他情況：

• 分布式/版本化配置

• 服務注冊和發現 Eureka

• 路由 Zuul

• 服務到服務的呼叫

• 負載均衡 Ribbon

• 斷路器 Hystrix

• 分布式訊息傳遞

2. 分布式系統的三個指標CAP

在介紹SpringCloud默認使用的注冊中心前，先介紹分布式系統的三個指標，分別是：

• Consistency：一致性，在分布式系統中，更新操作執行成功后所有的用戶的讀操作必須回傳最新值；client寫入，server同步至整個系統；

• Availability：可用性，只要收到用戶的請求，在一定的時間內服務器就必須給出回應，回應的結果可以是成功或是失敗；

• Partition tolerance：磁區容錯，即區間通信可能失敗，在網路中斷，訊息丟失的情況下，仍對外提供服務；一般無法避免，可以認為CAP中的P總是成立

CAP定律說的是，在一個分布式計算機系統中，一致性C，可用性A，磁區容錯性P這三種保證無法同時得到滿足，最多滿足兩個：

1. 放棄P

為了避免磁區容錯性問題的發生，一種做法是將所有與事務相關的資料都放在一臺服務器上，雖然不能保證100%系統不會出錯，但是不會碰到由磁區帶來的負面效果，這樣的做法會嚴重影響系統的擴展性，

2. 放棄A

放棄可用性，一旦遇到磁區容錯故障，受到影響的服務器需要等待一定的時間，因此會導致在等待期間系統無法對外提供服務，

3. 放棄C

這兒說的放棄一致性，并不是完全放棄資料的一致性，而是放棄資料的強一致性，而保留資料的最終一致性，以網路購物為例，對只剩下一件庫存的商品，如果同時接受到了兩份訂單，那么較晚的訂單將被告知商品告罄，

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

3. Eureka

基本介紹

Eureka是SpringCloud官方推薦用于服務注冊和發現，一個基于REST的服務

SpringBoot實作了Netflix OSS的集成，使用Eureka的原因之一是因為其可以利用Spring Cloud Netflix的其他組件：智能路由(Zuul)、客戶端負載均衡(Ribbon)等

基本組成

Eureka由多個Instance(服務實體)組成，分為Eureka Server和Eureka Client

其中Eureka Client又可細分為：Service Provider、Service Consumer

• Eureka Server：服務端，提供服務的注冊和發現；

• Eureka Client：客戶端

  • Service Provider：服務提供方，將自身服務注冊到Eureka，讓消費方找到
  • Service Consumer：服務消費方，從Eureka獲取注冊服務串列，從而消費服務

Eureka和Zookeeper

1）由CAP理論的角度來看

Zookeeper：ZK保證CP，突出強一致性，但無法保證每次訪問服務可用性，比如ZK會出現這樣一種情況：當master節點因為網路故障與其他節點失去聯系時，剩余節點會重新進行leader選舉，在ZK選舉leader期間整個ZK集群都是不可用的，這就導致了在選舉期間注冊服務癱瘓，在云部署的環境下，因網路問題使得ZK集群失去master節點是較大概率會發生的事兒，雖然服務最侄訓恢復，但是漫長的選舉時間導致的注冊長期不可用是難以容忍的，

Eureka：Eureka保證AP，Eureka在設計時就優先保證可用性，對于Eureka中的節點，每個節點都是平等的，幾個節點掛掉也不會影響正常節點的作業，剩余的節點依然可以提供注冊和查詢服務，但Eureka不保證強一致性，即查到的資訊可能不是最新的，此外Eureka還有一種自我保護機制，如果在15分鐘內超過85%的節點都沒有正常的心跳，那么Eureka就會認為客戶端和注冊中心出現了網路故障，但會保證當前節點依然可用，不會像ZK導致整個注冊服務癱瘓，

2）由節點分工的角度來看

Zookeeper：ZK集群中節點分為三類，承擔不同的任務

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

Eureka：在Eureka集群中每個節點都是平等的，每個節點扮演相同的角色，它們通過相互注冊的方式來感知對方的存在，當由注冊訊息時，它們會同步給集群內的其他節點

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

4. SpringCloud Demo

Demo整體結構(父子專案)

• api：Bean、DTO、POJO等以及Service介面

• controller：服務消費方，前端互動

• provider：服務提供方，服務實作

• registry：服務注冊中心

4.1 registry

1）pom.xml

關鍵點在于匯入eureka服務端依賴以及SpringCloud依賴

  <dependencies>
        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-server -->
        <!-- eureka服務端 -->
        <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

進行Eureka服務端的相關配置

spring.application.name=SpringCloudDemoRegistry

# server埠，自己喜歡
server.port=8888

# Eureka Server服務url以及默認zone，結尾必須eureka
eureka.client.service-url.defaultZone= http://127.0.0.1:8888/eureka/

# eureka的自我保護機制，k8s環境下建議false
eureka.server.enable-self-preservation=false

# false表示自己端就是注冊中心，我的功能就是維護服務實體，不需要從server獲取注冊的服務資訊
eureka.client.fetch-registry=false

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

3）EurekaregistryApplication

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

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

4.2 api

1）entity

物體類以部門和用戶資訊為例，由于演示使用了Lombok省點代碼，用于實作基本的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格式校驗
    private String uEmail;
    private String uAddress;
    private Date updateTime;
    private Department department;
}

2）UserService

UserService為服務介面，宣告需要提供和消費的方法，寫了幾個簡單查詢

public interface UserService {

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

    /**
     * 獲取用戶個人基本資訊
     * @param uId
     * @return
     */
    UserInfo getUserInfo(Integer uId);

    /**
     * 獲取用戶個人詳情資訊
     * @param uId
     * @return
     */
    UserInfo getUserDetailsInfo(Integer uId);
}

4.3 provider

1）pom.xml

關鍵點是引入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資料源等資訊

spring.application.name=SpringCloudDemoProvider

# Server埠
server.port=9999

# Eureka服務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資料源配置
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介面實作類，@Service用于標注業務層組件

自動注入mapper層的mapper介面并呼叫，mapper的SQL陳述句下面就略了，很簡單

需要注意的是，對于資料訪問層組件mapper，使用@Repository進行標注

@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

重點是rest包下的UserServer，要知道Eureka是一個基于REST的服務

使用@RestController標注并宣告為userServer，這個是SpringBoot注解，用于標注控制層組件

@RestController("userServer")
public class UserServer {

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

    @Autowired
    private UserService userService;

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

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

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

4.4 consumer

1）pom.xml

在Controller的pom.xml中也需要匯入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相關資訊

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服務客戶端

@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宣告呼叫方法

使用@FeignClient宣告服務提供方在application.properties中配置的spring.application.name

以及系結服務提供方對應rest包下的UserServer類的@RestController("userServer")

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

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

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

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

}

5）UserController

控制層，使用@RestController標注，并注入UserClient進行呼叫

@RestController
public class UserController {

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

    @Autowired
    private UserClient userClient;

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

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

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

}

4.5 POSTMAN一下

注意：最后記得mvn install，需要先將registry運行起來，再分別運行provider和controller

啟動registry：

啟動provider：

啟動consumer：

result：

標籤：其他

上一篇：Python爬蟲案例：逆向分析xx音樂請求引數（支持下載SQ超品音質）

下一篇：IDEA 2020.2 部署JSF專案