构建 Zookeeper + Dubbo + Spring Boot 的分布式调用项目

小咪咪 2022-06-13 06:21 138阅读 0赞

今天给大家介绍一下如何在SpringBoot中搭建Dubbo+Zookeeper来实现不同系统的RPC调用

想学习**分布式、微服务、JVM、多线程、架构、java、python**的童鞋，千万**不要**扫码，否则后果自负~

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbnpoaXFpYW5nMDMxNg_size_16_color_FFFFFF_t_70][]

这里先和大家说一下什么是RPC框架，简单的来说就是远程接口调用框架。像这类的框架有很多，例如：新浪研发的Motan，还有阿里研发的Dubbo等等之类的。如果大家想要了解更多可以看这篇博客介绍，里面对于框架的对比写的特别不错。

博客地址：[http://blog.csdn.net/liubenlong007/article/details/54692241][http_blog.csdn.net_liubenlong007_article_details_54692241]

经过考虑，我决定采用Dubbo+Zookeeper来实现RPC调用框架的实现。

**一：首先确定一下工具的版本和运行的环境：**

运行环境：JDK 7 或 8，Maven 3.0+

技术栈：SpringBoot 1.5+、Dubbo 2.5+、ZooKeeper 3.3+

其中SpringBoot ，Dubbo 只要在Maven中配置就可以自动下载jar了，ZooKeeper 需要独立加载软件并运行才可以。

**二：接下来先介绍的一下Zookeeper的安装和使用步骤：**

ZooKeeper 是一个分布式的，开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

**第一步：需要到官网下载ZooKeeper 3.3+的软件**

ZooKeeper下载地址：[http://www.apache.org/dyn/closer.cgi/zookeeper][http_www.apache.org_dyn_closer.cgi_zookeeper]

**第二步：下载完毕之后就需要做一些简单的配置了，配置过程如下：**

在 conf 目录新建 zoo.cfg ，照着该目录的 zoo\_sample.cfg 配置如下。

![Center][]

# 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.
    dataDir=/tmp/zookeeper
    # the port at which the clients will connect
    clientPort=2181

**第三步：****在 bin 目录下，启动 ZooKeeper**

![Center 1][]

这样关于ZooKeeper安装和使用就基本结束了，接下来是SpringBoot如何配置Dubbo和Zookeeper了。

**四：SpringBoot项目构建模块**

**首先新建一个SpringBoot项目，来作为Dubbo的客户端请求服务。**

首先需要在pom.xml加入相应的jar关联：

<dependency>
    			<groupId>io.dubbo.springboot</groupId>
    			<artifactId>spring-boot-starter-dubbo</artifactId>
    			<version>${dubbo-spring-boot}</version>
    		</dependency>

这里还需要额外的添加log4j关联，否则项目会启动报错（具体的原因我也不知道）

<dependency>
    			<groupId>log4j</groupId>
    			<artifactId>log4j</artifactId>
    			<version>1.2.14</version>
    		</dependency>

**接下来就是application.properties配置文件中关于Dubbo信息的配置了，配置内容如下所示：**

## tomcat端口号配置
    server.port=8001
    ## 项目访问路径配置
    server.context-path=/bootTest
    ## Dubbo 应用名称
    spring.dubbo.application.name=consumer
    ##Dubbo 注册中心地址
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    ## Dubbo 服务类包目录（service所在包的地址，这个千万不要配置错误）
    spring.dubbo.scan=lzq.boot.test.service

**接下来就是写功能代码主要有：接口，接口实现类，实体类，控制类，项目启动类**

**1实体类：**

package lzq.boot.test.entity;
    import java.io.Serializable;
    /**
     * 返回结果实体类
     * @author linzhiqiang
     *
     */
    public class ResultInfo implements Serializable{
        private static final long serialVersionUID = -1L;
    	private String resultInfo;
    	
    	public ResultInfo(String resultInfo) {
    		super();
    		this.resultInfo = resultInfo;
    	}
    
    	public ResultInfo() {
    		super();
    	}
    
    	public String getResultInfo() {
    		return resultInfo;
    	}
    
    	public void setResultInfo(String resultInfo) {
    		this.resultInfo = resultInfo;
    	};
    	
    }

**2.接口：**

package lzq.boot.test.service;
    /**
     * RPC调用接口
     * @author linzhiqiang
     *
     */
    
    import lzq.boot.test.entity.ResultInfo;
    
    public interface RPCInterface {
    	/**
    	 * 通过Dubbo实现远程RPC调用接口信息
    	 * @return
    	 */
    	public ResultInfo getRPCInfo();
    }

**3.接口实现类：**

package lzq.boot.test.service.impl;
    import org.springframework.stereotype.Component;
    import com.alibaba.dubbo.config.annotation.Reference;
    import lzq.boot.test.entity.ResultInfo;
    import lzq.boot.test.service.RPCInterface;
    /**
     * RPC调用业务逻辑处理
     * @author linzhiqiang
     */
    @Component
    public class RPCInterfaceImpl implements RPCInterface {
        @Reference(version = "1.0.0")
        RPCInterface rpcInterface;//调用远程接口的实现类
        
    	@Override
    	public ResultInfo getRPCInfo() {
    		ResultInfo resultInfo=rpcInterface.getRPCInfo();
    		return resultInfo;
    	}
    
    }

**4.控制类：**

package lzq.boot.test.controller;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    import lzq.boot.test.entity.ResultInfo;
    import lzq.boot.test.service.RPCInterface;
    /**
     * Dubbo测试
     * @author linzhiqiang
     *
     */
    @Controller
    public class DubboController {
    	@Autowired
    	private RPCInterface rpcInterface;
    	@RequestMapping("/dubbo")
    	@ResponseBody
    	public String errorNginxTest(){
    		ResultInfo resultInfo=rpcInterface.getRPCInfo();
    		return "result:"+resultInfo.getResultInfo();
    	}
    }

**5.项目启动类：**

package lzq.boot.test;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    @SpringBootApplication
    public class SpringBootTest1Application {
    	public static void main(String[] args) {
    		SpringApplication.run(SpringBootTest1Application.class, args);
    	}
    }

**最后就是新建一个SpringBoot项目，来作为Dubbo的服务端用来返回请求信息**。

**该项目和客户端项目基本差不多也是先在pom.xml 进行maven的配置**

在pom.xml加入相应的jar关联：

这里还是需要额外的添加log4j关联，否则项目会启动报错（具体的原因我也不知道）

<dependency>
    			<groupId>log4j</groupId>
    			<artifactId>log4j</artifactId>
    			<version>1.2.14</version>
    		</dependency>

**接下来还是application.properties配置文件中关于Dubbo信息的配置了，配置内容如下所示：**

## tomcat端口号配置
    server.port=8002
    ## 项目访问路径配置
    server.context-path=/bootTest
    ## Dubbo 应用名称
    spring.dubbo.application.name=provider
    ##Dubbo 注册中心地址
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    ##Dubbo 协议名称
    spring.dubbo.protocol.name=dubbo
    ##Dubbo 协议端口
    spring.dubbo.protocol.port=20880
    ## Dubbo 服务类包目录（service所在包的地址，这个千万不要配置错误）
    spring.dubbo.scan=lzq.boot.test.service

**接下来还是写功能代码主要有：接口，接口实现类，实体类，项目启动类**

**1实体类：**

**2.接口：**

**3.接口实现类：**

package lzq.boot.test.service.impl;
    import com.alibaba.dubbo.config.annotation.Service;
    import lzq.boot.test.entity.ResultInfo;
    import lzq.boot.test.service.RPCInterface;
    /**
     * RPC接口的实现类
     * @author linzhiqiang
     */
    //注册为 Dubbo 服务
    @Service(version = "1.0.0")
    public class RPCInterfaceImpl implements RPCInterface {
    	@Override
    	public ResultInfo getRPCInfo() {
    		ResultInfo resultInfo=new ResultInfo("我是RPC的返回信息，来自其它系统的实现方法");
    		return resultInfo;
    	}
    }

**4.项目启动类：**

package lzq.boot.test;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    @SpringBootApplication
    public class SpringBootTest2Application {
    	public static void main(String[] args) {
    		SpringApplication.run(SpringBootTest2Application.class, args);
    	}
    }

**启动dubbo的服务端的SpringBoot项目时候，显示以下信息就代表注册成功了。**

![Center 2][]

![Center 3][]

之后就可以启动dubbo客户端的SpringBoot项目了，在浏览器中访问控制器校验接口是否正确。

**下面是校验结果显示截图：**

![Center 4][]

**到这里关于构建 Zookeeper + Dubbo + Spring Boot 的分布式调用项目就基本结束了**

**如果大家对文章有什么问题或者疑意之类的，可以加我订阅号在上面留言，订阅号上面我会定期更新最新博客。如果嫌麻烦可以直接加我wechat：lzqcode**

![284_method_get-resource_shareToken_6CEF0002846344EAA8E81FC9E51F5C29_entryId_182345157][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpbnpoaXFpYW5nMDMxNg_size_16_color_FFFFFF_t_70]: /images/20220613/22574a68a8904bbdbc6b58b6dc996948.png
[http_blog.csdn.net_liubenlong007_article_details_54692241]: http://blog.csdn.net/liubenlong007/article/details/54692241
[http_www.apache.org_dyn_closer.cgi_zookeeper]: http://www.apache.org/dyn/closer.cgi/zookeeper
[Center]: /images/20220613/564e32d2703a499faf2f577808fb0044.png
[Center 1]: /images/20220613/84ad7e1557964d27b7adc38b74b4f16b.png
[Center 2]: /images/20220613/c26f6eca3ca14580aea70f16e719732e.png
[Center 3]: /images/20220613/c859994c06a748c7802daca82e71de14.png
[Center 4]: /images/20220613/b37691651ba44bf0870c7db6fd4790a2.png
[284_method_get-resource_shareToken_6CEF0002846344EAA8E81FC9E51F5C29_entryId_182345157]: https://note.youdao.com/yws/api/group/67516516/noteresource/C5C7035B3E5147589191CE5096EC74CE/version/284?method=get-resource&shareToken=6CEF0002846344EAA8E81FC9E51F5C29&entryId=182345157