springboot整合dubbo

导入依赖

服务调用者和服务发布者都需要引入该依赖

<!-- Spring Boot Dubbo 依赖 -->
<dependency>
  <groupId>com.gitee.reger</groupId>
  <artifactId>spring-boot-starter-dubbo</artifactId>
  <version>1.0.10</version>
</dependency>

该依赖不定时更新,可以关注最新版本
http://maven.aliyun.com/nexus/#nexus-search;quick~com.gitee.reger

添加dubbo配置

服务发布者和服务调用者都需要添加dubbo配置

服务发布者

在服务发布者的springboot主配置文件application.properties中添加dubbo配置

#dubbo服务名
spring.dubbo.application.name=xxx
#注册中中心
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
#dubbo的RPC协议
spring.dubbo.protocol.name=dubbo
#dubbo的RPC端口
spring.dubbo.protocol.port=20880
#远程服务超时时间
spring.dubbo.provider.timeout=5000
#发布服务扫描的路径
spring.dubbo.base-package=xxx

服务调用者

在服务调用者的springboot主配置文件application.properties中添加dubbo配置

#dubbo应用名
spring.dubbo.application.name=xxx
#连接的注册中心地址
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
#远程服务调用超时
spring.dubbo.consumer.timeout=5000
#启动时检查提供者是否存在,true报错,false忽略
spring.dubbo.consumer.check=false
#引用服务扫描的路径
spring.dubbo.base-package=xxx

定义服务接口

在api项目中定义接口

public interface IProductService {

    List<Product> getAllProduct();
}

发布服务

在服务发布者中实现接口,并且对外发布服务

注意:

  • @Service注解是dubbo的注解,不要导入了其他包*
  • 贴上@Service注解就代表发布服务,但是该服务必须要在dubbo配置spring.dubbo.base-package=xxx能扫描的范围之内
@Service
@Transactional
public class ProductServiceImpl implements IProductService {

    @Autowired
    ProductMapper productMapper;

    @Override
    public List<Product> getAllProduct() {
        return productMapper.selectAll();
    }
}

调用服务

注意:

  • @Reference注解是dubbo的注解,不要导入了其他包*
  • 贴上@Reference注解就代表调用服务,但是该服务必须要在dubbo配置spring.dubbo.base-package=xxx能扫描的范围之内
@Controller
public class ProductController {

    @Reference
    IProductService productService;

    @RequestMapping(value = "/getAllProduct")
    @ResponseBody
    public List<Product> getAllProduct(){
        return productService.getAllProduct();
    }
}

其他配置详解

应用配置参数(必须配置)

spring:
  dubbo: 
    application:
      name: demo-provider     # 必填 服务治理 当前应用名称,用于注册中心计算应用间依赖关系,注意:消费者和提供者应用名不要一样,此参数不是匹配条件,你当前项目叫什么名字就填什么,和提供者消费者角色无关,比如:kylin应用调用了morgan应用的服务,则kylin项目配成kylin,morgan项目配成morgan,可能kylin也提供其它服务给别人使用,但kylin项目永远配成kylin,这样注册中心将显示kylin依赖于morgan 1.0.16以上版本
      owner: luohaipeng       # 可选 服务治理 应用负责人,用于服务治理,请填写负责人公司邮箱前缀 2.0.5以上版本
      architecture:           # 可选 服务治理 用于服务分层对应的架构。如,intl、china。不同的架构使用不同的分层。 2.0.7以上版本
      compiler: javassist     # 可选 性能优化 Java字节码编译器,用于动态类的生成,可选:jdk或javassist 2.1.0以上版本
      environment:            # 可选 服务治理 应用环境,如:develop/test/product,不同环境使用不同的缺省值,以及作为只用于开发测试功能的限制条件 2.0.0以上版本
      logger: slf4j           # 可选 性能优化 日志输出方式,可选:slf4j,jcl,log4j,jdk 2.2.0以上版本
      organization:           # 可选 服务治理 组织名称(BU或部门),用于注册中心区分服务来源,此配置项建议不要使用autoconfig,直接写死在配置中,比如china,intl,itu,crm,asc,dw,aliexpress等 2.0.0以上版本
      version:                # 可选 服务治理 当前应用的版本 2.2.0以上版本

服务扫描的包(使用注解时必须配置)

