dubbo之整合SpringBoot

news2025/1/10 23:31:57

目录

zookeeper安装

1.拉取ZooKeeper镜像

2.新建文件夹

3.挂载本地文件夹并启动服务

4.查看容器

5.进入容器（zookeeper）

Dubbo Admin安装

1.下载dubbo-admin

 2.zip包解压

 3.修改配置文件

 4.打包项目

 5.启动jar

6.访问

 构建项目

api模块

1.创建实体类

2.创建测试接口

生产者模块

1.导入依赖

2.添加配置

3.编写启动类

4.添加mapper接口

5.实现接口

6.编写controller接口

7.调用接口

消费者模块

1.导入依赖

2.添加配置

3.编写启动类

4.调用生产者接口

5.调用接口

zookeeper安装

在docker下安装zookeeper

1.拉取ZooKeeper镜像

# 查看本地镜像
docker images
# 拉取ZooKeeper镜像最新版本
docker pull zookeeper:latest

2.新建文件夹

mkdir zookeeper

3.挂载本地文件夹并启动服务

docker run -d -e TZ="Asia/Shanghai" -p 2181:2181 -v /root/docker/zookeeper:/data --name zookeeper --restart always zookeeper

-d ：表示在一直在后台运行容器
-e TZ="Asia/Shanghai" ：指定上海时区
-p 2181:2181 ：对端口进行映射，将本地2181端口映射到容器内部的2181端口
-v ：将本地目录(文件)挂载到容器指定目录；
--name ：设置创建的容器名称
--restart always ：始终重新启动zookeeper

4.查看容器

docker ps

5.进入容器（zookeeper）

docker exec -it zookeeper bash      //只登录容器，不登录 zkCli
./bin/zkCli.sh    //执行脚本新建一个Client，即进入容器

Dubbo Admin安装

1.下载dubbo-admin

进入github，搜索dubbo-admin：https://github.com/apache/dubbo-admin

 2.zip包解压

 3.修改配置文件

D:\idealTestProjects\dubbo\dubbo-admin-develop\dubbo-admin-server\src\main\resources目录下，修改application.properties 配置文件

找到下面配置的注册中心的地址，修改为zookeeper注册中心的IP和端口，也可以自定义访问端口号

 4.打包项目

进入到D:\idealTestProjects\dubbo\dubbo-admin-develop\dubbo-admin-distribution目录下，按住shift+右键，打开power shell，执行清除并打包命令

mvn clean package -Dmaven.test.skip=true

都success后就成功了

 5.启动jar

在目录D:\idealTestProjects\dubbo\dubbo-admin-develop\dubbo-admin-distribution\target下，执行下面的命令启动dubbo-admin

java -jar .\dubbo-admin-0.5.0-SNAPSHOT.jar

6.访问

浏览器输入：43.139.136.235:6097,用户名密码都是root

 构建项目

api模块

项目结构：

1.创建实体类

@Data
public class User implements Serializable {
    private Long id;
    private String username;
    private String password;
}

注意：实体来要添加Serializable，否则会序列化报错

2.创建测试接口

public interface UserService {
    User selectUserById(Long id);
}

生产者模块

创建springboot项目：dubbo-develop-provider

1.导入依赖

    <dependencies>
        <dependency>
            <groupId>com.lgcgk</groupId>
            <artifactId>dubbo-develop-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!--dubbo 与 spring-boot 整合包-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        
        <!--springboot 启动核心包-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!--springboot rest -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!---dubbo 与 zookeeper整合包 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
        </dependency>

        <!--mysql相关的驱动-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>1.3.1</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
    </dependencies>

    <build>
        <resources>
            <resource>
                <!--   描述存放资源的目录，该路径相对POM路径-->
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.xml</include>
                </includes>
            </resource>
        </resources>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

2.添加配置

server:
  port: 6050

spring:
  application:
    name: dubbo-samples-privider
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/dubbo-sql?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&serverTimezone=GMT%2B8&nullCatalogMeansCurrent=true&allowPublicKeyRetrieval=true
    username: root
    password: 123456
