Dubbo入门实战（SpringBoot + Nacos）

news2024/10/6 0:26:16

本文主要介绍 Dubbo 3.0 整合 SpringBoot 的样例，这里使用 Nacos 作为注册中心，读者也可以使用 Zookeeper，项目结构为：

项目结构

  • interface-service：接口服务
  • user-service-provider：服务提供者
  • order-service-consumer：服务消费者

搭建父工程

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.tojintao</groupId>
    <artifactId>dubbo-springboot</artifactId>
    <version>1.0-SNAPSHOT</version>

    <modules>
        <module>user-service-provider</module>
        <module>order-service-consumer</module>
        <module>interface-service</module>
    </modules>

    <packaging>pom</packaging>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <spring.version>4.3.16.RELEASE</spring.version>
        <dubbo.version>3.0.7</dubbo.version>
        <junit.version>4.13.1</junit.version>
        <slf4j-log4j12.version>1.7.25</slf4j-log4j12.version>
        <spring-boot.version>2.3.1.RELEASE</spring-boot.version>
        <spring-boot-maven-plugin.version>2.1.4.RELEASE</spring-boot-maven-plugin.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <!-- Spring Boot -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-bom</artifactId>
                <version>${dubbo.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-dependencies-zookeeper</artifactId>
                <version>${dubbo.version}</version>
                <type>pom</type>
            </dependency>

            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
                <scope>test</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>${slf4j-log4j12.version}</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.7.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

接口服务 interface-service

在这里插入图片描述

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-springboot</artifactId>
        <groupId>cn.tojintao</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>interface-service</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

</project>

一、定义实体类

注意要实现 Serializable 接口。

public class User implements Serializable {

    private Long userId;

    private String userName;

    private Integer age;

	//省略......
}

二、定义接口

  • UserService
public interface UserService {

    List<User> getUserListByAge(Integer age);
}
  • OrderService
public interface OrderService {

    List<User> initOrder(Integer age);
}

服务提供者 user-service-provider

在这里插入图片描述

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-springboot</artifactId>
        <groupId>cn.tojintao</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>user-service-provider</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>cn.tojintao</groupId>
            <artifactId>interface-service</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- dubbo -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>

<!--二选一-->
<!--
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            <version>2.2.5.RELEASE</version>
        </dependency>
-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>3.1.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>1.4.2</version>
        </dependency>


        <!-- dubbo starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>

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

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>${spring-boot-maven-plugin.version}</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

一、application.yml

server:
  port: 8090

spring:
  application:
    name: user-service-provider

dubbo:
  application:
    name: user-service-provider
  protocol:
    name: dubbo
    port: 20890  # dubbo服务暴露的端口
  registry:
    protocol: nacos
    address: 127.0.0.1:8848
  config-center:
    protocol: nacos
    address: 127.0.0.1:8848
  metadata-report:
    protocol: nacos
    address: 127.0.0.1:8848

二、UserService实现类

核心注解 @DubboService 用于暴露 Dubbo 服务。

@DubboService
@Service
public class UserServiceImpl implements UserService {

    @Override
    public List<User> getUserListByAge(Integer age) {
        System.out.println(age);
        User user1 = new User(11L, "小明", age);
        User user2 = new User(12L, "小刚", age);
        return Arrays.asList(user1, user2);
    }
}

三、启动类

注解 @EnableDubbo 用于扫描 Dubbo 配置类以及指定扫描 @DubboService 的路径并注册 bean 到 Spring 容器。

@EnableDubbo
@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

服务消费者 order-service-consumer

在这里插入图片描述

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-springboot</artifactId>
        <groupId>cn.tojintao</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>order-service-consumer</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>cn.tojintao</groupId>
            <artifactId>interface-service</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- dubbo -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>3.1.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.nacos</groupId>
            <artifactId>nacos-client</artifactId>
            <version>1.4.2</version>
        </dependency>

        <!-- dubbo starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>

        <!-- spring starter -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>${spring-boot-maven-plugin.version}</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

一、application.yml

server:
  port: 8091

spring:
  application:
    name: order-service-consumer

dubbo:
  application:
    name: order-service-consumer
  protocol:
    name: dubbo
    port: 20890  # dubbo服务暴露的端口
  registry:
    protocol: nacos
    address: 127.0.0.1:8848
  config-center:
    protocol: nacos
    address: 127.0.0.1:8848
  metadata-report:
    protocol: nacos
    address: 127.0.0.1:8848

二、OrderService实现类

核心注解 @DubboReference 用于引用 Dubbo 服务，进行远程过程调用。

@Service
public class OrderServiceImpl implements OrderService {

    @DubboReference
    private UserService userService;

    @Override
    public List<User> initOrder(Integer age) {
        List<User> users = userService.getUserListByAge(age);
        for (User user : users) {
            System.out.println("init order by user : " + user);
        }
        return users;
    }
}

三、Controller 层提供 Rest 接口

@RestController
public class OrderController {

    @Autowired
    private OrderService orderService;

    @GetMapping("/getUserByAge")
    public List<User> getUserByAge(@RequestParam("age") Integer age) {
        return orderService.initOrder(age);
    }
}

四、启动类

同样注意使用 @EnableDubbo 注解。

@EnableDubbo
@SpringBootApplication
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

至此，Dubbo 与 SpringBoot 的整合就完成了，关于服务之间的调用与监控可以通过 dubbo-admin 进行观测。

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/30683.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

浅谈中小企业的供应商管理

浅谈中小企业的供应商管理

一、供应商管理的概念 供应商管理&#xff0c;是在新的物流与采购经济形势下&#xff0c;提出的管理机制。现代管理学如MBA、EMBA等将其分为竞争式及双赢式两种模式。供应商管理是供应链采购管理中一个很重要的环节&#xff0c;它在实现准时化采购中有很重要的作用。供应商管理…
阅读更多...
Linux | 进程间通信 | 匿名管道 | 命名管道 | 模拟代码实现进程通信 | 控制多子进程时的资源回收问题

Linux | 进程间通信 | 匿名管道 | 命名管道 | 模拟代码实现进程通信 | 控制多子进程时的资源回收问题

文章目录进程通信的意义匿名管道通信原理管道的访问控制进程控制管道的特点命名管道进程通信的意义 之前聊进程时&#xff0c;讲过一个性质&#xff0c;即进程具有独立性&#xff0c;两个进程之间的交互频率是比较少的。就连父子进程也只是共享代码&#xff0c;修改父子进程中…
阅读更多...
Bezier曲线与B-Spline曲线

Bezier曲线与B-Spline曲线

贝塞尔曲线 一阶贝塞尔曲线P01P_0^1P01​由两个控制点P0P_0P0​和P1P_1P1​完全定义&#xff0c;相当于线性插值。随着ttt从0到1变化&#xff0c;贝塞尔点从P0P_0P0​移动到P1P_1P1​. P01(1−t)P0tP1,t∈[0,1]P_{0}^{1}\left( 1-t\right) P_{0}tP_{1}\quad,t\in[0,1] P01​(1−…
阅读更多...
服务器是什么

服务器是什么

服务器是什么 服务器是什么&#xff1a;服务器英文名称为“Server”&#xff0c;指的是网络环境下为客户机(Client)提供某种服务的专用计算机&#xff0c;服务器安装有网络操作系统(如Windows Server、Linux、Unix等)和各种服务器应用系统软件(如Web服务、电子邮件服务)&#…
阅读更多...
操作系统：进程的创建（fork函数）、进程的替换（exec函数）、进程的阻塞（wait函数）、进程的终止（exit函数）、进程的挂起（sleep函数）

操作系统：进程的创建（fork函数）、进程的替换（exec函数）、进程的阻塞（wait函数）、进程的终止（exit函数）、进程的挂起（sleep函数）

文章目录1.进程的创建2.进程的替换3.进程的阻塞4.进程终止5.进程的挂起1.进程的创建 ①调用fork函数的进程为父进程&#xff0c;调用后生成一个子进程&#xff1b; ②创建子进程成功时&#xff0c;父进程中fork函数的返回值是子进程的进程号PID&#xff1b; ③创建子进程失败时…
阅读更多...
关于Java代码如何项目部署

关于Java代码如何项目部署

在研究注解的时候会用到反射&#xff0c;在学习反射的时候会涉及到关于class文件的生成&#xff0c;以及Class文件是如何被执行的等一系列关于文件转换的问题&#xff0c;接下来就借助学习反射来学习一下项目整体部署的过程和每个阶段要生成的文件. 我们写的代码写完并测试之后…
阅读更多...
粒子群算法求解电力系统环境经济调度+微电网调度（风、光、电动车、柴油机、主网）（Python代码实现）

粒子群算法求解电力系统环境经济调度+微电网调度（风、光、电动车、柴油机、主网）（Python代码实现）

目录 1 电力系统环境经济调度数学模型 2 改进粒子群算法解决 2.1 知识回顾 2.2 案例1——IEEE6节点 2.3 案例2——IEEE10 2.4 案例3——IEEE40 3 Python代码 1 电力系统环境经济调度数学模型 2 改进粒子群算法解决 2.1 知识回顾 先回顾一下相关知识点&#xff1a; *智…
阅读更多...
打开网站出现Internal Server Error的原因和解决方法

打开网站出现Internal Server Error的原因和解决方法

打开网站出现Internal server error 500错误&#xff0c;通常是服务端出现一些未知异常&#xff0c;但是在检查的时候我们不能仅仅只是关注应用服务&#xff0c;而是要关注从服务端接收请求开始&#xff0c;一直到应用服务的整条链路。 程序文件中的权限问题导致Internal Serv…
阅读更多...
正确的PMP®答题思路——让你考试更轻松

正确的PMP®答题思路——让你考试更轻松

想要考取PMP的小伙伴们&#xff0c;大家现在复习的如何呢&#xff1f;是不是还在不断刷题呢&#xff1f;做题不单单需要充足的知识储备&#xff0c;更需要正确的答题思路&#xff0c;今天小编给大家整理了PMP考试答题的一些思路&#xff0c;想要考取PMP的小伙伴们快来看看吧&am…
阅读更多...
Wireshark过滤器语法

Wireshark过滤器语法

1.官网地址 点击进入 2.捕获过滤器 使用捕获过滤器Wireshark只捕获满足过滤器条件的数据包进来。捕获过滤器采用BPF语法表达式&#xff0c;表达式由如下及部分组成: Dir 指明传输方向是前往还是来自 例如&#xff1a;src、dst Type 指出名字或数字所代表的意&#xff0c;例如…
阅读更多...
SpringCloud微服务（七）——Bus服务消息总线

SpringCloud微服务（七）——Bus服务消息总线

SpringCloud Bus动态刷新全局广播 SpringCloud Spring Cloud Bus配合Spring Cloud Config使用可以实现配置的动态刷新&#xff0c;通知一处&#xff0c;处处生效。而不用一个一个去通知。 Spring Cloud Bus是消息总线&#xff0c;广播通知都可以集成&#xff0c;不止用于实现…
阅读更多...
java项目测试成功后部署到服务器上的相关问题

java项目测试成功后部署到服务器上的相关问题

1.java项目是如何部署给用户使用的? 前提&#xff1a; 以一个web项目为例&#xff0c; 使用工具&#xff1a;开发工具&#xff1a;IDEA&#xff1b;Tomcat&#xff08;应用服务器&#xff09;&#xff1b;Navicat&#xff08;数据库&#xff09;&#xff1b;Jenkins&#xff…
阅读更多...
CDMP考试需不需要参加培训课程？培训机构哪家比较好？

CDMP考试需不需要参加培训课程？培训机构哪家比较好？

参加CDMP认证考试到底要不要参加培训课程&#xff0c;身边的很多同学都参加了培训班&#xff0c;我要参加吗&#xff1f;总是会有很这样的人提出这样的问题。 那么&#xff0c;我想说考试的结果不在于你定什么样的目标&#xff0c;如何做计划&#xff0c;而在于你何时开始行动…
阅读更多...
Flutter高仿微信-第26篇-新的朋友

Flutter高仿微信-第26篇-新的朋友

Flutter高仿微信系列共59篇&#xff0c;从Flutter客户端、Kotlin客户端、Web服务器、数据库表结构、Xmpp即时通讯服务器、视频通话服务器、腾讯云服务器全面讲解。 详情请查看 效果图&#xff1a; 实现代码&#xff1a; /*** Author : wangning* Email : maoning20080809163.c…
阅读更多...
智慧餐厅解决方案-最新全套文件

智慧餐厅解决方案-最新全套文件

智慧餐厅解决方案-最新全套文件一、建设背景二、建设思路1、刺激消费手段单一2、用户信息反馈量少3、商家推广覆盖面小4、生产力利用率偏低三、建设方案1 、组织人事在线管理&#xff0c;盘活内部人力资源2、多样化考勤方式&#xff0c;轻松实现多地工时管理3、数据成本分析&am…
阅读更多...
大数据（9f）Flink状态编程

大数据（9f）Flink状态编程

文章目录概述Managed StateOperator StateListStateBroadcastStateKeyed StateValueStateListStateMapStateReducingStateAggregatingState状态后端Appendix概述 流式计算 分为 无状态计算 和 有状态计算 流处理的状态功能&#xff1a;去重、监控…… 状态分类Managed StateR…
阅读更多...
半诚实模型与恶意模型

半诚实模型与恶意模型

原创 洪澄 开放隐私计算 开放隐私计算 开放隐私计算OpenMPC是国内第一个且影响力最大的隐私计算开放社区。社区秉承开放共享的精神&#xff0c;专注于隐私计算行业的研究与布道。社区致力于隐私计算技术的传播&#xff0c;愿成为中国 “隐私计算最后一公里的服务区”。 178篇…
阅读更多...
【Unity】自定义Untiy天空

【Unity】自定义Untiy天空

3、需求&#xff1a;更改默认天空盒&#xff0c;360显示所需的内容。 实施&#xff1a; 准备材料&#xff1a;一张8K图&#xff08;更清晰&#xff09; 步骤&#xff1a; 1、更改Camera为天空盒&#xff1b; 2、制作图片&#xff0c;怎么制作不说了&#xff0c;分辨率8192…
阅读更多...
Linux服务器安装部署最新稳定版本mongoDB社区版- Ubuntu-20.04版本

Linux服务器安装部署最新稳定版本mongoDB社区版- Ubuntu-20.04版本

没有玩过mongoDB&#xff0c;安装一次真&#x1f92c;波折&#xff0c;再次建议大家安装之前&#xff0c;一定要确定好服务器的操作系统&#xff0c;可以参考查看linux操作系统版本&#xff1a;Ubuntu&#xff1f;Centos&#xff1f;还是其他&#xff1f; 接前面在本地自测需要…
阅读更多...
解决jupyter下载好了库，但是无法使用的问题。以及补充jupyter如何下载新的库。

解决jupyter下载好了库，但是无法使用的问题。以及补充jupyter如何下载新的库。

文章目录出现原因验证解决步骤补充国内常用镜像源出现原因 出现这个问题的主要原因是&#xff0c;jupyter的内核&#xff08;或者说他使用的Python环境&#xff09;与下载库的环境不一样&#xff0c;解决办法就是更改kernel。换句话说就是将jupyter下载库的环境加入到内核环境…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023