AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

Springboot 最简单的整合Dubbo框架实战案例

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

分布式框架，目前比较热门的是springcloud和dubbo，虽然本人也是用cloud比较多，但是避免不了，有的项目就是需要用dubbo。


那么现在就给大家整一篇，简单清晰的spirngboot从零整合dubbo。

 

先看看这个简单的整合完毕后，项目结构是这样的：


image.png


里面包含的有，公共model模块、公共interface模块； 消费者consumer1服务、消费者consumer2服务、提供者provider服务；


里面的关联关系大致是，


a.提供者provider服务 是需要导入 公共model模块、公共interface模块 的，因为写的接口实现类会用到model和service；


b.消费者consumer1服务、消费者consumer2服务 是需要导入 公共interface模块 的（看实际需要导入model模块或是重建相关的业务model）


对了，消费者consumer、提供者provider都是需要注册到同一个zookpeer上去的，这样提供者才能通过注册中心将需要向外提供的接口暴露；消费者才能通过注册中心扫描使用相关的接口。


简单介绍先到这（深入理解可以额外去网上研究，这里只做整合实战介绍）。


首先我们创建一个Maven项目，然后建一个Module 起名为dubbomodel，


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>testdubbo</artifactId>
        <groupId>springboot-dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>dubbo-model</artifactId>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.18</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.6.RELEASE</version>
        </dependency>
    </dependencies>
</project>


ps：上面导入了lombok jar包其实仅仅为了省事，通过注解去弄set、get、构造等等方法，也可以不导入


然后简单建一个User.java：


package top.test.model.user.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
 * @Author：JCccc
 * @Description：
 * @Date： created in 10:09 2019/5/5
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
    private Integer id;
    private String username;
    private String password;
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
}


OK，公共model模块就这样先。


接着，再建一个Module，起名为dubbointerface：


pom文件不需要导入额外jar包:


<?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>testdubbo</artifactId>
        <groupId>springboot-dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>dubbo-interface</artifactId>
</project>


建一个简单的Service，准备暴露到注册中心zookeeper去，HelloService.java：


/**
 * @Author：JCccc
 * @Description：
 * @Date： created in 11:00 2019/4/25
 */
public interface HelloService {
    public  String sayHello(String name);
}


OK，公共interface模块就这样先。


接着，我们开始写一个 提供者provider服务，建一个Module（Springboot项目），起名为dubbo-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">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.4.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <groupId>test-dubbo</groupId>
  <artifactId>dubbo-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>dubbo-provider</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>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <!--公共interface模块-->
    <dependency>
      <groupId>springboot-dubbo</groupId>
      <artifactId>dubbo-interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <!--公共model模块-->
    <dependency>
      <groupId>springboot-dubbo</groupId>
      <artifactId>dubbo-model</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <!--引入dubbo的依赖-->
    <dependency>
      <groupId>com.alibaba.spring.boot</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.0.0</version>
    </dependency>
    <!-- 引入zookeeper的依赖 -->
    <dependency>
      <groupId>com.101tec</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.10</version>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>


可以看到，我们在provider服务里引入了公共的model、公共的interface、以及重要的dubbo依赖和zookeeper依赖。


接着是application.properties：


# 配置端口
server.port=8333
# 注册到本地zookeeper
spring.dubbo.application.name=dubbo-provider
spring.dubbo.application.registry=zookeeper://127.0.0.1:2181


然后写一个接口实现类HelloServiceImpl.java ，用于实现需要用到的接口（来自于导入的公共接口模块）：


import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.test.service.HelloService;
/**
 * @Author：JCccc
 * @Description：
 * @Date： created in 11:08 2019/4/25
 */
@Component
@Service
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}


特别提醒，这里的@Service使用的是dubbo依赖包提供的com.alibaba.dubbo.config.annotation.Service


在项目启动类需要开启dubbo自动配置注解，@EnableDubboConfiguration：


package testdubbo.dubboprovider;
import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
// 开启dubbo的自动配置
@EnableDubboConfiguration
public class DubboProviderApplication {
  public static void main(String[] args) {
    SpringApplication.run(DubboProviderApplication.class, args);
  }
}


OK，provider就这样先。


接着我们开始写一个消费者consumer ，建一个Module，起名为dubbo-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>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.4.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>
  <groupId>testdubbo</groupId>
  <artifactId>dubbo-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>dubbo-consumer</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>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>springboot-dubbo</groupId>
      <artifactId>dubbo-interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <!--引入dubbo的依赖-->
    <dependency>
      <groupId>com.alibaba.spring.boot</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.0.0</version>
    </dependency>
    <!-- 引入zookeeper的依赖 -->
    <dependency>
      <groupId>com.101tec</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.10</version>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>


