本文来写个详细的例子来说下dubbo+nacos+spring boot开发实战。本文不会讲述太多的理论的知识，会写一个最简单的例子来说明dubbo如何与nacos整合，快速搭建开发环境。文章目录环境准备dubbo简介nacos环境准备nacos与dubbo整合项目管理规范dubbo整合nacos案例创建公共接口模块创建服务提供者模块创建服务消费者模块服务调用测试本文小结环境准备dubbo简介dubbo核心节点之间的调用关系
节点说明
调用关系说明
服务容器负责启动，加载，运行服务提供者。服务提供者在启动时，向注册中心注册自己提供的服务。服务消费者在启动时，向注册中心订阅自己所需的服务。注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。nacos环境准备启动nacos，本文使用的是nacos1.4.3版本
打开nacos的控制面板
nacos与dubbo整合为了方便大家理解，这里写出对应的生产方、消费方 demo 代码，以及使用的注册中心。
项目管理规范springboot，netflix和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下
dubbo和cloud alibaba之间有版本之间的对应关系，本文选择的版本如下
为了后续方便使用springcloud alibaba进行开发，首先创建一个pom类型的父项目，主要用于项目技术栈版本管理，创建一个maven项目，名称为spring-cloud-alibaba-example，去除src文件，修改pom文件
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelversion>4.0.0</modelversion> <groupid>ah.wideth</groupid> <artifactid>spring-cloud-alibaba-example</artifactid> <version>1.0-snapshot</version> <parent> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-parent</artifactid> <version>2.3.12.release</version> <relativepath/> <!-- lookup parent from repository --> </parent> <packaging>pom</packaging> <properties> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <java.version>1.8</java.version> <spring-cloud.version>hoxton.sr12</spring-cloud.version> <com-alibaba-cloud.version>2.2.7.release</com-alibaba-cloud.version> </properties> <!--对项目版本进行管理--> <dependencymanagement> <dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-dependencies</artifactid> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupid>com.alibaba.cloud</groupid> <artifactid>spring-cloud-alibaba-dependencies</artifactid> <version>${com-alibaba-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencymanagement></project>
后续创建的项目都放到此目录下，只需要声明groupid和artifactid，会自动引用父项目spring-cloud-alibaba-example的版本。与其说是父项目，不如说是根项目: 因为下面每学习一个新的技术，就会新建一个真正的父项目，而在对应的父项目下面又会创建许多的子项目
dubbo整合nacos案例本文的案例是在上文nacos开发实例的基础之上继续编写的。下面开始创建我们的项目，贴上我的目录结构。
模块说明
public-api公共接口模块（接口），供服务消费者和服务提供者调用。dubbo-provider服务提供者模块（接口实现类），引入了public-api模块dubbo-consumer服务消费者模块（controller），引入了public-api模块消费者和提供者通过公共接口模块进行rpc远程调用父工程pom文件
<?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> <parent> <artifactid>spring-cloud-alibaba-example</artifactid> <groupid>ah.wideth</groupid> <version>1.0-snapshot</version> </parent> <modules> <module>public-api</module> <module>dubbo-provider</module> <module>dubbo-consumer</module> </modules> <artifactid>dubbo-nacos-example</artifactid> <name>dubbo-nacos-example</name> <description>duboo与nacos整合的父工程</description> <packaging>pom</packaging> <properties> <java.version>1.8</java.version> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <project.reporting.outputencoding>utf-8</project.reporting.outputencoding> <dubbo.version>2.7.13</dubbo.version> <nacos.version>1.4.1</nacos.version> </properties> <dependencies> <dependency> <groupid>com.alibaba.cloud</groupid> <artifactid>spring-cloud-starter-alibaba-nacos-discovery</artifactid> <!--解决nacos-client2.0报错的问题--> <exclusions> <exclusion> <artifactid>nacos-client</artifactid> <groupid>com.alibaba.nacos</groupid> </exclusion> </exclusions> </dependency> <!--dubbo相关--> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-spring-boot-starter</artifactid> <version>${dubbo.version}</version> </dependency> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo-registry-nacos</artifactid> <version>${dubbo.version}</version> </dependency> <dependency> <groupid>com.alibaba.nacos</groupid> <artifactid>nacos-client</artifactid> <version>${nacos.version}</version> </dependency> <!-- 解决dubbo2.7.13jar包冲突问题--> <dependency> <groupid>com.alibaba.spring</groupid> <artifactid>spring-context-support</artifactid> <version>1.0.11</version> </dependency> <dependency> <groupid>org.apache.dubbo</groupid> <artifactid>dubbo</artifactid> <version>${dubbo.version}</version> <exclusions> <exclusion> <groupid>org.springframework</groupid> <artifactid>spring</artifactid> </exclusion> <exclusion> <groupid>javax.servlet</groupid> <artifactid>servlet-api</artifactid> </exclusion> <exclusion> <groupid>log4j</groupid> <artifactid>log4j</artifactid> </exclusion> </exclusions> </dependency> </dependencies></project>
创建公共接口模块pom文件
<?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> <parent> <artifactid>dubbo-nacos-example</artifactid> <groupid>ah.wideth</groupid> <version>1.0-snapshot</version> </parent> <artifactid>public-api</artifactid> <name>public-api</name> <description>api公用接口</description> <packaging>jar</packaging> <properties> <java.version>1.8</java.version> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <project.reporting.outputencoding>utf-8</project.reporting.outputencoding> </properties> <dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> </dependencies> <build> <plugins> <plugin> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-maven-plugin</artifactid> </plugin> </plugins> </build></project>
公共接口模块里面只有一个接口，没有配置文件，打jar包
package ah.wideth.api;/** * 让生产者和服务消 * 费者来使用这个接口 */public interface infoservice { string getinfo();}
创建服务提供者模块pom文件
<?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> <parent> <artifactid>dubbo-nacos-example</artifactid> <groupid>ah.wideth</groupid> <version>1.0-snapshot</version> </parent> <artifactid>dubbo-provider</artifactid> <name>dubbo-provider</name> <description>dubbo的服务提供者模块</description> <properties> <java.version>1.8</java.version> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <project.reporting.outputencoding>utf-8</project.reporting.outputencoding> </properties> <dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <!--引入公共接口模块--> <dependency> <groupid>${project.groupid}</groupid> <artifactid>public-api</artifactid> <version>${project.version}</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-maven-plugin</artifactid> </plugin> </plugins> </build></project>
application.yml配置文件
server: port: 8180spring: application: name: dubbo-providerdubbo: registry: address: nacos://127.0.0.1:8848 #注册地址 application: name: dubbo-provider #应用名 protocol: name: dubbo #dubbo协议 port: 20880 #协议端口 scan: base-packages: ah.wideth.impl #扫包范围 provider: timeout: 30000 #超时时间
接口实现类，该类实现了上面我们在公共接口模块创建的接口
package ah.wideth.impl;import ah.wideth.api.infoservice;import org.apache.dubbo.config.annotation.dubboservice;import org.springframework.stereotype.component;// dubbo提供的service注解，用于声明对外暴露服务// service引入的是org.apache.dubbo.config.annotation.service包@component@dubboservicepublic class infoserviceimpl implements infoservice { @override public string getinfo() { return "hello，这里是dubbo-provider模块！"; }}
服务提供者启动类
package ah.wideth;import org.apache.dubbo.config.spring.context.annotation.enabledubbo;import org.springframework.boot.springapplication;import org.springframework.boot.autoconfigure.springbootapplication;import org.springframework.cloud.client.discovery.enablediscoveryclient;@enabledubbo@enablediscoveryclient@springbootapplicationpublic class dubboproviderapplication { public static void main(string[] args) { springapplication.run(dubboproviderapplication.class, args); system.out.println("dubbo服务提供者8180启动了"); }}
创建服务消费者模块pom文件
<?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> <parent> <artifactid>dubbo-nacos-example</artifactid> <groupid>ah.wideth</groupid> <version>1.0-snapshot</version> </parent> <artifactid>dubbo-consumer</artifactid> <name>dubbo-consumer</name> <description>dubbo的服务消费者模块</description> <properties> <java.version>1.8</java.version> <project.build.sourceencoding>utf-8</project.build.sourceencoding> <project.reporting.outputencoding>utf-8</project.reporting.outputencoding> </properties> <dependencies> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <!--引入公共接口模块--> <dependency> <groupid>${project.groupid}</groupid> <artifactid>public-api</artifactid> <version>${project.version}</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-maven-plugin</artifactid> </plugin> </plugins> </build></project>
application.yml配置文件
server: port: 8181spring: application: name: dubbo-consumerdubbo: registry: address: nacos://127.0.0.1:8848 #注册地址 application: name: dubbo-consumer #应用名 consumer: timeout: 30000 #超时时间
controller，调用公共接口模块创建的接口
package ah.wideth.controller;import ah.wideth.api.infoservice;import org.apache.dubbo.config.annotation.dubboreference;import org.springframework.web.bind.annotation.getmapping;import org.springframework.web.bind.annotation.restcontroller;@restcontrollerpublic class infocontroller { //dumbo提供的reference注解，用于调用远程服务 @dubboreference(check = false) private infoservice infoservice; @getmapping("/getinfo") public string getinfo(){ return infoservice.getinfo(); }}
服务消费者启动类
package ah.wideth;import org.apache.dubbo.config.spring.context.annotation.enabledubbo;import org.springframework.boot.springapplication;import org.springframework.boot.autoconfigure.springbootapplication;import org.springframework.cloud.client.discovery.enablediscoveryclient;@enabledubbo@enablediscoveryclient@springbootapplicationpublic class dubboconsumerapplication { public static void main(string[] args) { springapplication.run(dubboconsumerapplication.class, args); system.out.println("dubbo服务消费者8181启动了"); }}
服务调用测试打开nacos控制面板查看注册中心中的服务
启动nacos，启动服务提供者和服务消费者，调用服务消费者的getinfo方法，服务提供者会返回结果
本文小结本文编写了一个例子来对dubbo整合nacos进行服务调用的例子，不过要注意jar包的冲突问题。
以上就是springboot+dubbo+nacos 开发实战教程的详细内容。