rocketmq-connector
  • Message Connector 简介
  • 架构设计
    • Woker
    • Runtime
    • Connector
    • Routing Task
    • 消费位点同步
    • 消息路由监控
  • Quick Start
    • 前期准备
      • RocketMQ单机环境
      • RocketMQ集群搭建
    • RocketMQ Runtime
    • File Connector
  • RocketMQ Connect
    • RocketMQ Connect 简介
    • 应用场景
    • RocketMQ Runtime
      • 启动流程
      • Runtime 参数配置
      • RESTful 接口
      • Connector生命周期
      • 负载均衡
    • RocketMQ Console
      • Console 简介
      • 安装和使用
      • 使用指南
  • RocketMQ Connector
    • RocketMQ Replicator
      • Replicator简介
      • Replicator快速开始
      • Replicator 参数配置
    • Connect-Mongo
    • Connect-MySQL
    • Connect-Redis
  • 开发者中心
    • RELEASE NOTE
    • mqadmin 操作指南
    • 最佳实践
    • 工业实践
      • connector-mongo实践
  • 贡献者指北
    • 参与告知
    • 文档贡献指北
    • 本地调试向导
    • 一个简单Connector的实现
    • Contributor二三言
Powered by GitBook
On this page
  • Worker单实例
  • Worker 分布式集群

Was this helpful?

  1. 架构设计

Woker

运行Connector实例和Task的线程,一个Worker进程代表来一个Connector Runtime 运行时环境进程

Previous架构设计NextRuntime

Last updated 5 years ago

Was this helpful?

Worker的定义

运行Connector实例和Task的线程,一个Worker进程代表来一个Connector Runtime 运行时环境进程,多个Worker进程组成了一个集群,支持更多的Connect 和 Task的并行运行工作。其中,Connector Runtime 还具备了配置管理、负载均衡和任务调度。

Worker单实例

  • 若干个Connector实例以及相关联的Task任务都运行在同一个Worker实例进程上,这样子不需要调度和负载均衡,整个结构比较简单。

  • 缺点也明显,消息路由的弹性扩展,消息同步的吞吐量、可容错性都比较差。

Worker 分布式集群

若干个Connector实例以及相关联的Task任务会运行在不同的Worker实例进程上,这样子需要考虑好调度和负载均衡。在该模式中,弹性扩展、吞吐量和可容错性都比要提升很多。

Worker单实例
Worker 进程模型
Worker 分布式集群模型