然后是application.properties：


# 配置端口
server.port=8433
spring.dubbo.application.name=dubbo-consumer
spring.dubbo.application.registry=zookeeper://127.0.0.1:2181


接着写一个Controller来消费一下刚刚provider暴露到注册中心的接口，HelloController.java：


package testdubbo.dubboconsumer.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import top.test.service.HelloService;
/**
 * @Author：JCccc
 * @Description：
 * @Date： created in 11:12 2019/4/25
 */
@RestController
public class HelloController {
    @Reference
    private HelloService helloService;
    @RequestMapping("/hello")
    public String hello() {
        String hello = helloService.sayHello("world");
        System.out.println(helloService.sayHello("JCccc"));
        return hello;
    }
}


特别提醒，@Reference 这个注解是使用dubbo去zookeeper注册中心去扫描已经暴露的接口

 

在项目启动类需要开启dubbo自动配置注解，@EnableDubboConfiguration：


package testdubbo.dubboconsumer;
import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubboConfiguration
public class DubboConsumerApplication {
  public static void main(String[] args) {
    SpringApplication.run(DubboConsumerApplication.class, args);
  }
}


OK，消费者consumer2可以自己按照这个模式扩展，这里不用重复介绍了，我们来开始测试，


先将provider服务跑起来，再将consumer服务跑起来，


用postman调下消费者consumer的接口，


image.png


可以看到成功调用到消费者服务的接口，证明简单的一个流程走通。


OK，简单的springboot+dubbo框架整合使用到此。

