SpringCloud(一) - Dubbo + Zookeeper

xiaoqigui 2023-04-19 原文

Dubbo 和Zookeeper 不是SpringCloud的东西，放在这里只是为了方便复习；

1、下载安装Zookeeper和Dubbo

1.1 下载安装教程

下载安装教程 windows环境下安装zookeeper教程详解（单机版）

1.2 启动页面

1.2.1 zkServer.xmd zookeeper 服务端

1.2.2 zkCli.cmd zookeeper 客户端

1.3.3 运行 double-admin

java-jar dubbo-admin-0.0.1-SNAPSHOT.jar

访问localhost:7001

2、SpringBoot 集成 dubbo + zookeeper

2.1 模块项目建立

2.1.1 主项目

2.1.1.1 pom.xml

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>springboot-10-dubbo-96</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-10-dubbo-96</name>
    <!-- 主项目打包方式，pom方式 -->
    <packaging>pom</packaging>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <!-- 版本统一管理 -->
        <dubbo.version>0.1.0</dubbo.version>
        <zkclient.version>0.10</zkclient.version>
    </properties>

    <!-- 父项目中的 dependencyManagement 中定义的只是依赖的声明，并不实现引入，因此子项目需要显式的声明需要用的依赖 -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.kgc.sbt</groupId>
                <artifactId>contactmall96-common</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>

            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${dubbo.version}</version>
            </dependency>

            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

	<!-- 模块管理  -->
    <modules>
        <module>contactmall96-common</module>
        <module>contactmall96-server</module>
        <module>contactmall96-web</module>
    </modules>
    
    <!-- 不需要 build -->

</project>

2.1.2 公共模块 common模块

2.1.2.1 pom.xml

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-common</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>contactmall96-common</name>
    <!-- 普通jar包，不是可执行jar,用于提供公共jar,给其他模块提供依赖 -->
    <packaging>jar</packaging>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

    <!-- 不需要 build -->
    
</project>

2.1.2.2 公共Api接口

// 联系人 公共接口(基于dubbo的rpc远程接口服务调用)，
// 此接口是提供给消费端web调用获取数据
// 服务端server实现此接口，提供数据
public interface ContactApi {

    //根据联系人编号，查询联系人详情公共方法
    ContactVO queryContactById(Integer id);

}

2.1.2.3 其他公共资源

注意：视图层的实体一定要进行序列化，因为在网络上传输的对象需要序列化；(ContactVO implements Serializable)

2.1.3 服务提供者 server模块

2.1.3.1 pom.xml

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-server</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--   依赖了common 模块，跨域直接使用模块中的依赖和类     -->
        <dependency>
            <groupId>com.kgc.sbt</groupId>
            <artifactId>contactmall96-common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <!-- fastjson -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.62</version>
        </dependency>

        <!-- mysql-connector-java -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.30</version>
        </dependency>

        <!-- commons-lang -->
        <dependency>
            <groupId>commons-lang</groupId>
            <artifactId>commons-lang</artifactId>
            <version>2.6</version>
        </dependency>

        <!-- mybatis-plus-boot-starter -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.3.4</version>
        </dependency>

        <!-- 父项目中管理了版本的不需要指定版本 -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.1.3.2 dubbo配置

# 端口
server.port=8096

#数据源
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/kh96_springboot_contactdb?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
spring.datasource.username=root
spring.datasource.password=root

#mybatis-plus 配置
mybatis-plus.configuration.map-underscore-to-camel-case=true

# dubbo配置
dubbo.application.name=contact-provider
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
#端口号-1，会自动从20880开始递增，也可以指定（必须确保不冲突，一般不建议）(不要写成 dubbo.registry.port=-1)注册端口
#协议端口
dubbo.protocol.port=-1  
#扫描指定包下的服务
dubbo.scan.base-packages=com.kgc.sbt.provider

2.1.3.3 代码分布情况

注意：主启动类扫描包，@MapperScan("com.kgc.sbt.mapper")

2.1.3.4 公共Api接口的实现类(注册服务)

package com.kgc.sbt.provider;

import com.alibaba.dubbo.config.annotation.Service;  //@Service作用：将当前服务注册为服务提供者
import com.kgc.sbt.api.ContactApi;
import com.kgc.sbt.service.ContactService;
import com.kgc.sbt.vo.ContactVO;
import org.springframework.beans.factory.annotation.Autowired;

//联系人功能 的提供者
@Service  //是alibaba包下的，不是spring的业务组件注解，作用：将当前服务注册为服务提供者
public class ContactProvider implements ContactApi {

    @Autowired
    private ContactService contactService;

    @Override
    public ContactVO queryContactById(Integer id) {
        //调用业务接口，查询联系人的详情
        return contactService.getContactById(id);
    }


}

2.1.4 消费模块 web模块

2.1.4.1 pom.xml

