AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

（八）SpringCloud整合zookeeper

2023-01-08 100
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
注册配置 MSE Nacos/ZooKeeper，118元/月
任务调度 XXL-JOB 版免费试用，400 元额度，开发版规格
云原生网关 MSE Higress，422元/月
简介： （八）SpringCloud整合zookeeper

支付服务注册进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


文章标签：
微服务引擎
Java
Linux
网络安全
Maven
数据格式
JSON
关键词：
springcloud zookeeper
微服务引擎springcloud
springcloud微服务引擎
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
炒焖煎糖板栗
目录
相关文章
技术自由圈/原疯狂创客圈
|
6天前
|
Linux 网络安全 Docker
尼恩一键开发环境： vagrant+java+springcloud+redis+zookeeper镜像下载(&制作详解)
尼恩提供了一系列文章，旨在帮助开发者轻松搭建一键开发环境，涵盖Java分布式、高并发场景下的多种技术组件安装与配置。内容包括但不限于Windows和CentOS虚拟机的安装与排坑指南、MySQL、Kafka、Redis、Zookeeper等关键组件在Linux环境下的部署教程，并附带详细的视频指导。此外，还特别介绍了Vagrant这一虚拟环境部署工具，
技术自由圈/原疯狂创客圈
40 6
尼恩一键开发环境： vagrant+java+springcloud+redis+zookeeper镜像下载(&制作详解)
蓝染-惣右介
|
2月前
|
存储 SpringCloudAlibaba Java
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论
一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论。
蓝染-惣右介
107 1
【SpringCloud Alibaba系列】一文全面解析Zookeeper安装、常用命令、JavaAPI操作、Watch事件监听、分布式锁、集群搭建、核心理论
2G冲浪词条
|
6月前
|
XML Java 数据格式
Spring Cloud全解析：注册中心之zookeeper注册中心
使用ZooKeeper作为Spring Cloud的注册中心无需单独部署服务器，直接利用ZooKeeper服务端功能。项目通过`spring-cloud-starter-zookeeper-discovery`依赖实现服务注册与发现。配置文件指定连接地址，如`localhost:2181`。启动应用后，服务自动注册到ZooKeeper的`/services`路径下，形成临时节点，包含服务实例信息。
2G冲浪词条
453 3
香吧香
|
7月前
|
Java Spring
spring cloud gateway在使用 zookeeper 注册中心时，配置https 进行服务转发
spring cloud gateway在使用 zookeeper 注册中心时，配置https 进行服务转发
香吧香
174 3
诸葛子房
|
9月前
|
Java Spring
spring cloud使用zookeeper作为注册中心—consumer
spring cloud使用zookeeper作为注册中心—consumer
诸葛子房
67 0
诸葛子房
|
9月前
|
Java Spring 消息中间件
spring cloud 使用zookeeper作为注册中心—provider
spring cloud 使用zookeeper作为注册中心—provider
诸葛子房
96 0
阿里云博主-阿演
|
负载均衡 Java Apache
springcloud整合zookeeper注册中心
下载3.4的，3.5 的解压的时候回出现文件已存在的错误，解压完会多出来一个文件夹，然后启动的时候找不到jar包报错。
阿里云博主-阿演
131 1
springcloud整合zookeeper注册中心
游客w4fv6b2av3kec
|
Cloud Native 测试技术 API
【云原生】springcloud06——订单服务注册zookeeper
【云原生】springcloud06——订单服务注册zookeeper
游客w4fv6b2av3kec
118 0
游客w4fv6b2av3kec
|
算法 前端开发 Java
springcloud05——Zookeeper实现支付微服务
springcloud05——Zookeeper实现支付微服务
游客w4fv6b2av3kec
117 0
玉面大蛟龙
|
Java Linux 程序员
SpringCloud学习（八）：服务注册进入zookeeper
SpringCloud学习（八）：服务注册进入zookeeper
玉面大蛟龙
217 0
SpringCloud学习（八）：服务注册进入zookeeper

热门文章

最新文章

  • 1
    阿里云微服务引擎 MSE 及 云原生 API 网关 2025 年 1 月产品动态
  • 2
    微服务引擎 MSE 及云原生 API 网关 2025 年 1 月产品动态
  • 3
    2025春招 SpringCloud 面试题汇总
  • 4
    智慧工地解决方案，Spring Cloud智慧工地源代码
  • 5
    智慧工地云平台的技术架构解析：微服务+Spring Cloud如何支撑海量数据？
  • 6
    尼恩一键开发环境： vagrant+java+springcloud+redis+zookeeper镜像下载(&制作详解)
  • 7
    Spring Cloud是什么及基本特性都有哪些？
  • 8
    springcloud-config客户端启用服务发现报错找不到bean EurekaHttpClient
  • 9
    注册中心如何选型？Eureka、Zookeeper、Nacos怎么选
  • 10
    如何设计一个注册中心？以Zookeeper为例
  • 1
    尼恩一键开发环境： vagrant+java+springcloud+redis+zookeeper镜像下载(&制作详解)
    40
  • 2
    Spring Cloud是什么及基本特性都有哪些？
    41
  • 3
    智慧工地云平台的技术架构解析：微服务+Spring Cloud如何支撑海量数据？
    45
  • 4
    2025春招 SpringCloud 面试题汇总
    190
  • 5
    springcloud-config客户端启用服务发现报错找不到bean EurekaHttpClient
    26
  • 6
    智慧工地解决方案，Spring Cloud智慧工地源代码
    55
  • 7
    AI 时代：从 Spring Cloud Alibaba 到 Spring AI Alibaba
    139
  • 8
    微服务架构设计与实践：用Spring Cloud实现抖音的推荐系统
    101
  • 9
    建筑施工一体化信息管理平台源码，支持微服务架构，采用Java、Spring Cloud、Vue等技术开发。
    83
  • 10
    Spring Cloud Alibaba AI 入门与实践
    356

    • 相关课程

    更多
  • 微服务+全栈在线教育实战项目演练（SpringCloud Alibaba+SpringBoot）
  • Dubbo + ZooKeeper 的服务发现最佳实践
  • 分布式协调系统 Zookeeper 快速入门
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 大数据ZooKeeper快速入门
  • 微服务实战-服务注册与发现 - Nacos Discovery

    • 相关电子书

    更多
  • 搭建基于SpringCloud的微服务应用
  • ALI技术体系之MSE之Dubbo+Zookeeper最佳实
  • Apache Dubbo3 源码深入解读

    • 相关实验场景

    更多
  • 基于MSE实现微服务的全链路灰度
  • 基于MSE实现K8s集群内多服务的灰度发布
    • 下一篇
    阿里云oss简介和如何对接使用