springboot整合dubbo实现RPC服务远程调用

🕗 发布于 2024-04-17 11:46 spring boot dubbo rpc

一、dubbo简介

1.什么是dubbo

Apache Dubbo是一款微服务开发框架，他提供了RPC通信与微服务治理两大关键能力。有着远程发现与通信的能力，可以实现服务注册、负载均衡、流量调度等服务治理诉求。

2.dubbo基本工作原理

在这里插入图片描述

Contaniner:容器
Provider：服务提供者
Consumer：服务消费者
Registry：注册中心
Monitor：统计服务调用次数和调用时间的监控中心

3.具体介绍参考官方文档

文档|Apache Dubbo

二、准备dubbo-admin（管理控制台）和zookeeper（注册中心）

1.下载注册中心

docker pull zookeeper//拉取zookeeper镜像

docker run -d \
-p 2181:2181 \
-v /mydata/zookeeper/data:/data  \
--name zookeeper \
  zookeeper:latest
  这里我的端口号为2181，我的服务器地址为192.168.31.130
  yml配置文件里dubbo配置应该为：dubbo.registry.address=zookeeper://192.168.31.130:2181

-d：后台启动
-p：暴露端口号
-v：数据卷挂载
–name：指定容器名称

2.下载安装dubbo-admin（dubbo的管理控制台）

docker pull dubbo-admin //拉取镜像

//运行镜像
docker run -it -d \
--name dubbo-admin \
-v /mydata/zookeeper/dubbo-admin/data:/data \
-p 9952:8080 \
-e dubbo.registry.address=zookeeper://192.168.31.130:2181 \
-e dubbo.admin.root.password=root -e dubbo.admin.guest.password=root \
chenchuxin/dubbo-admin:latest

三、SpringBoot整合dubbo+zookeeper

分布式微服务主要是将应用的各项功能拆分成不同的模块，(根据不同的功能模块划分成不同的项目)发布在不同的服务器上，然后将需要向外提供的服务api做成分包，模块之间的相互调用通过分包api完成，dubbo的作用在于我们只需要将服务提供者的接口暴露给dubbo托管，服务消费者只要向registry注册中心注册并指定需要调用的服务，即可完成服务间调用，无需关心服务提供者的内部结构是怎样的，用户也感知不到调用了任何外部服务。

创建一个空项目，并创建commons-api、dubbo-provider、dubbo-consumer三个模块

在这里插入图片描述

3.1 在commons-api模块创建Account实体类和AccountService接口

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account implements Serializable {
    private int id;
    private String username;
    private double money;
}

package liao.com.service;
import liao.com.entity.Account;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface AccountService {
    /**
     * @Description:获取所有账户信息
     * @Params: []
     * @return java.util.List<liao.com.entity.Account>
     */

    List<Account> getAllAccounts();
    /**
     * @Description:根据用户名获取账户余额
     * @Params: [username]
     * @return double
     */
    Account getMoney(String username);

    /**
     * @Description:增加账户余额
     * @Params: [username, money]
     * @return int
     */
    int updateAddMoney(@Param("username") String username, @Param("money") double money);

    /**
     * @Description:减少账户余额
     * @Params: [username, money]
     * @return int
     */

    int updateSubMoney(@Param("username") String username, @Param("money") double money);
}

最后记得install打包到本地maven仓库里，provider服务提供者和consumer服务消费者需要用到

3.2创建provider服务提供者

3.2.1添加pom.xml依赖：

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </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.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.2</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.20</version>
        </dependency>


        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>
        <dependency><!--zookerper版本一定要匹配！ -->
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>2.7.8</version>
        </dependency>
        <!--这个是commons-api的maven依赖-->
        <dependency>
            <groupId>liao.com</groupId>
            <artifactId>commons-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

3.2.2application.properties文件

spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/demo?userSSL=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver


