seata笔记

本文主要是介绍seata笔记，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

seata笔记

seata的安装和启动

1. seata的下载地址
   https://github.com/seata/seata/releases
   里面都是linux、windows都同时可以用的绿色版安装包
   直接双击seata-server.bat就可以默认启动，默认端口为8091,如果想修改端口，也可以用配置项启动,如下<2>

2. seata的启动
   启动命令详解

Options:--host, -hThe host to bind.Default: 0.0.0.0--port, -pThe port to listen.Default: 8091--storeMode, -mlog store mode : file、dbDefault: file--help

例如需要修改默认端口:

seata-server.bat -p 18091
sh seata-server.sh -p 18091

不过linux中默认不会后台启动，需要启动命令支持一下：

nohup sh seata-server.sh -p 18091 > catalina.out 2>&1 &

源码的导入

在导入源码的过程中由于seata-serializer-protobuf工程采用了

<plugin><groupId>org.xolstice.maven.plugins</groupId><artifactId>protobuf-maven-plugin</artifactId><version>${protobuf-maven-plugin.version}</version><configuration><protoSourceRoot>${project.basedir}/src/main/resources/protobuf/io/seata/protocol/transcation/</protoSourceRoot><protocArtifact>com.google.protobuf:protoc:3.3.0:exe:${os.detected.classifier}</protocArtifact></configuration><executions><execution><goals><goal>compile</goal></goals></execution></executions></plugin>

插件来生产相关代码,而当工程路径太长时,或者有中文时,编译会失败,这是换用合理的路径下进行打包编译,然后在将编译后生成的代码拷贝到特定目录,当然也可以不用导入该工程,因为seata使用了很多序列化技术,选择其他的就可以了,默认是jackson序列化

seata的配置

seata的核心配置加载类是ConfigurationFactory,会经过

public static Configuration CURRENT_FILE_INSTANCE;static {load();}

和

private static volatile Configuration instance = null;/*** Gets instance.** @return the instance*/public static Configuration getInstance() {if (instance == null) {synchronized (Configuration.class) {if (instance == null) {instance = buildConfiguration();}}}return instance;}

为什么会进行两次加载,这是为了配置名称实现spi机制的扩展,代码如下

String configTypeName = CURRENT_FILE_INSTANCE.getConfig(ConfigurationKeys.FILE_ROOT_CONFIG + ConfigurationKeys.FILE_CONFIG_SPLIT_CHAR+ ConfigurationKeys.FILE_ROOT_TYPE);

所有配置的代理入口

• 第一级入口

ConfigurationCache.getInstance().proxy(...)

• 第二级入口

public class SpringBootConfigurationProvider implements ExtConfigurationProvider {private static final String INTERCEPT_METHOD_PREFIX = "get";@Overridepublic Configuration provide(Configuration originalConfiguration) {return (Configuration) Enhancer.create(originalConfiguration.getClass(), new MethodInterceptor() {@Overridepublic Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy)throws Throwable {if (method.getName().startsWith(INTERCEPT_METHOD_PREFIX) && args.length > 0) {Object result = null;String rawDataId = (String) args[0];...}return method.invoke(originalConfiguration, args);}});}
}

与spring boot的集成

maven依赖

<dependency><groupId>io.seata</groupId><artifactId>seata-spring-boot-starter</artifactId><version>${seata.version}</version>
</dependency>

所有配置在file.conf和registry.conf中的配置都可以使用spring boot的配置代替,例如如下application.yml配置案例

seata: registry: type: filetxServiceGroup: my_provider_groupconfig: type: file# file: # 经过调试得知 这个 config.file.name仅仅是一个名称而已,暂时认为没有实际的作用# name: ${user.dir}/config/file.confservice: vgroupMapping: my_provider_group: default# 这里与file.conf中有些不一样grouplist: default: wulinThinkPad:8091disableGlobalTransaction: false

自动创建DataSource的代理配置没有生效

在与spring boot的集成中,创建DataSource代理有三种方式
1. 手动创建,例如如下

@Primary
@Bean("dataSourceProxy")
public DataSource dataSourceProxy(DataSource dataSource) {DataSourceProxy dataSourceProxy = new DataSourceProxy(dataSource);return dataSourceProxy;
}

1. 启动类或者某个我们自己配置类上使用@EnableAutoDataSourceProxy

@Configuration
@EnableAutoDataSourceProxy
public class SeataConfiguration {}

1. 使用spring boot的自动配置方式

@ConditionalOnBean(DataSource.class)
@ConditionalOnExpression("${seata.enable:true} && ${seata.enableAutoDataSourceProxy:true} && ${seata.enable-auto-data-source-proxy:true}")
public class SeataDataSourceAutoConfiguration {
...
}

这个方式中要求DataSource的bean要存在,默认情况下如果我们使用DataSourceAutoConfiguration来构建我们的dataSource,那是没有问题的,但如果是我们自己构建的而且没有采用spring boot的自动配置方式,并且将DataSourceAutoConfiguration给排除了,例如如下

@Configuration
public class DBConfig {/*** 配置druid datasource*/@Bean(initMethod = "init", destroyMethod = "close")public DataSource dataSource() throws Exception{buildDs(props);return dataSource;}
}

我们可以看到这个DataSource,只是一个普通bean,正常情况下不会被提前实例化,因此SeataDataSourceAutoConfiguration因为不满足@ConditionalOnBean(DataSource.class)这个条件,所以才不生效

spring boot是如何使用DataSourceAutoConfiguration创建通用DataSource的

@Configuration
@ConditionalOnClass({ DataSource.class, EmbeddedDatabaseType.class })
@EnableConfigurationProperties(DataSourceProperties.class)
@Import({ Registrar.class, DataSourcePoolMetadataProvidersConfiguration.class })
public class DataSourceAutoConfiguration {@Configuration@Conditional(PooledDataSourceCondition.class)@ConditionalOnMissingBean({ DataSource.class, XADataSource.class })@Import({ DataSourceConfiguration.Tomcat.class, DataSourceConfiguration.Hikari.class,DataSourceConfiguration.Dbcp.class, DataSourceConfiguration.Dbcp2.class,DataSourceConfiguration.Generic.class })@SuppressWarnings("deprecation")protected static class PooledDataSourceConfiguration {}
}

上面代码创建通用DataSource的配置类是DataSourceConfiguration.Generic.class,我们来看看该类

abstract class DataSourceConfiguration {/*** Generic DataSource configuration.*/@ConditionalOnMissingBean(DataSource.class)@ConditionalOnProperty(name = "spring.datasource.type")static class Generic {@Beanpublic DataSource dataSource(DataSourceProperties properties) {return properties.initializeDataSourceBuilder().build();}}
}

我们可以看到要该类生效的条件必须要在application.yml配置文件中配置spring.datasource.type的key

这篇关于seata笔记的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---