三、spring-boot-dubbo（整合dubbo）

作者: 喝咖啡的蚂蚁 | 来源:发表于2018-08-02 11:14 被阅读0次

三、spring-boot-dubbo（整合dubbo）
CloudAlibaba——在nacos环境下整合dubbo
Spring Boot 与 Dubbo整合
Dubbo源码分析-Spring与Dubbo整合原理与源码分析（
Dubbo与Zookeeper、Spring框架的整合
阿里官方提供的dubbo-spring-boot-starter
dubbo入门-dubbo和springboot整合
io.dubbo.springboot版本不兼容dubbo-2.
Dubbo入门（三）--spring boot整合dubbo创建
Dubbo源码解析

构造服务端

本项目中dubbo基于zookeeper，所以需要先安装zookeeper。
项目地址：https://gitee.com/eaco/yi-spring-boot-study

引用dubbo的SpringBoot依赖包

       <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
        </dependency>

还需引用slf4j以及将log4j桥接到slf4j的依赖，可以看代码，这里不做列举

配置服务端application.properties

#dubbo 服务端配置
spring.dubbo.application.name=dubbo-server
spring.dubbo.application.registries.file=d:/dubbo.cache
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=cn.yi.springboot.dubbo.facade.impl

本文最后有dubbo配置相关的其他参数配置

编写dubbo提供者
编写服务端接口

public interface UserFacade {
    void sayHello();
}

编写服务端实现
注意：注解的Service非Spring 的Service，而是
com.alibaba.dubbo.config.annotation.Service

import cn.yi.springboot.dubbo.facade.UserFacade;
import com.alibaba.dubbo.config.annotation.Service;

/**
 * @author: yiz
 * @date: 2018/8/1 16:53
 **/
@Service
public class UserFacadeImpl implements UserFacade{
    @Override
    public void sayHello() {
        System.out.println("Dubbo welcome");
    }
}

构造客户端

配置客户端application.properties

spring.dubbo.application.name=bhcredit-web
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=cn.yi.springboot.dubbo.service.impl
spring.dubbo.application.registries.timeout = 3000

客户端接口

public interface UserService {
    void sayHello();
}

客户端实现

import cn.yi.springboot.dubbo.facade.UserFacade;
import cn.yi.springboot.dubbo.service.UserService;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

/**
 * @author: yiz
 * @date: 2018/8/1 17:08
 **/
@Service
public class UserServiceImpl implements UserService{
    @Reference
    private UserFacade userFacade;
    @Override
    public void sayHello() {
        userFacade.sayHello();
    }
}

## Dubbo 配置
# 扫描包路径
<br>spring.dubbo.scan=org.<br>spring.<br>springboot.dubbo

## Dubbo 应用配置
// 应用名称
<br>spring.dubbo.application.name=xxx

// 模块版本
<br>spring.dubbo.application.version=xxx

// 应用负责人
<br>spring.dubbo.application.owner=xxx

// 组织名(BU或部门)
<br>spring.dubbo.application.organization=xxx

// 分层
<br>spring.dubbo.application.architecture=xxx

// 环境，如：dev/test/run
<br>spring.dubbo.application.environment=xxx

// Java代码编译器
<br>spring.dubbo.application.compiler=xxx

// 日志输出方式
<br>spring.dubbo.application.logger=xxx

// 注册中心 0
<br>spring.dubbo.application.registries[0].address=zookeeper://127.0.0.1:2181=xxx
// 注册中心 1
<br>spring.dubbo.application.registries[1].address=zookeeper://127.0.0.1:2181=xxx

// 服务监控
<br>spring.dubbo.application.monitor.address=xxx

## Dubbo 注册中心配置类
// 注册中心地址
<br>spring.dubbo.application.registries.address=xxx

// 注册中心登录用户名
<br>spring.dubbo.application.registries.username=xxx

// 注册中心登录密码
<br>spring.dubbo.application.registries.password=xxx

// 注册中心缺省端口
<br>spring.dubbo.application.registries.port=xxx

// 注册中心协议
<br>spring.dubbo.application.registries.protocol=xxx

// ================客户端实现==========================
<br>spring.dubbo.application.registries.transporter=xxx

<br>spring.dubbo.application.registries.server=xxx

<br>spring.dubbo.application.registries.client=xxx

<br>spring.dubbo.application.registries.cluster=xxx

<br>spring.dubbo.application.registries.group=xxx

<br>spring.dubbo.application.registries.version=xxx

// 注册中心请求超时时间(毫秒)
<br>spring.dubbo.application.registries.timeout=xxx

// 注册中心会话超时时间(毫秒)
<br>spring.dubbo.application.registries.session=xxx

// 动态注册中心列表存储文件
<br>spring.dubbo.application.registries.file=xxx

// 停止时等候完成通知时间
<br>spring.dubbo.application.registries.wait=xxx

// 启动时检查注册中心是否存在
<br>spring.dubbo.application.registries.check=xxx

// 在该注册中心上注册是动态的还是静态的服务
<br>spring.dubbo.application.registries.dynamic=xxx

// 在该注册中心上服务是否暴露
<br>spring.dubbo.application.registries.register=xxx

// 在该注册中心上服务是否引用
<br>spring.dubbo.application.registries.subscribe=xxx


## Dubbo 服务协议配置


// 服务协议
<br>spring.dubbo.application.protocol.name=xxx

// 服务IP地址(多网卡时使用)
<br>spring.dubbo.application.protocol.host=xxx

// 服务端口
<br>spring.dubbo.application.protocol.port=xxx

// 上下文路径
<br>spring.dubbo.application.protocol.contextpath=xxx

// 线程池类型
<br>spring.dubbo.application.protocol.threadpool=xxx

// 线程池大小(固定大小)
<br>spring.dubbo.application.protocol.threads=xxx

// IO线程池大小(固定大小)
<br>spring.dubbo.application.protocol.iothreads=xxx

// 线程池队列大小
<br>spring.dubbo.application.protocol.queues=xxx

// 最大接收连接数
<br>spring.dubbo.application.protocol.accepts=xxx

// 协议编码
<br>spring.dubbo.application.protocol.codec=xxx

// 序列化方式
<br>spring.dubbo.application.protocol.serialization=xxx

// 字符集
<br>spring.dubbo.application.protocol.charset=xxx

// 最大请求数据长度
<br>spring.dubbo.application.protocol.payload=xxx

// 缓存区大小
<br>spring.dubbo.application.protocol.buffer=xxx

// 心跳间隔
<br>spring.dubbo.application.protocol.heartbeat=xxx

// 访问日志
<br>spring.dubbo.application.protocol.accesslog=xxx

// 网络传输方式
<br>spring.dubbo.application.protocol.transporter=xxx

// 信息交换方式
<br>spring.dubbo.application.protocol.exchanger=xxx

// 信息线程模型派发方式
<br>spring.dubbo.application.protocol.dispatcher=xxx

// 对称网络组网方式
<br>spring.dubbo.application.protocol.networker=xxx

// 服务器端实现
<br>spring.dubbo.application.protocol.server=xxx

// 客户端实现
<br>spring.dubbo.application.protocol.client=xxx

// 支持的telnet命令，多个命令用逗号分隔
<br>spring.dubbo.application.protocol.telnet=xxx

// 命令行提示符
<br>spring.dubbo.application.protocol.prompt=xxx

// status检查
<br>spring.dubbo.application.protocol.status=xxx

// 是否注册
<br>spring.dubbo.application.protocol.status=xxx