feat: 移除seata，分布式由rocketmq来处理

KouShenhai · Jul 27, 2024 · 5b5758c · 5b5758c
1 parent c53350b
commit 5b5758c
Show file tree

Hide file tree

Showing 291 changed files with 65 additions and 47,106 deletions.
diff --git a/README.adoc b/README.adoc
@@ -90,7 +90,6 @@ image::doc/image/老寇IoT云平台架构图-阿里巴巴.png[架构图,align=ce
 |Spring Authorization Server |1.3.1
 |Mybatis Plus                |3.5.7
 |Nacos                       |2.4.0.1
-|Seata                       |2.0.0
 |Sentinel                    |1.8.8
 |Redis                       |7.2.5
 |Elasticsearch               |8.14.3
@@ -113,7 +112,7 @@ image::doc/image/老寇IoT云平台架构图-阿里巴巴.png[架构图,align=ce
 - 负载均衡：Spring Cloud Loadbalancer
 - 服务熔断&降级&限流：Sentinel
 - 分库分表：Mybatis Plus
-- 分布式事务：Seata & RocketMQ
+- 分布式事务：RocketMQ
 - 消息队列：RocketMQ & Kafka & MQTT
 - 服务监控：Spring Boot Admin & Prometheus
 - 高亮搜索：Elasticsearch
@@ -167,15 +166,13 @@ image::doc/image/老寇IoT云平台架构图-阿里巴巴.png[架构图,align=ce
         └── laokou-common-openfeign                --- 远程调用组件
         └── laokou-common-data-cache               --- 数据缓存组件
         └── laokou-common-mybatis-plus             --- 对象映射组件
-        └── laokou-common-seata                    --- 分布式事务组件
         └── laokou-common-tdengine                 --- 时序数据库组件
         └── laokou-common-sentinel                 --- 服务限流&熔断降级组件
 ├── laokou-cloud
         └── laokou-gateway                         --- API网关
         └── laokou-monitor                         --- 服务监控
         └── laokou-register                        --- 服务治理
         └── laokou-sentinel                        --- 流量治理
-        └── laokou-seata                           --- 分布式事务
         └── laokou-snail-job                       --- 分布式任务调度
 ├── laokou-service
         └── laokou-iot                             --- 物联网模块

diff --git a/doc/db/kcloud_platform.sql b/doc/db/kcloud_platform.sql
@@ -2350,160 +2350,6 @@ VALUES ('95TxSsTPFA3tF12TBSMmUVK0da', '95TxSsTPFA3tF12TBSMmUVK0da', '2024-04-30
 		'{"@class":"java.util.Collections$UnmodifiableMap","settings.client.require-proof-key":false,"settings.client.require-authorization-consent":true}',
 		'{"@class":"java.util.Collections$UnmodifiableMap","settings.token.reuse-refresh-tokens":true,"settings.token.id-token-signature-algorithm":["org.springframework.security.oauth2.jose.jws.SignatureAlgorithm","RS256"],"settings.token.access-token-time-to-live":["java.time.Duration",3600.000000000],"settings.token.access-token-format":{"@class":"org.springframework.security.oauth2.server.authorization.settings.OAuth2TokenFormat","value":"self-contained"},"settings.token.refresh-token-time-to-live":["java.time.Duration",21600.000000000],"settings.token.authorization-code-time-to-live":["java.time.Duration",3600.000000000],"settings.token.device-code-time-to-live":["java.time.Duration",3600.000000000]}');
 
-create table if not exists public.seata_state_inst
-(
-	id                       varchar(48)  not null,
-	machine_inst_id          varchar(128) not null,
-	name                     varchar(128) not null,
-	type                     varchar(20),
-	service_name             varchar(128),
-	service_method           varchar(128),
-	service_type             varchar(16),
-	business_key             varchar(48),
-	state_id_compensated_for varchar(50),
-	state_id_retried_for     varchar(50),
-	gmt_started              timestamp(3) not null,
-	is_for_update            smallint,
-	input_params             text,
-	output_params            text,
-	status                   varchar(2)   not null,
-	excep                    bytea,
-	gmt_updated              timestamp(3),
-	gmt_end                  timestamp(3),
-	primary key (id, machine_inst_id)
-);
-
-comment on column public.seata_state_inst.id is 'id';
-
-comment on column public.seata_state_inst.machine_inst_id is 'state machine instance id';
-
-comment on column public.seata_state_inst.name is 'state name';
-
-comment on column public.seata_state_inst.type is 'state type';
-
-comment on column public.seata_state_inst.service_name is 'service name';
-
-comment on column public.seata_state_inst.service_method is 'method name';
-
-comment on column public.seata_state_inst.service_type is 'service type';
-
-comment on column public.seata_state_inst.business_key is 'business key';
-
-comment on column public.seata_state_inst.state_id_compensated_for is 'state compensated for';
-
-comment on column public.seata_state_inst.state_id_retried_for is 'state retried for';
-
-comment on column public.seata_state_inst.gmt_started is 'start time';
-
-comment on column public.seata_state_inst.is_for_update is 'is service for update';
-
-comment on column public.seata_state_inst.input_params is 'input parameters';
-
-comment on column public.seata_state_inst.output_params is 'output parameters';
-
-comment on column public.seata_state_inst.status is 'status(SU succeed|FA failed|UN unknown|SK skipped|RU running)';
-
-comment on column public.seata_state_inst.excep is 'exception';
-
-comment on column public.seata_state_inst.gmt_updated is 'update time';
-
-comment on column public.seata_state_inst.gmt_end is 'end time';
-
-alter table public.seata_state_inst
-	owner to root;
-
-create table if not exists public.seata_state_machine_def
-(
-	id               varchar(32)  not null
-		primary key,
-	name             varchar(128) not null,
-	tenant_id        varchar(32)  not null,
-	app_name         varchar(32)  not null,
-	type             varchar(20),
-	comment_         varchar(255),
-	ver              varchar(16)  not null,
-	gmt_create       timestamp(3) not null,
-	status           varchar(2)   not null,
-	content          text,
-	recover_strategy varchar(16)
-);
-
-comment on column public.seata_state_machine_def.id is 'id';
-
-comment on column public.seata_state_machine_def.name is 'name';
-
-comment on column public.seata_state_machine_def.tenant_id is 'tenant id';
-
-comment on column public.seata_state_machine_def.app_name is 'application name';
-
-comment on column public.seata_state_machine_def.type is 'state language type';
-
-comment on column public.seata_state_machine_def.comment_ is 'comment';
-
-comment on column public.seata_state_machine_def.ver is 'version';
-
-comment on column public.seata_state_machine_def.gmt_create is 'create time';
-
-comment on column public.seata_state_machine_def.status is 'status(AC:active|IN:inactive)';
-
-comment on column public.seata_state_machine_def.content is 'content';
-
-comment on column public.seata_state_machine_def.recover_strategy is 'transaction recover strategy(compensate|retry)';
-
-alter table public.seata_state_machine_def
-	owner to root;
-
-create table if not exists public.seata_state_machine_inst
-(
-	id                  varchar(128) not null
-		primary key,
-	machine_id          varchar(32)  not null,
-	tenant_id           varchar(32)  not null,
-	parent_id           varchar(128),
-	gmt_started         timestamp(3) not null,
-	business_key        varchar(48),
-	start_params        text,
-	gmt_end             timestamp(3),
-	excep               bytea,
-	end_params          text,
-	status              varchar(2),
-	compensation_status varchar(2),
-	is_running          smallint,
-	gmt_updated         timestamp(3) not null
-);
-
-comment on column public.seata_state_machine_inst.id is 'id';
-
-comment on column public.seata_state_machine_inst.machine_id is 'state machine definition id';
-
-comment on column public.seata_state_machine_inst.tenant_id is 'tenant id';
-
-comment on column public.seata_state_machine_inst.parent_id is 'parent id';
-
-comment on column public.seata_state_machine_inst.gmt_started is 'start time';
-
-comment on column public.seata_state_machine_inst.business_key is 'business key';
-
-comment on column public.seata_state_machine_inst.start_params is 'start parameters';
-
-comment on column public.seata_state_machine_inst.gmt_end is 'end time';
-
-comment on column public.seata_state_machine_inst.excep is 'exception';
-
-comment on column public.seata_state_machine_inst.end_params is 'end parameters';
-
-comment on column public.seata_state_machine_inst.status is 'status(SU succeed|FA failed|UN unknown|SK skipped|RU running)';
-
-comment on column public.seata_state_machine_inst.compensation_status is 'compensation status(SU succeed|FA failed|UN unknown|SK skipped|RU running)';
-
-comment on column public.seata_state_machine_inst.is_running is 'is running(0 no|1 yes)';
-
-alter table public.seata_state_machine_inst
-	owner to root;
-
-create unique index if not exists seata_state_machine_inst_business_key_tenant_id_idx
-	on public.seata_state_machine_inst (business_key, tenant_id);
-
 create table boot_sys_api_log
 (
 	id            bigint generated by default as identity