mybatis-plus:
  type-aliases-package: com.lgcgk.provider.entity
  mapper-locations: com/lgcgk/provider/mapper/*.xml

dubbo:
  application:
    name: ${spring.application.name}
  registry:
    address: zookeeper://127.0.0.1:2181
    timeout: 200000
  protocol:
    name: dubbo
    port: 20890
  scan:
    base-packages: com.lgcgk.provider.service.impl

dubbo配置：服务配置，用于暴露一个服务，定义服务的元信息，一个服务可以用多个协议暴露，一个服务也可以注册到多个注册中心

dubbo.protocol.name：dubbo服务名称

dubbo.protocol.port：dubbo服务端口

dubbo.registry.timeout:请求zookeeper超时时间

3.编写启动类

@EnableDubbo
@SpringBootApplication
@MapperScan("com.demo.provider.mapper")
public class ProviderApp {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApp.class,args);
        System.out.println("生产者启动完毕");
    }
}

dubbo必须配置注解@EnableDubbo

@EnableDubbo：整合了三个注解@EnableDubboConfig、@DubboComponentScan、@EnableDubboLifecycle

        1.@EnableDubboConfig：将用于解析配置相关的类注册到spring容器

        2.@DubboComponentScan：用于指定@Service扫描路径

        3.@EnableDubboLifecycle：注册了两个监听器到spring容器

4.添加mapper接口

public interface UserMapper {
    User selectUserById(Long id);
}

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="com.lgcgk.provider.mapper.UserMapper">

    <select id="selectUserById" resultType="com.lgcgk.api.entity.User">
        select * from user where id = #{id}
    </select>
</mapper>

5.实现接口

@DubboService
@AllArgsConstructor
public class UserServiceImpl implements UserService {

    UserMapper userMapper;

    public User selectUserById(Long id) {
        User user = userMapper.selectUserById(id);
        return user;
    }
}

1.@DubboService

在类上加入@DubboService注解，表示该Bean以ServiceBean形式注册到Spring容器中，以便后续创建Dubbo Service

2.@AllArgsConstructor

是lombok中的注解,作用在类上;使用后添加一个构造函数，该构造函数含有所有已声明字段属性参数;@Autowired和@resource可以用它来代替

6.编写controller接口

@RestController
@RequestMapping("/provider")
@AllArgsConstructor
public class UserController {
    UserService userService;

    @GetMapping("/selectUserById/{id}")
    public User selectUserById(@PathVariable("id")Long id){
        return userService.selectUserById(id);
    }

}

7.调用接口

 

消费者模块

1.导入依赖

    <dependencies>
        <!--dubbo-samples-springcloud-api 项目 依赖-->
        <dependency>
            <groupId>com.lgcgk</groupId>
            <artifactId>dubbo-develop-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <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.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
        </dependency>
    </dependencies>

2.添加配置

server:
  port: 6051
spring:
  application:
    name: dubbo-samples-consumer

dubbo:
  application:
    name: ${spring.application.name}
  registry:
    address: zookeeper://127.0.0.1:2181
    timeout: 200000
  protocol:
    name: dubbo-consumer

3.编写启动类

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

4.调用生产者接口

@RestController
@RequestMapping("/consumer")
@Slf4j
public class ConsumerUserController {
    @DubboReference( protocol = "dubbo", loadbalance = "random")
    UserService userService;

    @RequestMapping("/selectUserById/{id}")
    public User getUser(@PathVariable("id") Long id) {
        User user = userService.selectUserById(id);
        log.info("response from provider: {}", user);
        return user;
    }

}

@DubboReference：表名该类为Dubbo Reference，在需要调用的服务接口上使用即可直接调用远程服务。

protocol：调用的服务名

loadbalance：dubbo提供了4种负载均衡策略

        1.random：基于权重随机算法

        2.roundrobin：基于加权轮询算法

        3.leastactive：基于最少活跃调用数算法

        4.consistenthash：基于 hash 一致性

5.调用接口

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

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

相关文章

Tik Tok本土mcn怎么入驻，泰国市场发展概况分析！

Tik Tok本土mcn怎么入驻，泰国市场发展概况分析！

近日&#xff0c;TikTok海外本土MCN机构“Ma Go”获得数千万级别的A轮融资&#xff0c;本轮融资由北太平投资独家投资。 2021年10月份&#xff0c;“Ma Go”曾获得过知名投资人以及网红朱一旦的千万级别融资。 Ma Go联合创始人倪泽铭表示&#xff0c;本轮融资将继续扩展申请找…
阅读更多...
Jupyter Notebook 500 : Internal Server Error

Jupyter Notebook 500 : Internal Server Error

1. 这个问题的根本原因在于&#xff1a; pygments 包 版本过高。 安装pygments 2.6.1 2.jupyter版本如下 如果某个版本有冲突&#xff0c;卸载了重新安装一下就行。 安装命令&#xff1a; pip install pygments 2.6.1 -i https://pypi.tuna.tsinghua.edu.cn/simple 另外…
阅读更多...
GWJDN-400型2MHZ自动平衡高温介电温谱仪

GWJDN-400型2MHZ自动平衡高温介电温谱仪

GWJDN-400型2MHZ自动平衡高温介电温谱仪 GWJDN-400型2MHZ自动平衡高温介电温谱仪 关键词&#xff1a;介电常数&#xff0c;高温介电&#xff0c;自动平衡 主要功能&#xff1a; 材料介电常数测试仪 半导体材料的介电常数、导电率和C-V特性液晶材料:液晶单元的介电常数、弹性…
阅读更多...
【Go语言】Golang保姆级入门教程 Go初学者chapter2

【Go语言】Golang保姆级入门教程 Go初学者chapter2

【Go语言】变量 VSCode插件 setting的首选项 一个程序就是一个世界 变量是程序的基本组成单位 变量的使用步骤 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-zuxG8imp-1691479164956)(https://cdn.staticaly.com/gh/hudiework/imgmain/image-20…
阅读更多...
自学python，学了又忘，感觉学不好是为啥呢

自学python，学了又忘，感觉学不好是为啥呢

一、前言 最近发现&#xff0c;身边很多的小伙伴学Python都会遇到一个问题&#xff0c;就是资料也看了很多&#xff0c;也花了很多时间去学习但还是很迷茫&#xff0c;时间长了又发现之前学的知识点很多都忘了&#xff0c;都萌生出了想半路放弃的想法。 其实造成这样情况根本的…
阅读更多...
途乐证券|科创板中签规则？新股中签后多久上市？

途乐证券|科创板中签规则？新股中签后多久上市？

科创板是抢手的投资论题之一&#xff0c;满足条件的普通个人投资者也可以参与科创板新股申购&#xff0c;共享科创板市场盈利。那么&#xff0c;科创板中签有什么规矩&#xff1f;新股中签后多久上市&#xff1f;下面就和途乐证券一起来了解一下。 科创板中签规矩&#xff1f; …
阅读更多...
(vue)获取对象的键遍历，同时循环el-tab页展示key及内容

(vue)获取对象的键遍历，同时循环el-tab页展示key及内容

(vue)获取对象的键遍历&#xff0c;同时循环el-tab页展示key及内容 效果&#xff1a; 数据结构&#xff1a; "statusData": {"订购广度": [ {"id": 11, "ztName": "广", …
阅读更多...
如何使用Word转PDF转换器在线工具？在线Word转PDF使用方法

如何使用Word转PDF转换器在线工具？在线Word转PDF使用方法

Word转PDF转换器在线&#xff0c;是一种方便快捷的工具&#xff0c;可帮助您在不需要下载任何软件的情况下完成此任务。无论您是需要在工作中共享文档&#xff0c;还是将文件以PDF格式保存以确保格式不变&#xff0c;都可以依靠这款在线工具轻松完成转换。那么如何使用Word转PD…
阅读更多...
使用Openoffice或LibreOffice实现World、Excel、PPTX在线预览

使用Openoffice或LibreOffice实现World、Excel、PPTX在线预览

使用Openoffice或LibreOffice实现World、Excel、PPTX在线预览 预览方案使用第三方服务使用前端库转换格式 jodconverterjodconverter概述主要特性OpenOfficeLibreOffice jodconverter的基本使用添加依赖配置创建DocumentConverter实例上传与转换预览启动上传与预览World 与Spri…
阅读更多...
海外跨境购物商城汇率自动更新系统开发

海外跨境购物商城汇率自动更新系统开发

要搭建一个海外跨境购物商城多货币汇率自动更新系统&#xff0c;您可以按照以下步骤进行&#xff1a; 1. 选择合适的电子商务平台&#xff1a;选择一款适合海外跨境购物的电子商务平台。 2. 确定支付方式&#xff1a;选择支持多种货币支付的支付网关。确保支付网关支持自动汇…
阅读更多...
springboot（1）

springboot（1）

精要&#xff1a; 自动配置&#xff1a;针对很多Spring应用程序常见的应用功能&#xff0c;Spring Boot能自动提供相关配置。 起步依赖&#xff1a;告诉Spring Boot需要什么功能&#xff0c;它就能引入需要的库。 命令行界面&#xff1a;这是Spring Boot的可选特性&#xff0…
阅读更多...
基于DETR (DEtection TRansformer)开发构建MSTAR雷达影像目标检测系统

基于DETR (DEtection TRansformer)开发构建MSTAR雷达影像目标检测系统

关于DETR相关的实践在之前的文章中很详细地介绍过&#xff0c;感兴趣的话可以自行移步阅读即可&#xff1a; 《DETR (DEtection TRansformer)基于自建数据集开发构建目标检测模型超详细教程》 《书接上文——DETR评估可视化》 基于MSTAR雷达影像数据开发构建目标检测系统&am…
阅读更多...
力扣279.完全平方数（动态规划）

力扣279.完全平方数（动态规划）

class Solution { public:int numSquares(int n) {vector<int> f(n 1);for (int i 1; i < n; i) {int minn INT_MAX;for (int j 1; j * j < i; j) {minn min(minn, f[i - j * j]); //上一次的 & 当前数可以找到一个新的更大的平方}f[i] minn 1; }…
阅读更多...
分布式应用：Zabbix自定义监控模板

分布式应用：Zabbix自定义监控模板

目录 一、理论 1.zabbix监控模板 2.在客户端创建自定义 key 3.在 Web 页面创建自定义监控项模板 4.设置邮件报警 二、实验 1.在客户端创建自定义 key 2.在 Web 页面创建自定义监控项模板 3.设置邮件报警 三、问题 1.查看动作发送邮件失败 四、总结 一、理论 1.zab…
阅读更多...
功能上新｜全新GPU性能优化方案

功能上新｜全新GPU性能优化方案

GPU优化迎来了全新的里程碑&#xff01;我们深知移动游戏对高品质画面的追求日益升温&#xff0c;因此UWA一直着眼于移动设备GPU性能优化&#xff0c;以确保您的游戏体验尽善尽美。然而&#xff0c;不同GPU芯片之间的性能差异及可能导致的GPU瓶颈问题&#xff0c;让优化工作变得…
阅读更多...
Hybrid技术的下一站是什么？

Hybrid技术的下一站是什么？

Hybrid这个词&#xff0c;在App开发领域&#xff0c;相信大家都不陌生。Hybrid App是指介于web-app、native-app这两者之间的app&#xff0c;它虽然看上去是一个Native App&#xff0c;但只有一个UI WebView&#xff0c;里面访问的是一个Web App。Hybrid在移动领域的发展&#…
阅读更多...
低代码平台——需求和技术发展的产物

低代码平台——需求和技术发展的产物

前言&#xff1a;低代码平台是需求和技术发展的必然产物&#xff0c;从开发方式、开发门槛、开发效率各层面上&#xff0c;跟传统的开发方式有根本区别&#xff0c;是业界已达成共识的新技术方向。 一、低代码平台起源 从2016年开始&#xff0c;低代码突然进入快速发展阶段&…
阅读更多...
无涯教程-Perl - flock函数

无涯教程-Perl - flock函数

描述 该函数支持使用系统flock(),fcntl()锁定或lockf()在指定的FILEHANDLE上锁定文件。使用的确切实现方式取决于系统支持的功能。 OPERATION是此处定义的static 值之一。 Operation Result LOCK_SH Set shared lock. LOCK_EX Set exclusive lock. LOCK_UN Unlock specifi…
阅读更多...
用Vue实现页面访问拦截

用Vue实现页面访问拦截

(创作不易&#xff0c;感谢有你&#xff0c;你的支持&#xff0c;就是我前行的最大动力&#xff0c;如果看完对你有帮助&#xff0c;请留下您的足迹&#xff09; 目录 页面访问拦截 1.创建axios实例 2.添加拦截器 3.全局前置守卫 可选的第三个参数 next 总结&#xff1a…
阅读更多...
JDBC概念与类的详解

JDBC概念与类的详解

JDBC 文章目录 JDBC一、概念及入门二、各个类详解1、DriverManager&#xff1a;驱动管理对象&#xff08;1&#xff09;注册驱动&#xff08;2&#xff09;获取数据库连接 2、Connection&#xff1a;数据库连接对象&#xff08;1&#xff09;获取执行sql的对象&#xff08;2&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023