server.port=8887
mybaits.mapper-locations=classpath:dao/*.xml
mybatis.type-aliases-package=liao.com.entity
mybatis.configration-log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

dubbo.application.name=dubbo-provider-service
dubbo.registry.address=zookeeper://192.168.31.130:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20887
dubbo.scan.base-packages=liao.com
dubbo.registry.timeout=30000

3.2.3AccountDao.xml文件

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="liao.com.dao.AccountDao">
    <select id="getAccountByName" resultType="liao.com.entity.Account" parameterType="String">
        select id, username, money from account where username = #{username}
    </select>

    <update id="updateAddMoney">
        update account set money = money + #{money} where username = #{username}
    </update>

    <update id="updateSubMoney">
        update account set money = money - #{money} where username = #{username}
    </update>

    <select id="getAllAccounts" resultType="liao.com.entity.Account">
        select id, username, money from account
    </select>
</mapper>

3.2.4创建AccountDao

package liao.com.dao;

import liao.com.entity.Account;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * @author: lehu
 * @Description:账户类接口
 * @Params:
 * @return
 * @date 2024-04-13 02:38
 */

@Mapper
@Repository
public interface AccountDao {
    /**
     * @Description:获取所有账户信息
     * @Params: []
     * @return java.util.List<liao.com.entity.Account>
     */

    List<Account> getAllAccounts();
    /**
     * @Description:根据用户名获取账户余额
     * @Params: [username]
     * @return double
     */
    /*@Select("SELECT id, username,money FROM account WHERE username = #{username}")*/
    Account getMoney(String username);

    /**
     * @Description:增加账户余额
     * @Params: [username, money]
     * @return int
     */
    /*@Select("UPDATE account SET money = money + #{param2} WHERE username = #{param1}")*/
    int updateAddMoney(@Param("username") String username, @Param("money") double money);

    /**
     * @Description:减少账户余额
     * @Params: [username, money]
     * @return int
     */

    int updateSubMoney(@Param("username") String username, @Param("money") double money);
}

3.2.5创建AccountServiceImpl


//@DubboService注解标识该服务是服务提供者provider
@DubboService(version = "1.0.0")
//实现的AccountService接口导入Commons-api模块下的
public class AccountServiceImplPlus implements AccountService {
    @Resource
    private AccountDao accountDao;
    @Override
    public List<Account> getAllAccounts() {
        return accountDao.getAllAccounts();
    }

    @Override
    public Account getMoney(String username) {
        return accountDao.getAccountByName(username);
    }

    @Override
    public int updateAddMoney(String username, double money) {
        return accountDao.updateAddMoney(username, money);
    }

    @Override
    public int updateSubMoney(String username, double money) {
        return accountDao.updateSubMoney(username, money);
    }


}

3.3创建consumer服务消费者

依赖和provider服务提供者一样
application.properties配置文件也类似

创建AccountController


@RestController
@Slf4j
public class AccountController {

//@Reference代表是服务消费者，这里的AccountService接口也是导入的Commons-api模块里的
    @Reference(version = "1.0.0")
    private AccountService accountService;

    @RequestMapping("/getAccounts")
    public List<Account> getAccounts() {
        List<Account> allAccounts = accountService.getAllAccounts();
        log.info("allAccounts:{}", allAccounts);
        return allAccounts;
    }

    @RequestMapping("/getMoenyByUsername")
    public void addAccount(String username, String param1, double param2) {
        Account account = accountService.getMoney(username);
        log.info("account:{}", account);
        if (account.getMoney() > 10000) {
            accountService.updateAddMoney(param1, param2);
        }
    }

    @RequestMapping("/getAccountByUsername")
    public Account getAccountByUsername(@Param("username") String username) {
        Account account = accountService.getMoney(username);
        log.info("account:{}", account);
        return account;
    }

    @RequestMapping("/addAccount")
    public String addAccount(@Param("username") String username, @Param("money") Double money) {
        int i = accountService.updateAddMoney(username, money);
        if (i > 0) {
            return "success";
        } else {
            return "fail";
        }
    }

    @RequestMapping("/subAccount")
    public String subAccount(@Param("username") String username, @Param("money") Double money) {
        int i = accountService.updateSubMoney(username, money);
        if (i > 0) {
            return "success";
        } else {
            return "fail";
        }
    }

}

3.3测试

先启动服务提供者，再启动服务消费者
用postman测试一下基于Dubbo+Zookeeper的RPC远程服务调用

查询所有账户信息：
在这里插入图片描述

根据用户名来查询Account账户信息：
在这里插入图片描述

根据用户名来给用户转账：
在这里插入图片描述
再来查询不良帅的余额：

四、在zookeeper客户端命令查看dubbo服务的生产者与消费者

在这里插入图片描述
现在我的zookeeper注册中心部署在docker容器里，需要通过命令：docker exec -it 容器id /bin/bash进入容器内部

4.1进入容器内部后切换到bin目录下

