【Java】萌新的Spring纯注解集成Dubbo学习笔记

目录

介绍

Dubbo架构

实现

---

介绍

Dubbo 是一款高性能的 Java RPC 框架，它提供了完整的服务治理解决方案，包括远程服务调用、负载均衡、容错机制、服务注册和发现等功能。同时，Dubbo 与 Zookeeper 进行集成，利用 Zookeeper 作为注册中心来实现服务的注册与发现。

下面将详细介绍 Dubbo 的主要特性并穿插介绍与 Zookeeper 的集成：

1. 远程服务调用：Dubbo 提供了高效的远程服务调用功能，可以让服务消费者通过网络调用服务提供者的方法，实现分布式系统中的服务协作。通过 Dubbo 的配置，可以轻松地实现远程服务的调用和管理。

2. 负载均衡：Dubbo 支持多种负载均衡策略，可以根据实际需求选择合适的负载均衡算法，包括随机、轮询、最少活跃调用等。这些策略可以帮助系统在多个服务提供者之间进行负载均衡，提高系统的稳定性和性能。

3. 服务注册与发现：Dubbo 通过集成 Zookeeper 或其他注册中心，实现了服务的注册与发现功能。服务提供者会将自己的地址信息注册到 Zookeeper 中，而服务消费者则可以从注册中心获取可用的服务提供者列表，动态地发现和调用服务。

4. 容错机制：Dubbo 提供了多种容错处理方式，包括失败自动切换、失败重试、失败快速失败等，可以根据实际需求选择合适的容错机制来保障服务的可靠性和稳定性。

5. 服务治理：Dubbo 提供了丰富的服务治理功能，包括监控、路由、限流等，可以帮助开发者更好地管理和控制分布式系统中的服务。

在使用 Dubbo 时，通常需要借助 Zookeeper 来实现服务注册和发现功能。Zookeeper 是一个分布式协调服务，可以用于构建分布式系统的注册中心。Dubbo 通过与 Zookeeper 的集成，实现了服务提供者和消费者之间的动态注册与发现，从而提高了整个系统的灵活性和可靠性。

Dubbo架构

实现

1.Maven 依赖配置

<!-- Spring Boot 引导器 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>

<!-- Dubbo 依赖 -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.10</version>
</dependency>

<!-- ZooKeeper 客户端依赖 -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>4.2.0</version>
</dependency>

2.配置ZooKeeper注册中心

@Configuration
public class DubboConfig {

    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("zookeeper://127.0.0.1:2181");
        return registryConfig;
    }
}

3.配置Dubbo服务提供者

@Service
public class MyServiceImpl implements MyService {
    @Override
    public String sayHello() {
        return "Hello from Dubbo service!";
    }
}

public interface MyService {
    String sayHello();
}

4.配置Dubbo服务消费者

@RestController
public class MyController {
    @Reference
    private MyService myService;

    @RequestMapping("/hello")
    public String hello() {
        return myService.sayHello();
    }
}

5.Spring Boot应用程序入口

@SpringBootApplication
public class MyApplication {

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