Dubbo入门（二）——IDEA下Dubbo+Zookeeper搭建

news2024/12/29 12:49:12

目录

  • 一、Zookeeper
    • 1.1 下载
    • 1.2 安装
    • 1.3 修改配置文件
    • 1.4 启动
  • 二、Dubbo插件搭建
  • 三、手动创建
    • 3.1 创建项目
      • 3.1.1 pom依赖
    • 3.2 api模块
      • 3.2.1 pom依赖
      • 3.2.2 实体类
      • 3.2.3 service接口
    • 3.3 provider
      • 3.3.1 pom依赖
      • 3.3.2 配置文件
      • 3.3.3 mapper
      • 3.3.4 service实现类
      • 3.3.5 启动类
    • 3.4 consumer
      • 3.4.1 pom依赖
      • 3.4.2 配置文件
      • 3.4.3 控制层
      • 3.4.4 启动类
  • 四、测试

一、Zookeeper

我选择的是3.6.3版本的zookeeper

1.1 下载

官网：https://zookeeper.apache.org/releases.html

在这里插入图片描述
下载
在这里插入图片描述

1.2 安装

将下载的压缩包进行解压
在这里插入图片描述
将zookeeper配置至环境变量

变量名变量值
ZOOKEEPER_HOMED:\Program Files\apache-zookeeper-3.6.3-bin

在这里插入图片描述
path中引入zookeeper

%ZOOKEEPER_HOME%\bin
%ZOOKEEPER_HOME%\conf

在这里插入图片描述

1.3 修改配置文件

将conf下的zoo_sample.cfg复制并命名为zoo.cfg
并添加配置内容：

dataDir=D:\\azookerpersstudy\\data
dataLogDir=D:\\azookerpersstudy\\log

1.4 启动

在zookeeper下的bin目录下
点击zkservice.cmd
在这里插入图片描述
在这里插入图片描述

二、Dubbo插件搭建

idea已经有dubbo插件IntellijDubboPlugin，可快速构建一个 dubbo 项目
Configure→Plugins
输入Dubbo，点击installed
在这里插入图片描述
安装后，在创建项目界面就会多一个Dubbo的选项，点击Next
在这里插入图片描述
点击Next
在这里插入图片描述
设置项目路径和名称
在这里插入图片描述
点击finish
创建成功后，结构如下：
在这里插入图片描述

三、手动创建

以下示例为Dubbo+Zookeeper+SpringBoot+Mybatis集成项目

3.1 创建项目

选择maven，创建父项目dubbo_demo
在这里插入图片描述