跟服务提供者差不多，这里列出所有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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.kgc.sbt</groupId>
        <artifactId>springboot-10-dubbo-96</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../pom.xml </relativePath>
    </parent>
    <groupId>com.kgc.sbt</groupId>
    <artifactId>contactmall96-web</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>contactmall96-web</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.kgc.sbt</groupId>
            <artifactId>contactmall96-common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.1.4.2 dubbo配置

# 端口
server.port=8098

# dubbo 配置
dubbo.application.name=contact-consumer
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper

2.1.4.3 代码分布情况

2.1.4.4 获取公共Api的实现类(订阅服务)

import com.alibaba.dubbo.config.annotation.Reference; //作用，到注册中心订阅当前接口对象提供的服务，成为该接口的消费者
import com.kgc.sbt.api.ContactApi;
import com.kgc.sbt.vo.ContactVO;
import org.springframework.stereotype.Service;

@Service  //spring容器的业务注解
public class ContactServiceImpl implements com.kgc.sbt.service.ContactService {

    @Reference //alibaba下的，作用，到注册中心订阅当前接口对象提供的服务，成为该接口的消费者
    private ContactApi contactApi;

    @Override
    public ContactVO getContactById(Integer contactId) {
        //基于RPC远程接口调用，调用服务提供者提供的服务，就等价于调用此既可，只不过是远程
        return contactApi.queryContactById(contactId);
    }
}

2.2 测试

先启动zookeeper和dubbo-admin;

在启动服务提供模块和服务消费模块；

2.2.1 请求测试

2.2.1.1 dubbo-admin页面查看提供者和消费者

提供者：

消费者：

2.2.1.2 请求测试

2.2.2 多提供者，多消费者测试

2.2.2.1 复制服务

2.2.2.2 dubbo 查看提供者和消费者

提供者：

消费者：

2.2.2.3 两个消费者请求测试

2.2.3 一些重要的点

2.2.3.1提供者的权重

2.2.3.2 消费者的禁止

2.2.3.2.1 设置消费者禁止：

被禁止的客户端将收到访问禁止异常

2.2.3.2.1 测试访问：

2.2.3.3 消费者的屏蔽

2.2.3.3.1 设置消费者屏蔽：

屏蔽后，将不发起远程调用，直接在客户端返回空对象。

2.2.3.3.2 测试访问：

2.2.3.4 负载均衡

负载均衡有：随机(默认)，轮询，最少并发。

SpringCloud Zookeeper gt lt artifactId Java

有关SpringCloud(一) - Dubbo + Zookeeper的更多相关文章

