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

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

2022-05-31 399
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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框架案例
Spring Boot dubbo实战
Spring Boot dubbo案例
Dubbo框架案例
小目标青年
目录
相关文章
木流牛马
|
11月前
|
安全 Java Ruby
我尝试了所有后端框架 — — 这就是为什么只有 Spring Boot 幸存下来
作者回顾后端开发历程，指出多数框架在生产环境中难堪重负。相比之下，Spring Boot凭借内置安全、稳定扩展、完善生态和企业级支持，成为构建高可用系统的首选，真正经受住了时间与规模的考验。
木流牛马
719 2
啦啦啦191
|
12月前
|
监控 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
1507 3
游客ei4oozwd2l7wm
|
12月前
|
XML JSON Java
Spring框架中常见注解的使用规则与最佳实践
本文介绍了Spring框架中常见注解的使用规则与最佳实践，重点对比了URL参数与表单参数的区别，并详细说明了@RequestParam、@PathVariable、@RequestBody等注解的应用场景。同时通过表格和案例分析，帮助开发者正确选择参数绑定方式，避免常见误区，提升代码的可读性与安全性。
游客ei4oozwd2l7wm
544 0
一枚后端工程狮
|
10月前
|
安全 前端开发 Java
《深入理解Spring》：现代Java开发的核心框架
Spring自2003年诞生以来，已成为Java企业级开发的基石，凭借IoC、AOP、声明式编程等核心特性，极大简化了开发复杂度。本系列将深入解析Spring框架核心原理及Spring Boot、Cloud、Security等生态组件，助力开发者构建高效、可扩展的应用体系。（238字）
一枚后端工程狮
1093 55
蒋星熠Jaxonic
|
10月前
|
监控 Cloud Native Java
Spring Boot 3.x 微服务架构实战指南
🌟蒋星熠Jaxonic，技术宇宙中的星际旅人。深耕Spring Boot 3.x与微服务架构，探索云原生、性能优化与高可用系统设计。以代码为笔，在二进制星河中谱写极客诗篇。关注我，共赴技术星辰大海！（238字）
蒋星熠Jaxonic
1413 2
Spring Boot 3.x 微服务架构实战指南
varin
|
11月前
|
消息中间件 Ubuntu Java
SpringBoot整合MQTT实战：基于EMQX实现双向设备通信
本教程指导在Ubuntu上部署EMQX 5.9.0并集成Spring Boot实现MQTT双向通信，涵盖服务器搭建、客户端配置及生产实践，助您快速构建企业级物联网消息系统。
varin
3076 1
蓝易云
|
10月前
|
消息中间件 缓存 Java
Spring框架优化：提高Java应用的性能与适应性
以上方法均旨在综合考虑Java Spring 应该程序设计原则, 数据库交互, 编码实践和系统架构布局等多角度因素, 旨在达到高效稳定运转目标同时也易于未来扩展.
蓝易云
807 8
JJLIN距离
|
11月前
|
监控 Kubernetes Cloud Native
Spring Batch 批处理框架技术详解与实践指南
本文档全面介绍 Spring Batch 批处理框架的核心架构、关键组件和实际应用场景。作为 Spring 生态系统中专门处理大规模数据批处理的框架，Spring Batch 为企业级批处理作业提供了可靠的解决方案。本文将深入探讨其作业流程、组件模型、错误处理机制、性能优化策略以及与现代云原生环境的集成方式，帮助开发者构建高效、稳定的批处理系统。
JJLIN距离
902 1
啦啦啦191
|
安全 Java 微服务
Java 最新技术和框架实操：涵盖 JDK 21 新特性与 Spring Security 6.x 安全框架搭建
本文系统整理了Java最新技术与主流框架实操内容，涵盖Java 17+新特性（如模式匹配、文本块、记录类）、Spring Boot 3微服务开发、响应式编程（WebFlux）、容器化部署（Docker+K8s）、测试与CI/CD实践，附完整代码示例和学习资源推荐，助你构建现代Java全栈开发能力。
啦啦啦191
1073 1
Unfailed_realme
|
缓存 安全 Java
Spring 框架核心原理与实践解析
本文详解 Spring 框架核心知识，包括 IOC（容器管理对象）与 DI（容器注入依赖），以及通过注解（如 @Service、@Autowired）声明 Bean 和注入依赖的方式。阐述了 Bean 的线程安全（默认单例可能有安全问题，需业务避免共享状态或设为 prototype）、作用域（@Scope 注解，常用 singleton、prototype 等）及完整生命周期（实例化、依赖注入、初始化、销毁等步骤）。 解析了循环依赖的解决机制（三级缓存）、AOP 的概念（公共逻辑抽为切面）、底层动态代理（JDK 与 Cglib 的区别）及项目应用（如日志记录）。介绍了事务的实现（基于 AOP
Unfailed_realme
479 0

热门文章

最新文章

  • 1
    图解 Spring 循环依赖，写得太好了！
  • 2
    Spring3 MVC 集成Velocity中文支持
  • 3
    Spring 代理 Bean 中获取不到原始 Bean 对象注解的解决方法
  • 4
    F版本SpringCloud 3—大白话Eureka服务注册与发现
  • 5
    SpringCloud启动报错：Error creating bean with name configurationPropertiesBeans
  • 6
    Spring(十一)之AOP
  • 7
    Spring整合JMS（三）——MessageConverter介绍
  • 8
    Spring Security-退出登录和CSRF
  • 9
    Spring事务传播行为
  • 10
    spring-boot - demo
  • 1
    SpringBoot启动时连接Redis报错：ERR This instance has cluster support disabled - 如何解决？
    741
  • 2
    基于springboot的大学生兼职系统
    609
  • 3
    基于springboot的宠物领养系统
    786
  • 4
    2025基于springboot的校车预定全流程管理系统
    797
  • 5
    基于springboot的美食城服务管理系统
    534
  • 6
    基于springboot的高校运动会系统
    494
  • 7
    【Spring Boot实战】EasyPoi神技：一篇搞定“一对多+图片”导入！
    2206
  • 8
    《深入理解Spring》 Spring Boot——约定优于配置的革命者
    1185
  • 9
    《深入理解Spring》：Spring、Spring MVC与Spring Boot的深度解析
    2270
  • 10
    基于springboot的网咖网吧管理系统
    604

    • 相关课程

    更多
  • SpringBoot快速掌握 - 核心技术
  • SpringBoot快速掌握 - 高级应用
  • Java Web开发系列课程 - Spring框架入门
  • Spring Boot 2.5.x开发实战
  • Springboot项目云开发快速迁移
  • Spring Cloud微服务架构设计与开发实战

    • 相关电子书

    更多
  • 云栖社区特邀专家徐雷Java Spring Boot开发实战系列课程（第20讲）：经典面试题与阿里等名企内部招聘求职面试技巧
  • 微服务架构模式与原理Spring Cloud开发实战
  • 阿里特邀专家徐雷Java Spring Boot开发实战系列课程（第18讲）：制作Java Docker镜像与推送到DockerHub和阿里云Docker仓库
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！