无脑整合springboot2.7+nacos2.2.3+dubbo3.2.9实现远程调用及配置中心
简介:
好久没有写博客了,最近辞职了有时间进行一次分享,今天我们主要是使用单体服务springboot整合nacos实现配置中心,然后整合dubbo来实现远程的rpc调用。如下是本地案例架构图,生产者和消费者的配置在nacos配置中心上,将服务注册在nacos注册中心上,进行服务的管理,消费者通过http调用消费者接口。
1、环境准备及组件版本
- nacos 2.2.3
- mysql 5.7(用于nacos持久化)
- dubbo 3.2.9
- jdk8
- springboot 2.7.8
2、nacos下载与持久化配置
nacos下载连接
- 找到下边配置nacos-server-2.2.3\nacos\conf下的application.properties修改如下
spring.datasource.platform=mysql
# spring.sql.init.platform=mysql### Count of DB:
db.num=1### Connect URL of DB:
db.url.0=jdbc:mysql://192.168.1.9:3307/nacos1?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC
db.user.0=root
db.password.0=xxxxxx### Connection pool configuration: hikariCP
db.pool.config.connectionTimeout=30000
db.pool.config.validationTimeout=10000
db.pool.config.maximumPoolSize=20
db.pool.config.minimumIdle=2
注意:需要将ip和账号密码以及数据库名称改为自己创建的名称!
- 进入nacos-server-2.2.3\nacos\bin配置中打开cmd指令执行startup.cmd -m standalone
- 打开http://127.0.0.1:8848/nacos/地址没问题说明就安装好了
- 首先创建一个命名空间dev在dev中创建生产者和消费者配置
- 配置dubbo-consumer和dubbo-provider在配置中心中
# dubbo-consumer
spring:application:name: dubbo-consumer
# 服务器端口配置
server:port: 8801# Dubbo相关配置
dubbo:application:name: dubbo-consumer qos-port: 22223qos-enable: trueregistry:address: nacos://127.0.0.1:8848parameters:namespace: f5b986ac-74e6-4592-b874-0acfee2923dcscan:base-packages: com.example.dubboconsumer.service test: 测试
# dubbo-providerspring:application:name: dubbo-providerdubbo:application:name: dubbo-providerprotocol:name: dubboport: 20880registry:address: nacos://127.0.0.1:8848parameters:namespace: f5b986ac-74e6-4592-b874-0acfee2923dcscan:base-packages: com.example.dubboprovider.service
注意:文件格式都为yaml即可
3、idea构建项目
- 项目结构如下:api为接口模块、consumer为消费者、provider为生产者
- 父级项目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><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.7.8</version></parent><groupId>com.example</groupId><artifactId>dubbo-nacos-demo</artifactId><version>1.0.0-SNAPSHOT</version><packaging>pom</packaging><properties><java.version>1.8</java.version><dubbo.version>3.2.9</dubbo.version><nacos.version>2.2.3</nacos.version></properties><dependencies><!-- Dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId></dependency><dependency><groupId>com.alibaba.boot</groupId><artifactId>nacos-config-spring-boot-starter</artifactId></dependency></dependencies><dependencyManagement><dependencies><!-- 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.boot</groupId><artifactId>nacos-config-spring-boot-starter</artifactId><version>0.2.12</version></dependency></dependencies></dependencyManagement><modules><module>demo-api</module><module>dubbo-provider</module><module>dubbo-consumer</module></modules>
</project>
- 接口模块、生产者和消费者的配置分别如下
<?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><groupId>com.example</groupId><artifactId>dubbo-nacos-demo</artifactId><version>1.0.0-SNAPSHOT</version></parent><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0.0</version><packaging>jar</packaging></project>
<?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><groupId>com.example</groupId><artifactId>dubbo-nacos-demo</artifactId><version>1.0.0-SNAPSHOT</version></parent><artifactId>dubbo-provider</artifactId><packaging>jar</packaging><dependencies><!-- api组件依赖 --><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies></project>
<?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"><parent><artifactId>dubbo-nacos-demo</artifactId><groupId>com.example</groupId><version>1.0.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>dubbo-consumer</artifactId><packaging>jar</packaging><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target></properties><dependencies><!-- api组件依赖 --><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies>
</project>
注意事项:在搭建环境初期,由于dubbo相关依赖版本和springboot的版本存在版本不兼容问题调查很长时间解决所以请务必按照上述个版本引入其他版本可能存在不兼容问题!!!下面是各个版本兼容关系!
- api模块代码
package com.example.demoapi;public interface HelloService {String sayHello(String name);
}
- 生产者代码
package com.example.dubboprovider.service;import com.example.demoapi.HelloService;
import org.apache.dubbo.config.annotation.DubboService;@DubboService(version = "1.0.0")
public class HelloServiceImpl implements HelloService {@Overridepublic String sayHello(String name) {return "Hello " + name + " from Dubbo provider!";}
}
package com.example.dubboprovider;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@EnableDubbo
public class DubboProviderApplication {public static void main(String[] args) {SpringApplication.run(DubboProviderApplication.class, args);}}
nacos.config.server-addr=127.0.0.1:8848
nacos.config.data-id=dubbo-provider
nacos.config.namespace=f5b986ac-74e6-4592-b874-0acfee2923dc
nacos.config.type=yaml
nacos.config.auto-refresh=true
nacos.config.bootstrap.enable=true
- 消费者模块代码
package com.example.dubboconsumer.controller;import com.alibaba.nacos.api.config.annotation.NacosValue;
import com.example.demoapi.HelloService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;@RestController
public class ConsumerController {@DubboReference(version = "1.0.0",timeout = 5000)private HelloService helloService;@NacosValue(value = "${test}", autoRefreshed = true)private String test;@GetMapping("/hello/{name}")public String sayHello(@PathVariable String name) {return helloService.sayHello(name);}@GetMapping("/test")public String test() {return 11+test;}
}
package com.example.dubboconsumer;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@EnableDubbo
public class DubboConsumerApplication {public static void main(String[] args) {SpringApplication.run(DubboConsumerApplication.class, args);}}
#server.port=8081
nacos.config.server-addr=127.0.0.1:8848
nacos.config.data-id=dubbo-consumer
nacos.config.namespace=f5b986ac-74e6-4592-b874-0acfee2923dc
nacos.config.type=yaml
nacos.config.auto-refresh=true
nacos.config.bootstrap.enable=true
4、测试
- 通过消费者调用生产者接口
- 通过调用接口读取配置中心的配置test