springCloud整合Dubbo案例

news2025/1/12 21:09:22

前言：

好久没有使用dubbo了，温习一下。

一、先搭建一个SpringCloud框架

整体框架如下图

1. 先创建一个父工程：

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

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.fan</groupId>
    <artifactId>springclouddubbo</artifactId>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>provider</module>
        <module>consumer</module>
        <module>common</module>
    </modules>
    <packaging>pom</packaging>


    <!-- 统一管理jar包版本 -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <junit.version>4.12</junit.version>
        <log4j.version>1.2.17</log4j.version>
        <lombok.version>1.16.18</lombok.version>
        <mysql.version>5.1.47</mysql.version>
        <druid.version>1.1.16</druid.version>
        <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
    </properties>

    <!-- 子模块继承之后，提供作用：锁定版本+子modlue不用写groupId和version  -->
    <dependencyManagement>
        <dependencies>
            <!--spring boot 2.2.2-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.2.2.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud Hoxton.SR1-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Hoxton.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis.spring.boot.version}</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>${lombok.version}</version>
                <optional>true</optional>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <fork>true</fork>
                    <addResources>true</addResources>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

注意：刚创建时还没有 <modules>

2. 子工程 provider

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.8.RELEASE</version>
        </dependency>
    </dependencies>
ProviderApplication启动类：
@SpringBootApplication
public class ProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

 3. 子工程 consumer

pom同上，ConsumerApplication启动类：

@SpringBootApplication
public class ConsumerApplication {

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

4. 分别创建对应的controller与service

provider

@Service
public class UserService {
    public String getUser() {
        return "user";
    }
}
@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/user")
    public String getUser() {
        return userService.getUser();
    }
}

consumer

@Service
public class OrderService {

    // 使用restTemplate，调用服务提供者的Controller方法
    @Autowired
    private RestTemplate restTemplate;

    public String getUser() {
        String forObject = restTemplate.getForObject("http://localhost:8080/user", String.class);
        return forObject;
    }
}
@RestController
public class UserController {

    @Autowired
    private OrderService orderService;

    @GetMapping("/order")
    public String getUser() {
        return orderService.getUser();
    }
}

分别启动provider、consumer，访问 http://localhost:8081/order 查看是否成功。

二、改造Dubbo

1.为provider、consumer添加pom依赖

添加dubbo核心依赖、添加要使用的协议的依赖、添加要使用的注册中心依赖，这里我使用nacos作为注册中心需要引入俩个依赖。

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>3.0.7</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-rpc-dubbo</artifactId>
            <version>3.0.7</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>3.0.7</version>
        </dependency>

2.配置dubbo相关的基本信息

 配置application.properties，注意修改consumer对应的name

server.port=8081
dubbo.application.name=provider-application
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dobbo.protocol.host=127.0.0.1
dubbo.registry.address=zookeeper://127.0.0.1:2181
server.port=8082

dubbo.application.name=consumer-application
dubbo.registry.address=zookeeper://127.0.0.1:2181

3. 改造项目

由于dubbo是面向接口的形式，所以我们不在使用 RestTemplate 要替换为对应的服务接口。

（1）修改provider

        创建userseivce接口

public interface UserService {
    public String getUser();
}

        实现该接口

// 可以为Dubbo服务添加对应的版本
@DubboService(version = "1.0")
public class UserServiceImpl implements UserService {
    public String getUser() {
        return "user";
    }
}

@DubboService：SpringBoot将添加该注解的方法发布为Dubbo服务。

由于我们要提供服务接口，所以 provider中的controller已经没有用了，这里可以删除了。

（2）创建公共模块，抽象服务接口

创建公共模块，common，将provider中的 UserService移动到common中

为provider、consumer添加公共模块的依赖

        <dependency>
            <groupId>com.fan</groupId>
            <artifactId>common</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

（3）修改consumer

@Service
public class OrderService {

    @DubboReference
    private UserService userService;

    public String getUser() {
        return userService.getUser();
    }
}

  • @DubboReference：注入远程服务的代理对象。

（4）启动类开启@EnableDubbo

@EnableDubbo：用于扫描@DubboService(加在启动类上，就会扫描启动类所在包及其子包内的所有@DubboService)，并把对应的对象实例化，发布成RPC服务。

@DubboComponentScan：如果需要扫描其他包下的注解使用。

在yml配置文件中，扫描包dubbo.scan.base-packages等同于@EnableDubbo注解

4. 启动项目

先启动 provider、再启动consumer，浏览器访问：http://localhost:8082/order

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

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

相关文章

【Qt 初识】QPushButton 的详解以及 Qt 中的坐标

【Qt 初识】QPushButton 的详解以及 Qt 中的坐标