spring:
  dubbo: 
    base-package:             # 提供者service和消费者所在的java包,多个包用逗号分割

注册中心支持的配置参数 (必须配置)

spring:
  dubbo:
    registry:               # 应用注册中心配置项
      protocol: zookeeper   # 必填 服务发现 注册中心支持的协议 包括 dubbo,multicast,zookeeper,redis 默认是zookeeper
      address: 127.0.0.1    # 必填 服务发现 注册中心服务器地址,如果地址没有端口缺省为9090,同一集群内的多个地址用逗号分隔,如:ip:port,ip:port,不同集群的注册中心,请配置多个spring.dubbo.registry.标签 1.0.16以上版本
      port: 2181            # 可选 服务发现 注册中心缺省端口,当address没有带端口时使用此端口做为缺省值 2.0.0以上版本
      client: zkclient      # 可选 服务发现 注册中心支持的客户端, zookeeper 支持客户端包括 curator和zkclient,如果不配置,默认使用zkclient 
      session: 60000        # 可选 性能调优 注册中心会话超时时间(毫秒),用于检测提供者非正常断线后的脏数据,比如用心跳检测的实现,此时间就是心跳间隔,不同注册中心实现不一样。 2.1.0以上版本
      register: true        # 可选 服务治理 是否向此注册中心注册服务,如果设为false,将只订阅,不注册 2.0.5以上版本
      check: false          # 可选 服务治理 服务是否动态注册,如果设为false,注册后将显示后disable状态,需人工启用,并且服务提供者停止时,也不会自动取消册,需人工禁用。 2.0.5以上版本
      dynamic: true         # 可选 服务治理 服务是否动态注册,如果设为false,注册后将显示后disable状态,需人工启用,并且服务提供者停止时,也不会自动取消册,需人工禁用。 2.0.5以上版本
      file: regcache.log    # 可选 服务治理 使用文件缓存注册中心地址列表及服务提供者列表,应用重启时将基于此文件恢复,注意:两个注册中心不能使用同一文件存储 2.0.0以上版本
      username:             # 可选 服务治理 登录注册中心用户名,如果注册中心不需要验证可不填 2.0.0以上版本
      password:             # 可选 服务治理 登录注册中心密码,如果注册中心不需要验证可不填 2.0.0以上版本
      subscribe:            # 可选 服务治理 是否向此注册中心订阅服务,如果设为false,将只注册,不订阅 2.0.5以上版本
      timeout:              # 可选 性能调优 注册中心请求超时时间(毫秒) 2.0.0以上版本
      wait: 0               # 可选 性能调优 停止时等待通知完成时间(毫秒) 2.0.0以上版本
      transport: netty      # 可选 性能调优 网络传输方式,可选mina,netty 2.0.0以上版本
      id:                   # 可选 配置关联 注册中心引用BeanId,可以在<dubbo:service registry="">或<dubbo:reference registry="">中引用此ID 1.0.16以上版本

    registrys:               # 多个应用注册中心时配置项(注意,如果要配置多个注册中心,必须指定的不同的id和名字)
      - id: test2
        name: test2
        protocol: zookeeper   # 必填 服务发现 注册中心支持的协议 包括 dubbo,multicast,zookeeper,redis 默认是zookeeper
        address: 127.0.0.1    # 必填 服务发现 注册中心服务器地址,如果地址没有端口缺省为9090,同一集群内的多个地址用逗号分隔,如:ip:port,ip:port,不同集群的注册中心,请配置多个spring.dubbo.registry.标签 1.0.16以上版本
        port: 2182            # 可选 服务发现 注册中心缺省端口,当address没有带端口时使用此端口做为缺省值 2.0.0以上版本
        client: zkclient      # 可选 服务发现 注册中心支持的客户端, zookeeper 支持客户端包括 curator和zkclient,如果不配置,默认使用zkclient 

服务协议支持的类型(必须配置)