【云原生】SpringCloud-Spring Boot Starter使用测试 - 2
目录SpringBootStarter是什么？以前传统的做法使用SpringBootStarter之后starter的理念：starter的实现：创建SpringBootStarter步骤在idea新建一个starter项目、直接执行下一步即可生成项目。在xml中加入如下配置文件：创建proterties类来保存配置信息创建业务类：创建AutoConfiguration测试如下：SpringBootStarter是什么？ SpringBootStarter是在SpringBoot组件中被提出来的一种概念、简化了很多烦琐的配置、通过引入各种SpringBootStarter包可以快速搭建出一
【华为OD技术面试 | 真八股】MySQL联合索引，谈springIOC的理解，谈springAOP的理解，Erika和zookeeper等问题 - 2
文章目录华为OD面试流程1.mysql数据库建了两个字段，且设置了联合索引，如果其中有一个字段为空会出现什么问题？2.谈谈springIOC的理解，有什么好处，解决了什么问题3.谈谈springAOP的理解，切面编程有没有实际应用，有哪些注解，作用是什么，有那些应用场景？4.Erika和zookeeper有了解过吗，作用是什么，主要解决了什么问题5.谈谈JDK、JRE、JVM的理解，区别是什么6.谈谈对泛型的理解7.JVM的组成华为OD面试流程机试：三道算法题，关于机试，橡皮擦已经准备好了各语言专栏，可以直接订阅。性格测试：机试技术一面（本专栏核心）技术二面（本专栏核心）主管面试定级定薪发of
SpringCloud入门实战（七）-Hystrix入门简介 - 2
📝学技术、更要掌握学习的方法，一起学习，让进步发生👩🏻作者：一只IT攻城狮。💐学习建议：1、养成习惯，学习java的任何一个技术，都可以先去官网先看看，更准确、更专业。💐学习建议：2、然后记住每个技术最关键的特性（通常一句话或者几个字），从主线入手，由浅入深学习。❤️《SpringCloud入门实战系列》解锁SpringCloud主流组件入门应用及关键特性。带你了解SpringCloud主流组件,是如何一战解决微服务诸多难题的。项目demo：源码地址👉🏻SpringCloud入门实战系列不迷路👈🏻：SpringCloud入门实战（一）什么是SpringCloud？SpringCloud入门实战
手把手教你搭建SpringCloud Alibaba之生产者与消费者 - 2
SpringCloudAlibaba全集文章目录：零、手把手教你搭建SpringCloudAlibaba项目一、手把手教你搭建SpringCloudAlibaba之生产者与消费者二、手把手教你搭建SpringCloudAlibaba之Nacos服务注册中心三、手把手教你搭建SpringCloudAlibaba之Nacos服务配置中心四、手把手教你搭建SpringCloudAlibaba之Nacos服务集群配置五、手把手教你搭建SpringCloudAlibaba之Nacos服务持久化配置六、手把手教你搭建SpringCloudAlibaba之Sentinel实现流量实时监控七、手把手教你搭
Zookeeper、Nacos、Dubbo、Kafka之间的关系 - 2
1.Zookeeper　　Zookeeper是 ApacheHadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为Dubbo服务的注册中心，工业强度较高。　　Zookeeper的功能主要是它的树形节点来实现的。当有数据变化的时候或者节点过期的时候，会通过事件触发通知对应的客户端数据变化了，然后客户端再请求zookeeper获取最新数据，采用push-pull来做数据更新。服务注册和消费信息直接存储在zk树形节点上，集群下采用过半机制保证服务节点间一致性。　2.Nacos　　Nacos是 Alibaba 公司推出的开源工具，用于实现分布式系统的服务发现与配置管理。Nacos是Dub
Docker部署springcloud项目（清晰明了） - 2
概述最近在想做个cloud项目,gitee上找了个模板项目，后端使用到Nacos、Gateway、Security等技术，需要到Docker容器部署，在此总结一下，若有不足之处，望大佬们可以指出。什么是DockerDocker使用Google公司推出的Go语言进行开发实现，基于Linux内核的cgroup，namespace，以及AUFS类的UnionFS等技术，对进程进行封装隔离，属于操作系统层面的虚拟化技术。由于隔离的进程独立于宿主和其它的隔离的进程，因此也称其为容器。Docker在容器的基础上，进行了进一步的封装，从文件系统、网络互联到进程隔离等等，极大的简化了容器的创建和维护。使得Do
Zookeeper简单使用 - 2
Zookeeper一、zookeeper简述大型分布式计算开源的分布式配置服务，同步服务和命令注册。架构通过冗余实现高可用。目标：将那些负载且容易出错的分布式一致性服务封装其拉力，构成一个高效可靠的原语集，以一系列简单易用的接口提供给用户使用。一个典型的分布式数据一致性的解决方案，分布式应用程序可以基于它实现诸如数据发布/订阅、负载均衡、命令服务、分布式协调/通知，集群管理、master选举、分布式锁和分布式队列等。1.1zookeeper数据结构它提供的名称空间类似标准文件系统，k-v的形式存储。名称key由斜线/分割的一系列路径元素，zookeeper名称空间中的每个节点都是由一个路径标识
go-zookeeper Connect 在没有有效连接的情况下返回 - 2
我有一个关于zookeeper的问题，我正在尝试使用go-zookeeper实现简单的服务发现，我正在使用go-zookeeper:https://github.com/samuel/go-zookeeper我的问题是每当我使用例如连接到zookeeper时:zoo_keeper,_,err:=zk.Connect(s,time.Second)函数立即返回，没有报错，但还没有真正有效的连接。现在，例如，如果我想创建znode，我需要检查什么以确保在这样做之前我有一个有效的连接？最佳答案在尝试了几件事之后，感谢Imesha的建议，
zookeeper单节点部署，手把手从零到一 - 2
zookeeper单节点部署及注意事项kafka戳这里：kafka单节点部署，手把手从零到一事前准备：1、一台Linux服务器或者是一台虚拟机2、准备好JDK环境3、安装好wget（当然也可以不用这个，只是用于下载安装包的一个工具，所以能下载好包就是没问题的）4、需要了解vim的一些基础操作，不懂得可自行百度1、Zookeeper的单节点部署1.1、下载这里用的zookeeper版本为3.6.4运行命令：wgethttps://dlcdn.apache.org/zookeeper/zookeeper-3.6.4/apache-zookeeper-3.6.4-bin.tar.gz运行命令，进行压
windows - 尝试在 Windows 中启动 Zookeeper 时出现 "log4j.properties was unexpected at this time" - 2
我正在使用从Confluent(http://www.confluent.io/product/kafka-streams/)下载的kafka流。我按照说明在Windows上运行Zookeeper和Kafka。但是当我尝试使用命令启动ZooKeeper时D:\Softwares\confluent-3.0.1\bin\windows>zookeeper-server-start.bat./etc/kafka/zookeeper.properties，我得到错误D:\Softwares\confluent-3.0.1\bin\windows../../etc/kafka/log4j.pr