3.1.1 pom依赖

 	<groupId>com.tung</groupId>
    <artifactId>dubbo_demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

	<!-- 此处是springboot的父工程，用于指定springboot 版本 -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.7.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <!-- 统一版本管理 -->
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <java.version>1.8</java.version>
        <zk.version>3.6.2</zk.version>
        <dubbo.version>2.7.7</dubbo.version>
        <curator.framework.version>5.1.0</curator.framework.version>
        <curator.recipes.version>5.1.0</curator.recipes.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>${dubbo.version}</version>
            </dependency>

            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>${zk.version}</version>
            </dependency>

            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>${curator.framework.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>${curator.recipes.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

3.2 api模块

创建dubbo_api模块
在这里插入图片描述
api模块提供接口和实体类
在这里插入图片描述

3.2.1 pom依赖

<parent>
        <artifactId>dubbo_demo</artifactId>
        <groupId>com.tung</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo_api</artifactId>

    <name>dubbo_api</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
    </properties>

3.2.2 实体类

package com.tung.entity;

import java.io.Serializable;

/**
 * @author tung
 * @ClassName User
 * @Description 类的说明
 * @date 2022/12/29
 */
public class User implements Serializable {

    private  String id;
    private String name;
    private String password;


    public User(String id, String name, String password) {
        this.id = id;
        this.name = name;
        this.password = password;
    }

    public User() {
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

3.2.3 service接口

package com.tung.service;

import com.tung.entity.User;

import java.util.List;

/**
 * @author tung
 * @ClassName UserService
 * @Description 类的说明
 * @date 2022/12/29
 */
public interface UserService {

    List<User> findAll();
}

3.3 provider

创建dubbo_provider，操作跟dubbo_api一样。

3.3.1 pom依赖

	<parent>
        <artifactId>dubbo_demo</artifactId>
        <groupId>com.tung</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo_provider</artifactId>

    <name>dubbo_provider</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
    </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</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
        <!-- zookeeper和dubbo的集成包 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
        </dependency>
        <!-- zookeeper和dubbo的集成包 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
        </dependency>

        <!-- 刚刚创建的api接口模块 -->
        <dependency>
            <groupId>com.tung</groupId>
            <artifactId>dubbo_api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!--dubbo启动-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <!--mybatis-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>
        <!--mysql-connector-java-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
    </dependencies>

3.3.2 配置文件

application.yml

server:
  port: 8082

# 注册中心 zookeeper的地址
dubbo:
  registry:
    address: zookeeper://127.0.0.1:2181
    timeout: 20000

  application:
    name: dubbo-provider

  scan:
    base-packages: com.tung

  protocol:
    name: dubbo
    port: 20880

mybatis:
  config-location: classpath:mybatis-config.xml

spring:
  datasource:
    name : test
    url : jdbc:mysql://127.0.0.1:3306/demo?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
    username : root
    password: root
    driver-class-name: com.mysql.cj.jdbc.Driver

mybatis-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
        <!-- Globally enables or disables any caches configured in any mapper under this configuration -->
        <setting name="cacheEnabled" value="true"/>
        <!-- Sets the number of seconds the driver will wait for a response from the database -->
        <setting name="defaultStatementTimeout" value="3000"/>
        <!-- Enables automatic mapping from classic database column names A_COLUMN to camel case classic Java property names aColumn -->
        <setting name="mapUnderscoreToCamelCase" value="true"/>
        <!-- Allows JDBC support for generated keys. A compatible driver is required.
        This setting forces generated keys to be used if set to true,
         as some drivers deny compatibility but still work -->
        <setting name="useGeneratedKeys" value="true"/>
    </settings>
    <!-- Continue going here -->
</configuration>

3.3.3 mapper

package com.tung.mapper;

import com.tung.entity.User;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;

import java.util.List;

/**
 * @author tung
 * @ClassName UserMapper
 * @Description 类的说明
 * @date 2022/12/29
 */
@Mapper
public interface UserMapper {

    @Select("select id,name,password from t_user")
    List<User> findAll();
}

3.3.4 service实现类

package com.tung.service.impl;

import com.tung.entity.User;
import com.tung.mapper.UserMapper;
import com.tung.service.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

/**
 * @author tung
 * @ClassName UserServiceImpl
 * @Description 类的说明
 * @date 2022/12/29
 */
@Component
@DubboService(loadbalance = "roundrobin")
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public List<User> findAll() {
        return userMapper.findAll();
    }
}

3.3.5 启动类

package com.tung.service;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @author tung
 * @ClassName ProviderApplication
 * @Description 类的说明
 * @date 2022/12/29
 */
@SpringBootApplication
@MapperScan("com.tung.mapper")
public class ProviderApplication {

    public static void main(String[] args){
        SpringApplication.run(ProviderApplication.class,args);
    }
}

3.4 consumer

创建dubbo_consumer
在这里插入图片描述

3.4.1 pom依赖

	<parent>
        <artifactId>dubbo_demo</artifactId>
        <groupId>com.tung</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo_consumer</artifactId>
    <packaging>war</packaging>

    <name>dubbo_consumer Maven Webapp</name>
    <!-- FIXME change it to the project's website -->
    <url>http://www.example.com</url>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.7</maven.compiler.source>
        <maven.compiler.target>1.7</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.tung</groupId>
            <artifactId>dubbo_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.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>

        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>


    </dependencies>

3.4.2 配置文件

application.yml

server:
  port: 8083

# 注册中心 zookeeper的地址
dubbo:
  registry:
    address: zookeeper://127.0.0.1:2181
    timeout: 20000

  application:
    name: dubbo-consumer

  scan:
    base-packages: com.tung.controller

  protocol:
    name: dubbo-consumer
    port: 20881

3.4.3 控制层

package com.tung.controller;

import com.tung.entity.User;
import com.tung.service.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * @author tung
 * @ClassName UserController
 * @Description 类的说明
 * @date 2022/12/29
 */
@RestController
@RequestMapping("/user")
public class UserController {

    @DubboReference
    private UserService userService;

    @GetMapping("/findAll")
    public List<User> findAll(){
        return userService.findAll();
    }
}

3.4.4 启动类

package com.tung;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @author tung
 * @ClassName ConsumerApplication
 * @Description 类的说明
 * @date 2022/12/28
 */
@SpringBootApplication
public class ConsumerApplication {

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

四、测试

依次启动provider、consumer
访问consumer暴露的接口
在这里插入图片描述
成功

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

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

相关文章

冶金工艺流程（钢铁全流程）

冶金工艺流程（钢铁全流程）

工艺图 工艺讲解 生产流程从矿石原料采集开始,对于低品位的矿石&#xff0c;必须在冶炼前经选矿工序先选出铁精矿&#xff0c;然后进一步制成烧结矿或球团矿。 ————————————————————————————— 高炉冶炼是一个连续的、大规模的高温生产过程。铁矿石…
阅读更多...
为什么Aruba始终走在网络世界的前列？

为什么Aruba始终走在网络世界的前列？

编辑 | 阿冒 设计 | 沐由关于网络的价值&#xff0c;梅特卡夫定律&#xff08;Metcalfes law&#xff09;曾经在多年前就明白无误地告诉我们&#xff1a;VKN。其中&#xff0c;V代表一个网络的价值&#xff0c;N代表这个网络的节点数&#xff0c;K代表价值系数。如果梅特卡夫…
阅读更多...
47. 批量规范化 代码从零开始实现 + 简洁实现

47. 批量规范化 代码从零开始实现 + 简洁实现

1. 从零实现 下面&#xff0c;我们从头开始实现一个具有张量的批量规范化层。 import torch from torch import nn from d2l import torch as d2l# X是输入&#xff0c;gamma, beta是两个可以学习的参数&#xff0c;moving_mean, moving_var是整个数据集的均值和方差&#xf…
阅读更多...
ssh登录——scp传文件

ssh登录——scp传文件

一、ssh登录 1.基本用法 远程登录服务器&#xff1a; ssh userhostname# user: 用户名 # hostname: IP地址或域名 第一次登录时会提示&#xff1a; The authenticity of host 123.57.47.211 (123.57.47.211) cant be established. ECDSA key fingerprint is SHA256:iy237y…
阅读更多...
十分钟掌握 “UML ” 的基本使用

十分钟掌握 “UML ” 的基本使用

十分钟掌握 “UML ” 的基本使用 每博一文案 很喜欢这样一段话&#xff1a;内可以不跟别人计较&#xff0c;但一定要学会维护自己&#xff0c;你可以不跟别人争抢&#xff0c;但应该懂得远离小人。 人生在世&#xff0c;我们会遇到形形色色的人&#xff0c;人心隔肚皮&#xf…
阅读更多...
Pytorch深度学习实战——第3章课后习题

Pytorch深度学习实战——第3章课后习题

1.从list(range(9))list(range(9))list(range(9))中创建一个张量aaa并预测检查其大小、偏移量、步长。 import torch atorch.tensor(list(range(9))) print(a.storage_offset())#偏移量 print(a.stride())#步长 print(a.size())#大小a)使用ba.view(3,3)ba.view(3,3)ba.view(3,…
阅读更多...
Aspose.PDF for Java系列3-创建复杂的PDF

Aspose.PDF for Java系列3-创建复杂的PDF

创建复杂PDF 上篇文章展示了使用Java和Aspose.PDF简单步骤。本文中&#xff0c;我们将使用Java和Aspose.PDF创建更复杂的文档结构。此示例中&#xff0c;我们将创建包含图片、两个文本片段&#xff08;标题和段落&#xff09;和表格。 创建文档参考以下步骤&#xff1a; 实例…
阅读更多...
被房地产坑惨的老板电器，终于要“回血”了！

被房地产坑惨的老板电器，终于要“回血”了！

近期&#xff0c;随着房地产行业重新被定义为“国民经济的支柱产业”&#xff0c;叠加疫情防控转向&#xff0c;笼罩在家电行业上空的阴霾逐渐消散&#xff0c;家电股预期改善&#xff0c;纷纷迎来估值修复。尤其是曾遭房地产暴击的老板电器&#xff0c;有望抓住房地产回暖的窗…
阅读更多...
Synchronized

Synchronized

Synchronized前言1.synchronized修饰符和线程控制1.1synchronized修饰符和Object Monitor模式1.2 synchronized修饰符可标注的位置2. 方法2.1 waitwait多态表达式notify()方法和notifyAII()方法interrupt中断信号判断是否收到interrupt中断信号的方法前言 悲观锁在Java中有两种…
阅读更多...
Jenkins环境搭建

Jenkins环境搭建

Jenkins环境搭建 一、Jenkins下载&#xff1a;Jenkins 点击Download&#xff0c;进入新的页面后点击下载Jenkins的war包&#xff0c;如下图&#xff1a; 注意&#xff1a;Jenkins是java语言开发&#xff0c;需要安装JDK并进行环境变量配置&#xff0c;Jenkins可以在Tomcat容器…
阅读更多...
java注解(Annotation)和反射(Reflection)

java注解(Annotation)和反射(Reflection)

文章目录重要的点一 注解(Annotation)(Annotation)(Annotation)1.1 注解初识1.2 内置注解1.3 内置注解代码演示1.4 元注解(meta−annotation)(meta-annotation)(meta−annotation)1.5 元注解代码演示1.6 自定义注解1.7 自定义注解代码演示二 反射(Reflection)(Reflection)(Refl…
阅读更多...
gitlab-ci.yml关键字（三）before_script 、script 、after_script

gitlab-ci.yml关键字（三）before_script 、script 、after_script

before_script before_script 用于定义在每个作业执行之前所运行的一系列脚本命令。这里需要注意的是&#xff0c;before_script 运行的时机&#xff0c;是在制品&#xff08;artifacts&#xff09;恢复后&#xff0c;也就意味着&#xff0c;在这个时机中是可以操作制品的。 …
阅读更多...
Unity 解决QFramework WebGL报错

Unity 解决QFramework WebGL报错

Unity 解决QFramework WebGL报错&#x1f95d;错误描述☕原因&#x1f364; 解决方案&#x1f95d;错误描述 在新建工程中只导入了QFramework&#xff0c;Build WebGL(空场景) 会看到如下错误&#xff1a; Exception: Non-Public Constructor() not found! in QFramework.Saf…
阅读更多...
点云 3D 目标检测 - SECOND（Sensors 2018）

点云 3D 目标检测 - SECOND（Sensors 2018）

点云 3D 目标检测 - SECOND&#xff08;Sensors 2018&#xff09;摘要1. 引言2. 相关工作2.1 基于前视图和图像的方法2.2 基于鸟瞰图的方法2.3 基于3D的方法2.4 基于融合的方法3. SECOND检测器3.1 网络架构3.1.1 点云分组3.1.2 Voxelwise特征提取器3.1.3 稀疏卷积中间提取器3.1…
阅读更多...
代码模板3---基础算法(双指针算法/位运算/离散化/区间合并)

代码模板3---基础算法(双指针算法/位运算/离散化/区间合并)

①双指针算法 一般做题&#xff1a;先用暴力做法&#xff0c;然后去看是否存在某种性质&#xff08;如单调性&#xff0c;维护这个区间的单调性即可&#xff09; AcWing 799. 最长连续不重复子序列 - AcWing AcWing 800. 数组元素的目标和 - AcWing AcWing 2816. 判断子序列 - …
阅读更多...
期货交易软件哪个好？为什么选择期货MT4平台软件？

期货交易软件哪个好？为什么选择期货MT4平台软件？

越来越多人选择期货投资&#xff0c;因为期货投资具有高投资高回报的特征。在做期货交易时&#xff0c;很多投资者会发现市场上有各种各样的期货交易软件。如果第一次接触期货交易&#xff0c;难免会不知道选择哪个期货交易软件更好。下面为大家讲讲期货交易软件哪个好&#xf…
阅读更多...
centos7安装rabbitmq集群

centos7安装rabbitmq集群

公司号口项目让运维安装rabbitmq&#xff0c;结果rabbitmq页面state都显示down了&#xff0c;问运维居然说都正常&#xff0c;麻蛋欺负我无知&#xff0c;自己搞一遍试试。 前言 RabbitMQ是一个开源的强大的企业消息系统&#xff0c;支持主流的操作系统&#xff0c;支持多种开…
阅读更多...
OpenHarmony#深入浅出学习eTs#（七）判断密码是否正确

OpenHarmony#深入浅出学习eTs#（七）判断密码是否正确

本项目Gitee仓地址&#xff1a;深入浅出eTs学习: 带大家深入浅出学习eTs (gitee.com) 一、基本界面 本项目基于#深入浅出学习eTs#&#xff08;四&#xff09;登陆界面UI&#xff0c;继续进行&#xff0c;实现一个判断的功能 二、控件介绍 TextInput 可以输入单行文本并支持…
阅读更多...
如果我是核酸系统架构师，我会这么用MQ。。。

如果我是核酸系统架构师，我会这么用MQ。。。

V-xin&#xff1a;ruyuan0330 获得600页原创精品文章汇总PDF 目录 一、前情提示二、保证投递消息不丢失的confirm机制三、confirm机制的代码实现四、confirm机制投递消息的高延迟性五、高并发下如何投递消息才能不丢失六、消息中间件全链路100%数据不丢失能做到吗&#xff1f;…
阅读更多...
医学图像包——DCMTK、VTK、ITK、RTK、SimpleITK

医学图像包——DCMTK、VTK、ITK、RTK、SimpleITK

1.ITK-医学图像处理软件包 ITK&#xff08; Insight Segmentation and Registration Toolkit&#xff09;是美国国家卫生院下属的国立医学图书馆开发的一款医学图像处理软件包&#xff0c;是一个开源的、跨平台的影像分析扩展软件工具。 ITK的开发过程中采用了先进的多模态数…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023