shardingsphered 线程安全问题示例分析
shardingsphere
shardingsphere 版本 3.1.0 ,也是目前的最新的正式版,项目并发量很高很笨重(启动较慢),且使用了按天分表策略,在使用 shardingsphere 的过程中发现其存在分表策略的线程安全问题,会导致分表策略没有执行,直接查询的没有分表策略的逻辑表。
原因:
io.shardingsphere.core.parsing.antlr.extractor.impl.FromWhereExtractor
实现类定义
public final class FromWhereExtractor implements OptionalSQLSegmentExtractor {
private final TableNameExtractor tableNameExtractor = new TableNameExtractor();
private PredicateExtractor predicateSegmentExtractor;
...
public Optional<FromWhereSegment> extract(final ParserRuleContext ancestorNode, final ParserRuleContext rootNode) {
...
predicateSegmentExtractor = new PredicateExtractor(result.getTableAliases());
...
}
...这个地方 predicateSegmentExtractor 是有线程安全问题的。
并发量高的时候,predicateSegmentExtractor 成为竞争资源。
现象分析
这导致的现象是:
应用启动后分表策略不起效果,且是随机性的,假设有 20 个应用节点,应用重启之后,其中会有一个或者少量节点会出现分表策略无效,查询不到结果,再针对这个节点进行重启就会恢复正常,随机性极高。
不仅仅是我们遇到这个问题,有别的研发公司也遇到过这种问题:
https://github.com/apache/shardingsphere/issues/1967
以上就是shardingsphered 线程安全问题示例分析的详细内容,更多关于shardingsphered 线程安全的资料请关注脚本之家其它相关文章!
相关文章
java servlet手机app访问接口(一)数据加密传输验证
这篇文章主要为大家详细介绍了java servlet手机app访问接口(一),数据加密传输验证,具有一定的参考价值,感兴趣的小伙伴们可以参考一下2016-12-12
Spring Boot教程之利用ActiveMQ实现延迟消息
这篇文章主要给大家介绍了关于Spring Boot教程之利用ActiveMQ实现延迟消息的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Spring Boot具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧2019-11-11
Java工具之ja-netfilter 2022.1 配置教程
这篇文章主要介绍了Java工具之ja-netfilter 2022.1 配置教程,本防火墙基于javaagent,所以目前只有基于java的程序能够使用,需要的朋友可以参考下2022-04-04
WebClient抛UnsupportedMediaTypeException异常解决
这篇文章主要为大家介绍了WebClient抛UnsupportedMediaTypeException异常的解决方案,文中给大家介绍了六中方案,有需要的朋友可以借鉴参考下,希望能够有所帮助2022-02-02


最新评论