文章目录 1. Qt 中的信号槽机制 &#x1f34e;2. 通过图形化界面的方式实现 &#x1f34e;3. 通过纯代码的方式实现按钮版的HelloWorld &#x1f34e;4. 设置坐标 &#x1f34e; 1. Qt 中的信号槽机制 &#x1f34e; 》&#x1f427; 本质就是给按钮的点击操作&#xff0c;关联…
阅读更多...
Nodejs 第八十四章（ElasticSearch搜索）

Nodejs 第八十四章（ElasticSearch搜索）

ElasticSearch基本用法在之前的篇章介绍过了 这里不在过多阐述 模拟假数据 安装库 faker-js/faker 模拟假数据的一个库非常好用支持中文使用中文 locale: [zh_CN], 设置即可生成名字&#xff0c;邮箱&#xff0c;手机号&#xff0c;id&#xff0c;年龄&#xff0c;性别生成完成…
阅读更多...
【自然语言处理】面向新冠肺炎的社会计算应用

【自然语言处理】面向新冠肺炎的社会计算应用

面向新冠肺炎的社会计算应用 1 任务目标 1.1 案例简介 新冠肺炎疫情牵动着我们每一个人的心&#xff0c;在这个案例中&#xff0c;我们将尝试用社会计算的方法对疫情相关的新闻和谣言进行分析&#xff0c;助力疫情信息研究。本次作业为开放性作业&#xff0c;我们提供了疫情…
阅读更多...
软件安装下载失败，常见问题汇总（微软软件必备运行库）

软件安装下载失败，常见问题汇总（微软软件必备运行库）

文章目录 前言一、卸载软件二、激活软件无法打开&#xff1f;三、安装软件必备运用库扩展&#xff1a;win64位操作系统跟win32位操作系统区别之处 前言 我们在安装激活一些常用的办公软件&#xff0c;如&#xff1a;visio、Matlab、office等等&#xff0c;经常会遇到各种问题&…
阅读更多...
Feature Alignment and Uniformity for Test Time Adaptation--论文笔记

Feature Alignment and Uniformity for Test Time Adaptation--论文笔记

论文笔记 资料 1.代码地址 https://github.com/SakurajimaMaiii/TSD 2.论文地址 https://arxiv.org/abs/2303.10902 3.数据集地址 论文摘要的翻译 TTA在接收训练分布外的测试域样本时对深度神经网络进行自适应。在这样设置下&#xff0c;模型只能访问在线未标记的测试样…
阅读更多...
在conda的环境中安装Jupyter及其他软件包

在conda的环境中安装Jupyter及其他软件包

Pytorch版本、安装和检验 大多数软件包都是随Anaconda安装的&#xff0c;也可以根据需要手动安装一些其他软件包。 目录 创建虚拟环境 进入虚拟环境 安装Jupyter notebook 安装matplotlib 安装 pandas 创建虚拟环境 基于conda包的环境创建、激活、管理与删除http://t.cs…
阅读更多...
云计算【第一阶段（29）】远程访问及控制

云计算【第一阶段（29）】远程访问及控制

一、ssh远程管理 1.1、ssh (secureshell)协议 是一种安全通道协议对通信数据进行了加密处理&#xff0c;用于远程管理功能SSH 协议对通信双方的数据传输进行了加密处理&#xff0c;其中包括用户登录时输入的用户口令&#xff0c;建立在应用层和传输层基础上的安全协议。SSH客…
阅读更多...
2个月拿下TOGAF证书的一点心得分享，干货很多！

2个月拿下TOGAF证书的一点心得分享，干货很多！

人物背景介绍&#xff1a; 从报名TOGAF考试到拿证&#xff0c;只用了两个月不到的时间。 考试成绩&#xff1a;TOGAF L1L2通过&#xff0c;L1获得87分&#xff0c;L2 获得70分。 引言&#xff1a; TOGAF证书作为国际架构标准&#xff0c;不仅包括了架构顶点思维&#xff0c…
阅读更多...
SpringBoot注解--11--@JSONField @JsonProperty

SpringBoot注解--11--@JSONField @JsonProperty

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一个问题&#xff1a;后端实体类isXXX开头的属性&#xff0c;传到前端后自动去掉is解决方法&#xff1a; JsonProperty和JSONField1.简介2.注解的区别2.1 底层框架不…
阅读更多...
使用pip或conda离线下载安装包，使用pip或conda安装离线安装包

使用pip或conda离线下载安装包，使用pip或conda安装离线安装包

使用pip或conda离线下载安装包&#xff0c;使用pip或conda安装离线安装包 一、使用pip离线下载安装包1. 在有网络的机器上下载包和依赖2. 传输离线安装包 二、在目标机器上离线安装pip包三、使用conda离线下载安装包1. 在有网络的机器上下载conda包2. 传输conda包或环境包3. 在…
阅读更多...
基于QT开发的反射内存小工具

基于QT开发的反射内存小工具

