2. 程式人生 > 其它 >（八）SpringCloud整合zookeeper

（八）SpringCloud整合zookeeper

阿新 • • 發佈：2021-10-01

支付服務註冊進zookeeper

zookeeper是一個分散式協調工具，可以實現註冊中心功能

環境搭建

先確認兩臺機器是否能夠ping通，關閉Linux伺服器防火牆

1.本地ping雲伺服器公網ip

C:\Users\Lenovo>ping 81.68.160.85

正在 Ping 81.68.160.85 具有 32 位元組的資料:
來自 81.68.160.85 的回覆: 位元組=32 時間=32ms TTL=49
來自 81.68.160.85 的回覆: 位元組=32 時間=32ms TTL=49
來自 81.68.160.85 的回覆: 位元組=32 時間=32ms TTL=49
來自 81.68.160.85 的回覆: 位元組=32 時間=35ms TTL=49

81.68.160.85 的 Ping 統計資訊:
    資料包: 已傳送 = 4，已接收 = 4，丟失 = 0 (0% 丟失)，
往返行程的估計時間(以毫秒為單位):
    最短 = 32ms，最長 = 35ms，平均 = 32ms

2.雲伺服器ping本地內網地址

[root@VM-4-15-centos bin]# ping -c 4  192.168.31.244
PING 192.168.31.244 (192.168.31.244) 56(84) bytes of data.

--- 192.168.31.244 ping statistics ---
4 packets transmitted, 0 received, 100% packet loss, time 2999ms

服務提供者

1.新建名為cloud-provider-payment8004的Maven工程

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>cloud2021</artifactId>
        <groupId>com.ylc.cloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

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

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <!-- SpringBoot整合Web元件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency><!-- 引入自己定義的api通用包，可以使用Payment支付Entity -->
            <groupId>com.ylc.cloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>${project.version}</version>
        </dependency>
        <!-- SpringBoot整合zookeeper客戶端 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
            <!--先排除自帶的zookeeper3.5.3 防止與3.4.9起衝突-->
            <exclusions>
                <exclusion>
                    <groupId>org.apache.zookeeper</groupId>
                    <artifactId>zookeeper</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!--新增zookeeper3.5.7版本-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.7</version>
        </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>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

3.YML

8004表示註冊到zookeeper伺服器的支付服務提供者埠號
server:
  port: 8004

#服務別名----註冊zookeeper到註冊中心名稱
spring:
  application:
    name: cloud-provider-payment
  cloud:
    zookeeper:
      connect-string: 127.0.0.1:2181 # 192.168.111.144:2181 #

4.主啟動類

package com.ylc.cloud;

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

@SpringBootApplication
@EnableDiscoveryClient//該註解用於向使用consul或者zookeeper作為註冊中心時註冊服務
public class PaymentMain8004 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8004.class, args);
    }
}

5.controller

package com.ylc.cloud.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;

@RestController
@Slf4j
public class PaymentController
{
    @Value("${server.port}")
    private String serverPort;

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

6.啟動8004註冊進zookeeper（要先啟動zookeeper的server）

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/D:/%e8%bd%af%e4%bb%b6/maven-repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/D:/%e8%bd%af%e4%bb%b6/maven-repository/org/slf4j/slf4j-log4j12/1.7.29/slf4j-log4j12-1.7.29.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder]

原因是Zookeeper中安裝了slf4j發生了衝突，在匯入的時候排除就好了

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.5.7</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
        </exclusion>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
    </exclusions>
</dependency>

使用外網訪問阿里雲伺服器ZooKeeper_Life is for sharing的部落格-CSDN部落格

在連通伺服器上zookeeper的時候，注意關閉伺服器防火牆
還要開放伺服器的安全組埠，不然連不上
還要在zookeeper配置檔案zoo.cfg中，新增

7.測試

啟動zookeeper客戶端

