企业级SpringBoot与Dubbo的并用 | 好好学java | Spring Boot | Spring Cloud | 微服务 | Java技术 | Java面试 | 分布式

springboot,springboot教程,springboot源码

springboot教程

发布日期: 2021-04-05

作者: 欧阳思海

文章字数: 2.1k

阅读时长: 9 分

阅读次数:

本人花费半年的时间总结的《Java面试指南》已拿腾讯等大厂offer，已开源在github ，欢迎star！

本文GitHub https://github.com/OUYANGSIHAI/JavaInterview 已收录，这是我花了6个月总结的一线大厂Java面试总结，本人已拿大厂offer，欢迎star

原文链接：blog.ouyangsihai.cn >> 企业级SpringBoot与Dubbo的并用

点击上方“Java知音”，选择“置顶公众号”

技术文章第一时间送达！

作者：SimpleWu cnblogs.com/SimpleWu/p/10833555.html

推荐阅****读

****2. ****

****4. ****

SpringBoot越来越热门以至于达到烂大街可见的程度，而Dubbo这个基于二进制的微服务框架又捐献给Apache孵化，如果不会如何使用那么是不是很不好意思呢？

这次从公司的项目中抽一个小列子来熟悉下如果从零构建，至于深入了解-传送门:Dubbo官方中文手册

版本:

Springboot2.x

Double2.6

Zk3.4.14

JDK8

Double2.6

JDK8

这里就不介绍Dubbo了，不了解的可以看这里：

https://www.cnblogs.com/SimpleWu/p/9769797.html

zookeepr安装

下载去官网查找稳定的版本进行使用:

http://www.apache.org/dyn/closer.cgi/zookeeper/

先在服务器上安装zookeeper。


cd /usr/local/src/
#下载
sudo wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
#解压
tar -zxvf zookeeper-3.4.14.tar.gz
#修改配置文件名称
mv conf/zoo_sample.cfg zoo.cfg
#启动zk
./bin/zkServer.sh start
#出现以下字样代表启动成功，默认端口2181
Starting zookeeper ... STARTED

SpringBoot2.x整合Dubbo

父工程搭建(pom工程)


groupIdcom.simple.springboot/groupId
    artifactIdyun-double/artifactId
    version0.0.1-SNAPSHOT/version
packagingpom/packaging
nameyun-double/name
descriptiondouble/description

!--统一管理依赖版本--
properties
    java.version1.8/java.version
    double.version2.0.0/double.version
    zkclient.version0.10/zkclient.version
/properties

!-- 依赖于SpringBoot --
parent
        groupIdorg.springframework.boot/groupId
        artifactIdspring-boot-starter-parent/artifactId
        version2.1.4.RELEASE/version
        relativePath/
/parent

!--依赖定义--
dependencyManagement
    dependencies
        dependency
            groupIdcom.alibaba.spring.boot/groupId
            artifactIddubbo-spring-boot-starter/artifactId
            version${double.version}/version
        /dependency
        dependency
            groupIdcom.101tec/groupId
            artifactIdzkclient/artifactId
            version${zkclient.version}/version
        /dependency
    /dependencies
/dependencyManagement

创建公共接口工程common

该工程用于存储服务层接口，以减少代码的冗余。


modelVersion4.0.0/modelVersion

parent
    groupIdcom.simple.springboot/groupId
    artifactIdyun-double/artifactId
    version0.0.1-SNAPSHOT/version
/parent

groupIdcom.simple.springboot/groupId
artifactIdcommon/artifactId
version0.0.1-SNAPSHOT/version

namecommon/name
description公共接口/description

创建公共接口


public interface UserService {

    String getUserById(int id);

}

创建服务提供者(provider)

Pom文件


modelVersion4.0.0/modelVersion

groupIdcom.simple.springboot/groupId
artifactIdprovider/artifactId
version0.0.1-SNAPSHOT/version
packagingjar/packaging

nameprovider/name
description生产者/description


parent
    groupIdcom.simple.springboot/groupId
    artifactIdyun-double/artifactId
    version0.0.1-SNAPSHOT/version
/parent

