SpringBoot项目集成Dubbo

news2024/11/30 6:39:07

1.环境搭建

为整合Dubbo之前,我们所写的项目都是单一应用架构,只需要一个应用,将所有功能都部署在一起,在应用内部是控制层调用业务层,业务层调用数据持久层;如今,整合Dubbo后,我们可以将应用程序的不同功能单元进行拆分(将控制层、业务层以及数据持久层拆分),各个服务之间通过RPC通信!
下面,我们就开始在SpringBoot项目中集成Dubbo;首先我们需要创建一个空项目,在空项目中创建三个模块,分别定义工程。服务提供者以及服务消费者!
接口工程:存放pojo实体和业务接口;
服务提供者: 存放业务接口的实现类并将服务暴露到注册中心,并调用数据持久层;
服务消费者:处理浏览器客户端发送的请求,从注册中心调用服务提供者所提供的服务。

1.创建一个空项目

打开IDEA,单击文件,选择新建,点击项目,最后选择空项目,具体如下所示:
在这里插入图片描述

2.创建接口工程模块

由于接口工程只需要存放一个pojo实体类和抽象的业务接口,因此创建一个普通的Maven项目即可!
打开IDEA,单击文件,选择新建,点击新模块。具体如下所示:
在这里插入图片描述
紧接着按照自己的方式选择模块名称和位置,具体如下所示:最后点击完成!
在这里插入图片描述

3.创建服务提供者模块

创建服务提供者需要依托一个SpringBoot项目,因此我们首先要创建一个SpringBoot项目。具体步骤如下,
打开IDEA,单击文件,选择新建,点击新模块。具体如下所示:
在这里插入图片描述

点击下一步后选择Spring Web依赖即可完成创建!

4.创建服务消费者模块

服务消费者模块与服务提供者模块大同小异,按照创建服务提供者的方式创建即可,更换一下服务消费者的模块名称即可完成创建,具体如下所示:
在这里插入图片描述

2.接口工程中抽象接口的编写

在dubbo-springboot-interfaces模块中创建一个UserService接口,具体如下所示:

public interface UserService {
    int getCount();//获取当前网站在线人数
}

3.服务提供者模块的编写

1.导入服务提供者所需的依赖

<dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.8.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.8.0</version>
        </dependency>
<!--        dubbo集成SpringBoot起步依赖-->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.0.0</version>

        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
            <exclusions>
                <exclusion>
                    <artifactId>slf4j-log4j12</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>zookeeper</artifactId>
                    <groupId>org.apache.zookeeper</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- 导入接口工程-->
        <dependency>
            <groupId>com.xing</groupId>
            <artifactId>dubbo-springboot-interfaces</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

2.编写服务提供者配置文件

这里需要注意,spring.dubbo.server=true代表该模块是服务的提供者,spring.dubbo.registry配置的是zookeeper的IP和端口,因此启动项目的前提是要在Linux系统中开启zookeeper!

# 应用名称
spring.application.name=dubbo-springboot-provider
# 应用服务 WEB 访问端口
server.port=8081
# 设置上下文根
server.servlet.context-path=/
#dubbo配置
spring.dubbo.server=true
# 设置注册中心
spring.dubbo.registry=zookeeper://IP:2181

3.实现接口工程中的抽象接口

这里需要注意的是,我们需要导入的@Service是com.alibaba.dubbo.config.annotation包下的,同时需要使用@Component将此类装入spring容器中,这里并未调用真实的数据持久层,只是模拟调用!

package com.xing.dubbospringbootprovider.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.xing.dubbospringbootconsumer.service.UserService;
import org.springframework.stereotype.Component;

@Component
@Service(interfaceClass = UserService.class,version = "2.6.0",timeout = 15000)
public class UserServiceImpl implements UserService {
    @Override
    public int getCount() {
        //调用数据持久层
        return 1024;
    }
}

4.在服务提供者主启动类上开启Dubbo配置

在模块主启动类上加上@EnableDubboConfiguration即可以开启开启dubbo配置!

package com.xing.dubbospringbootprovider;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubboConfiguration //开启dubbo配置
public class DubboSpringbootProviderApplication {

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

3.服务消费者模块的编写

1.导入服务消费者所需的依赖

这里所需要的依赖与服务提供者相同,这里就不过多展示了,有需要的可以拷贝服务提供者所展示的依赖。

2.编写服务消费者配置文件

这里配置文件中的IP需要更换为自己购买的阿里云服务器的IP;

# 应用名称
spring.application.name=dubbo-springboot-consumer
# 应用服务 WEB 访问端口
server.port=8083
# 配置上下文根
server.servlet.context-path=/
# 配置注册中心
spring.dubbo.registry=zookeeper://IP:2181

3.编写控制层代码

消费者使用@Reference(interfaceClass = UserService.class,version = “2.6.0”,check = false)注解,从注册中心调用服务提供者所提供的服务。

package com.xing.dubbospringbootconsumer.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.xing.dubbospringbootconsumer.service.UserService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class UserController {
    @Reference(interfaceClass = UserService.class,version = "2.6.0",check = false)
    private UserService userService;
    
    @RequestMapping("/count")
    @ResponseBody
    public String getCount(){
        int count=userService.getCount();
        return "当前在线的人数为:"+count;
    }
}

4.在服务消费者主启动类上开启Dubbo配置

package com.xing.dubbospringbootconsumer;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubboConfiguration //开启Dubbo配置
public class DubboSpringbootConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboSpringbootConsumerApplication.class, args);
    }
}

