지역 사회 배우다 도구 라이브러리 여가
찾다
한국어
집 > Java > java지도 시간 > 본문

Java Seata의 배포 및 통합 방법은 무엇입니까?

WBOY
풀어 주다： 2023-05-14 14:55:06
앞으로
755명이 탐색했습니다.

sata 배포 및 통합

1. Seata의 tc-server 배포

1) 다운로드

먼저 Seata-server 패키지를 다운로드해야 합니다.

java seata部署和集成的方法是什么

2) 압축을 푼다

중국어 디렉터리, 해당 디렉터리 구조는 다음과 같습니다:

java seata部署和集成的方法是什么

3) 구성 수정

conf 디렉터리의 Registry.conf 파일 수정:

java seata部署和集成的方法是什么

내용은 다음과 같습니다. 

registry {
  # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
  type = "nacos"

  nacos {
    # seata tc 服务注册到 nacos的服务名称，可以自定义
    application = "seata-tc-server"
    serverAddr = "127.0.0.1:8848"
    group = "DEFAULT_GROUP"
    namespace = ""
    cluster = "SH"
    username = "nacos"
    password = "nacos"
  }
}

config {
  # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
  type = "nacos"
  # 配置nacos地址等信息
  nacos {
    serverAddr = "127.0.0.1:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
    dataId = "seataServer.properties"
  }
}
로그인 후 복사
4) 추가 nacos의 구성

특별한 주의: TC 서비스 클러스터가 구성을 공유할 수 있도록 하기 위해 nacos를 통합 구성 센터로 선택했습니다. 따라서 서버 구성 파일인 SeataServer.properties 파일을 nacos에서 구성해야 합니다.

형식은 다음과 같습니다.

java seata部署和集成的方法是什么

구성 내용은 다음과 같습니다. 

# 数据存储方式，db代表数据库
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
# 事务、日志等配置
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000

# 客户端与服务端传输方式
transport.serialization=seata
transport.compressor=none
# 关闭metrics功能，提高性能
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898
로그인 후 복사

데이터베이스 주소, 사용자 이름, 비밀번호는 자신의 데이터베이스 정보로 수정해야 합니다.

5) 데이터베이스 테이블 생성

특별 참고 사항: tc 서비스가 분산 트랜잭션을 관리할 때 트랜잭션 관련 데이터를 데이터베이스에 기록해야 합니다. 이러한 테이블을 미리 생성해야 합니다.

sata라는 새 데이터베이스를 생성하고 사전 수업 자료에서 제공하는 sql 파일을 실행합니다.

java seata部署和集成的方法是什么

