上次讲到ThreadLocal的使用场景,这次接着讲。
管理应用程序的线程安全
使用ThreadLocal来实现线程安全,我觉得得有两个前提
- 数据资源并非只有一个,即不需要非要竞争同一个资源
- 多线程情况下不能使用同一个数据资源
而数据库连接就是这一类资源。数据库连接可以有多个,但是是优先的。而且不同线程间不可以使用相同的数据库连接,不然事务无法保证。下面我们就来实现一个没有池化功能数据库连接管理功能
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionManager
{
private static final ThreadLocal<Connection> connectionHolder = new ThreadLocal<Connection>();
public static Connection getConnection()
{
// ThreadLocal取得当前线程的connection
Connection conn = connectionHolder.get();
// 如果ThreadLocal没有绑定相应的Connection,创建一个新的Connection,
// 并将其保存到本地线程变量中。
if (conn == null)
{
try
{
Class.forName("");
conn = DriverManager.getConnection("url", "user_name", "password");
// 将当前线程的Connection设置到ThreadLocal
connectionHolder.set(conn);
}
catch (ClassNotFoundException e)
{
// do not do like this
}
catch (SQLException e)
{
// do not do like this
}
}
return conn;
}
/**
* 关闭Connection,清除集合中的Connection
*/
public static void closeConnection()
{
// ThreadLocal取得当前线程的connection
Connection conn = connectionHolder.get();
// 当前线程的connection不为空时,关闭connection.
if (conn != null)
{
try
{
conn.close();
// connection关闭之后,要从ThreadLocal的集合中清除Connection
connectionHolder.remove();
}
catch (SQLException e)
{
// do not do like this
}
}
}
}
线程内的数据传递
之前在搜索部门做过一个系统,是用来解析关键字的系统。而对于不同的关键字所配置的业务规则时不相同的,而且业务规则之间有优先级的概念。所以该系统整体上是使用责任链的设计模式来架构设计的。总体类似于下面这种。
也许你会说,有必要使用ThreadLocal来传递参数吗,直接使用一个RequestParamVo对象来封装所有的参数不就行了吗。实际上也是可以的。这里我只不过提供另外一种实现思路而已。
所以我建议如果使用ThreadLocal来传递参数并没有给你带来多少好处的话,我建议不要使用ThreadLocal
下面我们来介绍一个使用ThreadLocal使得数据传递特别方便的案例。
使用ThreadLocal来实现读写分离,具体可参考koala
PS:注意切面的顺序
某些情况下的性能优化
- 某些资源没有必要多线程竞争,所以可以使用ThreadLocal这种以空间换时间的方式来提高性能
- 有些时候线程执行的时候需要初始化某些耗费时间的资源,这个时候就可以在线程执行前来初始化这些资源,并且将这些资源绑定到当前线程上,以避免重复初始化。
比如,在做分布式session的时候,我们是把session存储到redis中了,所以在调用HtppSession的getAttribute方法的时候,实际上是在调用HtppSession的代理对象,而该代理对象实际上是在调用redis的get命令。如果程序比较正常的话,那么直接调用redis的命令就可以了。但是如果出现下面的代码,那将是灾难性的。
HttpSession session = getSession();
for(int i = 0;i < n ;i++){
String val = session.getAttribute("som key");//执行了n次redis的命令调用
this.doSomething(val);
}
所以我们可以将session中的数据在线程启动的时候一次性load到内存中,然后绑定到该线程上。这样之后在调用HttpSession的getAttribute方法时,实际上是从ThreadLocal中缓存的数据中获取的。具体的时候可以使用Filter来实现。顺便说一句,HttpSession的代理对象也可以在Filter中来设置。不可该Filter的优先级应该高于其他所有的Filter。这里就不贴代码了。