精彩专题推荐:建站之入门课 建站之必修课 建站之关键课 网站价值所在 流量提高专题 css+div 标准 个人网站打造全过程
返回建站学首页
导航:
建站首页 | 网站设计 | 网站开发 | 网站运营 | 网页软件 | 建站指南 | 搜索优化 | 图像处理 | 视频教程 | 书籍教程 | 建站专题
当前位置:首页>网站开发>JSP教程>正文

让不同的Servlet在一个Session共享连接


来源:网络 时间:07-08-02 点击: 点击这里收藏本文

下面是一个实例:

1   protected void doGet(HttpServletRequest req, HttpServletResponse res)
throws ServletException, IOException {
2    
3     // 同步代码取得数据库连接
4     synchronized (session) {
5         // 看看这个持有者是否已经在 session 中了
6         ConnectionHolder holder = (ConnectionHolder) session.getAttribute
("servletapp.connection");
7
8         // 如果不在,就创建一个数据库连接,并把它交给持有者。
9         if (holder == null) {
10           try {
11             holder = new ConnectionHolder(DriverManager.getConnection(
"Connection URL"));
12             session.setAttribute("servletapp.connection", holder);
13           }
14           catch (SQLException sqle) {
15             // 错误处理代码
16           }
17         }
18
19         // 从容器取得实际连接
20         conn = holder.getConnection();
21     }
    .... // 别忘了commit
  }

这段代码看起来有那么几行。但实际上,在每个session中,只有第一次执行的servlet需要进行数据库连接操作,此后的servlet只会执行第4、6、20这三行。

==== 谁来负责断开连接? ====

当 servlet 们不必再为创建数据库连接费心的时候,也就没有人愿意管关闭连接这档子事了。事实上,更重要的是,他们没法管。因为这个连接是放在 session 中的,而没有谁能准确的预测,一个 session 会何时终止。

好在有一种叫做“监听器”(Listener)的东西可以专门管这件事。Listener有很多方法,其中的两个方法是:

public void valueBound(HttpSessionBingEvent event);

public void valueUnbound(HttpSessionBingEvent event);

这两个方法可以在一个 session 被创建/失效的时候分别自动执行。我们就把关闭连接的代码放在第二个方法中,这样,当一个 session 失效的时候,数据库连接就会自动关闭。

要想让一个类成为Listener,只需让它实现 HttpSessionBindingListener 接口。我们的 connection 是由 ConnectionHolder 这个类来保管的,因此最方便的办法就是把它注册成一个监听器。

具体方法是:

public void valueUnbound(HttpSessionBindingEvent event) {
    // 当从Session删除或当Session结束时,关闭数据连接。
    try {
        if (con != null) {
          con.rollback(); // 放弃所有未提交的数据
          con.close();
        }
    }
    catch (SQLException e) {
        // 错误处理代码
    }
  }

==== 完整示例 ====

下面是一个完整的 ConnectionHolder:

import javax.servlet.http.HttpSessionBindingListener;
import javax.servlet.http.HttpSessionBindingEvent;
import java.sql.Connection;
import java.sql.SQLException;
public class ConnectionHolder implements HttpSessionBindingListener {
  public ConnectionHolder(Connection con) {
    // 保存连接
    this.con = con;
    try {
        con.setAutoCommit(false);
    }
    catch(SQLException e) {
        // 错误处理代码
    }
  }
  public Connection getConnection() {
    return con;
  }
  public void valueBound(HttpSessionBindingEvent event) {
    // 当增加Session时,什么也不做
  }
  public void valueUnbound(HttpSessionBindingEvent event) {
    // 当从Session删除或当Session结束时,关闭数据连接。
    try {
        if (con != null) {
          con.rollback(); // 放弃所有未发送数据
          con.close();
        }
    }
    catch (SQLException e) {
        // 错误处理代码
    }
  }
  private Connection con = null;
}

9 7 3 1 2 4 8 :

  把此文章收藏到:          
广而告之
文章搜索
  • Google JZxue.Com

关于我们 | 联系我们 | 友情链接 | 网站地图
Copyright © 2005 - 2006 建站学 All rights reserved.