SpringBoot整合Dubbo框架简单实例

1、创建项目

这是整个项目的目录结构，DubboTest只是起一个聚合模块的作用，除了pom.xml其余的都可以删除

2、创建模块

依次按照流程创建consumer、provider、service三个模块，一个是消费者一个是提供者一个是公共服务接口。

3、配置好maven文件

consumer的pom.xml:

<?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> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.7.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <modelVersion>4.0.0</modelVersion> <properties> <java.version>1.8</java.version> </properties> <artifactId>consumer</artifactId> <dependencies> <dependency> <groupId>com.my</groupId> <artifactId>service</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo</artifactId> <version>2.7.3</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>4.0.1</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.8.0</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.13</version> <type>pom</type> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.10</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>

provider的pom.xml:

<?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> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.7.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <modelVersion>4.0.0</modelVersion> <properties> <java.version>1.8</java.version> </properties> <artifactId>provider</artifactId> <dependencies> <dependency> <groupId>com.my</groupId> <artifactId>service</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo</artifactId> <version>2.7.3</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>4.0.1</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.8.0</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.13</version> <type>pom</type> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.10</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>

service的pom.xml:

<?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>DubboTest</artifactId> <groupId>com.my</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>service</artifactId> <properties> <!-- 项目编译编码--> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <!-- maven编译的jdk版本--> <maven.compiler.encoding>UTF-8</maven.compiler.encoding> <java.version>1.8</java.version> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> </properties> </project>

4、编码

整体的目录结构 consumer代码： TestController:

@RestController public class TestController { //与实现接口类中version对应一致 @Reference(version = "1.0.1") private TestService testServiceImpl; @RequestMapping("/ins") public String ins(){ testServiceImpl.ins(); return "ins"; } @RequestMapping("/del") public String del(){ testServiceImpl.del(); return "del"; } @RequestMapping("/upd") public String upd(){ testServiceImpl.upd(); return "upd"; } @RequestMapping("/sel") public String sel(){ testServiceImpl.sel(); return "sel"; } }

ConsumerApplication:

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

application.properties:

#dubbo configuration dubbo.application.name=dubbo_consumer dubbo.registry.protocol=zookeeper dubbo.registry.address=zookeeper://127.0.0.1:2181 #避免端口冲突 server.port=8085

provider代码： service.impl,这里注册的version与对应的消费者中创造服务接口的reference对应的version必须是一致的，这才保证了能够在注册中心中服务发现对应的接口，interfaceClass就是我们进行映射的接口类

@Service(version = "1.0.1",interfaceClass = TestService.class) public class TestServiceImpl implements TestService { @Override public void ins() { System.out.println("insert"); } @Override public void del() { System.out.println("delete"); } @Override public void upd() { System.out.println("update"); } @Override public void sel() { System.out.println("select"); } }

providerApplication

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

application.properties

#spring项目名 spring.application.name=dubbo_auto_configuration_provider_demo #Dubbo provider configuration dubbo.application.name=dubbo_provider dubbo.registry.protocol=zookeeper dubbo.registry.address=zookeeper://127.0.0.1:2181 dubbo.protocol.name=dubbo dubbo.protocol.port=20880 #扫描注解包通过该设置将服务注册到zookeeper dubbo.scan.base-packages=com.my.provider.service server.port= 8084

service代码： TestService

public interface TestService { public void ins(); public void del(); public void upd(); public void sel(); }

5、启动本地Zookeeper

Zookeeper下载链接，点击链接后找一个适合的下载镜像，然后将zookeeper解压到你的文件夹，之后将在conf目录下新建一个zoo.cfg，将conf之前的cfg内容复制到zoo.cfg中，删除原来那个，即可。如果点击zkServer.cmd秒关闭，打开源码在最后一行加上一句pause即可

6、结果演示

通过8085端口调用到了在8084服务中实现的接口 演示就到这里结束了~觉得有用的可以点赞支持一下