dubbo是阿里开源的一个微服务框架，性能很高，现在由apache维护。
此处写一个demo，订单服务获取订单所属用户的信息，order-service调用user-service。
这个模块用来存放微服务中所有的实体类，以及所有的服务提供者提供的服务接口。
只写实体类和接口，使用普通的maven项目即可。
（1）pom.xml
我要评论 <dependency>
<groupid>org.projectlombok</groupid>
<artifactid>lombok</artifactid>
<version>1.18.12</version>
</dependency>
我要使用lombok，添加lombok的依赖
（2）新建包model，用于存放所有的model。包下新建实体类user：
//注意：实体类要可序列化
@getter
@setter
public class user implements serializable {
private integer id;
private string username;
private string password;
private string tel;
private string address;
}
（3）新建包service，用于存放所有服务提供者提供的服务接口。包下新建userservice：
public interface userservice {
user finduserbyid(integer id);
}
建包的方式有很多，比如用户服务要提供很多接口，可以在service下新建包user-service；
比如一个服务提供者一个包，user-service包下新建model包、service包，分别放本服务的model、提供的服务接口。
之所以把model写在这个子模块中，是因为服务接口的参数类型、返回值类型很多都要声明为实体类。
（4）使用maven install打包为jar安装到本地仓库，实际开发是安装到公司私服。
如果后续要更新、维护这个jar包，实际开发是以新版本号的方式来开发、安装，要使用新的jar包需要改pom.xml中的版本号；
自己操作的话，可以直接在原来代码的基础上改（使用原版本号），然后安装覆盖掉仓库中原来安装的jar包。
（1）pom.xml
<!-- api接口的jar包 -->
<dependency>
<groupid>com.chy.mall</groupid>
<artifactid>api</artifactid>
<version>1.0-snapshot</version>
</dependency>
<!-- dubbo的依赖 -->
<dependency>
<groupid>org.apache.dubbo</groupid>
<artifactid>dubbo-spring-boot-starter</artifactid>
<version>2.7.6</version>
</dependency>
<!-- zk的依赖 -->
<dependency>
<groupid>org.apache.dubbo</groupid>
<artifactid>dubbo-dependencies-zookeeper</artifactid>
<version>2.7.6</version>
<type>pom</type>
<exclusions>
<exclusion>
<groupid>org.slf4j</groupid>
<artifactid>slf4j-log4j12</artifactid>
</exclusion>
</exclusions>
</dependency>
使用zk作为注册中心、配置管理中心，这里添加的zk依赖是作为zkcli。
zk的依赖要用<exclusions>去掉slf4j部分，因为spring-boot-strat已经包含了slf4j，如果不去掉会报错：slf4j绑定了多个jar包中的logger......
像这种多处引入同一个依赖的，用maven看一下依赖关系图，重复的保留一个即可。
dubbo可以使用多种注册中心，比如zk、redis等，上面的zk依赖只包含以zk作为注册中心的依赖，服务只能以zk作为注册中心。
zk的依赖可以换为以下2种中的任一种，均包含了dubbo支持的所有的注册中心的依赖：
<dependency>
<groupid>org.apache.dubbo</groupid>
<artifactid>dubbo</artifactid>
<version>2.7.6</version>
</dependency>
<dependency>
<groupid>com.alibaba</groupid>
<artifactid>dubbo</artifactid>
<version>2.6.8</version>
</dependency>
（2）新建包service，包下新建类userserviceimpl实现服务接口userservice
//此处的@service是dubbo下的注解，不是spring的注解
@service
public class userserviceimpl implements userservice {
@override
public user finduserbyid(integer id) {
user user = new user();
user.setid(id);
user.setusername("chy");
return user;
}
}
实现服务接口的类都放到一个包下。
（3）配置文件
spring.application.name=user-service #如果指定了spring应用名称，可以缺省dubbo的应用名称，这2个至少要配置1个。缺省dubbo的应用名称时默认值是spring的应用名称 #dubbo.application.name=user-service
#注册中心地址 dubbo.registry.address=zookeeper://192.168.1.9:2181 #端口号可以写在address中，也可以单独写。实质是从address中获取的port是null，后面设置的port覆盖了null #dubbo.registry.port=2181
#指定dubbo使用的协议、端口 dubbo.protocol.name=dubbo dubbo.protocol.port=20880
#指定注册到zk上超时时间，ms dubbo.registry.timeout=10000
#指定实现服务(提供服务）的包 dubbo.scan.base-packages=com.chy.user-service.service
连接到zkserver的时间开销大，如果不将注册的超时时间设置大一些，可能会报错：zookeeper not connected，时间不够，还没连上就超时取消了。
提供服务的包也可以引导类上指定：
@springbootapplication
// @enabledubbo //会扫描所有的包，从中找出dubbo的@service标注的类
// @dubbocomponentscan(basepackages = "com.chy.user-service.service") //只扫描指定的包
public class userserviceapplication {
public static void main(string[] args) {
springapplication.run(userserviceapplication.class, args);
}
}
可以在配置文件中配置，也可以使用上面2个注解中的一个。
（1）pom.xml
<!-- api接口的jar包 -->
<dependency>
<groupid>com.chy.mall</groupid>
<artifactid>api</artifactid>
<version>1.0-snapshot</version>
</dependency>
<!-- dubbo的依赖 -->
<dependency>
<groupid>org.apache.dubbo</groupid>
<artifactid>dubbo-spring-boot-starter</artifactid>
<version>2.7.6</version>
</dependency>
<!-- zk的依赖 -->
<dependency>
<groupid>org.apache.dubbo</groupid>
<artifactid>dubbo-dependencies-zookeeper</artifactid>
<version>2.7.6</version>
<type>pom</type>
<exclusions>
<exclusion>
<groupid>org.slf4j</groupid>
<artifactid>slf4j-log4j12</artifactid>
</exclusion>
</exclusions>
</dependency>
web项目自然要有spring-boot-start-web。
（2）新建包controller，包下新建类ordercontroller来调用服务
@controller
public class ordercontroller {
@reference //注入要调用的服务
private userservice userservice;
@requestmapping("/user/{id}")
@responsebody
public user getuser(@pathvariable integer id){
//调用服务
user user= userservice.finduserbyid(id);
return user;
}
}
一般是在service层调用服务，此处只是demo
（3）配置文件
#应用名称 spring.application.name=order-service #dubbo.application.name=order-service
#注册中心地址 dubbo.registry.address=zookeeper://192.168.1.9:2181 #dubbo.registry.port=2181
#协议、端口 dubbo.protocol.name=dubbo dubbo.protocol.port=20880
#连接zk的超时时间，ms dubbo.registry.timeout=10000
#启动应用时是否检查注册中心上有没有依赖的服务，默认true #dubbo.consumer.check=false
缺省dubbo.consumer.check配置时，默认为true，要检查。
消费者连接注册中心时，会订阅要调用的服务，如果提供该服务的服务器一台都没有，会报错，这个消费者无法启动，这样在消费者启动时就能检查到是否有可用的生产者，提前发现问题。
调试时，如果先启动消费者，后启动|未启动生产者，消费者往往启动不了，报错：创建不了xxx bean，因为 injection of @reference dependencies is failed ，没有生产者提供该服务。
设置为false，消费者启动时不检查，就算没有生产者提供该服务，消费者也能正常启动，只是调用该服务时会出错。
地址栏输入 http://127.0.0.1:8080/user/1 看到已经输出user对象信息
zkserver上，dubbo的根目录是/dubbo，
一个提供的服务对应一个znode，包名.服务接口名 的形式，/dubbo/service.userservice
这个节点的子节点providers存储此服务的所有提供者的注册信息，子节点consumers存储订阅此服务的所有消费者的信息。
dubbo @service标注的类所实现的接口，会自动在zkserver上创建一个对应的znode，包名.接口名的形式；
生产者实现该接口，并使用dubbo @service标识该类是服务提供者，实现的接口就是它提供的服务；消费者使用@reference来订阅、引用服务。
官方demo是用spring整合dubbo、使用xml文件进行配置，因为springboot是近几年才推出、流行的，对dubbo的支持比spring要差一些，少数（冷门）配置尚未实现。
dubbo的配置可以写在springboot配置文件中，也可以在resources下新建spring配置文件，来写dubbo的配置。
dubbo的架构：
dubbo配置加载流程：
dubbo的协议有很多种，最常用的是dubbo协议：
集群容错：
调用服务时，如果调用失败，默认会重试2次，总共3次。
dubbo的注册中心也有很多种，设置可以不要注册中心，消费者可以通过ip、port直连提供者，直接调用。
一般使用zk作为注册中心。
dubbo一般使用20880端口，可以改，
消费者、提供者使用的端口可以相同，也可以不同。
指定注册中心：
#协议、ip:port可以写在一起 dubbo.config-center.address=zookeeper://192.168.1.9:2181
#也可以分开写 dubbo.registry.protocol=zookeeper dubbo.registry.address=192.168.1.9:2181 #如果是集群，逗号分隔 dubbo.registry.address=192.168.1.9:2181,192.168.1.10:2181
设置连接到注册中心的超时时间：
#这个是提供者、消费者都可以使用的 dubbo.registry.timeout=10000 #也可以使用专门的 dubbo.consumer.timeout=10000 dubbo.provider.timeout=10000
升级系统时dubbo的服务接口不兼容怎么办？
使用版本号，dubbo的@service、@reference都可以指定version属性，@service指定提供的是该服务接口哪个版本的实现，@reference指定调用该服务接口的哪个版本，提供者、消费者使用版本号来对接。
xml配置思想相同。
如对本文有疑问， 点击进行留言回复！！
第三次学JAVA再学不好就吃翔(part88)--ArrayList嵌套ArrayList
使用ffmpeg视频切片并加密和视频AES-128加密后播放
JAVA程序设计：最长重复子串（LeetCode：1044）
LiveGBS国标GB/T28181云端录像分布式录像存储自动清理时移回看录像下载播放
网友评论