• Cloud整合Zookeeper代替Eureka

    微服务间通信重构与服务治理笔记-CSDN博客

    Zookeeper是一个分布式协调工具,可以实现注册中心功能

    安装Zookeeper

    随便 就用最新版本吧

    进入Zookeeper 包目录

    cd /usr/local/develop/

    解压

    tar -zxvf apache-zookeeper-3.9.1-bin.tar.gz -C /usr/local/develop

    进入配置文件  

    cd /usr/local/develop/apache-zookeeper-3.9.1-bin/conf

    复制文件

    cp zoo_sample.cfg zoo.cfg

    编辑文件 

    vim zoo.cfg

    mkdir /usr/local/develop/apache-zookeeper-3.9.1-bin/data  这个没必要  会自动创建

     cd /usr/local/develop/apache-zookeeper-3.9.1-bin/bin

    启动Zookeeper

    ./zkServer.sh start

    安装JDK

    解压

    tar -zxvf /usr/local/develop/jdk-8u191-linux-x64.tar.gz -C /usr/local/develop

    配置JAVA_HOME

    export JAVA_HOME=/usr/local/develop/jdk1.8.0_191

    export PATH=$JAVA_HOME/bin:$PATH

    export CLASSPATH=.:$JAVA_HOME/lib

    让环境变量生效

    source /etc/profile

    java -version 查看jdk版本 至此JDK安装完成

    which java 查看调用的是安装在哪里的java

    进入Zookeeper启动目录

    cd /usr/local/develop/apache-zookeeper-3.9.1-bin/bin

    启动

    ./zkServer.sh start

    停止

    ./zkServer.sh stop
     

    配置Zookeeper为系统服务

    vim /etc/systemd/system/zookeeper.service

    [Unit]
    Description=Apache ZooKeeper server
    After=network.target

    [Service]
    Type=forking
    ExecStart=/usr/local/develop/apache-zookeeper-3.9.1-bin/bin/zkServer.sh start
    ExecStop=/usr/local/develop/apache-zookeeper-3.9.1-bin/bin/zkServer.sh stop
    User=root
    Group=root
    Restart=on-failure
    Environment="JAVA_HOME=/usr/local/develop/jdk1.8.0_191"

    [Install]
    WantedBy=multi-user.target

    是配置生效

    systemctl daemon-reload

    开机自启  看自己实际需要

    systemctl enable zookeeper.service

    systemctl start zookeeper.service    启动
    systemctl stop zookeeper.service    停止
    systemctl restart zookeeper.service    重启
    systemctl status zookeeper.service   查看状态

    admin.serverPort=8888指定了ZooKeeper的管理服务器端口。这个管理服务器提供了一个简单的HTTP接口，用于获取ZooKeeper服务的状态和性能指标等信息。通过访问这个端口，你可以获取到ZooKeeper实例的各种管理信息，比如运行状态、连接数、节点数量等。

    默认情况下，ZooKeeper的管理界面并不提供一个全面的Web界面来浏览这些信息，而是提供了一个简单的HTTP服务，通过发送HTTP请求到这个端口，可以获取到JSON格式的状态信息。

    IP:8888/commands/stat

    关闭Zookeeper服务

    systemctl stop zookeeper.service

    systemctl start zookeeper.service

    Docker安装Zookeeper

    docker run -d --name zookeeper --privileged=true -p 2181:2181  -v /mydata/zookeeper/data:/data -v /mydata/zookeeper/conf:/conf -v /mydata/zookeeper/logs:/datalog zookeeper:3.5.7
     

    后面补

    创建支付模块(生产者)

    重新构建支付模块

    pom.xml

    1. <?xml version="1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <parent>
    6.         <artifactId>SpringCloud</artifactId>
    7.         <groupId>org.example</groupId>
    8.         <version>1.0-SNAPSHOT</version>
    9.     </parent>
    10.     <modelVersion>4.0.0</modelVersion>
    11.  
    12.     <artifactId>cloud-provider-payment8084</artifactId>
    13.  
    14.     <properties>
    15.         <maven.compiler.source>8</maven.compiler.source>
    16.         <maven.compiler.target>8</maven.compiler.target>
    17.     </properties>
    18.     <dependencies>
    19.         <dependency>
    20.             <groupId>org.example</groupId>
    21.             <artifactId>cloud-api-commons</artifactId>
    22.             <version>${project.version}</version>
    23.         </dependency>
    24.         
    25.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
    26.         <dependency>
    27.             <groupId>org.springframework.boot</groupId>
    28.             <artifactId>spring-boot-starter-web</artifactId>
    29.         </dependency>
    30.  
    31.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
    32.         <dependency>
    33.             <groupId>org.springframework.boot</groupId>
    34.             <artifactId>spring-boot-starter-actuator</artifactId>
    35.         </dependency>
    36.  
    37.         <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-zookeeper-discovery -->
    38.         <dependency>
    39.             <groupId>org.springframework.cloud</groupId>
    40.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    41.         </dependency>
    42.  
    43.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-devtools -->
    44.         <dependency>
    45.             <groupId>org.springframework.boot</groupId>
    46.             <artifactId>spring-boot-devtools</artifactId>
    47.             <scope>runtime</scope>
    48.             <optional>true</optional>
    49.         </dependency>
    50.  
    51.         <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
    52.         <dependency>
    53.             <groupId>org.projectlombok</groupId>
    54.             <artifactId>lombok</artifactId>
    55.             <optional>true</optional>
    56.         </dependency>
    57.  
    58.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-test -->
    59.         <dependency>
    60.             <groupId>org.springframework.boot</groupId>
    61.             <artifactId>spring-boot-starter-test</artifactId>
    62.             <scope>test</scope>
    63.         </dependency>
    64.  
    65.  
    66.     </dependencies>
    67.  
    68. </project>

    application.yml

    1. server:
    2.   port: 8084
    3.  
    4. spring:
    5.   application:
    6.     name: cloud-provider-payment
    7.   cloud:
    8.     zookeeper:
    9.       connect-string: xxx.xx.xxx.x:2181

    启动类

    控制器

    1. package com.exempla.pay01.controller;
    2.  
    3. import lombok.extern.slf4j.Slf4j;
    4. import org.springframework.beans.factory.annotation.Value;
    5. import org.springframework.web.bind.annotation.GetMapping;
    6. import org.springframework.web.bind.annotation.RequestMapping;
    7. import org.springframework.web.bind.annotation.RestController;
    8.  
    9. import java.util.UUID;
    10.  
    11. /**
    12.  * @author hrui
    13.  * @date 2024/3/2 6:07
    14.  */
    15. @RestController
    16. @Slf4j
    17. @RequestMapping("/payment")
    18. public class PaymentController {
    19.  
    20.     @Value("${server.port}")
    21.     private String serverPort;
    22.  
    23.     @GetMapping(value = "/zk")
    24.     public String paymentzk(){
    25.         return "springcloud with zookeeper:"+serverPort+"\t"+ UUID.randomUUID().toString();
    26.     }
    27. }

    启动8084 注册进Zookeeper   lombok找不到  加个版本

    记得Zookeeper服务器开通安全组

    有可能版本冲突  解决办法

    cd /usr/local/develop/apache-zookeeper-3.9.1-bin/bin

    ./zkCli.sh

    ls /

    ls /services

    ls /services/cloud-provider-payment

    ls /services/cloud-provider-payment/04bbfd46-50e0-462a-bd22-b8083cc445cf

    get /services/cloud-provider-payment/04bbfd46-50e0-462a-bd22-b8083cc445cf

    上面这个JSON串 就是微服务注册相关的信息

    quit

    也可以

    IP:8888/commands/stat 看下

    访问接口  可以

    localhost:8084/payment/zkicon-default.png?t=N7T8http://localhost:8084/payment/zk

    创建订单模块(消费者)

     

    pom.xml

    1.  
    2.     <dependencies>
    3.  
    4.         <dependency>
    5.             <groupId>com.atguigu.springcloud</groupId>
    6.             <artifactId>cloud-api-commons</artifactId>
    7.             <version>${project.version}</version>
    8.         </dependency>
    9.  
    10.  
    11.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
    12.         <dependency>
    13.             <groupId>org.springframework.boot</groupId>
    14.             <artifactId>spring-boot-starter-web</artifactId>
    15.         </dependency>
    16.  
    17.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
    18.         <dependency>
    19.             <groupId>org.springframework.boot</groupId>
    20.             <artifactId>spring-boot-starter-actuator</artifactId>
    21.         </dependency>
    22.  
    23.         <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-zookeeper-discovery -->
    24.         <dependency>
    25.             <groupId>org.springframework.cloud</groupId>
    26.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
    27.         </dependency>
    28.  
    29.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-devtools -->
    30.         <dependency>
    31.             <groupId>org.springframework.boot</groupId>
    32.             <artifactId>spring-boot-devtools</artifactId>
    33.             <scope>runtime</scope>
    34.             <optional>true</optional>
    35.         </dependency>
    36.  
    37.         <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
    38.         <dependency>
    39.             <groupId>org.projectlombok</groupId>
    40.             <artifactId>lombok</artifactId>
    41.             <optional>true</optional>
    42.         </dependency>
    43.  
    44.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-test -->
    45.         <dependency>
    46.             <groupId>org.springframework.boot</groupId>
    47.             <artifactId>spring-boot-starter-test</artifactId>
    48.             <scope>test</scope>
    49.         </dependency>
    50.  
    51.  
    52.     </dependencies>

    启动类

    application.yml

    1. server:
    2.   port: 80
    3.  
    4. spring:
    5.   application:
    6.     name: cloud-consumer-order
    7.   cloud:
    8.     zookeeper:
    9.       connect-string: xxx.xx.xx.x:2181

    配置RestTemplate和负载均衡

    控制器

    启动服务

    localhost/consumer/payment/zk

    关于@EnableDiscoveryClient 注解  早期版本确实生产者和消费者启动类要加  后来就不需要了

  • 相关阅读:
    2022杭电多校联赛第九场 题解
    mysql常见错误
    JS点击按钮获取列表信息，纯JS代码创建表格，如何引入CSS框架，＜svg＞标签
    用飞书写博客,并自动部署
    了解 NFT 质押：Web3 中赚取被动收益的另一种方式
    SOFAStack软件供应链安全产品解析——SCA软件成分分析
    KUKA机器人通过3点法设置工作台基坐标系的具体方法
    React 知识点：基础语法、组件、React-Router、Redux
    Tech Lead（技术经理） 带人之道
    VUE核心
  • 原文地址：https://blog.csdn.net/tiantiantbtb/article/details/136408824