当前位置: 首页 > news >正文

鄂尔多斯市东胜区城市建设局网站上海网站seo外包

鄂尔多斯市东胜区城市建设局网站,上海网站seo外包,wordpress主题h5,网站建设朝阳分布式事务:在分布式系统中,一个业务需要多个微服务合作完成,每个微服务都有事务,这多个事务必须同时成功或失败分支事务:每个微服务的事务全局事务:整个业务的事务1 seata1.1 seata中3个角色TC(Transaction Coordinator)事务协调者:维护全局和分支事务的状态,协调全局事务提交…

分布式事务:在分布式系统中,一个业务需要多个微服务合作完成,每个微服务都有事务,这多个事务必须同时成功或失败

        分支事务:每个微服务的事务

        全局事务:整个业务的事务

1 seata

1.1 seata中3个角色

        TC(Transaction Coordinator)事务协调者:维护全局和分支事务的状态,协调全局事务提交或回滚

        TM(Transaction Manager)事务管理器:定义全局事务的范围,开启、提交、回滚全局事务

        RM(Resource Manager)资源管理器:管理分支事务,与TC交谈以注册分支事务和报告分支事务的状态

1.2 部署TC服务

1.2.1 准备数据库表

        新建seata数据库,在数据库中新建一下4个表

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `global_table`
(`xid`                       VARCHAR(128) NOT NULL,`transaction_id`            BIGINT,`status`                    TINYINT      NOT NULL,`application_id`            VARCHAR(32),`transaction_service_group` VARCHAR(32),`transaction_name`          VARCHAR(128),`timeout`                   INT,`begin_time`                BIGINT,`application_data`          VARCHAR(2000),`gmt_create`                DATETIME,`gmt_modified`              DATETIME,PRIMARY KEY (`xid`),KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(`branch_id`         BIGINT       NOT NULL,`xid`               VARCHAR(128) NOT NULL,`transaction_id`    BIGINT,`resource_group_id` VARCHAR(32),`resource_id`       VARCHAR(256),`branch_type`       VARCHAR(8),`status`            TINYINT,`client_id`         VARCHAR(64),`application_data`  VARCHAR(2000),`gmt_create`        DATETIME(6),`gmt_modified`      DATETIME(6),PRIMARY KEY (`branch_id`),KEY `idx_xid` (`xid`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(`row_key`        VARCHAR(128) NOT NULL,`xid`            VARCHAR(128),`transaction_id` BIGINT,`branch_id`      BIGINT       NOT NULL,`resource_id`    VARCHAR(256),`table_name`     VARCHAR(32),`pk`             VARCHAR(36),`status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',`gmt_create`     DATETIME,`gmt_modified`   DATETIME,PRIMARY KEY (`row_key`),KEY `idx_status` (`status`),KEY `idx_branch_id` (`branch_id`),KEY `idx_xid` (`xid`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;CREATE TABLE IF NOT EXISTS `distributed_lock`
(`lock_key`       CHAR(20) NOT NULL,`lock_value`     VARCHAR(20) NOT NULL,`expire`         BIGINT,primary key (`lock_key`)
) ENGINE = InnoDBDEFAULT CHARSET = utf8mb4;INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

        在需要接入seata的微服务对应的数据库中新建undo_log表(XA模式不需要此表,AT模式需要此表)

CREATE TABLE `undo_log` (`id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键ID',`branch_id` bigint NOT NULL COMMENT '分支事务ID',`xid` varchar(100) CHARACTER SET utf8mb3 COLLATE utf8_general_ci NOT NULL COMMENT '全局事务唯一标识',`context` varchar(128) CHARACTER SET utf8mb3 COLLATE utf8_general_ci NOT NULL COMMENT '上下文',`rollback_info` longblob NOT NULL COMMENT '回滚信息',`log_status` int NOT NULL COMMENT '状态,0正常,1全局已完成(防悬挂)',`log_created` datetime NOT NULL COMMENT '创建时间',`log_modified` datetime NOT NULL COMMENT '修改时间',PRIMARY KEY (`id`),UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AT模式回滚日志表';

1.2.2 准备配置文件(application.yml)

sever:port: 7099 #web控制台spring:application:name: seata-serverlogging:config: classpath:logback-spring.xmlfile:path: ${user.home}/logs/seataconsole: #控制台帐号密码user:username: adminpassword: adminseata:config: #seata配置中心,可以选择file表示直接配置在当前文件(application.yaml)中,也可以选择配置在nacos中type: file
#    nacos:
#      server-addr: nacos:8848
#      group: DEFAULT_GROUP
#      namespace: "" #不写默认public
#      dataId: seataServer.properties
#      username: nacos
#      password: nacosregistry: #seata注册中心,选择nacostype: nacosnacos:application: seata-serverserver-addr: nacos:8848 #nacos地址,可以写成容器名(nacos)+端口,要求nacos和seata部署在同一个docker中,且彼此在同一个网络里; 也可以写成IP地址+端口group: DEFAULT_GROUPnamespace: "" #不写默认publicusername: rootpassword: 123456#cluster: default #tc集群名称security:secretKey: SeataSecretKey0c382ef121d778043159209298fd40bf3850a017tokenValidityInMilliseconds: 1800000ignore:urls: /,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.ico,/console-fe/public/**,/api/v1/auth/login
#如果上面的seata.config.type写的是nacos,就将一下配置写在nacos中;  如果写的是file,就将一下配置写在本application.yml中server:max-commit-retry-timeout: -1 #二阶段提交重试超时时长(默认-1,表示无限重试)max-rollback-retry-timeout: -1 #二阶段回滚重试超时时长(默认-1,表示无限重试)rollback-retry-timeout-unlock-enable: falseenable-check-auth: trueenable-parallel-request-handle: trueretry-dead-threshold: 130000xaer-nota-retry-timeout: 60000enableParallelRequestHandle: truerecovery:committing-retry-period: 1000 #二阶段提交未完成状态全局事务重试提交线程间隔时间(默认1000ms)async-committing-retry-period: 1000 #二阶段异步提交状态重试提交线程间隔时间(默认1000ms)rollbacking-retry-period: 1000 #二阶段回滚状态重试回滚线程间隔时间(默认1000ms)timeout-retry-period: 1000 #超时状态检测重试线程间隔时间(默认1000ms),检测出超时将全局事务置入回滚会话管理器undo:log-save-days: 7 #undo保留天数(默认7天)log-delete-period: 86400000 #undo清理线程间隔时间ms(默认86400000ms)session:branch-async-queue-size: 5000enable-branch-async-remove: falsestore:mode: db #也可以存储在file或redis中session:mode: dblock:mode: dbdb:datasource: druiddb-type: mysqldriver-class-name: com.mysql.cj.jdbc.Driver #mysql8以后的驱动用这个(.cj)#此种写法要保证seata与mysql在同一个docker,且在同一个网络中, 否则要写成IP地址(jdbc:mysql://123.123.123.123:3306/seata......)url: jdbc:mysql://mysql:3306/seata?rewriteBatchedStatements=true&serverTimezone=UTCuser: rootpassword: 123456min-conn: 10 #数据库初始连接数max-conn: 100 #数据库最大连接数global-table: global_table #全局事务表名branch-table: branch_table #分支事务表名lock-table: lock_table #全局锁表名distributed-lock-table: distributed_lockquery-limit: 1000 #查询全局事务一次的最大条数(默认100)max-wait: 5000 #获取连接时最大等待时间ms(默认5000ms)metrics:enabled: falseregistry-type: compactexporter-list: prometheusexporter-prometheus-port: 9898transport:rpc-tc-request-timeout: 15000enable-tc-server-batch-send-response: falseshutdown:wait: 3thread-factory:boss-thread-prefix: NettyBossworker-thread-prefix: NettyServerNIOWorkerboss-thread-size: 1

1.2.3 Docker部署

        拉取seata镜像

docker pull seataio/seata-server

        创建seata容器(命令行创建)

docker run --name seata_container \
-p 8099:8099 \
-p 7099:7090 \
--restart=always \
--network sunner_network \
-e SEATA_IP=123.123.123.123 \
-e SEATA_PORT=8099 \
-v /root/docker_seata/application.yml:/seata-server/resources/application.yml \
-v /root/docker_seata/logs:/root/logs \
-d \
seataio/seata-server:latest

        创建seata容器(compose文件创建)

service:seata:image: seataio/seata-servercontainer_name: seata_containerrestart: always  #自动重启ports:- "8099:8099" #微服务与seata连接- "7099:7099" #web控制台environment:SEATA_IP: 123.123.123.123 #seata所在地址SEATA_PORT: 8099volumes:- "/root/docker_seata/application.yml:/seata-server/resources/application.yml"  #日志- "/root/docker_seata/logs:/root/logs"  #项目目录networks:- sunner_network

2 微服务继承seata

2.1 引入依赖

<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

2.2 微服务配置添加seata

        在nacos中新建shar-seata.yaml文件,用于保存seata配置

seata:registry: #注册中心的配置,微服务根据这些信息去注册中心获取TC服务地址type: nacos #注册中心类型-nacosnacos:server-addr: 106.13.228.161:8848namespace: "" #不写默认publicgroup: DEFAULT_GROUPapplication: seata-server #seata服务名,在nacos注册的服务名#username: nacos #nacos帐号(nacos开启鉴权才填)#password: nacos #nacos密码(nacos开启鉴权才填)tx-service-group: txg #事务组名称(集群)service:vgroup-mapping: #事务组与TC集群的映射关系txg: "default"#txg2: "abc"#txg3: "bbb"data-source-proxy-mode: AT #默认AT模式

        在对应的微服务bootstrp.yaml引入nacos中的seata共享配置share-seata.yaml

spring:cloud:nacos:config:file-extension: yaml #文件后缀名/配置格式shared-configs: #共享配置- data-id: share-seata.yaml

3 XA模式

3.1 XA模式流程

        一阶段:

                ① RM注册分支事务到TC

                ② RM执行分支事务业务sql,但不提交(会锁定数据库)

                ③ RM报告执行状态到TC

        二阶段:

                ① TC检测各分支事务执行状态

                        如果都成功,通知所有RM提交事务

                        如果有失败,通知所有RM回滚事务

                ② RM接收TC命令(提交或回滚)

3.2 XA模式优缺点

        优点:●满足事务的强一致性

                ●实现简单,没有代码侵入

                ●利用数据库机制回滚(常用数据库都支持)

        缺点:●因为一阶段需要锁定数据库,要等二阶段结束才释放,性能较差

                ●依赖关系型数据库

3.3 XA模式的使用

        修改需要使用seata的微服务的bootstrap.yaml(或application.yaml),也可以修改nacos的shar-seata.yaml

seata:data-source-proxy-mode: XA #默认AT模式

        在"全局事务"入口的方法上添加@GlobalTransactional注解

        在其他微服务的"分支事务"方法上添加@Transactional注解

4 AT模式(默认)

4.1 AT模式流程

        一阶段:

                ① RM注册分支事务

                ② 记录undo-log(数据快照)

                ③ 执行业务sql并提交

                ④ 报告事务状态

        二阶段:

                RM提交,删除undo-log数据

                RM回滚,根据undo-log恢复数据到更新前

4.2 AT模式优缺点

        优点:●AT模式一阶段直接提交,不锁定资源,性能高

                ●利用数据快照undo-log回滚

        缺点:●不能满足事务强一致性

4.3 AT模式的使用

        修改需要使用seata的微服务的bootstrap.yaml(或application.yaml),也可以修改nacos的shar-seata.yaml

seata:data-source-proxy-mode: AT #默认AT模式

        在需要接入seata的微服务对应的数据库中新建undo_log表(XA模式不需要此表,AT模式需要此表)  《见1.2.1》

        在"全局事务"入口的方法上添加@GlobalTransactional注解

        在其他微服务的"分支事务"方法上添加@Transactional注解

http://www.dtcms.com/a/514554.html

相关文章:

  • 新手建站织梦网站添加视频教程
  • drupal网站建设数据库不改域名和空间 只改网站类型
  • 网站开发工作难吗秀网站
  • 如何让新网站快速收录机械公司网站源码
  • 网站与公众号的区别wordpress大前端美化版
  • 衡水seo_衡水网站建设-燕丰收郑州发布
  • 专门做985招聘信息的网站将网站打造成
  • 东源县住房和城乡建设部网站dedecms游戏门户网站源码
  • 佛山做外贸网站方案网站开发课程报告心得
  • 网站建设电销话术开场白新闻类的网站如何做优化
  • 网站后台添加图片链接网站怎么做维护
  • 建设网站服务器网站建设推广用兴田德润
  • 电子商务网站建设概念wordpress百度收录优化
  • 北京建机网站手机网站开发培训
  • 建立网站目录结构的原则找国外客户用哪个平台
  • 天津网站免费制作平顶山哪里有做网站的公司
  • 用织梦做的网站做网站都需要什么技术
  • 毕设做网站有什么题目网站的建设方法不包括什么问题
  • 学习网站后台维护邢台网站制作哪家好
  • 烟台网站制作人才招聘建设内部网站
  • 为什么做的网站在浏览器搜不到朋友圈网页怎么制作
  • 网站建设 新手从做网贷网站多少钱
  • 广州皮具网站建设筑站网络推广
  • 佛山建设工程信息网站苏州网站建设与网络营销
  • 给客户做一个网站ppt怎么做石家庄哪里能做门户网站的
  • 做打鱼网站犯法不毕业设计网站建设体会
  • 发软文的网站wordpress钉钉登陆
  • 公司做网站的目的服装网站建设企业需求调查
  • 龙华网站制作天津建立网站营销设计
  • mvc5网站开发哪个网站银锭专业做银锭的