Dubbo+Zookeeper

Apache ZooKeeper

通过当前页面下载Zookeeper

在这里启动zookeeper

可以根据这个页面简单学习一下，但是没有集成mysql，也会出现一些报错，且在这之后我们要使用的管理页面是vue的dubbo-admin

dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。-阿里云开发者社区

图文并茂，万字长文！彻底搞清楚Spring Boot 整合Dubbo+Zookeeper【分布式实战】 - 知乎

这是我的模块设计，在设计各个模块的内容之前，先通过github获取dubbo的管理界面

通过GitHub拉取该项目apache/dubbo-admin: The ops and reference implementation for Apache Dubbo

dubbon-admin-ui的vue项目通过vscode启动的视图页面来管理dubbo的项目

npm install
下载node_modules
如果报错应该是node的版本不对，如果安装了nvm可以通过nvm切换至16.x.x版本
npm run dev
启动项目

通过root/root登录dubbo-admin

先启动zookeeper
需要使用这个视图页面来管理dubbo的项目，我们还得启动拉取项目中的dubbo-admin-server模块并先更新完pom.xml中的依赖，maven的版本等等基本项也得改掉，之后启动项目成功便能使用这个视图页面来管理dubbo的项目

根据我的模块设计，我们开始对项目进行架构设计

先引入我们需要的总依赖

<!-- 引入dubbo -->  
<!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->  
<dependency>  
    <groupId>org.apache.dubbo</groupId>  
    <artifactId>dubbo-dependencies-bom</artifactId>  
    <version>3.2.5</version>  
    <type>pom</type>  
    <scope>import</scope>  
</dependency>  
  
<!-- https://mvnrepository.com/artifact/org.apache.curator/curator-x-discovery -->  
<dependency>  
    <groupId>org.apache.curator</groupId>  
    <artifactId>curator-x-discovery</artifactId>  
    <version>4.3.0</version>  
</dependency>  
  
  
<!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端 -->  
<dependency>  
    <groupId>org.apache.curator</groupId>  
    <artifactId>curator-framework</artifactId>  
    <version>2.12.0</version>  
</dependency>  
  
  
<dependency>  
    <groupId>org.apache.dubbo</groupId>  
    <artifactId>dubbo</artifactId>  
    <version>3.2.5</version>  
</dependency>  
  
<dependency>  
    <groupId>org.jetbrains.kotlin</groupId>  
    <artifactId>kotlin-reflect</artifactId>  
    <version>1.9.0</version>  
</dependency>  
  
  
<dependency>  
    <groupId>org.apache.dubbo.extensions</groupId>  
    <artifactId>dubbo-mock-api</artifactId>  
    <version>3.0.0</version>  
</dependency>  
  
<dependency>  
    <groupId>org.apache.curator</groupId>  
    <artifactId>curator-framework</artifactId>  
    <version>4.3.0</version>  
</dependency>  
  
<dependency>  
    <groupId>org.apache.curator</groupId>  
    <artifactId>curator-recipes</artifactId>  
    <version>4.3.0</version>  
</dependency>  
  
  
<!-- MyBatis-Plus -->  
<dependency>  
    <groupId>com.baomidou</groupId>  
    <artifactId>mybatis-plus-boot-starter</artifactId>  
    <version>3.5.3.2</version>  
</dependency>  
  
<!-- Spring Boot Web -->  
<dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-web</artifactId>  
</dependency>  
  
<dependency>  
    <groupId>org.mybatis.spring.boot</groupId>  
    <artifactId>mybatis-spring-boot-starter</artifactId>  
    <version>2.2.2</version>  
</dependency>

这里的依赖总的划分一下的话如下图所示

实例

pojo

@Data  
  
@AllArgsConstructor  
  
@NoArgsConstructor  
public class User implements Serializable {  
    private static final long serialVersionUID = 1L;  // 显式定义  
  
    private Long id;  
    private String name;  
}

service

public interface UserService extends IService<User> {}

实例
控制类

@RestController  
@RequestMapping("/user")  
public class UserController {  
    private static final Logger log = LoggerFactory.getLogger(UserController.class);  
  
    @Reference(timeout = 5000, retries = 1, check = true)  
    private UserService userService;  
  
    @GetMapping("/{id}")  
    public ResponseEntity<User> getUser(@PathVariable("id") Long id) {  
        log.info("调用远程服务，用户ID: {}", id);  
        User user = userService.getById(id);  
        if (user == null) {  
            return ResponseEntity.notFound().build();  
        }  
        return ResponseEntity.ok(user);  
    }  
}

yml

server:  
  port: 8081  
spring:  
  datasource:  
    url: jdbc:mysql://localhost:3306/dubbo?useSSL=false&serverTimezone=UTC  
    username: root  
    password: 20050101  
    driver-class-name: com.mysql.cj.jdbc.Driver  
  application:  
    name: dubbo-consumer  
  
dubbo:  
  application:  
    name: dubbo-consumer  # 消费者应用名称  
    qos-enable: false     # 禁用 QoS（可选）  
  
  registry:  
    address: zookeeper://127.0.0.1:2181  # 注册中心地址（ZooKeeper）  
    # 如果使用 Nacos 注册中心，可以配置为：  
    # address: nacos://127.0.0.1:8848  
  
  protocol:  
    name: dubbo  # 使用的协议类型  
    port: 20882     # 消费者端口（通常不需要配置，Dubbo 会自动分配）  
  
  consumer:  
    check: false  # 是否在启动时检查服务提供者是否存在  
    timeout: 3000 # 调用超时时间（单位：毫秒）  
    retries: 2    # 调用失败时的重试次数  
    loadbalance: random  # 负载均衡策略（random、roundrobin、leastactive 等）  
    cluster: failover    # 集群容错策略（failover、failfast、failsafe 等）

实例

mapper

@Mapper  
public interface UserMapper extends BaseMapper<User> {}

impl

@DubboService  
@Service  
public class UserServiceImpl extends ServiceImpl<UserMapper,User> implements UserService {}

启动类

@EnableDubbo  
@SpringBootApplication  
public class UserServiceProviderApplication {  
  
    public static void main(String[] args) {  
        SpringApplication.run(UserServiceProviderApplication.class, args);  
    }  
  
}

yml

server:  
  port: 20881  
spring:  
  datasource:  
    url: jdbc:mysql://localhost:3306/dubbo?useSSL=false&serverTimezone=UTC  
    username: root  
    password: 20050101  
    driver-class-name: com.mysql.cj.jdbc.Driver  
  application:  
    name: dubbo-provider  
  
dubbo:  
  application:  
    name: dubbo-provider  
    qos-enable: true  
  registry:  
    address: zookeeper://127.0.0.1:2181  
  protocol:  
    name: dubbo  
    port: 20880

启动后可以在服务关系中看见他们模块之间的关系
也可以去调用接口测试接口的使用