dependencies
    !-- SpringBoot快速启动Duubbo --
    dependency
        groupIdcom.alibaba.spring.boot/groupId
        artifactIddubbo-spring-boot-starter/artifactId
    /dependency
    !-- Zk客户端依赖 --
    dependency
        groupIdcom.101tec/groupId
        artifactIdzkclient/artifactId
        !-- 排除依赖里的日志 --
        exclusions
            exclusion
                groupIdlog4j/groupId
                artifactIdlog4j/artifactId
            /exclusion

            exclusion
                groupIdorg.slf4j/groupId
                artifactIdslf4j-api/artifactId
            /exclusion

            exclusion
                groupIdorg.slf4j/groupId
                artifactIdslf4j-log4j12/artifactId
            /exclusion
        /exclusions
    /dependency
    !-- 导入公共接口依赖 --
    dependency
        groupIdcom.simple.springboot/groupId
        artifactIdcommon/artifactId
        version0.0.1-SNAPSHOT/version
    /dependency
/dependencies

build
    plugins
        plugin
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-maven-plugin/artifactId
        /plugin
    /plugins
/build

在pom文件中我们需要引入Dubbo,Zk客户端并且引入公共接口工程

application.properties配置文件


#dubbo.application.name 应用名称
#dubbo.registry.address 注册中心地址
#dubbo.protocol.name 协议名称
#dubbo.protocol.port 协议端口
#dubbo.scan dubbo 服务类包目录
#server.port=8080
spring.application.name=user-pro
dubbo.application.name=user-provider1
dubbo.registry.address=zookeeper://192.168.197.133:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

在这里dubbo.application.name应用名称一定不能重复

实现UserService


@Component
@Service(timeout = 10000,interfaceClass = UserService.class)
public class UserServiceImpl implements UserService {

    @Override
    public String getUserById(int id) {
        if(id == 1) {
            return "SimpleWu";
        }else {
            return "Apache Dubbo";
        }
    }
}

@Service 这个注解使用的不是Spring里面的，而是com.alibaba.dubbo.config.annotation.Service

timeout 配置超时时间

interfaceClass 接口类

version 服务版本，如果配置了服务版本在消费端引用也必须一样，具体等会说

interfaceClass 接口类

创建启动类

在该工程中我们不需要引入Web模块浪费端口号，只需要这样写启动类


@EnableDubbo
@EnableDubboConfiguration
@DubboComponentScan("com.simple.springboot.provider.common.impl")
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication app = new SpringApplication(ProviderApplication.class);
        app.run(args);
        //dubbo Main独立运行，脱离web容器
        Main.main(args);
    }

}

@EnableDubbo 启动Dubbo功能

@EnableDubboConfiguration 启动Duubbo配置

@DubboComponentScan 扫描提供者实现类

@EnableDubboConfiguration 启动Duubbo配置

创建服务消费者(consumer)

POM文件


modelVersion4.0.0/modelVersion


groupIdcom.simple.springboot/groupId
artifactIdconsumer/artifactId
version0.0.1-SNAPSHOT/version


nameconsumer/name
description消费者/description

parent
    groupIdcom.simple.springboot/groupId
    artifactIdyun-double/artifactId
    version0.0.1-SNAPSHOT/version
/parent

dependencies
    dependency
        groupIdorg.springframework.boot/groupId
        artifactIdspring-boot-starter-web/artifactId
    /dependency

    dependency
        groupIdorg.springframework.boot/groupId
        artifactIdspring-boot-starter-test/artifactId
    /dependency
    !-- SpringBoot快速启动Duubbo --
    dependency
        groupIdcom.alibaba.spring.boot/groupId
        artifactIddubbo-spring-boot-starter/artifactId
    /dependency
    !-- Zk客户端依赖 --
    dependency
        groupIdcom.101tec/groupId
        artifactIdzkclient/artifactId
        !-- 排除依赖里的日志 --
        exclusions
            exclusion
                groupIdlog4j/groupId
                artifactIdlog4j/artifactId
            /exclusion

            exclusion
                groupIdorg.slf4j/groupId
                artifactIdslf4j-api/artifactId
            /exclusion

            exclusion
                groupIdorg.slf4j/groupId
                artifactIdslf4j-log4j12/artifactId
            /exclusion
        /exclusions
    /dependency
    !-- 导入公共接口依赖 --
    dependency
        groupIdcom.simple.springboot/groupId
        artifactIdcommon/artifactId
        version0.0.1-SNAPSHOT/version
    /dependency
