发布：2023/9/6 8:24:36作者：管理员 来源：本站 浏览次数：1143
序言：学习一项新技术，一般从是什么、为什么、怎么用三个方面进行学习。本篇文章也不例外，笔者将从Dubbo是什么？、为什么会产生Dubbo技术？、如何在项目中使用Dubbo技术。最后，笔者将结合一个实际案例运用dubbo技术，给出一个Demo演示并贴出源码。
一、Dubbo是什么？
Dubbo是由阿里巴巴开源的RPC服务开发框架。RPC全称是Remote procedure call，即远程过程调用。使得调用远程的程序服务像在本地调用一样。rpc可以在提供强大的远程调能力时不损失本地调用的语义简洁性，使得构建分布式技术（应用）更加容易。它提供了三大核心能力：
面向接口的远程方法调用可靠、智能的容错和负载均衡服务主动注册和发现能力
二、为什么为产生Dubbo技术？
1）单一应用框架（ORM）
当网站流量很小，只需要一个应用，将所有功能都部署在一起，以减少部署节点和成本。
2）垂直应用框架（MVC）
单一应用架构扩容较麻烦，于是把系统中独立大部分拆分出来，形成了垂直应用架构，每个应用独立开发、独立部署。
3）分布式应用架构（RPC）
当垂直应用越来越多，每个系统的相同逻辑代码无法复用，且难免需要不同应用交互，于是将核心业务抽离出来，形成分布式应用架构。
微服务落地过程中，还需要解决以下许多问题，如：
服务之间如何高性能通信服务调用如何做到负载均衡、限流如何进行服务治理......
于是，Dubbo作为分布式服务框架应运而生。
三、如何使用Dubbo技术？
为了学习如何使用Dubbo，首先我们要了解dubbo的架构是怎么样的，如上图所示，dubbo 的核心架构中，分了4个角色：注册中心、服务提供者、服务消费者、监控中心。它们的功能分别是：
Registry：注册中心，负责服务地址的注册和查找，服务的Provider和Consumer只在启动时与注册中心交互，注册中心通过长连接感知Provider的存在，在Provider出现宕机的时候，注册中心会立即推送相关事件通知consumer。Provider：服务提供者。在它启动的时候，会向Registry进行注册操作，将自己的地址和相关配置信息封装成Url添加到Zookeeper中。Consumer：服务消费者。在它启动时，会向Registry进行订阅操作。Comsumer和Provider建立的是长连接，且Comsumer会缓存Provider信息，所以一旦建立，即使注册中心宕机，也不会影响已运行的Provider和Consumer。Monitor：监控中心。用于统计服务的调用次数和调用时间，监控中心宕机不会影响Provider和Consumer，只是丢失监控数据。
这里我们使用zookeeper作为注册中心。构建一个简单的Dubbo demo程序。
// 服务提供者
package com.example.dubbo.zk.providerzk.service;
import com.alibaba.dubbo.config.annotation.Service;
import com.demo.dubbo.api.Hello;
import org.springframework.beans.factory.annotation.Value;
@Service(timeout = 5000, version = "0.1.0")
public class HelloService implements Hello {
@Value("${server.port}")
String port;
@Override
public String hello(String name) {
return "hello " + name + " (" + port + ")";
}
}
appllication.properties
# 应用名
spring.application.name=service-provider-zk
server.port=9090
# 扫描 Dubbo 服务的位置
dubbo.scan.base-packages=com.example.dubbo.zk.providerzk.service
# Dubbo 协议
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
## Dubbo 注册中心
dubbo.registry.address=zookeeper://127.0.0.1:2181
#服务消费者
package com.demo.dubbo.zk.consumerzk;
import com.alibaba.dubbo.config.annotation.Reference;
import com.demo.dubbo.api.Hello;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class ConsumerZkApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerZkApplication.class, args);
}
@Reference(version = "0.1.0")
private Hello helloService;
@Bean
public ApplicationRunner runner() {
return args -> System.out.println(helloService.hello("dubbo-zk"));
}
}
##
# 服务名
spring.application.name=service-consumer-zk
# 端口
server.port=8081
# Dubbo 注册中心
dubbo.registry.address=zookeeper://127.0.0.1:2181
tips：消费者消费服务，需保证版本号version一致，进一步延伸，在本地测试中，可通过修改版本号和测试环境的服务隔离开。
源码链接：https://gitee.com/burceli/dubbo_demo.git
