dubbo入门

zookeeper安装与配置

下载地址：http://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/

选择 zookeeper-3.4.14.tar.gz 即可

zookeeper配置

安装完成之后，进入conf文件，复制zoo_sample.cfg文件 并命名为zoo.cfg

然后进入bin目录 点击zkServer.cmd启动zookeeper服务

没有报错 就算启动完成

接着可以启动zkCli.cmd启动客户端 进行测试 但是一般开发中 我们的java程序就是客户端 因此这里只是为了测试

连接成功以后 使用ls /命令就可以看到zookeeper的当前节点数量

也可以使用create -e key value的方式进行节点的创建

windows环境下和Linux环境下的操作一样 linux环境下启动 .sh后缀的服务即可

Dubbo

async：异步调用 sync：同步调用 init：数据初始化

生产者向注册中心注册服务

消费者订阅注册中心，当有新的服务被注册，注册中心就会通知消费者

消费者就可以进行同步调用实现对生产者服务的调用

dubbo是一个rpc框架 主要提供通讯和序列化，序列化是为了保证数据可以在网络中传输

rpc：远程调用 通俗点说就是两个部署在 不同服务器上的程序， A可以调用B 。区别与本地调用 主要是部署在了不同的服务器上

DubboAdmin下载与安装

下载地址 https://github.com/apache/dubbo-admin.git 选择 master 0.2.0 分支

下载完成之后 修改配置文件 在dubbo-admin-master-0.2.0dubbo-adminsrcmainresourcesapplication.properties文件中修改zookeeper的地址即可

默认主页地址是localhost:7001

打包

在当前文件夹下 以管理员身份打开cmd

然后执行打包命令mvn clean package -Dmaven.test.skip=true 打成jar包 以后可以直接执行jar运行程序

也可以每次在Idea中打开该文件 运行该程序 效果都一样

运行

打包成功之后 将zookeeper服务启动

在dubbo-admin-master-0.2.0dubbo-admintarget文件夹下 打开cmd窗口使用 java -jar dubbo-admin.jar命令 运行程序

然后访问localhost:7001进入admin界面 默认账号密码都是admin

DubboAdmin是一个监控管理后台 可以查看我们注册了哪些服务 哪些服务被消费了

dubbo是一个jar包 需要在我们的java程序中引入

zookeeper负责服务注册与发现

整合springboot 准备工作

创建一个空的项目

添加model模块 xxxx.-provider、xxx-consumer、common-interface

xxxx-provider：生产者模块 主要用于提供服务

xxxx-consumer：消费者模块 主要用于服务调用

common-interface：用于存放生产者和消费者中用到的接口和实体类 作为公共模块 提高复用

创建之后的结构图

依赖导入

工共模块 只存放实体类和接口 因此只需要引入lombok即可

<?xml version="1.0" encoding="UTF-8"?> 4.0.0 org.llf common-interface 1.0-SNAPSHOT org.projectlombok lombok 1.18.20 8 8

生产者和消费者都需要导入dubbo、zookeeper以及其他依赖包 因此两个模块的依赖是一致的

<?xml version="1.0" encoding="UTF-8"?> 4.0.0 org.springframework.boot spring-boot-starter-parent 2.5.3 com.llf adress-service-provider 1.0 adress-service-provider adress-service-provider 1.8 org.springframework.boot spring-boot-starter-web org.apache.dubbo dubbo-spring-boot-starter 2.7.8 org.apache.curator curator-recipes 4.2.0 org.apache.curator curator-framework 4.2.0 org.llf common-interface 1.0-SNAPSHOT com.github.sgroschupf zkclient 0.1 org.apache.zookeeper zookeeper 3.4.14 org.slf4j slf4j-log4j12 org.springframework.boot spring-boot-starter-test test org.springframework.boot spring-boot-maven-plugin

这里需要注意的是 需要将工共模块引入到消费者、生产者的依赖中 以便于引用

环境配置

通过dubbo-admin的配置文件 可以知道 配置dubbo 只需要配置几个属性即可

---------------生产者配置-----------------server.port=8081#服务应用名字dubbo.application.name=addressServiceProvider#哪些服务需要注册 扫描的包dubbo.scan.base-packages=com.llf.addressserviceprovider.service.*#服务注册地址dubbo.registry.address=zookeeper://127.0.0.1:2181#端口配置 默认208800dubbo.protocol.port=20880#使用的协议名字dubbo.protocol.name=dubbo---------------------消费者配置-------------------server.port=8082#服务应用名字dubbo.application.name=addressServiceProvider#向哪一个服务注册中心进行远程调用dubbo.registry.address=zookeeper://127.0.0.1:2181#端口配置 默认208800dubbo.protocol.port=20880#使用的协议名字dubbo.protocol.name=dubbo