spring:
  dubbo:
    protocol:               # 默认的应用协议栈
      name: dubbo           # 必填 性能调优 协议名称 2.0.5以上版本
      serialization: hessian2 #可选 性能调优 协议序列化方式,当协议支持多种序列化方式时使用,比如:dubbo协议的dubbo,hessian2,java,compactedjava,以及http协议的json等 2.0.5以上版本
      accepts: 0            # 可选 性能调优 服务提供方最大可接受连接数 2.0.5以上版本
      accesslog: false      # 可选 服务治理 设为true,将向logger中输出访问日志,也可填写访问日志文件路径,直接把访问日志输出到指定文件 2.0.5以上版本
      buffer: 8192          # 可选 性能调优 网络读写缓冲区大小 2.0.5以上版本
      charset: UTF-8        # 可选 性能调优 序列化编码 2.0.5以上版本
      client: netty         # 可选 性能调优 协议的客户端实现类型,比如:dubbo协议的mina,netty等 2.0.5以上版本
      codec: dubbo          # 可选 性能调优 协议编码方式 2.0.5以上版本
      contextpath:          # 可选 服务治理 2.0.6以上版本
      dispatcher: all       # 可选 性能调优 协议的消息派发方式,用于指定线程模型,比如:dubbo协议的all, direct, message, execution, connection等 2.1.0以上版本
      heartbeat: 0          # 可选 性能调优 心跳间隔,对于长连接,当物理层断开时,比如拔网线,TCP的FIN消息来不及发送,对方收不到断开事件,此时需要心跳来帮助检查连接是否已断开 2.0.10以上版本
      host:                 # 可选 服务发现 -服务主机名,多网卡选择或指定VIP及域名时使用,为空则自动查找本机IP,-建议不要配置,让Dubbo自动获取本机IP 2.0.5以上版本 
      id: dubbo             # 可选 配置关联 协议BeanId,可以在<dubbo:service protocol="">中引用此ID,如果ID不填,缺省和name属性值一样,重复则在name后加序号。 2.0.5以上版本
      iothreads:            # 可选 性能调优 io线程池大小(固定大小) 2.0.5以上版本 
      path:                 # 可选 服务发现 提供者上下文路径,为服务path的前缀 2.0.5以上版本
      payload: 88388608     # 可选 性能调优 请求及响应数据包大小限制,单位:字节 2.0.5以上版本
      port:                 # 可选 服务发现 不输入或者输入0,将自动在53600~53688之间生产一个  服务端口  2.0.5以上版本 , 
      queues: 0             # 可选 性能调优 线程池队列大小,当线程池满时,排队等待执行的队列大小,建议不要设置,当线程程池时应立即失败,重试其它服务提供机器,而不是排队,除非有特殊需求。 2.0.5以上版本
      register: true        # 可选 服务治理 该协议的服务是否注册到注册中心 2.0.8以上版本
      server:               # 可选 性能调优 协议的服务器端实现类型,比如:dubbo协议的mina,netty等,http协议的jetty,servlet等 2.0.5以上版本
      telnet:               # 可选 服务治理 所支持的telnet命令,多个命令用逗号分隔 2.0.5以上版本
      threadpool: fixed     # 可选 性能调优 线程池类型,可选:fixed/cached 2.0.5以上版本
      threads: 100          # 可选 性能调优 服务线程池大小(固定大小) 2.0.5以上版本
      transporter: netty    # 可选 性能调优 协议的服务端和客户端实现类型,比如:dubbo协议的mina,netty等,可以分拆为server和client配置 2.0.5以上版本

提供者默认的配置参数(可选配置)

