devbox
从前慢现在也慢
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Cloud整合Zookeeper代替Eureka

作者：从前慢现在也慢 | 2024-03-06 01:32:58

赞

踩

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 注解  早期版本确实生产者和消费者启动类要加  后来就不需要了

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/195258
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号