IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 【springboot+dubbo+zookeeper】编写provider和consumer详解 -> 正文阅读

[大数据]【springboot+dubbo+zookeeper】编写provider和consumer详解

前提:zookeeper作为注册中心是已经启动了,而且端口已经放行

?项目结构

服务提供者和消费者,导入的pom依赖一致


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

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-zookeeper</artifactId>
            <version>3.0.1</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.curator</groupId>
                    <artifactId>curator-recipes</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>

?服务提供者(service)

配置文件

server:
  port: 8001 #端口
spring:
  application:
    name: dubbo-service
dubbo:
  application:
    #dubbo向注册中心zookeeper中注册的名称,唯一
    name: dubbo-service
  #dubbo注册中心和地址
  registry:
    #注册中心
    protocol: zookeeper
    #注册中心地址
    address: zookeeper://192.168.146.128:2181
    #连接的超时时间
    timeout: 600000
  protocol:
    name: dubbo #dubbo协议
    port: 20880
  #dubbo通过扫描包的形式注册 提供服务接口也就是@DubboService所在的位置
  scan:
    base-packages: com.xx.dubbo.service.impl

提供的服务接口,测试代码,没有具体的逻辑

?随后就可以启动service了,zookeeper注意是开启的

服务消费者(consumer)

配置文件

server:
  port: 8002 #端口
spring:
  application:
    name: dubbo-consumer
dubbo:
  application:
    #dubbo向注册中心zookeeper中注册的名称,唯一
    name: dubbo-consumer
  #dubbo注册中心协议和地址
  registry:
    protocol: zookeeper
    address: zookeeper://192.168.146.128:2181
    timeout: 600000

工程内提供一个zookeeper中注入的服务接口,注意:接口的路径和提供者provider中的路径一致

?

测试调用:通过@dubboreference注入?

?测试:

至此调用成功。

有个优化代码的点:consumer中的提供的调用者的接口可以抽取出来,比如提供一个子工程,专为写要提供的接口,consumer和provider都依赖这个工程,随后进行重写或者直接继承,这样当接口特别多时就不用再consumer中重新定义?

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-08-08 11:24:53  更:2021-08-08 11:25:35 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年5日历 -2024/5/17 18:28:11-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码