4.开启zookeeper服务

这里就不详细讲解如何安装zookeeper了,有需要的读者可以自己去网上下载并配置环境!

cd /opt/zookeeper/apache-zookeeper-3.5.6-bin/bin/
# 启动zookeeper
./zkServer.sh start

可以通过./zkServer.sh status查看是否启动成功,出现以下数据即启动成功!
在这里插入图片描述

5.修改IDEA的环境配置

这里需要注意,我们创建的模块,默认的目标字节码版本是5,我们需要修改为8,否则可能会出现内部Java编译器错误;
在这里插入图片描述
同时,如果启动项目发现出现Class path contains multiple SLF4J bindings.的问题,可以参考我使用maven Helper解决问题的办法,解决问题的文档

最后,如果需要同时启动多个SpringBoot实例,这里需要修改IDEA启动的配置,具体如下所示:
点击编辑配置,勾选允许并运行的选项即可,同时,每个不同的模块需要设置不同的端口号,否则同样是不能同时运行的!
在这里插入图片描述
最后,解决所有问题后,运行的效果如下所示:
在这里插入图片描述

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

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

相关文章

独立产品灵感周刊 DecoHack #039 - 制作自己的音乐墙

本周刊记录有趣好玩的独立产品设计开发相关内容&#xff0c;每周发布&#xff0c;往期内容同样精彩&#xff0c;感兴趣的伙伴可以点击订阅我的周刊。为保证每期都能收到&#xff0c;建议邮件订阅。欢迎通过 Twitter 私信推荐或投稿。自荐产品 1. planet-tab - 由独立开发者 ha…

【云原生】Docker的私有仓库部署——Harbor

内容预知 1.Docker原生私有仓库—— Registry 1.1 Registry的简单了解 1.2 Registry的部署过程 步骤一&#xff1a;拉取相关的镜像 步骤二&#xff1a;进行 Registry的相关yml文件配置&#xff08;docker-compose&#xff09; 步骤三&#xff1a;镜像的推送 2. Registry的…

SpringBoot SpringBoot 原理篇 2 自定义starter 2.6 拦截器开发

SpringBoot 【黑马程序员SpringBoot2全套视频教程&#xff0c;springboot零基础到项目实战&#xff08;spring boot2完整版&#xff09;】 SpringBoot 原理篇 文章目录SpringBootSpringBoot 原理篇2 自定义starter2.6 拦截器开发2.6.1 拦截器开发2.6.2 小结2 自定义starter …

2022年11月27日学习 SVM

SVM&#xff0c;英文全称为 Support Vector Machine&#xff0c;中文名为支持向量机 ​ SVM也是一种分类算法&#xff0c;它的核心思想用我自己的话来讲就是先找到两个类别中距离最近的几个点作为支持向量&#xff0c;然后计算超平面&#xff0c;超平面需要间隔最大化。然后用超…

【Hack The Box】linux练习-- Previse

HTB 学习笔记 【Hack The Box】linux练习-- Previse &#x1f525;系列专栏&#xff1a;Hack The Box &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐️留言&#x1f4dd; &#x1f4c6;首发时间&#xff1a;&#x1f334;2022年11月27日&#x1f334; &#x1f…

Microsoft SQL Server中的错误配置

介绍 这篇文章将介绍如何利用Microsoft SQL Server中的错误配置&#xff0c;尝试获取反向shell并熟悉Impacket工具的使用&#xff0c;以便进一步攻击某些服务。 impacket的安装地址&#xff1a;https://github.com/SecureAuthCorp/impacket Impacket是用于处理网络协议的Pyt…

FPGA学习-vivado软件的使用

FPGA学习-vivado软件的使用1.杂谈2. vivado新建工程1.杂谈 又被封了7天。 正好封控前领导让我改下fpga代码&#xff0c;趁这个机会好好学习下&#xff0c;虽然在这块一片空白&#xff0c;但是毕竟这块是我的短板&#xff0c;一个不会写代码的硬件工程师是一个不完整的硬件工程…

无条码商品新建商品档案,搭配蓝牙便携打印机移动打印条码标签

null无条码商品的商品档案新建&#xff0c;并打印条码标签&#xff0c;即可实现仓库条码管理&#xff0c;扫码入库&#xff0c;出库&#xff0c;盘点等操作。, 视频播放量 1、弹幕量 0、点赞数 0、投硬币枚数 0、收藏人数 0、转发人数 0, 视频作者 汉码盘点机PDA, 作者简介 &am…