[zk: localhost:2181(CONNECTED) 0] ls /
[services, zookeeper]
[zk: localhost:2181(CONNECTED) 1] ls /services
[cloud-provider-payment]
[zk: localhost:2181(CONNECTED) 2] ls /services/cloud-provider-payment
[3e41dc65-cff7-4c86-97fb-e4eb1c11e12d]
[zk: localhost:2181(CONNECTED) 4] get /services/cloud-provider-payment/3e41dc65-cff7-4c86-97fb-e4eb1c11e12d
{"name":"cloud-provider-payment","id":"3e41dc65-cff7-4c86-97fb-e4eb1c11e12d","address":"DESKTOP-NV7QOIN","port":8004,"sslPort":null,"payload":{"@class":"org.springframework.cloud.zookeeper.discovery.ZookeeperInstance","id":"application-1","name":"cloud-provider-payment","metadata":{}},"registrationTimeUTC":1631507714643,"serviceType":"DYNAMIC","uriSpec":{"parts":[{"value":"scheme","variable":true},{"value":"://","variable":false},{"value":"address","variable":true},{"value":":","variable":false},{"value":"port","variable":true}]}}

json格式化get /services/cloud-provider-payment/3e41dc65-cff7-4c86-97fb-e4eb1c11e12d結果

{
    "name":"cloud-provider-payment",
    "id":"3e41dc65-cff7-4c86-97fb-e4eb1c11e12d",
    "address":"DESKTOP-NV7QOIN",
    "port":8004,
    "sslPort":null,
    "payload":{
        "@class":"org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
        "id":"application-1",
        "name":"cloud-provider-payment",
        "metadata":{

        }
    },
    "registrationTimeUTC":1631507714643,
    "serviceType":"DYNAMIC",
    "uriSpec":{
        "parts":[
            {
                "value":"scheme",
                "variable":true
            },
            {
                "value":"://",
                "variable":false
            },
            {
                "value":"address",
                "variable":true
            },
            {
                "value":":",
                "variable":false
            },
            {
                "value":"port",
                "variable":true
            }
        ]
    }
}

臨時還是持久節點

ZooKeeper的服務節點是臨時節點，服務登出以後一段時間後（心跳時間）會消失

訂單服務註冊進zookeeper

1.新建cloud-consumerzk-order80

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>cloud2021</artifactId>
        <groupId>com.ylc.cloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

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

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <dependencies>
        <!-- SpringBoot整合Web元件 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- SpringBoot整合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>
        <!--新增zookeeper3.4.9版本-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.7</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-api</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </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>
            <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

#服務別名----註冊zookeeper到註冊中心名稱
spring:
  application:
    name: cloud-consumer-order
  cloud:
    zookeeper:
      connect-string: 81.68.160.85:2181

4.主啟動類

package com.ylc.cloud;

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

@SpringBootApplication
@EnableDiscoveryClient
public class OrderZKMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderZKMain80.class, args);
    }
}

5.業務類

config

package com.ylc.cloud.config;

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

@Configuration
public class ApplicationContextConfig {
    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate()
    {
        return new RestTemplate();
    }
}

controller

package com.ylc.cloud.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;

@RestController
@Slf4j
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.驗證測試

執行ZooKeeper服務端，cloud-consumerzk-order80，cloud-provider-payment8004

[root@VM-4-15-centos apache-zookeeper-3.5.7-bin]# bin/zkCli.sh
[zk: localhost:2181(CONNECTED) 0] ls /
[services, zookeeper]
[zk: localhost:2181(CONNECTED) 1] ls /services
[cloud-consumer-order, cloud-provider-payment]

7.訪問測試地址 http://localhost/consumer/payment/zk

相關推薦

（八）SpringCloud整合zookeeper

支付服務註冊進zookeeper zookeeper是一個分散式協調工具，可以實現註冊中心功能

Storm 系列（八）—— Storm 整合 HDFS 和 HBase

一、Storm整合HDFS 1.1 專案結構 本用例原始碼下載地址：storm-hdfs-integration 1.2 專案主要依賴

Dubbo原始碼解析（十八）遠端通訊——Zookeeper

遠端通訊——Zookeeper 目標：介紹基於zookeeper的來實現的遠端通訊、介紹dubbo-remoting-zookeeper內的原始碼解析。

Hadoop 系列（八）—— 基於 ZooKeeper 搭建 Hadoop 高可用叢集

