SpringCloud&alibaba學習筆記系列3

SpringCloud&alibaba學習筆記系列

該筆記僅作為個人學習使用。

第三章zookeeper的服務發現與注冊

官網：https://zookeeper.apache.org/

使用zookeeper代替eureka

3.1注冊中心zookeeper

3.1.1概述

ZooKeeper是Hadoop的正式子項目，它是一個針對大型分布式系統的可靠協調系統，提供的功能包括：配置維護、名字服務、分布式同步、組服務等。也可以實作注冊中心功能；

3.1.2下載下傳安裝

下載下傳安裝這裡就不贅述，詳見我我的部落格《離線安裝zookeeper》。

3.2服務提供者

下面我們實際示範通過zookeeper作為服務注冊中心和如何注冊到zookeeper。

1.建立cloud-provider-payment8004

SpringCloud&alibaba學習筆記系列3

2.pom檔案

直接從8001拷貝過來依賴

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2020</artifactId>
        <groupId>com.jzt</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-provider-payment8004</artifactId>

    <dependencies>

        <!--zookeeper用戶端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
            <!--解決zookeeper版本沖突問題-->
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.9</version>
        </dependency>

        <dependency>
            <groupId>com.jzt</groupId>
            <artifactId>cloud-api-common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</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-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.14</version>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>
</project>

3.yml配置

server:
  port: 8004

spring:
  application:
    name: cloud-provider-payment
  cloud:
    zookeeper:
      connect-string: 192.168.31.111:2181

4.主啟動類

package com.jzt;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
//import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

/**
 * 功能描述：
 *
 * @Author: sj
 * @Date: 2020/10/25 11:26
 */
@SpringBootApplication
//@EnableEurekaClient
@EnableDiscoveryClient  //使用consul或者zookeeper作為注冊中心時注冊服務
public class PaymentService8004 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentService8004.class, args);
    }
}

5.controller

package com.jzt.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.UUID;

/**
 * 功能描述：
 *
 * @Author: sj
 * @Date: 2020/10/25 15:46
 */
@RestController
@Slf4j
public class PaymentController {
    @Value("${server.port}")
    private String port;

    @RequestMapping(value = "/payment/zk")
    public String paymentzk(){
        return "zookeeper :"+port+"\t"+ UUID.randomUUID().toString();
    }
}

6.解決jar包沖突問題

啟動後的問題：

SpringCloud&alibaba學習筆記系列3

這是因為springcloud的zookeeper元件自帶zookeeper包，這與自己引入的zookeeper的版本不一緻，最終導緻出錯。

可以使用标簽來去除springcloud自身依賴的zookeeper包：

<!--zookeeper用戶端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.9</version>
        </dependency>

7.測試

http://localhost:8004/payment/zk

SpringCloud&alibaba學習筆記系列3

進入zookeeper，檢視節點資訊：

SpringCloud&alibaba學習筆記系列3

在zookeeper伺服器中也能夠檢視到我們建立的服務了！說明我們的cloud-payment-service8004已經成功注冊到zookeeper注冊中心。

服務節點是臨時節點還是持久節點

zookeeper的節點時臨時性的。當zookeeper接收不到注冊服務的心跳時會立刻删除該服務節點。zookeeper在CAP理論中屬性CP模型

3.3服務消費者

下面我們建構一個服務消費者，将它也注冊到zookeeper中。

1.建立cloud-consumerzk-order80

SpringCloud&alibaba學習筆記系列3

2.配置POM檔案

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>springcloud2020</artifactId>
        <groupId>com.jzt</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumerzk-order80</artifactId>

    <dependencies>
        <!--zookeeper用戶端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
            <!--解決zookeeper版本沖突問題-->
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.9</version>
        </dependency>

        <dependency>
            <groupId>com.jzt</groupId>
            <artifactId>cloud-api-common</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</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-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.14</version>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

    </dependencies>
</project>

3.配置yml檔案

server:
  port: 80

spring:
  application:
    name: cloud-comsumerzk-order
  cloud:
    zookeeper:
      connect-string: 192.168.31.111:2181

4.主啟動類

package com.jzt;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 功能描述：
 *
 * @Author: sj
 * @Date: 2020/11/10 7:21
 */
@SpringBootApplication
@EnableDiscoveryClient
public class OrderZkOrder80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderZkOrder80.class, args);
    }
}

5.業務類

配置類

package com.jzt.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * 功能描述：
 *
 * @Author: sj
 * @Date: 2020/11/10 7:24
 */
@Configuration
public class ApplicationContextConfig {

    @Bean
    @LoadBalanced   //開啟負載均衡功能
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

controller

package com.jzt.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

/**
 * 功能描述：
 *
 * @Author: sj
 * @Date: 2020/11/10 7:29
 */
@RestController
public class OrderZKController {

    public static final String INVOKE_URL = "http://cloud-provider-payment";

    @Resource
    private RestTemplate restTemplate;

    @GetMapping(value = "consumer/payment/zk")
    public String paymentInfo(){
        String result = restTemplate.getForObject(INVOKE_URL+"/payment/zk", String.class);
        return result;
    }
}

6.測試

SpringCloud&alibaba學習筆記系列3

檢視zookeeper節點資訊，發現cloud-consumer-order服務已經注冊到zk中。

SpringCloud&alibaba學習筆記系列3

服務調用也能正常執行。

SpringCloud&alibaba學習筆記系列3

第三章zookeeper的服務發現與注冊

3.1注冊中心zookeeper

3.1.1概述

3.1.2下載下傳安裝

3.2服務提供者

1.建立cloud-provider-payment8004

2.pom檔案

3.yml配置

4.主啟動類

5.controller

6.解決jar包沖突問題

7.測試

3.3服務消費者

1.建立cloud-consumerzk-order80

2.配置POM檔案

3.配置yml檔案

4.主啟動類

5.業務類

6.測試

繼續閱讀

分布式幂等問題解決方案三部曲綱要一背景二什麼是幂等三解決方案三部曲四總結

分布式配置中心+總線——config+bus前言服務端用戶端SpringCloud Bus

微服務架構專題十：Spring-Cloud 之 config 分布式配置中心

Spring Cloud 之Config分布式集中配置中心詳解

springcloud-config配置中心分布式管理

Config：分布式中心

spring cloud備忘筆記-7-分布式配置中心（Spring Cloud Config）

SpringCloud實戰之路 | 應用篇（七）分布式配置中心Spring Cloud Config+Bus

【SpringCloud】搭建高可用分布式配置中心（Spring Cloud Config）（一）全過程詳解（手動重新整理）Spring Cloud 2.0.2.RELEASE

Spring Cloud Config 元件、配合GitHub搭建高可用分布式配置中心

從零開始搭建微服務：跨域處理

線上搭建SpringCloud，一分鐘搞定

谷粒商城：認證服務準備+60s短信驗證

cron 表達式解讀

微服務-性能壓測\緩存redis和分布式鎖redisson和SpringCache

sleuth鍊路追蹤

SpringCloud&amp;alibaba學習筆記系列3

第三章zookeeper的服務發現與注冊

3.1注冊中心zookeeper

3.1.1概述

3.1.2下載下傳安裝

3.2服務提供者

1.建立cloud-provider-payment8004

2.pom檔案

3.yml配置

4.主啟動類

5.controller

6.解決jar包沖突問題

7.測試

3.3服務消費者

1.建立cloud-consumerzk-order80

2.配置POM檔案

3.配置yml檔案

4.主啟動類

5.業務類

6.測試

繼續閱讀

SpringCloud&alibaba學習筆記系列3