大家知道springBoot发明的初衷是为了减少xml的配置,而dubbo的传统方式就是xml配置,所以既然用了springBoot就应该遵循它的规则,在集成dubbo时改为全编程式注解的方式。下面我来为大家详细介绍集成的步骤:
一:安装zookeeper 首先去官网下载zookeeper,下载地址为:http://mirror.bit.edu.cn/apache/zookeeper/;我选择的版本是 zookeeper-3.5.4; 下载完以后解压到本地目录,然后复制conf目录下的zoo_sample.cfg文件,并改名为zoo.cfg。在安装目录下新建data和log文件夹,随后编辑该文件: 注意:dataDir和dataLogDir是zookeeper解压的本地目录,视自己放的位置而更改。
代码语言:javascript复制
# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
dataDir=C:/zookeeper-3.4.13/data
dataLogDir=C:/zookeeper-3.4.13/log
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
完成以上步骤后就可以进入C:zookeeper-3.4.13bin 双击zkserver.cmd启动zookper。 二:创建服务提供者工程 建议使用idea工具!!!我先是在本地磁盘建了一个文件夹springBoot-dubbo,然后选择File - open打开这个文件夹,接着在这个文件夹上创建model工程,如下图所示:
选择spring initializr
如果相同的依赖太多,你也可以考虑创建pom父工程,统一依赖管理。 1.服务者的pom.xml:
代码语言:javascript复制
<?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>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.2.RELEASE</version>
<relativePath/>
</parent>
<groupId>com.wenxue</groupId>
<artifactId>springBoot-dubbo-provider</artifactId>
<packaging>jar</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>springBoot-dubbo-provider</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</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-test</artifactId>
<scope>test</scope>
</dependency>
<!--sproingBoot整合dubbo的依赖-->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2.添加application.propertis文件,配置dubbo相关信息
#提供服务名称,可任意抒写
spring.dubbo.application.name=provider
#zookeeper地址及端口号
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
#dubbo协议
spring.dubbo.protocol.name=dubbo
#duboo端口号
spring.dubbo.protocol.port=20880
#这是你要发布到dubbo提供服务的接口所在包位置
spring.dubbo.scan=com.wenxue.demo.dubboService
#tomcat端口号
server.port=8888
3.编写接口及实现类(重点):
package com.wenxue.demo.dubboService.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.wenxue.demo.dubboService.TestDubboService;
@Service(version = "1.0.0")//该注解的作用就是发布服务
public class TestDubboServiceImpl implements TestDubboService {
@Override
public void toProvider() throws Exception {
System.out.println("恭喜你连接成功");
}
}
注意:上面的@Service注解是“com.alibaba.dubbo.config.annotation” 包下的,不是spring的,如果导错了包将会无法发布服务。
工程目录结构如下:
三:创建消费者工程 创建过程同上。 1.消费者的pom.xml:
代码语言:javascript复制
<?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>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.2.RELEASE</version>
<relativePath/>
</parent>
<groupId>com.wenxue</groupId>
<artifactId>springBoot-dubbo-consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springBoot-dubbo-consumer</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</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-test</artifactId>
<scope>test</scope>
</dependency>
<!--springBoot整合dubbo的依赖-->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2.编写applicat.properties:
代码语言:javascript复制
#消费者名称,可任意抒写
spring.dubbo.application.name=consumer
#zookeeper地址及端口号
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
#消费方 调用 服务费 @Reference注入 所在包位置
spring.dubbo.scan=com.wenxue.demo.controller
#tomcat端口号
server.port=8889
这里要特别注意,消费方的spring.dubbo.scan是消费方调用服务费所在包的位置,也就是打注解@Reference的包位置。我看过网上很多人都把服务费和消费方的spring.dubbo.scan都说成是服务方接口所在的包位置,经过本人测试这是不准确的。 3.编写Controller:
代码语言:javascript复制
package com.wenxue.demo.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.wenxue.demo.dubboService.TestDubboService;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
@Component
@RequestMapping("/")
public class TestDubboController {
@Reference(version = "1.0.0")//该注解的作用就是订阅服务
private TestDubboService testServices;
@RequestMapping("/testDubbo")
public void testDubbo() throws Exception {
testServices.toProvider();
}
}
4.定义服务方接口 方式一: 由于消费方和服务方不在同一个工程,所以需要将服务方的接口拷贝过来。 方式二:如果你觉得拷贝包太麻烦了的话,还可以有第二种方案,那就是导入服务方的工程依赖 <!--引入服务方工程的目的为了注入服务方的接口--> <!--<dependency>--> <!--<groupId>com.wenxue</groupId>--> <!--<artifactId>springBoot-dubbo-provider</artifactId>--> <!--<version>0.0.1-SNAPSHOT</version>--> <!--</dependency>--> 以上两种方式任君选择,不过本人建议使用第一种,以免增加maven仓库的导入量。或许读者你也会疑问:“导入了服务费的工程,不需要dubbo不也可以调用吗?”但是经过我测试是不可以的。这说明了springBoot的底层做了某些特殊的封装。 5.启动工程 接下来先启动服务者,再启动消费者就可以了。(如果你想看的更加清楚,可以下载dubbo-admin.war,放入tomcat启动后访问http://localhost:8088/dubbo-admin-2.5.4 。 就可以看见服务的发布与订阅是否成功与失败。密码账户默认都是是root)
6.测试调用: *如果不出意外,你会发现,在controller调用远程服务时出现了“java.lang.NullPointerException: null”的异常,那就恭喜你已经中了第一坑。哈哈。 那是因为TestDubboService并没有成功被订阅,所以是空对象。造成这种现象的原因一般都是:“因为你消费方的接口的包路径与服务方的包路径不同所导致的!所以,一定要从服务方连包带接口拷贝到消费方!一定要从服务方连包带接口拷贝到消费方!一定要从服务方连包带接口拷贝到消费方! 重要的事情说三遍!!!” 如下图所示:
最后测试调用: 访问:http://localhost:8889/testDubbo ,如果控制台打印出“恭喜你连接成功了!” 那就没问题了
其它可能存在的问题说明: 1.一定要导入log4j的jar,否则会报错; 2.使用debug时,会出现服务端连续执行三次的情况; 3.在执行远程调用时可能会出现空指针异常,那是因为服务端的接口没有注入进来,可能是因为消费方接口包路径与服务方的接口路径不一致,或者是消费方的spring.dubbo.scan=xxx 路径定义错了。
作者:龚文学 原文:https://blog.csdn.net/qq_41899174/article/details/86751255