05、SpringBoot实战:搭建springboot-dubbo

本文详细介绍了Apache Dubbo分布式服务框架的核心原理、特点以及与SpringBoot的整合搭建实战。包含Dubbo架构演进、工作原理、服务提供者与消费者配置、Zookeeper注册中心使用,并提供了完整的项目代码示例,帮助开发者快速上手微服务开发。

目录

    • 一、 Dubbo的简单介绍
      1. 网站架构的发展历程
    1. dubbo核心工作原理
    • 调用流程
    1. dubbo特点
  • 二、 springboot-Dubbo搭建
      1. 项目依赖
    1. 服务提供者
    1. 服务消费者
    1. 项目启动流程和结构
      1. 启动注册中心:
      1. 启动服务提供者 dubbo-provider
      1. 启动服务消费者dubbo-consumer
      1. 服务调用
  • 三、项目地址

一、 Dubbo的简单介绍

Dubbo 是一个分布式服务框架,致力于提供高性能和透明化的 RPC 远程服务调用方案,以及 SOA 服务治理方案

1. 网站架构的发展历程

网站架构随着业务的发展,逻辑越来越复杂,数据量越来越大,交互越来越多…

 

  • 单一应用架构(ORM)

当网站流量很小时,将所有的功能部署到一起,以减少部署节点和成本。此时,只需要使用简化增删改查的工作量,采用数据访问框架(ORM)。

  • 垂直应用架构 (MVC)

当访问量逐渐增大,单一应用带来的加速度越来越小。此时,将应用拆分成互不相干的几个应用,所以采用MVC框架。

  • 分布式服务架构 (RPC)

当垂直应用越来越多,应用之交互不可避免,将核心业务抽取出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速地响应多变的市场需求。此时,用于提高业务复用及整合的服务框架(RPC)是关键。

  • 面向服务框架 (SOA)

当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。此时,用于提高机器利用率的 资源调度和治理中心(SOA) 是关键。

2. dubbo核心工作原理

 

节点角色说明
Provider暴露服务的服务提供方
Registry服务的注册与发现的注册中心,如zookeper(推荐)、multicast、redis、simple
Consumer调用远程服务的服务消费方
Monitor统计服务的调用次数和调用时间的监控中心
Container服务运行容器
调用流程

1、 启动Zookeeper,执行zkServer.cmd;
2、 启动服务提供者,provider;
3、 启动服务消费者,consumer;
(服务消费者在启动时,向注册中心订阅自己所需的服务)
4、 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于TCP长连接推送变更数据给消费者;
5、 服务消费者从提供的服务列表中,基于软负载均衡算法,选一台提供者进行调用,如果失败,则选择另一台调用;
6、 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到检测中心;

3. dubbo特点

1、 Dubbo支持RPC调用,服务之间的调用性能会很好,效率很高;
2、 支持多种序列化协议,如Hessian(默认)、HTTP、WebService;
3、 对比springcloud;

组件DubboSpring Cloud
服务注册中心ZookeeperSpring Cloud Netflix Eureka
服务监控Dubbo-monitorSpring Boot Admin
断路器不完善Spring Cloud Netfix Hystrix
服务网关Spring Cloud Netflix Gateway
服务配置Spring Cloud Config
服务跟踪Spring Cloud Sleuth
消息总线Spring Cloud Bus
数据流Spring Cloud Stream
批量任务Spring Cloud Task

二、 springboot-Dubbo搭建

直接上图,先大致看看项目结构:

 

  • dubbo-provider 是所谓的服务提供者,springboot项目;
  • dubbo-consumer 是服务消费者,springboot项目;
  • dubbo-api 是服务提供者的接口API,最普通的maven项目。

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;

// 让Dubbo开启自动配置
@EnableDubboConfiguration
@SpringBootApplication
public class DubboConsumerApplication {
   
     

    public static void main(String[] args) {
   
     
        SpringApplication.run(DubboConsumerApplication.class, args);
    }

}

4. 项目启动流程和结构

1. 启动注册中心:

执行zkServer.cmd。

2. 启动服务提供者 dubbo-provider

如下图,说明dubbo-provider启动,并且已经连上注册中心

 

3. 启动服务消费者dubbo-consumer

 

4. 服务调用

访问地址:http://localhost:9021/hello

 

三、项目地址

springboot-dubbo-demo

完结撒花~

版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: