dubbo本地调用和远程调用_使用dubbo+zookeeper实现远程调用

深碍√TFBOYSˉ_ 2023-01-01 09:53 336阅读 0赞

使用dubbo+zookeeper实现远程调用

一、配置环境  
dubbo下载地址：  
github源码下载：https://github.com/dangdangdotcom/dubbox  
配置一下dubbo-admin中WEB-INF下的properties：

dubbo.registery.address=zookeeper://127.0.0.1:2181
    dubbo.admin.root.password=root
    dubbo.admin.guest.password=guest

打war包放入tomcat运行：  
1、进入下载的文件夹中  
2、在路径栏输入cmd  
3、输入 mvn install -Dmaven.test.skip=true

![06b75bbc603daf4f55f97d1317199c14.png][]

然后找到打包好的war文件：dubbo-admin-版本.war

把他放入准备好的Tomcat下的webapps目录下

启动tomcat

如：在D:apache-tomcat-9.0.12bin下点击startup.bat启动

最后在网址输入:http://localhost:8089/“这里是dubbo的名称也就是war包的名称”/governance/services/com.eoin.service.IGoodsService/providers/1

最后用户名和密码都是root

zookeeper：  
1.下载zookeeper文件：http://mirror.bit.edu.cn/apache/zookeeper/

2.下载后找到zookeeper-3.4.9conf目录下的zoo\_sample.cfg文件，将他改名为zoo.cfg

然后打开：

dataDir=D:zookeeper-3.4.10bindata  
dataLogEir=D:zookeeper-3.4.10binlog

这两个是日志可以自己定义

剩下的：

tickTime：基本事件单元，以毫秒为单位。这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，它用来控制心跳和超时，也就是每个 tickTime 时间就会发送一个心跳。默认情况下最小的会话超时时间为两倍的 tickTime。  
clientPort：监听客户端连接的端口。这个端口就是客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。  
dataDir：是 Zookeeper 保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。  
dataLogDir：是 Zookeeper 保存日志文件的目录

3.启动Zookeeper：

在bin下面找到zkEnv.cmd，点击启动

然后你可以在dubbo上看见这个服务

注：一定要先将java环境变量配置好

**然后进入主题，开始创建dubbo项目：**  
1、搭建springboot项目：  
创建工程：

![17dd4aa8bb61bb696a3156bf3ab26e39.png][]

选择springboot：

![4d73c1e47d8d5aa66b82d19867b93714.png][]

填入包名、项目名：

![21532d52e7f4f91e96bdf3677151f347.png][]

选择依赖：

![c50b7dc5d1ca841b3a3ea6e52d34ca8d.png][]

确认包名及工程路径：

![77df0e396af64a0d7e2297237811a979.png][]

点击finish，项目创建完成

ps：这里我使用了阿里巴巴的Java 工程脚手架，地址：https://start.aliyun.com/  
还略有一些不足，我已经加入了这个项目的用户群，进行问题反馈，大佬们也很快就解决了我提出的问题。

因为创建这个工程，是需要做通知推送功能，所以同时集成了阿里巴巴的移动推送功能。

首先，项目搭建好后，先来配置消费者端。

**生产者端**

创建dubbo-provider.xml，如下图：

![aa6512c4d384d93e2e463a0119eabd0c.png][]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans.xsd
            http://code.alibabatech.com/schema/dubbo
            http://code.alibabatech.com/schema/dubbo/dubbo.xsd
            ">
        
        <bean class="cn.com.cherish.push.api.Impl.IPushServiceImpl" id="pushService" />
    
        <dubbo:application name="whb-provider" owner="whb" />
        
        <dubbo:registry address="zookeeper://127.0.0.1:2181" />
        
        <dubbo:protocol name="dubbo" port="20880" />
        
        <dubbo:monitor address="192.168.10.175:6888" />
        
        <dubbo:service connections="100" interface="cn.com.cherish.push.api.IPushService" protocol="dubbo" ref="pushService" timeout="50000" />
    </beans>

同时配置config文件让配置生效：

import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.ImportResource;
    
    @Configuration
    @ImportResource(locations={"classpath:dubbo-provider.xml"})
    public class DubboConfig {
    }

然后编写service以及实现类中的代码，注意，这种方法不需要加@Service注解，配置文件中已经配置了扫描。

注意，生产者端路径一定要和消费者路径一致，不然会调用不到！

**消费者端：**  
dubbo-consumer.xml：

![f32a71d9d0efaeed22929cfbdb21afaf.png][]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans.xsd
            http://code.alibabatech.com/schema/dubbo
            http://code.alibabatech.com/schema/dubbo/dubbo.xsd
            ">
    	
    	<dubbo:consumer check="false"/>
    	
    	<dubbo:application name="whb_admin_guoy_test"/>
    	
    	<dubbo:registry id="pushServiceRegistry" address="zookeeper://127.0.0.1:2181"/>
    	
    	<dubbo:protocol name="dubbo" port="20880"/>
    	
    	<dubbo:reference id="pushService" interface="cn.com.cherish.push.api.IPushService" timeout="10000000" registry="pushServiceRegistry"/>
    
    </beans>

然后进行远程调用，看到dubbo-admin中，生产者消费者已经全部启动，到此调用结束。

问题：  
1、注意dubbo生产者消费者jar包一定要一致！  
因为消费者端是老项目，jar包什么的都不好动，用的是dubbox2.8.4版本，这个版本是当当网维护的dubbo，在maven的依赖库中找不到，只能自己打包。版本一定要一致！！！否则会一直报错调用不到！

[06b75bbc603daf4f55f97d1317199c14.png]: /images/20221120/420ace189c864fadae7ab488ec5e0137.png
[17dd4aa8bb61bb696a3156bf3ab26e39.png]: /images/20221120/8db55135f057488ebb928810b166a675.png
[4d73c1e47d8d5aa66b82d19867b93714.png]: /images/20221120/b2b6535bb7c042e4a092d628083fce86.png
[21532d52e7f4f91e96bdf3677151f347.png]: /images/20221120/f3a83a1cdce5429386b2da16ca71c98f.png
[c50b7dc5d1ca841b3a3ea6e52d34ca8d.png]: /images/20221120/e6a564331b6843219d231c740bd8f70b.png
[77df0e396af64a0d7e2297237811a979.png]: /images/20221120/15095e8c05534a97ae0a696f38bc31c7.png
[aa6512c4d384d93e2e463a0119eabd0c.png]: /images/20221120/a629c8512e6f4ad68659005b5d0cf639.png
[f32a71d9d0efaeed22929cfbdb21afaf.png]: https://img-blog.csdnimg.cn/img_convert/f32a71d9d0efaeed22929cfbdb21afaf.png