spring:
  dubbo: 
    provider:                 # 公用的生产者配置
      retries: -1             # 可选 性能调优 远程服务调用重试次数,不包括第一次调用,不需要重试请设为0 2.0.5以上版本
      accesslog: false        # 可选 服务治理 设为true,将向logger中输出访问日志,也可填写访问日志文件路径,直接把访问日志输出到指定文件 2.0.5以上版本
      delay: 0                # 可选 性能调优 延迟注册服务时间(毫秒)- ,设为-1时,表示延迟到Spring容器初始化完成时暴露服务 2.0.5以上版本
      deprecated: false       # 可选 服务治理 服务是否过时,如果设为true,消费方引用时将打印服务过时警告error日志 2.0.5以上版本
      document:               # 可选 服务治理 服务文档URL 2.0.5以上版本
      dynamic: true           # 可选 服务治理 服务是否动态注册,如果设为false,注册后将显示后disable状态,需人工启用,并且服务提供者停止时,也不会自动取消册,需人工禁用。 2.0.5以上版本
      executes: 0             # 可选 性能调优 服务提供者每服务每方法最大可并行执行请求数 2.0.5以上版本
      group:                  # 可选 服务发现 服务分组,当一个接口有多个实现,可以用分组区分 2.0.5以上版本
      id: dubbo               # 可选 配置关联 协议BeanId,可以在<dubbo:service proivder="">中引用此ID 1.0.16以上版本
      layer:                  # 可选 服务治理 服务提供者所在的分层。如:biz、dao、intl:web、china:acton。 2.0.7以上版本
      listener:               # 可选 性能调优 服务提供方导出服务监听器名称,多个名称用逗号分隔 2.0.5以上版本
      mock: false             # 可选 服务治理 设为true,表示使用缺省Mock类名,即:接口名 + Mock后缀。 2.0.5以上版本
      owner:                  # 可选 服务治理 服务负责人,用于服务治理,请填写负责人公司邮箱前缀 2.0.5以上版本
      path:                   # 可选 服务发现 提供者上下文路径,为服务path的前缀 2.0.0以上版本 
      protocol: dubbo         # 可选 性能调优 协议名称 1.0.16以上版本
      proxy: javassist        # 可选 性能调优 生成动态代理方式,可选:jdk/javassist 2.0.5以上版本
      registry:               # 可选 配置关联 向指定注册中心注册,在多个注册中心时使用,值为spring.dubbo.registry.的id属性,多个注册中心ID用逗号分隔,如果不想将该服务注册到任何registry,可将值设为N/A 2.0.5以上版本
      stub: false             # 可选 服务治理 设为true,表示使用缺省代理类名,即:接口名 + Local后缀。 2.0.5以上版本
      token: false            # 可选 服务治理 令牌验证,为空表示不开启,如果为true,表示随机生成动态令牌 2.0.5以上版本
      version: 0.0.0          # 可选 服务发现 服务版本,建议使用两位数字版本,如:1.0,通常在接口不兼容时版本号才需要升级 2.0.5以上版本
      weight: 0               # 可选 性能调优 服务权重 2.0.5以上版本
      accepts: 0              # 可选 性能调优 服务提供者最大可接受连接数 2.0.5以上版本
      actives: 0              # 可选 性能调优 每服务消费者每服务每方法最大并发调用数 2.0.5以上版本
      async: false            # 可选 性能调优 是否缺省异步执行,不可靠异步,只是忽略返回值,不阻塞执行线程 2.0.5以上版本
      buffer: 8192            # 可选 性能调优 网络读写缓冲区大小 2.0.5以上版本
      charset: UTF-8          # 可选 性能调优 序列化编码 2.0.5以上版本
      client: netty           # 可选 性能调优 协议的客户端实现类型,比如:dubbo协议的mina,netty等 2.0.0以上版本
      cluster: failover       # 可选 性能调优 集群方式,可选:failover/failfast/failsafe/failback/forking 2.0.5以上版本
      codec: dubbo            # 可选 性能调优 协议编码方式 2.0.0以上版本
      connections: 0          # 可选 性能调优 对每个提供者的最大连接数,rmi、http、hessian等短连接协议表示限制连接数,dubbo等长连接协表示建立的长连接个数 2.0.5以上版本
      default: false          # 可选 配置关联 是否为缺省协议,用于多协议 1.0.16以上版本
      host:                   # 可选 服务发现 服务主机名,多网卡选择或指定VIP及域名时使用,为空则自动查找本机IP,建议不要配置,让Dubbo自动获取本机IP 1.0.16以上版本
      iothreads:              # 可选 性能调优 IO线程池,接收网络读写中断,以及序列化和反序列化,不处理业务,业务线程池参见threads配置,此线程池和CPU相关,不建议配置。 2.0.5以上版本
      loadbalance: random     # 可选 性能调优 负载均衡策略,可选值:random,roundrobin,leastactive,分别表示:随机,轮循,最少活跃调用 2.0.5以上版本
      payload: 88388608       # 可选 性能调优 请求及响应数据包大小限制,单位:字节 2.0.0以上版本
      queues: 0               # 可选 性能调优 线程池队列大小,当线程池满时,排队等待执行的队列大小,建议不要设置,当线程程池时应立即失败,重试其它服务提供机器,而不是排队,除非有特殊需求。 2.0.5以上版本
      serialization: hessian2 # 可选 性能调优 协议序列化方式,当协议支持多种序列化方式时使用,比如:dubbo协议的dubbo,hessian2,java,compactedjava,以及http协议的json,xml等 2.0.5以上版本
      server: netty           # 可选 性能调优 协议的服务器端实现类型,比如:dubbo协议的mina,netty等,http协议的jetty,servlet等 2.0.0以上版本
      telnet:                 # 可选 服务治理 所支持的telnet命令,多个命令用逗号分隔 2.0.5以上版本
      threadpool: fixed       # 可选 性能调优 线程池类型,可选:fixed/cached 2.0.5以上版本
      threads: 100            # 可选 性能调优 线程池类型,可选:fixed/cached 2.0.5以上版本
      timeout: 1000           # 可选 性能调优 远程服务调用超时时间(毫秒) 2.0.5以上版本
      filter:                 # 可选 性能调优 服务提供方远程调用过程拦截器名称,多个名称用逗号分隔 2.0.5以上版本