이 테이블에는 주로 글로벌 트랜잭션, 지점 트랜잭션 및 글로벌 잠금 정보가 기록됩니다. 

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- 分支事务表
-- ----------------------------
DROP TABLE IF EXISTS `branch_table`;
CREATE TABLE `branch_table`  (
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `transaction_id` bigint(20) NULL DEFAULT NULL,
  `resource_group_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `resource_id` varchar(256) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `branch_type` varchar(8) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `status` tinyint(4) NULL DEFAULT NULL,
  `client_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `gmt_create` datetime(6) NULL DEFAULT NULL,
  `gmt_modified` datetime(6) NULL DEFAULT NULL,
  PRIMARY KEY (`branch_id`) USING BTREE,
  INDEX `idx_xid`(`xid`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

-- ----------------------------
-- 全局事务表
-- ----------------------------
DROP TABLE IF EXISTS `global_table`;
CREATE TABLE `global_table`  (
  `xid` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `transaction_id` bigint(20) NULL DEFAULT NULL,
  `status` tinyint(4) NOT NULL,
  `application_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `transaction_service_group` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `transaction_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `timeout` int(11) NULL DEFAULT NULL,
  `begin_time` bigint(20) NULL DEFAULT NULL,
  `application_data` varchar(2000) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `gmt_create` datetime NULL DEFAULT NULL,
  `gmt_modified` datetime NULL DEFAULT NULL,
  PRIMARY KEY (`xid`) USING BTREE,
  INDEX `idx_gmt_modified_status`(`gmt_modified`, `status`) USING BTREE,
  INDEX `idx_transaction_id`(`transaction_id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

SET FOREIGN_KEY_CHECKS = 1;
로그인 후 복사
6) TC 서비스를 시작합니다.

bin 디렉토리에 들어가서 Seata-server.bat를 실행하세요.

java seata部署和集成的方法是什么

성공적으로 시작되면 Seata-server가 nacos 등록 센터에 등록되어 있어야 합니다.

브라우저를 열고 nacos 주소: http://localhost:8848를 방문한 후 서비스 목록 페이지에 들어가면 Seata-tc-server 정보를 볼 수 있습니다:

java seata部署和集成的方法是什么

2. 마이크로서비스 통합 Seata 1 ) 종속성 소개

1) 종속성 소개

먼저 마이크로서비스에 Seata 종속성을 도입해야 합니다. 

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
    <exclusions>
        <!--版本较低，1.3.0，因此排除-->
        <exclusion>
            <artifactId>seata-spring-boot-starter</artifactId>
            <groupId>io.seata</groupId>
        </exclusion>
    </exclusions>
</dependency>
<!--seata starter 采用1.4.2版本-->
<dependency>
    <groupId>io.seata</groupId>
    <artifactId>seata-spring-boot-starter</artifactId>
    <version>${seata.version}</version>
</dependency>
로그인 후 복사
2) 구성 파일을 수정합니다.

application.yml 파일을 수정하고 일부 구성을 추가해야 합니다. 

seata:
  registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
    # 参考tc服务自己的registry.conf中的配置
    type: nacos
    nacos: # tc
      server-addr: 127.0.0.1:8848
      namespace: ""
      group: DEFAULT_GROUP
      application: seata-tc-server # tc服务在nacos中的服务名称
      cluster: SH
  tx-service-group: seata-demo # 事务组，根据这个获取tc服务的cluster名称
  service:
    vgroup-mapping: # 事务组与TC服务cluster的映射关系
      seata-demo: SH
로그인 후 복사

3. TC 서비스 높음 사용 가능 및 오프사이트 재해 복구 1) 오프사이트 재해 복구를 위한 TC 클러스터 시뮬레이션

1) 오프사이트 재해 복구를 위한 TC 클러스터 시뮬레이션

2개의 Seata TC 서비스 노드 시작 계획:

노드 이름ip 주소 포트 번호클러스터 이름
seata127.0.0.18091SH
seata2127.0.0.18 092 HZ

A Seata 서비스 이전에 시작했는데 포트는 8091, 클러스터 이름은 SH입니다.

이제, Seata 디렉토리를 복사하고 이름을 Seata2로 지정합니다.

seat2/conf/registry.conf의 내용을 다음과 같이 수정합니다. 

registry {
  # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
  type = "nacos"

  nacos {
    # seata tc 服务注册到 nacos的服务名称，可以自定义
    application = "seata-tc-server"
    serverAddr = "127.0.0.1:8848"
    group = "DEFAULT_GROUP"
    namespace = ""
    cluster = "HZ"
    username = "nacos"
    password = "nacos"
  }
}

config {
  # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
  type = "nacos"
  # 配置nacos地址等信息
  nacos {
    serverAddr = "127.0.0.1:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
    dataId = "seataServer.properties"
  }
}
로그인 후 복사

seata2/bin 디렉토리에 들어가서 다음 명령을 실행합니다. 

seata-server.bat -p 8092
로그인 후 복사

nacos 열기 콘솔을 열고 서비스 목록을 확인하세요:

java seata部署和集成的方法是什么

자세한 내용을 보려면 클릭하세요:

java seata部署和集成的方法是什么

2) nacos에 대한 트랜잭션 그룹 매핑 구성

다음으로 tx-service-group과 클러스터-nacos 구성 간의 매핑 관계를 구성해야 합니다. 센터.

새 구성 만들기:

java seata部署和集成的方法是什么

구성 내용은 다음과 같습니다.

# 事务组映射关系
service.vgroupMapping.seata-demo=SH

service.enableDegrade=false
service.disableGlobalTransaction=false
# 与TC服务的通信配置
transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.enableClientBatchSendRequest=false
transport.threadFactory.bossThreadPrefix=NettyBoss
transport.threadFactory.workerThreadPrefix=NettyServerNIOWorker
transport.threadFactory.serverExecutorThreadPrefix=NettyServerBizHandler
transport.threadFactory.shareBossWorker=false
transport.threadFactory.clientSelectorThreadPrefix=NettyClientSelector
transport.threadFactory.clientSelectorThreadSize=1
transport.threadFactory.clientWorkerThreadPrefix=NettyClientWorkerThread
transport.threadFactory.bossThreadSize=1
transport.threadFactory.workerThreadSize=default
transport.shutdown.wait=3
# RM配置
client.rm.asyncCommitBufferLimit=10000
client.rm.lock.retryInterval=10
client.rm.lock.retryTimes=30
client.rm.lock.retryPolicyBranchRollbackOnConflict=true
client.rm.reportRetryCount=5
client.rm.tableMetaCheckEnable=false
client.rm.tableMetaCheckerInterval=60000
client.rm.sqlParserType=druid
client.rm.reportSuccessEnable=false
client.rm.sagaBranchRegisterEnable=false
# TM配置
client.tm.commitRetryCount=5
client.tm.rollbackRetryCount=5
client.tm.defaultGlobalTransactionTimeout=60000
client.tm.degradeCheck=false
client.tm.degradeCheckAllowTimes=10
client.tm.degradeCheckPeriod=2000

# undo日志配置
client.undo.dataValidation=true
client.undo.logSerialization=jackson
client.undo.onlyCareUpdateColumns=true
client.undo.logTable=undo_log
client.undo.compress.enable=true
client.undo.compress.type=zip
client.undo.compress.threshold=64k
client.log.exceptionRate=100
로그인 후 복사
3) 마이크로서비스는 nacos 구성을 읽습니다

다음으로 마이크로서비스가 허용되도록 각 마이크로서비스의 application.yml 파일을 수정해야 합니다. nacos를 읽으려면 

seata:
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      username: nacos
      password: nacos
      group: SEATA_GROUP
      data-id: client.properties
로그인 후 복사

마이크로 서비스를 다시 시작하세요. 이제 마이크로 서비스가 tc의 SH 클러스터 또는 tc의 HZ 클러스터에 연결되는지 여부는 nacos의 client.properties에 의해 결정됩니다.

lient.log.ExceptionRate=100

## 3.微服务读取nacos配置

接下来，需要修改每一个微服务的application.yml文件，让微服务读取nacos中的client.properties文件：

```yaml
seata:
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      username: nacos
      password: nacos
      group: SEATA_GROUP
      data-id: client.properties
로그인 후 복사

마이크로 서비스를 다시 시작하세요. 이제 마이크로 서비스가 tc의 SH 클러스터에 연결되는지 tc의 HZ 클러스터에 연결되는지 여부는 nacos의 client.properties에 의해 결정됩니다.

위 내용은 Java Seata의 배포 및 통합 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨：
java seata
원천：yisu.com
이전 기사：Java 디자인 패턴 템플릿 방법 예시 분석 다음 기사：springboot에서 비동기 작업을 구현하는 방법
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
최신 이슈
자동 반올림 없이 JavaScript에서 문자열을 19자리 숫자로 변환하는 방법은 무엇입니까? 숫자로 변환하려는 경우 문자열 입력 숫자 input="6145390195186705543"(6145390195186705000)이 있습니다.
에서 2024-03-30 14:42:35
0
1
367
관련 주제
더>
인기 추천
인기 튜토리얼
더>
관련 튜토리얼
인기 추천
최신 강좌
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