一、高可用簡介 Hadoop 高可用 (High Availability) 分為 HDFS 高可用和 YARN 高可用，兩者的實現基本類似，但 HDFS NameNode 對資料儲存及其一致性的要求比 YARN ResourceManger 高得多，所以它的實現也更加複雜，故

Spring Boot實戰（八）：Spring Boot整合Mybatis並完成CRUD操作

MyBatis 是一款優秀的持久層框架，被各大網際網路公司使用，本文使用Spring Boot整合Mybatis，並完成CRUD操作。

Apache Dubbo 原始碼搭建與解讀（八）—— Dubbo 註冊中心之ZooKeeper

Dubbo Provider 在啟動時會將自身的服務資訊整理成 URL 註冊到註冊中心，Dubbo Consumer 在啟動時會向註冊中心訂閱感興趣的 Provider 資訊，之後 Provider 和 Consumer 才能建立連線，進行後續的互動。可見

（八）前後端整合之跨域問題

springboot專案+vue的整合，解決方案有兩種：一是直接採用springboot的註解@CrossOrigin；二是新增配置類

Spring學習（八） 整合mybatis

技術標籤：Spring後端Javamybatisspringjava 十二、整合Mybatis 步驟： 匯入相關的jar包

SpringCloud微服務實戰——搭建企業級開發框架（八）：使用註解校驗微服務訊息引數

  平時開發過程中，經常要用到引數校驗，如果直接在程式碼邏輯裡面寫引數校驗，程式碼有點冗餘且用起來不是非常方便，顯得程式碼邏輯複雜且重複程式碼太多，這裡我們使用註解的方式進行引數校驗,SpringBoot中常用

OpenGL學習（八）-- OpenGL ES 初探（上）

我的 OpenGL 專題學習目錄，希望和大家一起學習交流進步！ OpenGL學習（一）-- 術語瞭解

iOS彙編教程（八）靜態連結中的 Relocation - 靜態庫連結時是如何保證對變數的相對定址依然正確的？

系列文章 iOS彙編入門教程（一）ARM64彙編基礎 iOS彙編入門教程（二）在Xcode工程中嵌入彙編程式碼

Dubbo原始碼解析（七）註冊中心——zookeeper

註冊中心——zookeeper 目標：解釋以為zookeeper實現的註冊中心原理，解讀duubo-registry-zookeeper的原始碼

Dubbo原始碼解析（八）遠端通訊——開篇

遠端通訊——開篇 目標：介紹之後解讀遠端通訊模組的內容如何編排、介紹dubbo-remoting-api中的包結構設計以及最外層的的原始碼解析。

Flink 系列（八）—— Flink Standalone 叢集部署

一、部署模式 Flink 支援使用多種部署模式來滿足不同規模應用的需求，常見的有單機模式，Standalone Cluster 模式，同時 Flink 也支援部署在其他第三方平臺上，如 YARN，Mesos，Docker，Kubernetes 等。以下主要介紹

Java SE基礎鞏固（八）：序列化

在資料處理中，將資料結構或者物件轉換成其他可用的格式，並做持久化儲存或者將其傳送到網路流中，這種行為就是序列化，反序列化則是與之相反。

探索ElasticSearch-深入搜尋之全文搜尋（八）

前言 學習需要先打好基礎，最後才能逐步深入。今天來重新探索下ElasticSearch的全文搜尋。

Hive 系列（八）—— Hive 資料查詢詳解

一、資料準備 為了演示查詢操作，這裡需要預先建立三張表，並載入測試資料。

HBase 系列（八）——HBase 協處理器

一、簡述 在使用 HBase 時，如果你的資料量達到了數十億行或數百萬列，此時能否在查詢中返回大量資料將受制於網路的頻寬，即便網路狀況允許，但是客戶端的計算處理也未必能夠滿足要求。在這種情況下，協處理器（Copr

Scala 系列（八）—— 類和物件

一、初識類和物件 Scala 的類與 Java 的類具有非常多的相似性，示例如下： // 1. 在 scala 中，類不需要用 public 宣告,所有的類都具有公共的可見性

Spark 系列（八）—— Spark SQL 之 DataFrame 和 Dataset

一、Spark SQL簡介 Spark SQL 是 Spark 中的一個子模組，主要用於操作結構化資料。它具有以下特點：