文章标签：
微服务引擎
Java
应用服务中间件
Dubbo
Maven
关键词：
Spring boot框架
Spring Boot框架实战
Dubbo springboot
Dubbo框架
Spring Boot案例
小目标青年
目录
相关文章
木流牛马
|
9月前
|
安全 Java Ruby
我尝试了所有后端框架 — — 这就是为什么只有 Spring Boot 幸存下来
作者回顾后端开发历程，指出多数框架在生产环境中难堪重负。相比之下，Spring Boot凭借内置安全、稳定扩展、完善生态和企业级支持，成为构建高可用系统的首选，真正经受住了时间与规模的考验。
木流牛马
686 2
啦啦啦191
|
10月前
|
监控 Java API
Spring Boot 3.2 结合 Spring Cloud 微服务架构实操指南 现代分布式应用系统构建实战教程
Spring Boot 3.2 + Spring Cloud 2023.0 微服务架构实践摘要 本文基于Spring Boot 3.2.5和Spring Cloud 2023.0.1最新稳定版本，演示现代微服务架构的构建过程。主要内容包括： 技术栈选择：采用Spring Cloud Netflix Eureka 4.1.0作为服务注册中心，Resilience4j 2.1.0替代Hystrix实现熔断机制，配合OpenFeign和Gateway等组件。 核心实操步骤： 搭建Eureka注册中心服务 构建商品
啦啦啦191
1460 3
小华同学ai
|
NoSQL 安全 Java
2.2k star 单点登录框架揭秘！主流SSO太重？SpringBoot轻量级Smart‑SSO轻松接入·分布式·强踢人
Smart-SSO 是一个基于 SpringBoot 的轻量级单点登录框架，采用 OAuth2 授权码与 RBAC 权限设计，解决跨域认证、单点退出、令牌过期等痛点。支持自动续签、强制踢人、按钮级权限控制及分布式部署，适合中小团队快速构建高可用认证中台。项目已获 2.2k Star，代码开源，接入简单，是企业级应用的理想选择。[详情见 GitHub](https://github.com/a466350665/smart-sso)。
小华同学ai
678 23
高端源码库
|
JavaScript 前端开发 Java
制造业ERP源码，工厂ERP管理系统，前端框架：Vue，后端框架：SpringBoot
这是一套基于SpringBoot+Vue技术栈开发的ERP企业管理系统，采用Java语言与vscode工具。系统涵盖采购/销售、出入库、生产、品质管理等功能，整合客户与供应商数据，支持在线协同和业务全流程管控。同时提供主数据管理、权限控制、工作流审批、报表自定义及打印、在线报表开发和自定义表单功能，助力企业实现高效自动化管理，并通过UniAPP实现移动端支持，满足多场景应用需求。
高端源码库
1230 1
蒋星熠Jaxonic
|
8月前
|
监控 Cloud Native Java
Spring Boot 3.x 微服务架构实战指南
🌟蒋星熠Jaxonic，技术宇宙中的星际旅人。深耕Spring Boot 3.x与微服务架构，探索云原生、性能优化与高可用系统设计。以代码为笔，在二进制星河中谱写极客诗篇。关注我，共赴技术星辰大海！（238字）
蒋星熠Jaxonic
1350 2
Spring Boot 3.x 微服务架构实战指南
varin
|
9月前
|
消息中间件 Ubuntu Java
SpringBoot整合MQTT实战：基于EMQX实现双向设备通信
本教程指导在Ubuntu上部署EMQX 5.9.0并集成Spring Boot实现MQTT双向通信，涵盖服务器搭建、客户端配置及生产实践，助您快速构建企业级物联网消息系统。
varin
2977 1
源码世界
|
前端开发 Java 物联网
智慧班牌源码，采用Java + Spring Boot后端框架，搭配Vue2前端技术，支持SaaS云部署
智慧班牌系统是一款基于信息化与物联网技术的校园管理工具，集成电子屏显示、人脸识别及数据交互功能，实现班级信息展示、智能考勤与家校互通。系统采用Java + Spring Boot后端框架，搭配Vue2前端技术，支持SaaS云部署与私有化定制。核心功能涵盖信息发布、考勤管理、教务处理及数据分析，助力校园文化建设与教学优化。其综合性和可扩展性有效打破数据孤岛，提升交互体验并降低管理成本，适用于日常教学、考试管理和应急场景，为智慧校园建设提供全面解决方案。
源码世界
739 70
北风几吹夏
|
监控 Java 调度
SpringBoot中@Scheduled和Quartz的区别是什么？分布式定时任务框架选型实战
本文对比分析了SpringBoot中的`@Scheduled`与Quartz定时任务框架。`@Scheduled`轻量易用，适合单机简单场景，但存在多实例重复执行、无持久化等缺陷；Quartz功能强大，支持分布式调度、任务持久化、动态调整和失败重试，适用于复杂企业级需求。文章通过特性对比、代码示例及常见问题解答，帮助开发者理解两者差异，合理选择方案。记住口诀：单机简单用注解，多节点上Quartz；若是任务要可靠，持久化配置不能少。
北风几吹夏
1100 4
星兽
|
11月前
|
消息中间件 NoSQL Java
SpringBoot框架常见的starter你都用过哪些 ？
本节介绍常见的Spring Boot Starter，分为官方（如Web、AOP、Redis等）与第三方（如MyBatis、MyBatis Plus）两类，用于快速集成Web开发、数据库、消息队列等功能。
星兽
550 0
varin
|
缓存 安全 Java
深入解析HTTP请求方法：Spring Boot实战与最佳实践
这篇博客结合了HTTP规范、Spring Boot实现和实际工程经验，通过代码示例、对比表格和架构图等方式，系统性地讲解了不同HTTP方法的应用场景和最佳实践。
varin
1164 5

热门文章

最新文章

  • 1
    基于 Spring Cloud 的微服务架构分析
  • 2
    spring - AOP 使用方式（二）
  • 3
    Spring MVC 之请求处理方法可接收参数(三)
  • 4
    spring整合消息队列rabbitmq
  • 5
    SpringCloud Alibaba学习
  • 6
    （四）海哇VR全景电商平台-海哇VR海播模块（海哇直播带货、短视频带货）Spring Cloud B2B2C 电子商务
  • 7
    spring各种类型的属性注入
  • 8
    spring log 日志管理
  • 9
    Spring自动化装配bean
  • 10
    spring 定时任务执行两次解决办法
  • 1
    SpringBoot启动时连接Redis报错：ERR This instance has cluster support disabled - 如何解决？
    708
  • 2
    基于springboot的大学生兼职系统
    583
  • 3
    基于springboot的宠物领养系统
    747
  • 4
    2025基于springboot的校车预定全流程管理系统
    750
  • 5
    基于springboot的美食城服务管理系统
    499
  • 6
    基于springboot的高校运动会系统
    466
  • 7
    【Spring Boot实战】EasyPoi神技：一篇搞定“一对多+图片”导入！
    2061
  • 8
    《深入理解Spring》 Spring Boot——约定优于配置的革命者
    1127
  • 9
    《深入理解Spring》：Spring、Spring MVC与Spring Boot的深度解析
    2181
  • 10
    基于springboot的网咖网吧管理系统
    572

    • 相关课程

    更多
  • SpringBoot实战教程
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • SpringBoot快速掌握 - 核心技术
  • SpringBoot快速掌握 - 高级应用
  • Dubbo分布式服务治理实战
  • Springboot项目云开发快速迁移

    • 相关电子书

    更多
  • Dubbo开源现状与2.7规划
  • Dubbo分布式服务治理实战
  • 《Dubbo 3.0 前瞻》
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！