前言 最近项目需要需要开发一个反射内存小工具&#xff0c;经过2天的修修改终于完成了。界面如下&#xff1a; 功能简介 反射内存指定地址数据读取反射内存指定地址数据写入反射内存指定地址数据清理十进制、十六进制、二进制数据相互转换 部分代码 void RfmMain::setWOthe…
阅读更多...
十七、计算机视觉-图像平滑处理

十七、计算机视觉-图像平滑处理

提示&#xff1a;云峰 文章目录 前言一、均值滤波&#xff08;Mean Filtering&#xff09;二、高斯滤波器&#xff08;Gaussian Filter&#xff09;&#xff1a;三、中值滤波器&#xff08;Median Filter&#xff09; 前言 在本节中&#xff0c;我们将探讨图像处理中的平滑处理…
阅读更多...
短视频矩阵管理系统：如何提升内容质量，帮助企业获客？

短视频矩阵管理系统：如何提升内容质量，帮助企业获客？

在数字化营销蓬勃发展的今天&#xff0c;短视频已成为企业推广的重要阵地。然而&#xff0c;如何高效管理短视频内容&#xff0c;提升内容质量&#xff0c;进而帮助企业精准获客&#xff0c;成为企业亟待解决的问题。短视频矩阵管理系统应运而生&#xff0c;以其强大的功能和灵…
阅读更多...
uniapp:使用mescroll实现左导航，右数据（数据带分页）

uniapp:使用mescroll实现左导航，右数据（数据带分页）

<template><view class"u-wrap"><u-navbar title"复购" :is-back"false" :border-bottom"false" title-color"#282828"></u-navbar><view class"u-menu-wrap"><scroll-view scr…
阅读更多...
Visual Studio下安装引入Boost库

Visual Studio下安装引入Boost库

背景&#xff1a; 在 Win 上通过 Visual Studio 运行 c 代码&#xff0c;引入头文件 #include <boost/...>&#xff0c;显式无法打开&#xff0c;需要手动下载boost并进行配置。 1、下载boost Boost官网&#xff1a;Boost Downloads 下载boost&#xff0c;解压&#xf…
阅读更多...
2024年高职物联网实验室建设及物联网实训平台整体解决方案

2024年高职物联网实验室建设及物联网实训平台整体解决方案

随着物联网技术的蓬勃发展&#xff0c;其在各行业的应用日益广泛&#xff0c;对具备物联网专业技能的高素质人才需求也急剧增加。为了满足这一市场需求&#xff0c;高职院校作为技能型人才培养的重要阵地&#xff0c;亟需加强物联网专业的建设。本文旨在提出《2024年高职物联网…
阅读更多...
STM32基础篇：EXTI × 事件 × EXTI标准库

STM32基础篇：EXTI × 事件 × EXTI标准库

EXTI EXTI简介 EXTI&#xff1a;译作外部中断/事件控制器&#xff0c;STM32的众多片上外设之一&#xff0c;能够检测外部输入信号的边沿变化并由此产生中断。 例如&#xff0c;在检测按键时&#xff0c;按键按下时会使电平产生翻转&#xff0c;因此可以使用EXTI来读取按下时…
阅读更多...
ChatGPT摆脱“AI味”：全面提升写作质感

ChatGPT摆脱“AI味”：全面提升写作质感

ChatGPT在各种写作、创作场景都发挥了很大的价值&#xff0c;即使中文语料库占比不到5%&#xff0c;也能生成流畅的中文文本。但随着使用的深入&#xff0c;大家也逐渐发现了机器生成的内容&#xff0c;往往带有一种僵硬、刻板的“AI味”&#xff0c;尤其在论文、自媒体写作中&…
阅读更多...
[RK3308H_Linux] 关于8+2（8路模拟麦克风 + 2路es7243e回采）的调试心得

[RK3308H_Linux] 关于8+2（8路模拟麦克风 + 2路es7243e回采）的调试心得

问题描述 RK3308H 使用8路个模拟麦克风录音&#xff0c;2路用es7243e做回采 解决方案&#xff1a; 首先先调8路模拟麦克风&#xff0c;根据原理图确定使用的是哪路I2S。 以下为dts配置&#xff0c;acodec的属性注释附上。 &acodec {status "okay";rockchip,m…
阅读更多...
CCNA-2-V7-模块7–9:可用且可靠的网络考试答案

CCNA-2-V7-模块7–9:可用且可靠的网络考试答案

1.一台启用了DHCP的客户端PC刚刚启动。客户端PC在与DHCP服务器通信时，将在哪两个步骤中使用广播消息？(选两个。) DHCPDISCOVERDHCPACKDHCPOFFERDHCPREQUESTDHCPNAK 2.管理员发出命令:管理员想达到什么目的？ Router(config)# interface g0/1 Router(config-if)# ip address …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023