云端数据分发用例(备注)

配置服务端
配置订阅客户端

配置服务端

服务端一键安装，包含组件

zcbus_service
zcbuskafka
zcbuszookeeper
mysql
zcbusweb
其中WEB服务所在的主机，作为对外网提供全局ID的服务地址。

AUX为主服务，down为子服务

aux_down
负责监控，收集云端管理服务器MYSQL的增量数据，将负责将云端管理信息下发的服务。最终将数据下发到指定的KAFKA对应的TOPIC中。
aux_up
负责，监控，接收客户端返回的状态信息等服务。当客户端运行之后，心跳信息，客户端装载基本信息等均需要收到服务端，应用到服务端管理数据库中。

配置订阅客户端

客户端配置，包含组件：

    http://127.0.0.1/databus/globalid

客户端启动，会依赖一个数据下行维护服务，为

aux_client服务
负责客户端信息接收，以及客户端信息返回的服务

其中，客戶端云上云下数据交换服务中，带有CUSTOMERID/NODEID的表，在服务端均需要为符合索引
初始化过程中，需要初始化信息：
1、服务商基本信息
2、用户基本信息
3、容器基本信息

需要下发列表：

    bus_in_tables
    bus_product_tables_relation
    bus_client_product
    bus_client_check_table_list
    zbomc_manager_menu
    zbomc_sys_users
    zbomc_customer
    zbomc_cooperative_manufacturers
    bus_cluster_container_customer
    bus_cluster_container_properties

需要上传列表：

    bus_client_apply_ddl_key_map
    bus_client_check_table_content_queue
    bus_client_db_parameter
    bus_client_ddl_ignore_keys
    bus_client_ddl_operation_list
    bus_client_exception_data
    bus_client_file_upload
    bus_client_kafka_properties
    bus_client_kafka_tag_mgr
    bus_client_main_control
    bus_client_main_control_properties
    bus_client_op_check_table_detail
    bus_client_op_ddl_filter_record
    bus_client_op_ddl_operation_log
    bus_client_op_ddl_record_detail
    bus_client_op_full_load_info
    bus_client_op_idx_map
    bus_client_op_real_load_info
    bus_client_op_relation_keys
    bus_client_op_status_alive
    bus_client_op_status_info
    bus_client_product_object
    bus_client_product_object_check
    bus_client_product_object_properties
    bus_cluster_container_properties
    bus_op_customer_alive

INSERT INTO `bus_aux_topic_point` (`topic`, `offset`, `starttime`) VALUES ('common_zcbus_down', 0, NULL);
INSERT INTO `bus_aux_topic_point` (`topic`, `offset`, `starttime`) VALUES ('common_zcbus_up', 0, NULL); 
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (1, 'zcbus', 'bus_op_customer_alive', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (2, 'zcbus', 'bus_client_apply_ddl_key_map', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (3, 'zcbus', 'bus_client_check_table_content_queue', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (4, 'zcbus', 'bus_client_db_parameter', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (5, 'zcbus', 'bus_client_ddl_ignore_keys', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (6, 'zcbus', 'bus_client_ddl_operation_list', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (7, 'zcbus', 'bus_client_exception_data', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (8, 'zcbus', 'bus_client_file_upload', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (9, 'zcbus', 'bus_client_kafka_properties', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (10, 'zcbus', 'bus_client_kafka_tag_mgr', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (11, 'zcbus', 'bus_client_main_control', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (12, 'zcbus', 'bus_client_main_control_properties', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (13, 'zcbus', 'bus_client_op_check_table_detail', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (14, 'zcbus', 'bus_client_op_ddl_filter_record', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (15, 'zcbus', 'bus_client_op_ddl_operation_log', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (16, 'zcbus', 'bus_client_op_ddl_record_detail', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (17, 'zcbus', 'bus_client_op_full_load_info', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (18, 'zcbus', 'bus_client_op_idx_map', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (19, 'zcbus', 'bus_client_op_real_load_info', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (20, 'zcbus', 'bus_client_op_relation_keys', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (21, 'zcbus', 'bus_client_op_status_alive', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (22, 'zcbus', 'bus_client_op_status_info', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (23, 'zcbus', 'bus_client_product_object', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (24, 'zcbus', 'bus_client_product_object_check', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (25, 'zcbus', 'bus_client_product_object_properties', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (26, 'zcbus', 'bus_cluster_container_properties', NULL, 1);
INSERT INTO `bus_aux_up_tab_list` (`id`, `tableSchema`, `tableName`, `lastmark`, `valid`) VALUES (27, 'zcbus', 'bus_op_customer_alive', NULL, 1);

文档更新时间: 2022-03-23 20:06 作者：阿力