Spring整合mybatis中的sqlSession是如何做到线程隔离的?

转载自  Spring整合mybatis中的sqlSession是如何做到线程隔离的?

项目中常常使用mybatis配合spring进行数据库操作,但是我们知道,数据的操作是要求做到线程安全的,而且按照原来的jdbc的使用方式,每次操作完成之后都要将连接关闭,但是实际使用中我们并没有这么干。

更让人疑惑的点是,spring中默认使用单例形式来加载bean,而往往我们也不会改变这种默认,所以,是所有线程共享数据连接?

让我们来看看真相!

自然是要个栗子的:

我们来看下spring中配置mybatis数据库操作bean(使用 druid 连接池):

    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"><property name="url" value="${jdbc.url}" /><property name="driverClassName" value="${jdbc.driver}" /><property name="username" value="${jdbc.username}" /><property name="password" value="${jdbc.password}" /></bean><bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSource" /><property name="configLocation" value="classpath:mybatis-config.xml" /></bean><!-- scope="prototype" 另说,另讨论,我们先以mapper形式看一下 --><bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate"><constructor-arg index="0" ref="sqlSessionFactory" /></bean><!-- 事务 --><bean name="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"></property></bean>

而在java代码中使用则是使用依赖注入直接使用 @resource sqlSession, 如下:

    @Resourceprivate SqlSessionTemplate sqlSession;@Overridepublic User getUser(Map<String, String> cond) {// 此句执行db查询User result = sqlSession.selectOne(NAME_SPACE+ ".getUser", cond);return result;}

这个sqlSession就是直接去操作数据库了看起来是这样,是在bean初始化的时候依赖注入的!

所以,难道每次进入该操作的时候,sqlSession 的实例都会变化吗?答案是否定的。

那么,肯定就是往下使用的时候才发生的变化呗!

再往下走,可以看到,调用了一个代理来进行具体的查询!

  // org/mybatis/spring/SqlSessionTemplate.selectOne()public <T> T selectOne(String statement, Object parameter) {return this.sqlSessionProxy.<T> selectOne(statement, parameter);}

为啥要用代理呢?自己直接查不就行了吗?其实,用代理是有好处的,那就可以可以进行另外的包装!

代理是怎么生成的呢?其实只要看一下 SqlSessionTemplate 的构造方法就知道了!

/*** Constructs a Spring managed {@code SqlSession} with the given* {@code SqlSessionFactory} and {@code ExecutorType}.* A custom {@code SQLExceptionTranslator} can be provided as an* argument so any {@code PersistenceException} thrown by MyBatis* can be custom translated to a {@code RuntimeException}* The {@code SQLExceptionTranslator} can also be null and thus no* exception translation will be done and MyBatis exceptions will be* thrown** @param sqlSessionFactory* @param executorType* @param exceptionTranslator*/public SqlSessionTemplate(SqlSessionFactory sqlSessionFactory, ExecutorType executorType,PersistenceExceptionTranslator exceptionTranslator) {notNull(sqlSessionFactory, "Property 'sqlSessionFactory' is required");notNull(executorType, "Property 'executorType' is required");this.sqlSessionFactory = sqlSessionFactory;this.executorType = executorType;this.exceptionTranslator = exceptionTranslator;// 生成代理 SqlSessionInterceptor 为 InvocationHandlerthis.sqlSessionProxy = (SqlSession) newProxyInstance(SqlSessionFactory.class.getClassLoader(),new Class[] { SqlSession.class },new SqlSessionInterceptor());}

从上面的代码,看不到细节,但是,大致还是知道代理的具体实现了!即使用 SqlSessionInterceptor 去处理具体查询逻辑!

我们来看下 SqlSessionInterceptor 的实现!

/*** Proxy needed to route MyBatis method calls to the proper SqlSession got* from Spring's Transaction Manager* It also unwraps exceptions thrown by {@code Method#invoke(Object, Object...)} to* pass a {@code PersistenceException} to the {@code PersistenceExceptionTranslator}.*/private class SqlSessionInterceptor implements InvocationHandler {public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {SqlSession sqlSession = getSqlSession(SqlSessionTemplate.this.sqlSessionFactory,SqlSessionTemplate.this.executorType,SqlSessionTemplate.this.exceptionTranslator);try {Object result = method.invoke(sqlSession, args);if (!isSqlSessionTransactional(sqlSession, SqlSessionTemplate.this.sqlSessionFactory)) {// force commit even on non-dirty sessions because some databases require// a commit/rollback before calling close()sqlSession.commit(true);}return result;} catch (Throwable t) {Throwable unwrapped = unwrapThrowable(t);if (SqlSessionTemplate.this.exceptionTranslator != null && unwrapped instanceof PersistenceException) {// release the connection to avoid a deadlock if the translator is no loaded. See issue #22closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);sqlSession = null;Throwable translated = SqlSessionTemplate.this.exceptionTranslator.translateExceptionIfPossible((PersistenceException) unwrapped);if (translated != null) {unwrapped = translated;}}throw unwrapped;} finally {if (sqlSession != null) {closeSqlSession(sqlSession, SqlSessionTemplate.this.sqlSessionFactory);}}}}

SqlSessionInterceptor 是 SqlSessionTemplate 的内部类,目的只有一个,就是处理多个 session 的db操作!

所有请求都被 invoke() 拦截,从而做相应处理:

  • 进入请求,先生成一个新的sqlSession,为本次db操作做准备;

  • 通过反射调用请求进来的方法,将 sqlSession 回调,进行复杂查询及结果映射;

  • 如果需要立即提交事务,do it;

  • 如果出现异常,包装异常信息,重新抛出;

  • 操作完成后,关闭本次session;

到这里,其实我们好像已经明白了,其实外面的 sqlSession 单例,并不会影响具体的db操作控制,所以不用担心session的线程安全问题!

不过,还有个点值得考虑下,如果我一次请求里有多次数据库操作,难道我真的要创建多个sqlSession或者说数据库连接?不会吧!

如果这个问题得不到解决,可能你并不真正了解session的定义了!

所以我们需要继续看一下 session 到底是怎么获取的?

getSqlSession() 方法是在 SqlSessionUtils 中实现的!如下:

/*** Gets an SqlSession from Spring Transaction Manager or creates a new one if needed.* Tries to get a SqlSession out of current transaction. If there is not any, it creates a new one.* Then, it synchronizes the SqlSession with the transaction if Spring TX is active and* <code>SpringManagedTransactionFactory</code> is configured as a transaction manager.** @param sessionFactory a MyBatis {@code SqlSessionFactory} to create new sessions* @param executorType The executor type of the SqlSession to create* @param exceptionTranslator Optional. Translates SqlSession.commit() exceptions to Spring exceptions.* @throws TransientDataAccessResourceException if a transaction is active and the*             {@code SqlSessionFactory} is not using a {@code SpringManagedTransactionFactory}* @see SpringManagedTransactionFactory*/public static SqlSession getSqlSession(SqlSessionFactory sessionFactory, ExecutorType executorType, PersistenceExceptionTranslator exceptionTranslator) {notNull(sessionFactory, "No SqlSessionFactory specified");notNull(executorType, "No ExecutorType specified");SqlSessionHolder holder = (SqlSessionHolder) TransactionSynchronizationManager.getResource(sessionFactory);// 如果已经有holder,则直接返回,复用连接if (holder != null && holder.isSynchronizedWithTransaction()) {if (holder.getExecutorType() != executorType) {throw new TransientDataAccessResourceException("Cannot change the ExecutorType when there is an existing transaction");}holder.requested();if (logger.isDebugEnabled()) {logger.debug("Fetched SqlSession [" + holder.getSqlSession() + "] from current transaction");}return holder.getSqlSession();}if (logger.isDebugEnabled()) {logger.debug("Creating a new SqlSession");}SqlSession session = sessionFactory.openSession(executorType);// Register session holder if synchronization is active (i.e. a Spring TX is active)//// Note: The DataSource used by the Environment should be synchronized with the// transaction either through DataSourceTxMgr or another tx synchronization.// Further assume that if an exception is thrown, whatever started the transaction will// handle closing / rolling back the Connection associated with the SqlSession.if (TransactionSynchronizationManager.isSynchronizationActive()) {Environment environment = sessionFactory.getConfiguration().getEnvironment();if (environment.getTransactionFactory() instanceof SpringManagedTransactionFactory) {if (logger.isDebugEnabled()) {logger.debug("Registering transaction synchronization for SqlSession [" + session + "]");}holder = new SqlSessionHolder(session, executorType, exceptionTranslator);TransactionSynchronizationManager.bindResource(sessionFactory, holder);TransactionSynchronizationManager.registerSynchronization(new SqlSessionSynchronization(holder, sessionFactory));holder.setSynchronizedWithTransaction(true);holder.requested();} else {if (TransactionSynchronizationManager.getResource(environment.getDataSource()) == null) {if (logger.isDebugEnabled()) {logger.debug("SqlSession [" + session + "] was not registered for synchronization because DataSource is not transactional");}} else {throw new TransientDataAccessResourceException("SqlSessionFactory must be using a SpringManagedTransactionFactory in order to use Spring transaction synchronization");}}} else {if (logger.isDebugEnabled()) {logger.debug("SqlSession [" + session + "] was not registered for synchronization because synchronization is not active");}}return session;}

如上获取 sqlSession 逻辑,主要分两种情况!

  1. 如果存在holder,则返回原有的sqlSession,到于这个holder我们稍后再说;

  2. 如果没有,则创建一个新连接!

所以,看起来情况还不是太糟,至少有复用的概念了!

那么问题来了,复用?如何做到线程安全?所以我们要看下 SqlSessionHolder 的实现了!

获取holder是通过 TransactionSynchronizationManager.getResource(sessionFactory); 获取的:

public static Object getResource(Object key) {Object actualKey = TransactionSynchronizationUtils.unwrapResourceIfNecessary(key);// 实际获取Object value = doGetResource(actualKey);if (value != null && logger.isTraceEnabled()) {logger.trace("Retrieved value [" + value + "] for key [" + actualKey + "] bound to thread [" +Thread.currentThread().getName() + "]");}return value;}private static Object doGetResource(Object actualKey) {Map<Object, Object> map = resources.get();if (map == null) {return null;}Object value = map.get(actualKey);// Transparently remove ResourceHolder that was marked as void...if (value instanceof ResourceHolder && ((ResourceHolder) value).isVoid()) {map.remove(actualKey);// Remove entire ThreadLocal if empty...if (map.isEmpty()) {resources.remove();}value = null;}return value;}

咱们忽略对 key 的处理,实际是直接调用 doGetResource() 获取holder。而 doGetResource() 中,则使用了 resources 来保存具体的 kv。 resources 明显是个共享变量,但是看起来这里没有任何的加锁操作!这是为何?

只要看一下 resources 的定义就知道了,其实现为 ThreadLocal, 所以是线程安全了!

private static final ThreadLocal<Map<Object, Object>> resources =new NamedThreadLocal<Map<Object, Object>>("Transactional resources");

在新的请求进来时,自然是没有值的,所以直接返回null.而后续进入,则获取缓存返回!

而对于没有获取到 holder 的情况,则需要重新创建一个 session 了!

这里获取session由DefaultSqlSessionFactory 进行创建!如下:

// org.apache.ibatis.session.defaults.DefaultSqlSessionFactory.openSession()public SqlSession openSession(ExecutorType execType) {return openSessionFromDataSource(execType, null, false);}private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {Transaction tx = null;try {final Environment environment = configuration.getEnvironment();// SpringManagedTransactionFactoryfinal TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);final Executor executor = configuration.newExecutor(tx, execType);return new DefaultSqlSession(configuration, executor, autoCommit);} catch (Exception e) {closeTransaction(tx); // may have fetched a connection so lets call close()throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);} finally {ErrorContext.instance().reset();}}

创建 session 几件事:

  • 根据环境配置,开启一个新事务,该事务管理器会负责后续jdbc连接管理工作;

  • 根据事务创建一个 Executor,备用;

  • 用DefaultSqlSession 将 executor 包装后返回,用于后续真正的db操作;

至此,真正的 sqlSession 已经创建成功!返回后,就可以真正使用了!

等等,创建的session好像并没有保存,那么还是那个问题,每个sql都会创建一个 sqlSession ? 好吧,是这样的!前面的holder,只是用于存在事务操作的连接!(holder的理解出了偏差哦)

但是有一点,这里虽然创建了多个 sqlSession 实例,但是并不意味着有多个db连接,具体使用db连接时,则一般会会使用连接池来进行优化!如前面提到的 druid 就是个不错的选择!

真实的jdbc连接获取,是在进行真正的 query 时,才进行调用 getConnection() 进行接入!

具体则是在 doQuery() 时,进行st的组装时调用的 ,如下:

// SimpleExecutor.prepareStatement()private Statement prepareStatement(StatementHandler handler, Log statementLog) throws SQLException {Statement stmt;// 获取 jdbc 连接,返回 java.sql.ConnectionConnection connection = getConnection(statementLog);stmt = handler.prepare(connection);handler.parameterize(stmt);return stmt;}// 调用 BaseExecutor.getConnection()protected Connection getConnection(Log statementLog) throws SQLException {// SpringManagedTransaction 管理 connectionConnection connection = transaction.getConnection();if (statementLog.isDebugEnabled()) {return ConnectionLogger.newInstance(connection, statementLog, queryStack);} else {return connection;}}

通过前面通过事务管理工厂创建的 SpringManagedTransaction 进行 connection 获取!一个事务管理器只会存在一次获取数据库连接的操作!

public Connection getConnection() throws SQLException {if (this.connection == null) {openConnection();}return this.connection;}// 而 SpringManagedTransaction 又将connection交由 DataSourceUtils 进行管理!// org/springframework/jdbc/datasource/DataSourceUtilspublic static Connection getConnection(DataSource dataSource) throws CannotGetJdbcConnectionException {try {// 真正的连接获取return doGetConnection(dataSource);}catch (SQLException ex) {throw new CannotGetJdbcConnectionException("Could not get JDBC Connection", ex);}}/*** Actually obtain a JDBC Connection from the given DataSource.* Same as {@link #getConnection}, but throwing the original SQLException.* <p>Is aware of a corresponding Connection bound to the current thread, for example* when using {@link DataSourceTransactionManager}. Will bind a Connection to the thread* if transaction synchronization is active (e.g. if in a JTA transaction).* <p>Directly accessed by {@link TransactionAwareDataSourceProxy}.* @param dataSource the DataSource to obtain Connections from* @return a JDBC Connection from the given DataSource* @throws SQLException if thrown by JDBC methods* @see #doReleaseConnection*/public static Connection doGetConnection(DataSource dataSource) throws SQLException {Assert.notNull(dataSource, "No DataSource specified");ConnectionHolder conHolder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);if (conHolder != null && (conHolder.hasConnection() || conHolder.isSynchronizedWithTransaction())) {conHolder.requested();if (!conHolder.hasConnection()) {logger.debug("Fetching resumed JDBC Connection from DataSource");conHolder.setConnection(dataSource.getConnection());}return conHolder.getConnection();}// Else we either got no holder or an empty thread-bound holder here.logger.debug("Fetching JDBC Connection from DataSource");// 通过接入的dataSource进行连接获取,这里将会是最终的jdbc连接Connection con = dataSource.getConnection();if (TransactionSynchronizationManager.isSynchronizationActive()) {logger.debug("Registering transaction synchronization for JDBC Connection");// Use same Connection for further JDBC actions within the transaction.// Thread-bound object will get removed by synchronization at transaction completion.ConnectionHolder holderToUse = conHolder;if (holderToUse == null) {holderToUse = new ConnectionHolder(con);}else {holderToUse.setConnection(con);}holderToUse.requested();TransactionSynchronizationManager.registerSynchronization(new ConnectionSynchronization(holderToUse, dataSource));holderToUse.setSynchronizedWithTransaction(true);if (holderToUse != conHolder) {TransactionSynchronizationManager.bindResource(dataSource, holderToUse);}}return con;}

上面的实现主要做三件事:

  1. 再次确认,是否存在事务处理,holder是否存在,如果有则复用;

  2. 如果没有,那再从数据源处获取连接;

  3. 获取新连接成功后,检查如果存在事务,则将新获取的连接放入holder中保存起来,以备下次使用;

获取jdbc连接后,就可以真正发起execute()查询了。

数据库连接的疑问算是解答了!我们发现,外部的框架并没有多少为我们节省db连接的动作!而是把最终 getConnection() 交给 datasource 数据源!

而真正解决我们连接复用的问题的,是像 Druid 这样的连接池组件!所以,咱们可以单独来看这些中间件了!

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/323396.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Net知识图谱

对于Web系统开发来说&#xff0c;Net其实也是有好多知识点需要学的&#xff0c;虽然目前JAVA是主流&#xff0c;就业市场比较大&#xff0c;但Net也在积极的拥抱开源&#xff0c;大Net Core 2 出来了&#xff0c;这无疑给Net开发者带来更大的希望&#xff0c;好了&#xff0c;以…

域名配置https时,请求无响应的解决方法

大家好&#xff0c;我是雄雄&#xff0c;欢迎关注微信公众号&#xff1a;雄雄的小课堂。 前言 在项目需要上线时&#xff0c;我们经常会遇到这样的需求&#xff0c;将http的域名换成https&#xff0c;或者当我们使用小程序开发时&#xff0c;只支持https的请求方式&#xff0c…

三步搭建网站

这两天无意中想了解更广泛的编程知识&#xff0c;便去看了些php的视频。我想把本机当成服务器来用&#xff0c;因为事先已经注册了域名&#xff0c;但当我又重新登录腾讯云的时候&#xff0c;上面显示我可以免费领取一个15天的服务器&#xff0c;抱着试一试的心态&#xff0c;领…

USACO2.3【dfs,dp,背包】

正题 T1:最长前缀 LongestPrefixLongest PrefixLongestPrefix 评测记录: https://www.luogu.org/recordnew/lists?uid52918&pidP1470 题目大意 求有字符串集合VVV中的字符可以组成的字符串s的最长前缀。 解题思路 用fif_ifi​表示能否组成长度为i的最长前缀&#xff0c…

jenkins~集群分发功能的具体实现

前一讲主要说了jenkins分发的好处《jenkins~集群分发功能和职责处理》&#xff0c;它可以让具体的节点干自己具体的事&#xff0c;比如windows环境下的节点&#xff0c;它只负责编译&#xff0c;发布windows的生态环境的项目&#xff1b;而linux节点主要负责和它相关的项目&…

一个经典面试题:如何保证缓存与数据库的双写一致性?

转载自 一个经典面试题&#xff1a;如何保证缓存与数据库的双写一致性&#xff1f; 只要用缓存&#xff0c;就可能会涉及到缓存与数据库双存储双写&#xff0c;你只要是双写&#xff0c;就一定会有数据一致性的问题&#xff0c;那么你如何解决一致性问题&#xff1f; 面试题…

让日子充实点

html基础学习&#xff1a;jscsshtml jquery学习 php学习 实在受不了了&#xff0c;学的走火入魔了。我就搞不懂自己和文件的配置较什么劲&#xff0c;为了配置PHP和mysql。我花了太多精力。主要不是在于策略&#xff0c;方法就那一两种&#xff0c;我搞不懂自己为什么就逮这不…

2018NOIP普及组初赛解析

前言 今年因为新政策的原因导致我又得回到普及组 我们东莞的成绩也出来了&#xff0c;虽然本来就是稳进&#xff0c;但是还是要认真对待。 然而我这个菜鸡运气好了点86分 正题 这里就不放题目了&#xff0c;观看本博客之前请拿好初赛试卷 选择题 答案:D 解析:扫描仪是输出设备…

.NET十年回顾

一、 引子 从我还是编程菜鸟时起&#xff0c;.NET就从来没让我失望过。总是惊喜不断。 当年我第一个项目是做个进销存。用的Winform。当时我是机电工程师。编程只是业余心血来潮而已。 .NET的低门槛、VS良好的编程体验及MSDN完善的说明让我从此踏上了码农的不归之路。 回首十…

常用公有云接入——亚马逊

一、什么是 Amazon EC2&#xff1f; Amazon Elastic Compute Cloud (Amazon EC2) 在 Amazon Web Services (AWS) 云中提供可扩展的计算容量。使用 Amazon EC2 可避免前期的硬件投入&#xff0c;因此您能够快速开发和部署应用程序。通过使用 Amazon EC2&#xff0c;您可以根据自…

nssl1191,P2700-逐个击破(平津战役)【并查集】

正题 题目大意 一棵树n个点 有k个点被占领&#xff0c;删除每一条边都有不同的代价&#xff0c;然后要求所以被占领的点相互隔开&#xff0c;代价最小。 解题思路 我们可以考虑反构图&#xff0c;将边权排序&#xff0c;然后对于每条边&#xff0c;如果加入这条边后不会使敌军…

C#生成anb文件

今天我们来看看C#中如何生成anb文件。 这个anb文件本来是要对接别的平台的&#xff0c;人家提供给我们一个协议&#xff0c;然后通过程序来生成&#xff0c;然后对方会根据生成的anb文件进行解析&#xff0c;然后得到心电图啥的。 代码如下&#xff1a; private void create…

开源纯C#工控网关+组态软件

一、 前言 在园子潜水也七八年了。说来惭愧&#xff0c;这么多年虽然一直自称.NET铁杆粉丝&#xff0c;然仅限于回几个不痛不痒的贴&#xff0c;既没有发布过代码&#xff0c;也没有写过文章。 看着.NET和C#在国外风生水起&#xff0c;国内却日趋没落&#xff0c;我也早觉得有…

面试官:给我说一下你理解的分布式架构

转载自 面试官&#xff1a;给我说一下你理解的分布式架构 # 什么是分布式架构 分布式系统&#xff08;distributed system&#xff09; 是建立在网络之上的软件系统。 内聚性&#xff1a;是指每一个数据库分布节点高度自治&#xff0c;有本地的数据库管理系统。 透明性&am…

c语言程序设计--图书管理系统

这个原本是c语言程序设计书里面的习题&#xff0c;老师布置的作业&#xff0c;既然写好了&#xff0c;就在网上分享下&#xff0c;相信肯定有很多和我一样使用的是这本教材&#xff0c;大家可以借鉴下答案&#xff0c;在dev c上运行是没有任何错误的。文末已经贴了源码&#xf…

Access denied for user ‘root‘ @‘123.233.244.218‘(using password:YES)的解决方法

大家好&#xff0c;我是雄雄&#xff0c;欢迎关注微信公众号&#xff1a;雄雄的小课堂。 前言 在我们新买了个服务器之后&#xff0c;数据库我觉得是比不可少的吧&#xff0c;任何一个项目&#xff0c;只要是动态的&#xff0c;都需要数据做数据的服务于支撑&#xff0c;目前我…

nssl1192-加密【字符串hash】

正题 题目大意 对于每个字母都有一个加密后的字母对应。 然后给一段字母其中包括密文和密文对应的原文的一部分(也有可能没有原文)&#xff0c;求一段最短的密文加原文。 解题思路 枚举密文和原文分界处。然后用字符串hash判断改变后的密文和后段原文是否相等。 code #inclu…

初探SQL Server 2017 on Docker@macOS

编者语&#xff1a;假期到了最后一天&#xff0c;或者你人在旅途&#xff0c;或者你睡了8天&#xff0c;而我在家修炼了几天&#xff0c;完成了一堆好玩的&#xff0c;慢慢和大家分享下。 9月27日SQL Server 2017 正式发布&#xff0c;看点一堆&#xff0c;而这次发布不仅有传统…

阿里面试,为什么Kafka不支持读写分离

转载自 阿里面试&#xff0c;为什么Kafka不支持读写分离 为什么数据库、redis都支持了读写分离功能&#xff0c;而kafka却没有&#xff1f; 厮大也是狠人&#xff0c;直接打开源码从头开始讲&#xff0c;我一看这情况不对&#xff0c;按照这进度得讲到天黑了&#xff0c;蹭着…

手机号、邮箱、用户名均可登录系统的实现方式

大家好&#xff0c;我是雄雄&#xff0c;欢迎关注微信公众号&#xff1a;雄雄的小课堂 前言 现在是2022年4月28日13:41:29&#xff01; 需求&#xff1a;用户可以通过手机号、邮箱来注册我们的系统&#xff0c;用户完成之后&#xff0c;可以去完善自己的个人信息&#xff0c;…