ITPub博客

首页 > Linux操作系统 > Linux操作系统 > 设计模式应用之Observer模式(1)

设计模式应用之Observer模式(1)

原创 Linux操作系统 作者:husthxd 时间:2005-06-06 00:00:00 0 删除 编辑

关于observer模式的细节可以参考讲述设计模式的书籍。其类图如下所示:

http://blog.itpub.net/get/11/observer.jpg


Author:husthxd

From:www.itpub.net

Msn:husthxd@hotmail.com

本例主要讲述如何在项目中应用observer模式以满足客户的需求,客户需求如下:
1. 审核小组成员签名是在专门的机器上,所有成员每人一台机器坐在一起讨论,讨论完一起签名确认。
2. 定义会议室中某几台机器为审核小组讨论所要使用的机器,其中一台定义为主控机,有且只有一台。
3. 在会议室专门的机器上登录了的用户均为在此期间的审核小组成员
4. 未被主控机器访问的项目不视为进入审核小组审核状态,已被主控机访问审核页面的项目视为进入审核状态,并记录当前在特定机器上登陆的用户为该项目的审核小组成员。
5. 若中途有用户在特定的机器上登陆进入,则该用户也成为当时进入审核小组讨论状态但未审结的项目所对应的审核小组中的一员。
6. 若中途有用户退出系统,如存在已进入小组讨论状态但该用户未签名的项目,则在该用户退出前提示该用户有尚未签名的条目,但可不签名。该成员离开后,将不属于当时已进入小组讨论状态项目的审核小组成员,不需要该用户签名确认。

从需求我们可以看出,审核小组是一个虚拟的概念,审核小组成员是随着用户登陆和退出系统动态变化的,因而我们可以应用第二种方式的observer模式监听用户的登陆和退出从而触发相应的事件。
ActionListener作为用户登陆和退出的监听接口,代码如下:
package test.pattern;

/**
* Description : 监听器
* Author : husthxd
* 来自
www.itpub.net
* Date: 2005-6-3
* Time: 12:08:22
* Version 1.0
*/
public interface ActionListener {
//登陆
public void login(User user) throws CustomException;

//退出
public void logout(User user) throws CustomException;
}
ActionListener的实现类DefaultLogonListener,用户在登陆和退出的时候在相应的表中记录:
package test.pattern;

import org.apache.log4j.Logger;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.util.Map;

/**
* Description :
* Author : husthxd
* 来自
www.itpub.net
* Date: 2005-6-3
* Time: 12:18:53
* Version 1.0
*/
public class DefaultLogonListener implements ActionListener {
static Logger logger = Logger.getLogger(DefaultLogonListener.class);
public DefaultLogonListener() {
}
//登陆
public void login(User user) throws CustomException {
Connection conn = null;
try {
//数据库连接
conn = ConnMgr.getConnection();
conn.setAutoCommit(false);
//sql语句
StringBuffer sqlstmt = new StringBuffer();
//判断用户是否已经在表中
//构造sql语句
sqlstmt.append("select count(*) v_count from LOGIN_USER where USERID =");
sqlstmt.append(user.getUserId());
logger.debug("sql语句:" + sqlstmt);
//取得结果
Map map = BusinessLogicQueryHelper.factory().getRecord(conn, sqlstmt.toString());
int iCount = Integer.parseInt(map.get("v_count").toString());
if (iCount > 0) {
return;
}
//执行sql语句
sqlstmt.append("insert into LOGIN_USER values (?,?)");
PreparedStatement stmt = conn.prepareStatement(sqlstmt.toString());
//设置参数
stmt.setInt(1, user.getUserId());
stmt.setString(2, user.getUserName());
//执行
stmt.execute();
conn.commit();
} catch (Exception e) {
try {
conn.rollback();
} catch (Exception e2) {
}
throw new CustomException("出错!" + e);
} finally {
ConnMgr.closeConnection(conn);
}
}

//退出
public void logout(User user) throws CustomException {
Connection conn = null;
try {
//数据库连接
conn = ConnMgr.getConnection();
conn.setAutoCommit(false);
StringBuffer sqlstmt = new StringBuffer();
//执行sql语句
sqlstmt.append("DELETE FROM LOGIN_USER WHERE USERID = ? ");
logger.debug("sql语句:" + sqlstmt);
PreparedStatement stmt = conn.prepareStatement(sqlstmt.toString());
stmt.setInt(1, user.getUserId());
//执行
stmt.execute();
conn.commit();
} catch (Exception e) {
try {
conn.rollback();
} catch (Exception e2) {
}
throw new CustomException("出错!" + e);
} finally {
ConnMgr.closeConnection(conn);
}
}
}

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/6906/viewspace-21823/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论
ITPUB数据库版块资深版主,对Oracle、PostgreSQL有深入研究。

注册时间:2007-12-28

  • 博文量
    1399
  • 访问量
    3843657