docker exec -it 容器id /bin/bash //进入容器内部
cd bin //切换到bin目录

4.2 执行命令./zkCli.sh

./zkCli.sh

4.3 在命令行输入ls /dubbo,即可查到dubbo服务对外提供的接口，如下图：

在这里插入图片描述

4.4 查看消费者命令：

ls /dubbbo/liao.com.service.AccountService/consumers

会看到消费者的信息，截图如下：
在这里插入图片描述

4.5 查看生产者命令：

ls /dubbo/liao.com.common.CommonService/providers

会看到生产者的信息，截图如下：
在这里插入图片描述

OK结束！

原文地址：https://blog.csdn.net/qq_43634655/article/details/137711856

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：详解IP安全：【IPSec协议簇 - AH协议 - ESP协议 - IKE协议】
下一篇：使用SpringBoot3+Vue3开发公寓管理系统

【go从零单排】上下文（context）
在 Go 语言中，上下文（context）是一个重要的概念，主要用于管理请求的生命周期、传递取消信号、超时控制以及传递请求范围内的值。上下文通常与并发编程相关，尤其是在处理 HTTP 请求和其他 I/
阅读更多2024-11-15
Ubuntu 20.04 配置开发环境(持续更新)
搜狗输入法不能显示中文。
阅读更多2024-11-15
在ubuntu上安装ubuntu22.04并ros2 humble版本的docker容器记录
"registry-mirrors" : ["https://你的.mirror.swr.myhuaweicloud.com"],4、已经打包了ubuntu22
阅读更多2024-11-15
如何在 Ubuntu 22.04 上安装 ownCloud
ownCloud 是一个开源的个人云存储平台，它允许用户在本地服务器上存储和同步文件，提供了一个类似于 Dropbox 或 Google Drive 的服务，但是更加注重隐私和数据控制。文件存储：用户
阅读更多2024-11-15
idea 删除本地分支后，弹窗 delete tracked brank
在 IntelliJ IDEA 中，删除本地分支后弹出 “Delete tracked branch” 的提示，这表示删除的是一个跟踪分支（tracked branch）。具体来说，当前删除的本地分
阅读更多2024-11-15
「JVM详解」
JVM：全称 Java Virtual Machine，即 Java 虚拟机，一种规范，本身是一个虚拟计算机，直接和操作系统进行交互，与硬件不直接交互，而操作系统可以帮我们完成和硬件进行交互的工作
阅读更多2024-11-15
WPF中Prism框架的简单使用
自动匹配导入4.写Login.XAML代码和LoginViewModel代码LoginViewModel如下：5.创建其他的UserControl 并学好MainWindow.XAML和MainWin
阅读更多2024-11-15
Linux——GPIO输入输出裸机实验
在程序启动时，BSS段会被清零，并且其大小会被计算到程序的总内存占用中，尽管它在磁盘上的表示可能非常小或甚至没有。在程序启动时，BSS段会被清零，并且其大小会被计算到程序的总内存占用中，尽管它在磁盘上
阅读更多2024-11-15
planRAG运行记录
运行planRAG过程记录
阅读更多2024-11-15
vue面试题8|[2024-11-14]
vue面试题
阅读更多2024-11-15

springboot整合dubbo实现RPC服务远程调用

一、dubbo简介

1.什么是dubbo

2.dubbo基本工作原理

3.具体介绍参考官方文档

二、准备dubbo-admin（管理控制台）和zookeeper（注册中心）

1.下载注册中心

2.下载安装dubbo-admin（dubbo的管理控制台）

三、SpringBoot整合dubbo+zookeeper

创建一个空项目，并创建commons-api、dubbo-provider、dubbo-consumer三个模块

3.1 在commons-api模块创建Account实体类和AccountService接口

3.2创建provider服务提供者

3.2.1添加pom.xml依赖：

3.2.2application.properties文件

3.2.3AccountDao.xml文件

3.2.4创建AccountDao

3.2.5创建AccountServiceImpl

3.3创建consumer服务消费者

创建AccountController

3.3测试

四、在zookeeper客户端命令查看dubbo服务的生产者与消费者

4.1进入容器内部后切换到bin目录下

4.2 执行命令./zkCli.sh

4.3 在命令行输入ls /dubbo,即可查到dubbo服务对外提供的接口，如下图：

4.4 查看消费者命令：

4.5 查看生产者命令：

相关文章