从零开始搭建 springboot-dubbo 的例子
Dubbo 是一个分布式服务框架, 致力于提供高性能和透明化的 RPC 远程服务调用方案, 以及 SOA 服务治理方案
一, Dubbo 的简单介绍
1. 网站架构的发展历程
网站架构随着业务的发展, 逻辑越来越复杂, 数据量越来越大, 交互越来越多.......
单一应用架构(OORM)
当网站流量很小时, 将所有的功能部署到一起, 以减少部署节点和成本. 此时, 只需要使用简化增删改查的工作量, 采用数据访问框架(ORM).
垂直应用架构 (MVC)
当访问量逐渐增大, 单一应用带来的加速度越来越小. 此时, 将应用拆分成互不相干的几个应用, 所以采用 MVC 框架.
分布式服务架构 (RPC)
当垂直应用越来越多, 应用之交互不可避免, 将核心业务抽取出来, 作为独立的服务, 逐渐形成稳定的服务中心, 使前端应用能更快速地响应多变的市场需求. 此时, 用于提高业务复用及整合的服务框架 (RPC) 是关键.
流动计算框架 (SQA)
当服务越来越多, 容量的评估, 小服务资源的浪费等问题逐渐显现, 此时需增加一个调度中心基于访问压力实时管理集群容量, 提高集群利用率. 此时, 用于提高机器利用率的 资源调度和治理中心(SOA) 是关键.
2. dubbo 核心工作原理
节点 | 角色说明 |
---|---|
Provider | 暴露服务的服务提供方 |
Registry | 服务的注册与发现的注册中心,如 zookeper(推荐)、multicast、redis、simple |
Consumer | 调用远程服务的服务消费方 |
Monitor | 统计服务的调用次数和调用时间的监控中心 |
Container | 服务运行容器 |
调用流程
服务器负责启动, 加载, 运行服务提供者.
服务提供者在启动时, 向注册中心注册自己所提供的服务
服务消费者在启动时, 向注册中心订阅自己所需的服务
注册中心返回服务提供者地址列表给消费者, 如果有变更, 注册中心将基于 TCP 长连接推送变更数据给消费者
服务消费者从提供的服务列表中, 基于软负载均衡算法, 选一台提供者进行调用, 如果失败, 则选择另一台调用
服务消费者和提供者, 在内存中累计调用次数和调用时间, 定时每分钟发送一次统计数据到检测中心
3. dubbo 特点
Dubbo 支持 RPC 调用, 服务之间的调用性能会很好, 效率很高
支持多种序列化协议, 如 Hessian(默认),HTTP,webService
对比 springcloud
二, springboot-Dubbo 搭建
想要使用 Dubbo 的话, 按照前面的原理图, 我们主要使用它的服务远程调用功能, 也就是两个项目之间相互通讯, 即 RPC
直接上图, 先大致看看项目结构:
dubbo-provider 是所谓的服务提供者, springboot 项目
dubbo-consumer 是服务消费者, springboot 项目
dubbo-API 是服务提供者的接口 API, 最普通的 maven 项目
这里可以会想起 dubbo 工作原理的图:
0 dubbo-provider 先在容器里初始化启动
1 dubbo-provider 去注册中心去注册服务, 注册中心使用 zookeeper
2 dubbo-consumer 去注册中心发现需要的服务
3 注册中心返回 dubbo-provider 的服务
4 dubbo-consumer 直接去调用 dubbo-provider
1. 项目依赖
dubbo 的 jar 包依赖(spring-boot)
- <!-- dubbo 依赖 -->
- <dependency>
- <groupId>com.alibaba.spring.boot</groupId>
- <artifactId>dubbo-spring-boot-starter</artifactId>
- <version>2.0.0</version>
- </dependency>
注册中心 zookeeper 的 jar 包依赖
- <!-- 引入 zookeeper 的依赖 -->
- <dependency>
- <groupId>com.101tec</groupId>
- <artifactId>zkclient</artifactId>
- <version>0.10</version>
- </dependency>
2. 服务提供者
服务提供者 dubbo-provider 提供 HelloService.sayHello()接口
- package com.dubbo.provider.service;
- import com.alibaba.dubbo.config.annotation.Service;
- import com.dubbo.service.HelloService;
- import org.springframework.stereotype.Component;
- //@Service 是 dubbo 里的注解, 作用是暴露服务, 不要选择 spring 的 @Service
- @Service
- @Component
- public class HelloServiceImpl implements HelloService {
- @Override
- public String sayHello(String name) {
- return "Hello" + name;
- }
- }
还要在 springboot 的启动类上加一个开启 Dubbo 的注解
- package com.dubbo.provider;
- import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
- import org.springframework.boot.SpringApplication;
- import org.springframework.boot.autoconfigure.SpringBootApplication;
- // 开启 dubbo 的自动配置
- @EnableDubboConfiguration
- @SpringBootApplication
- public class DubboProviderApplication {
- public static void main(String[] args) {
- SpringApplication.run(DubboProviderApplication.class, args);
- }
- }
3. 服务消费者
dubbo-consumer 远程调用 dubbo-consumer 提供的服务 HelloService.sayHello()接口
- package com.dubbo.consumer.controller;
- import com.alibaba.dubbo.config.annotation.Reference;
- import com.dubbo.service.HelloService;
- import org.springframework.Web.bind.annotation.RequestMapping;
- import org.springframework.Web.bind.annotation.RestController;
- @RestController
- public class HelloController {
- @Reference//dubbo 注解, 可以仔细了解下这个注解
- private HelloService helloService;
- @RequestMapping(value = "/hello")
- public String hello() {
- String hello = helloService.sayHello("world");
- System.out.println(helloService.sayHello("BJQ"));
- return hello;
- }
- }
同上, 这个也需要让 Dubbo 开启自动配置
- package com.dubbo.consumer;
- import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
- import org.springframework.boot.SpringApplication;
- import org.springframework.boot.autoconfigure.SpringBootApplication;
- // 就是这里, 对, 没错 ->_->
- @EnableDubboConfiguration
- @SpringBootApplication
- public class DubboConsumerApplication {
- public static void main(String[] args) {
- SpringApplication.run(DubboConsumerApplication.class, args);
- }
- }
4. 项目启动流程和结构
1. 启动祖册中心:
项目启动需要去官网下载 zookeper 注册中心 http://mirror.bit.edu.cn/apache/zookeeper/ , 解压, 配置一下 zoo.cfg 配置文件, 然后启动 zkServer.cmd(以下是我的简单配置)
- tickTime=2000
- initLimit=10
- syncLimit=5
- dataDir=F:\\zookeeper-3.4.14\\temp\\zookeeper
- dataLogDir=F:\\zookeeper-3.4.14\\temp\\zookeeper-logs
- clientPort=2181
2. 启动服务提供方 dubbo-provider
如下图, 说明 dubbo-provider 启动, 并且已经连上注册中心
3. 启动服务消费方 dubbo-consumer
效果跟上面差不多
4. 服务调用结果
自己去试试, 皮一下,, 哈哈 QWQ
注意点和问题
dubbo 直连, 这个可以在测试的过程中使用
dubbo 的高校序列化协议可以选的, 默认是 hessian
dubbo 是基于 TCP 协议去做的, 所以很快.
在启动 zookeeper 时, 会有窗口一闪而过的情况, 有可能时 jdk 环境变量有空格, 还有可能是 zk 的 dataDir 路径不对
《完》
来源: https://www.cnblogs.com/baijinqiang/p/10848259.html