调用者默认的配置(可选配置)

spring:
  dubbo: 
    consumer:                   # 公用的消费者配置
      lazy: true                #
      timeout: 1000             # 可选 性能调优 远程服务调用超时时间(毫秒) 1.0.16以上版本
      check: true               # 可选 服务治理 启动时检查提供者是否存在,true报错,false忽略 1.0.16以上版本
      retries: 2                # 可选 性能调优 远程服务调用重试次数,不包括第一次调用,不需要重试请设为0 1.0.16以上版本
      filter:                   # 可选 性能调优 服务消费方远程调用过程拦截器名称,多个名称用逗号分隔 2.0.5以上版本
      actives: 0                # 可选 性能调优 每服务消费者每服务每方法最大并发调用数 2.0.5以上版本
      async: false              # 可选 性能调优 是否缺省异步执行,不可靠异步,只是忽略返回值,不阻塞执行线程 2.0.0以上版本
      cache:                    # 可选 服务治理 以调用参数为key,缓存返回结果,可选:lru, threadlocal, jcache等 Dubbo2.1.0及其以上版本支持
      cluster: failover         # 可选 性能调优 集群方式,可选:failover/failfast/failsafe/failback/forking 2.0.5以上版本
      connections: 100          # 可选 性能调优 每个服务对每个提供者的最大连接数,rmi、http、hessian等短连接协议支持此配置,dubbo协议长连接不支持此配置 1.0.16以上版本
      generic: false            # 可选 服务治理 是否缺省泛化接口,如果为泛化接口,将返回GenericService 2.0.0以上版本
      init: false               # 可选 性能调优 是否在afterPropertiesSet()时饥饿初始化引用,否则等到有人注入或引用该实例时再初始化。 2.0.10以上版本
      layer:                    # 可选 服务治理 服务调用者所在的分层。如:biz、dao、intl:web、china:acton。 2.0.7以上版本
      listener:                 # 可选 性能调优 服务消费方引用服务监听器名称,多个名称用逗号分隔 2.0.5以上版本
      loadbalance: random       # 可选 性能调优 负载均衡策略,可选值:random,roundrobin,leastactive,分别表示:随机,轮循,最少活跃调用 1.0.16以上版本
      owner:                    # 可选 服务治理 调用服务负责人,用于服务治理,请填写负责人公司邮箱前缀 2.0.5以上版本
      proxy: javassist          # 可选 性能调优 生成动态代理方式,可选:jdk/javassist 2.0.5以上版本
      registry:                 # 可选 配置关联 向指定注册中心注册,在多个注册中心时使用,值为spring.dubbo.registry.的id属性,多个注册中心ID用逗号分隔,如果不想将该服务注册到任何registry,可将值设为N/A 2.0.5以上版本
      retries: 2                # 可选 性能调优 远程服务调用重试次数,不包括第一次调用,不需要重试请设为0 1.0.16以上版本
      validation:               # 可选 服务治理 是否启用JSR303标准注解验证,如果启用,将对方法参数上的注解进行校验 Dubbo2.1.0及其以上版本支持
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,142评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,298评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,068评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,081评论 1 291
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,099评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,071评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,990评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,832评论 0 273
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,274评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,488评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,649评论 1 347
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,378评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,979评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,625评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,796评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,643评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,545评论 2 352

推荐阅读更多精彩内容