代码编写

这里的service是从公共模块引入的 而不是自己写的 import的地址是从所在路径的上一级开始

消费者

package com.llf.orderserviceconsummer.service;import Pojo.Address;import Pojo.Order;import Service.OrderService;import Service.AddressService;import org.apache.dubbo.config.annotation.DubboReference;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.stereotype.Service;import java.util.ArrayList;import java.util.Iterator;@Servicepublic class OrderServiceImpl implements OrderService { @DubboReference //使用DubboReference注解引用服务 而不是autowired AddressService addressService; @Override public Order getOrderById(String userId) { Logger logger = LoggerFactory.getLogger(this.getClass()); Order order = new Order(); ArrayList list = addressService.findAddressById(userId); Iterator iterator = list.iterator(); if (iterator.hasNext()) { Address address = iterator.next(); order = new Order(userId, "小孩嗝屁丸", address.getUserName(), address.getAddress()); } else { System.out.println("数据不匹配"); } logger.info("远程调用成功！"); return order; }}

生产者

package com.llf.addressserviceprovider.service;import Pojo.Address;import Service.AddressService;import org.apache.dubbo.config.annotation.DubboService;import org.springframework.stereotype.Service;import java.util.ArrayList;@Service // 注册到spring容器中@DubboService // 注册到dubbo中public class AddressServiceImpl implements AddressService { @Override public ArrayList findAddressById(String userId) { ArrayList list = new ArrayList<>(); list.add(new Address(userId,"张三","12345656565","北京市昌平区")); return list; }}

工共接口

package Service;import Pojo.Address;import java.util.ArrayList;public interface AddressService { public ArrayList findAddressById(String userId);}------------------------------------------------------------------------------package Service;import Pojo.Order;public interface OrderService { public Order getOrderById(String userId);}

启动测试

首先启动zookeeper然后启动dubbo-admin 进行监控启动消费者和生产者服务 需要在启动类添加 @EnableDubbo注解测试

@Autowired OrderServiceImpl orderService; @Test void contextLoads() { Order order = orderService.getOrderById("111"); System.out.println(order); }

结果 dubbo配置优先级

如图所示，优先级的属性依次为虚拟机参数>xml配置>dubbo.properties,虚拟机参数即程序启动之前我们通过-D配置的dubbo属性,xml配置即我们项目中自己写的xml文件或者是springboot中的application.properties，当公共配置很简单，没有多注册中心，多协议等情况，或者想多个 Spring 容器想共享配置的情况下可以用dubbo.properties作为缺省配置；需要注意的是我这里的测试用例都是写在application.properties中,当然如果感觉不习惯,也可以跟普通maven项目一样新建xml文件,在xml中进行配置，只是不要忘了在springboot的启动类中添加@importResource(locations=“xml路径”)注解来引入就行,

虚拟机参数大于xml配置、properties配置大于默认配置

dubbo默认端口20880 默认协议dubbo 可以不进行配置

可以在resources根目录下创建dubbo.properties配置文件 将application.properties中的dubbo配置文件剪贴到dubbo.properties中 同样可以识别生效

#服务应用名字dubbo.application.name=addressServiceProvider#向哪一个服务注册中心进行远程调用dubbo.registry.address=zookeeper://127.0.0.1:2181#端口配置 默认208800dubbo.protocol.port=20880#使用的协议名字dubbo.protocol.name=dubbo

dubbo超时设置与检查设置

超时设置分为三种方式 ：全局配置、service类配置、具体方法配置

优先级比较：同级别 ：消费者配置 > 生产者配置

​ 不同级别 ： 具体方法配置 > service类配置 > 全局配置

​ 同一个模块 ：具体方法配置 > service类配置 > 全局配置

xml配置

这里需要注意的是 生产者是 < /dubbo:provider >

​ 消费者是 < /dubbo:provider >

其他配置都相同

注解配置

生产者

全局配置 dubbo.provider.imeout=2000service类配置 @DubboService(timeout = 2000)具体方法配置 @DubboService(methods = { @Method(name = "findAddressById",timeout = 1000，retries = 1)}) retries指的是超时重连次数 默认为2次 超时重连次数不包含第一次连接

消费者

全局配置 dubbo.consummer.imeout=2000service类配置 @DubboReference(timeout = 2000)具体方法配置 @DubboReference(methods = { @Method(name = "findAddressById",timeout = 1000，retries = 1)}) retries指的是超时重连次数 默认为2次 超时重连次数不包含第一次连接

检查设置

一般启动顺寻是先启动生产者，再启动消费者 因此dubbo默认是开启检查设置的

我们可以在设置超时设置的相同位置 添加check属性 并设置为false 既可以关闭检查设置。

优先级顺序与超时设置的优先级顺序相同