备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

（八）SpringCloud整合zookeeper

2023-01-08 59
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
简介： （八）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微服务引擎
微服务引擎springcloud
springcloud zookeeper
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
炒焖煎糖板栗
目录
相关文章
诸葛子房
|
4月前
|
Java Spring
spring cloud使用zookeeper作为注册中心—consumer
spring cloud使用zookeeper作为注册中心—consumer
诸葛子房
24 0
诸葛子房
|
4月前
|
Java Spring 消息中间件
spring cloud 使用zookeeper作为注册中心—provider
spring cloud 使用zookeeper作为注册中心—provider
诸葛子房
32 0
阿里云博主-阿演
|
10月前
|
负载均衡 Java Apache
springcloud整合zookeeper注册中心
下载3.4的，3.5 的解压的时候回出现文件已存在的错误，解压完会多出来一个文件夹，然后启动的时候找不到jar包报错。
阿里云博主-阿演
97 1
springcloud整合zookeeper注册中心
游客w4fv6b2av3kec
|
11月前
|
Cloud Native 测试技术 API
【云原生】springcloud06——订单服务注册zookeeper
【云原生】springcloud06——订单服务注册zookeeper
游客w4fv6b2av3kec
77 0
游客w4fv6b2av3kec
|
11月前
|
算法 前端开发 Java
springcloud05——Zookeeper实现支付微服务
springcloud05——Zookeeper实现支付微服务
游客w4fv6b2av3kec
79 0
玉面大蛟龙
|
Java Linux 程序员
SpringCloud学习（八）：服务注册进入zookeeper
SpringCloud学习（八）：服务注册进入zookeeper
玉面大蛟龙
163 0
SpringCloud学习（八）：服务注册进入zookeeper
llsydn
|
设计模式 Java 关系型数据库
spring cloud使用zookeeper作为服务注册中心和配置中心
现在用spring cloud框架搭建微服务已经是比较流行了，毕竟这个是spring提供给我们的一个框架，可以很好配合spring boot使用，很快就可以搭建出一个微服务来，大大的减少了工作量。
llsydn
239 0
爱编程的大李子
|
存储 负载均衡 监控
SpringCloud Day02---服务发现与注册(Eureka+zookeeper+Consul（四）
SpringCloud Day02---服务发现与注册(Eureka+zookeeper+Consul
爱编程的大李子
133 0
SpringCloud Day02---服务发现与注册(Eureka+zookeeper+Consul（四）
zhishijike
|
30天前
|
Java Nacos Sentinel
Spring Cloud Alibaba 面试题及答案整理，最新面试题
Spring Cloud Alibaba 面试题及答案整理，最新面试题
zhishijike
139 0
hhzz
|
1月前
|
SpringCloudAlibaba Java 持续交付
【构建一套Spring Cloud项目的大概步骤】&【Springcloud Alibaba微服务分布式架构学习资料】
【构建一套Spring Cloud项目的大概步骤】&【Springcloud Alibaba微服务分布式架构学习资料】
hhzz
131 0

热门文章

最新文章

  • 1
    云效 AppStack + 阿里云 MSE 实现应用服务全链路灰度
  • 2
    云原生最佳实践系列 6：MSE 云原生网关使用 JWT 进行认证鉴权
  • 3
    云原生最佳实践系列2：基于 MSE 云原生网关同城多活
  • 4
    阿里云微服务引擎及 API 网关 2024 年 3 月产品动态
  • 5
    KubeSphere 核心实战之三【在kubesphere平台上部署ElasticSearch、应用商店部署RabbitMQ和应用市场部署Zookeeper】（实操篇 3/4）
  • 6
    ZooKeeper分布式协调服务详解：面试经验与必备知识点解析
  • 7
    nacos常见问题之Serverless 应用引擎2.0不支持 MSE nacos如何解决
  • 8
    【ZooKeeper系列】那ZooKeeper为什么还采用ZAB协议
  • 9
    云原生最佳实践系列 3：基于 SpringCloud 应用玩转 MSE
  • 10
    【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（八）Config服务配置+bus消息总线+stream消息驱动+Sleuth链路追踪
  • 1
    Spring Boot、Spring Cloud与Spring Cloud Alibaba版本对应关系
    404
  • 2
    SpringCloud Alibaba集成Dubbo实现远程服务间调用
    38
  • 3
    【十】SpringCloud Alibaba之整合gateway（包括配置详解以及各种坑）
    74
  • 4
    【九】SpringCloud Alibaba之整合Sentinel（实现热点控制）
    32
  • 5
    【八】SpringCloud Alibaba之整合Sentinel（实现流量控制3）
    33
  • 6
    【七】SpringCloud Alibaba之整合Sentinel（实现流量控制2）
    26
  • 7
    【六】SpringCloud Alibaba之整合Sentinel（实现流量控制）
    47
  • 8
    【五】SpringCloud Alibaba之整合Dubbo（实现远程调用）
    44
  • 9
    【四】SpringCloud Alibaba之重构Maven结构
    28
  • 10
    【三】SpringCloud Alibaba之Nacos整合篇（作为配置中心）
    225

    • 相关课程

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

    • 相关电子书

    更多
  • 《MSE 微服务网关》
  • 微服务引擎 MSE 治理中心重磅发布
  • 阿里云微服务引擎 MSE 2.0 线上发布

    • 相关实验场景

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