/dependencies

build
    plugins
        plugin
            groupIdorg.springframework.boot/groupId
            artifactIdspring-boot-maven-plugin/artifactId
        /plugin
    /plugins
/build

在这个工程中我们是需要依赖Web的，不然咋访问呢

编写Application.properties配置文件


spring.application.name=user-con
server.port=8080
dubbo.application.name=user-consumer
dubbo.registry.address=zookeeper://192.168.197.133:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
#dubbo.scan=com.simple.springboot.provider.common.impl

在这里dubbo.application.name应用名称一定不能重复，dubbo.scan 该配置指向应该是要和服务提供方一致

编写Controller


@RestController
public class UserController {

    //timeout 可以不指定，如果提供则有填写但是version一定要指定 不然会找不到服务 直连需要加url="dubbo://localhost:20880"
    @Reference
    private UserService userService;

    @GetMapping("/dubbo/user/{id}")
    public String getUserById(@PathVariable int id){
        return userService.getUserById(id);
    }
}

在这里是使用@Reference去发现服务而不是@Autowired去注入Bean，@Reference 里面可以配置version,timeout超时时间

如果需要Dubbo直连url=”dubbo://localhost:20880”

dubbo提供了四种负载均衡策略,分别是：

1、Random LoadBalance 按权重的随机负载均衡,也是dubbo默认的负载均衡策略

2、RoundRobin LoadBalance 按权重的轮询负载均衡,即在轮询的基础上添加了权重的策略

3、LeastActive LoadBalance 最少活跃调用数,相同活跃数的随机访问,活跃数指调用前后的计数差即响应时间的长短;这种策略可以使响应慢的提供者收到的请求较少,大大提供系统性能

4、ConsistentHash LoadBalance 一致性哈希；相同参数的请求总是发到同一提供者

负载均衡的配置：@Reference(loadbalance = “roundrobin”)，loadbalance 的值即为四种负载均衡的名称,全部小写

在集群调用失败时，Dubbo 提供了多种容错方案，缺省为 failover 重试。下面列举dubbo支持的容错策略：

1、Failover Cluster：失败自动切换，当出现失败，重试其它服务器。通常用于读操作，但重试会带来更长延迟。可通过 retries=”XXX” 来设置重试次数(不含第一次)。

2、Failfast Cluster：快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。

3、Failsafe Cluster：失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。

4、Failback Cluster：失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。

5、Forking Cluster：并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 forks=”2” 来设置最大并行数。

6、Broadcast Cluster：广播调用所有提供者，逐个调用，任意一台报错则报错 [2]。通常用于通知所有提供者更新缓存或日志等本地资源信息。

配置如下：@Reference(cluster = “failsafe”)这里表示使用失败安全的容错策略

编写启动类


/**
 * @author:SimpleWu
 * @date: 2019-05-08
 */
@EnableDubbo
@SpringBootApplication
@EnableDubboConfiguration
@DubboComponentScan("com.simple.springboot.provider.common.impl")
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class,args);
    }
}

然后直接就可以访问成功了。

如果不想使用注解扫描可以使用properties进行配置


#dubbo.scan=com.simple.springboot.provider.common.impl

参考代码：

https://gitlab.com/450255266/code/tree/master/SpringBoot/dubbo/yun-double

注意事项:

Dubbo是一个二进制的Rpc框架在传输数据过程中，实体类必须经过序列化。

在使用poi导出功能时一定不能把response传到Service层，否则传输到Service是导出不了文件而报错，至于文件下载也一样但是相信一般都会有单独的文件服务器。

看完本文有收获？请转发分享给更多人

原文始发于微信公众号（Java知音）：

本人花费半年的时间总结的《Java面试指南》已拿腾讯等大厂offer，已开源在github ，欢迎star！

本文GitHub https://github.com/OUYANGSIHAI/JavaInterview 已收录，这是我花了6个月总结的一线大厂Java面试总结，本人已拿大厂offer，欢迎star

原文链接：blog.ouyangsihai.cn >> 企业级SpringBoot与Dubbo的并用