【SpringBoot学习笔记十四】SpringBoot+Dubbo+Zookeeper集成开发（下）

2023-06-18 160

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

服务治理 MSE Sentinel/OpenSergo，Agent数量不受限

简介： 【SpringBoot学习笔记十四】SpringBoot+Dubbo+Zookeeper集成开发（下）

执行命令：mvn clean package -Dmaven.test.skip=true，可能会遇到标签报错问题，调整下即可

然后在控制中心执行如下命令：

cd dubbo-admin-distribution/target
//因为我们生成的版本为0.3.0，所以命令如下
java -jar dubbo-admin-0.3.0.jar

命令执行后dubbo服务启动，我们再将zookeeper服务启动后注册中心才可用：

我们访问地址http://localhost:7001/，结果如下：

输入配置文件中的账号密码即可登录：

3 创建服务提供者模块

首先我们创建一个服务提供者，也就是服务生产者模块。

选择如下依赖即可：

1 pom.xml依赖

在pom.xml文件中配置坐标如下：

<dependencies>
        <!--导入Dubbo依赖-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <!--导入zookeeper依赖-->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--引入zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <!--解决 java.lang.NoClassDefFoundError: org/apache/curator/framework/recipes/cache/TreeCacheListener-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </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>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-common</artifactId>
            <version>2.7.12</version>
        </dependency>
    </dependencies>

2 生产者Dubbo配置

在配置文件中进行Dubbo的配置

application.yml

server:
  port: 8081 # 服务端口
dubbo:
  application:
    name: provider-server # 注册服务应用名字
  scan:
    base-packages: com.example.providerserver.service # dubbo服务发布者所在的包
  registry:
    address: 127.0.0.1:2181 # zookeeper注册中心的地址
    protocol: zookeeper
  protocol:
      name: dubbo
      port: 20880

3 接口服务代码配置

BookService

package com.example.providerserver.service;
public interface BookService {
    String getBookByUserId(Integer id);
}

BookServiceImpl

package com.example.providerserver.service;
import org.springframework.stereotype.Component;
import org.apache.dubbo.config.annotation.Service;
@Service // dubbo的注解，可以被扫描到，在项目一启动就自动注册到注册中心
@Component
public class BookServiceImpl implements BookService {
    @Override
    public String getBookByUserId(Integer id) {
        if(id==1){
            return "tml很帅,他喜欢《围城》";
        }
        return "查无此人";
    }
}

创建完成后整体布局如下：

4 创建服务消费者模块

首先我们创建一个服务消费者模块：

选择如下依赖即可：

1 pom.xml

在pom.xml中配置坐标如下，和生产者的依赖一样：

<dependencies>
        <!--导入依赖-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <!--zkclient-->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--解决日志冲突-->
        <!--引入zookeeper-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <!--解决 java.lang.NoClassDefFoundError: org/apache/curator/framework/recipes/cache/TreeCacheListener-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </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>
        <dependency>
            <groupId>com.example</groupId>
            <artifactId>provider-server</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

2 消费者Dubbo配置

在配置文件中进行Dubbo的配置

server:
  port: 8082
dubbo:
  application:
     name: consumer-server
  registry:
    address: 127.0.0.1:2181 # zookeeper注册中心的地址
    protocol: zookeeper
  protocol:
    name: dubbo
    port: 20880

3 消费者接口代码配置

本来正常步骤是需要将服务提供者的接口打包，然后用pom文件导入，我们这里使用简单的方式，直接将服务的接口拿过来，路径必须保证正确，即和服务提供者相同

UserInfoService

package com.example.consumerserver.service;
public interface UserInfoService {
    String getBook();
}

UserInfoServiceImpl

package com.example.consumerserver.service;
import com.example.providerserver.service.BookService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;
@Service
public class UserInfoServiceImpl implements UserInfoService {
    @Reference
    BookService bookService; //远程引用指定的服务，按照全类名进行匹配，看谁给注册中心注册了这个全类名
    @Override
    public String getBook() {
        String bookName = bookService.getBookByUserId(1);
        System.out.println("在注册中心买到"+bookName);
        return bookName;
    }
}

UserController

package com.example.consumerserver.controller;
import com.example.consumerserver.service.UserInfoService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
public class UserController {
    @Resource
    UserInfoService userInfoService;
    @GetMapping("/userinfo")
    public String userinfo(){
       String book= userInfoService.getBook();
       return book;
    }
}

创建完成后整体布局如下：

5 测试Dubbo远程RPC调用

按照如下步骤进行测试，首先我们整体看下模块划分如下：整体模块划分如下

1 开启zookeeper

直接双击zkServer.cmd即可

2 打开dubbo-admin实现监控

我们先启动监控服务：

然后访问网址：http://localhost:7001/

3 启动服务者

然后我们启动服务者：

4 启动消费者

启动完服务者后，我们再启动下消费者：

5 页面请求测试

我们访问消费者的Controller，间接的调用远程服务：

同时观察dubbo-admin也体现出了注册信息：

服务关系：

总结一下

花了很长的篇幅和时间来学习关于分布式架构、集群、分布式理论，再到RPC调用方式，具体到Dubbo如何实现分布式的RPC调用。然后又以SpringBoot为核心，zookeeper为注册中心，Dubbo为RPC框架实践了一把Dubbo的调用方式，总算搞清楚了Dubbo的作用机制和使用方式，说白了RPC就是大家把服务都注册到一个注册中心，然后通过注册中心远程调用自己想要调用的资源，Dubbo让这看起来就像你在本地调用一样。其实Dubbo这种RPC调用和HTTP调用实现目的是类似的，但是Dubbo因为使用的是 TCP/IP是传输层协议，所以要比 HTTP协议包装一层一般而言要快些。有个比较形象的例子：

HTTP，讲普通话，好处就是谁都听得懂，谁都会讲。
RPC，讲黑话，好处是可以更精简、更加保密、更加可定制，坏处就是要求“说”黑话的那一方（client端）也要懂，而且一旦大家都说一种黑话了，换黑话就困难了

目前对于分布式的架构来说，用RPC方式的Dubbo比HTTP的会多一些，HTTP通常用作对外提供服务。

【SpringBoot学习笔记十四】SpringBoot+Dubbo+Zookeeper集成开发（下）

3 创建服务提供者模块

1 pom.xml依赖

2 生产者Dubbo配置

3 接口服务代码配置

4 创建服务消费者模块

1 pom.xml

2 消费者Dubbo配置

3 消费者接口代码配置

5 测试Dubbo远程RPC调用

1 开启zookeeper

2 打开dubbo-admin实现监控

3 启动服务者

4 启动消费者

5 页面请求测试

总结一下

热门文章

最新文章

相关课程

相关电子书

相关实验场景

【SpringBoot学习笔记 十四】SpringBoot+Dubbo+Zookeeper集成开发（下）

3 创建服务提供者模块

1 pom.xml依赖

2 生产者Dubbo配置

3 接口服务代码配置

4 创建服务消费者模块

1 pom.xml

2 消费者Dubbo配置

3 消费者接口代码配置

5 测试Dubbo远程RPC调用

1 开启zookeeper

2 打开dubbo-admin实现监控

3 启动服务者

4 启动消费者

5 页面请求测试

总结一下

热门文章

最新文章

相关课程

相关电子书

相关实验场景

【SpringBoot学习笔记十四】SpringBoot+Dubbo+Zookeeper集成开发（下）