【WSN通信】A_Star改进LEACH多跳传输协议【含Matlab源码 487期】

⛄一、 A_Star改进LEACH多跳传输协议简介 1 理论基础 1.1 A*算法 A算法是一种智能搜索算法,他在求解问题时所得到的结果会选择所有路径中代价最小的节点。 A算法是一种基于启发式函数的算法,搜索过程如下:首先创建两个分别命名为open表和close表的表格,其中open表中存放还未访…

【Hack The Box】linux练习-- Doctor

HTB 学习笔记 【Hack The Box】linux练习-- Doctor &#x1f525;系列专栏&#xff1a;Hack The Box &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐️留言&#x1f4dd; &#x1f4c6;首发时间&#xff1a;&#x1f334;2022年11月23日&#x1f334; &#x1f3…

量子计算(九):复合系统与联合测量

文章目录 复合系统与联合测量 一、张量积 二、复合系统的状态演化 复合系统与联合测量 拥有两个或两个以上的量子比特的量子系统通常被称为复合系统&#xff08;composite systems&#xff09;。单量子比特系统的描述与测量已有所了解&#xff0c;那么多个量子比特的系统该如…

R语言基于ARMA-GARCH过程的VaR拟合和预测

本文展示了如何基于基础ARMA-GARCH过程&#xff08;当然这也涉及广义上的QRM&#xff09;来拟合和预测风险价值&#xff08;Value-at-Risk&#xff0c;VaR&#xff09;。 最近我们被客户要求撰写关于ARMA-GARCH的研究报告&#xff0c;包括一些图形和统计输出。 视频&#xff…

树莓派安装ubuntu系统

ubuntu镜像下载 官方地址&#xff1a;https://cn.ubuntu.com/download/raspberry-pi 清华镜像&#xff1a;https://mirrors.tuna.tsinghua.edu.cn/ubuntu-cdimage/ubuntu/releases/22.04.1/release/ 准备树莓派镜像工具&#xff08;Raspberry Pi Imager&#xff09; 下载地…

如何在 Spring Boot 中使用 JPA 和 JPQL 进行自定义查询示例

在本教程中&#xff0c;您将了解如何在 Spring Boot 示例中使用 Spring JPA Query进行自定义查询。我将向您展示&#xff1a; 使用JPQL&#xff08;Java持久性查询语言&#xff09;的方法如何在 Spring 引导中执行 SQL 查询具有 WHERE 条件的 JPA 选择查询示例内容 JPQL 与本机…

【408专项篇】C语言笔记-第七章(函数)

第一节&#xff1a;函数的声明与定定义 1. 函数的声明与定义 函数间的调用关系是&#xff1a;由主函数调用其他函数&#xff0c;其他函数也可以互相调用。同一个函数可以被一个或多个函数调用任意次。 #include "func.h"int main() {int a10;aprint_star(a);print_…

SPI和API还在傻傻分不清楚?

什么是SPI 介绍 再聊下一个类加载器框架OSGI之前&#xff0c;我们首先学习一下前驱知识SPI 全称&#xff1a;Service Provider Interface 区别于API模式&#xff0c;本质是一种服务接口规范定义权的转移&#xff0c;从服务提供者转移到服务消费者。 怎么理解呢&#xff1f…

JavaScript游戏开发(3)(笔记)

文章目录七、支持移动设备的横向卷轴游戏准备7.1 角色的简单移动7.2 背景7.3 加入敌人与帧数控制7.4 碰撞、计分、重新开始7.5 手机格式7.6 全屏模式7.7 存在的问题附录素材可以去一位大佬放在github的源码中直接下&#xff0c;见附录。 七、支持移动设备的横向卷轴游戏 使用…

手摸手使用IDEA创建多模块(maven)项目

有了前面两篇手摸手打底&#xff0c;相信大家对IDEA创建项目和配置使用maven已经没有什么问题了。那么这篇文章阅读起来也会非常流畅。 对于IDEA来说&#xff0c;可以用拼接模块&#xff08;Module&#xff09;并引用的方式来“搭”一个项目&#xff08;Project&#xff09;。…

【全志T113-S3_100ask】15-2 linux系统gpio模拟spi驱动屏幕——ILI9341

【全志T113-S3_100ask】15-2 linux系统gpio模拟spi驱动屏幕——ILI9341背景&#xff08;一&#xff09;查阅参考文档&#xff08;二&#xff09;使能内核模块&#xff08;三&#xff09;修改设备树&#xff08;四&#xff09;测试&#xff08;五&#xff09;后语背景 在上一小…

nginx的安装与nginx降权+匹配php

安装nginx: 安装的插件的作用: 1.gcc 可以编译 C,C,Ada,Object C和Java等语言&#xff08;安装 nginx 需要先将官网下载的源码进行编译&#xff0c;编译依赖 gcc 环境&#xff09; 2.pcre pcre-devel pcre是一个perl库&#xff0c;包括perl兼容的正则表达式库&#xff0c;ngin…