基于JSP实现的在线投票系统

一、设计方案

1.1 投票系统的功能组成

投票系统功能有：选择投票和个人操作及设置，投票设置，投票结果分析，投票操作保障。

1.1.1 选择投票和个人操作及设置

列出所有正在进行的投票活动的简略信息，供投票人选择：（也应可查看已有结果的投票活动情况）列出信息有：投票活动的名称、发起人、投票人数、投票时间等
点击选择某投票活动后，列出该次投票活动的详细内容介绍，可选择进入投票
进行投票操作：要先输入验证信息（如系统自动检测该机IP地址是否合法，检测投票人是否合法，检测验证码是否合法等），如无错误才可以进行投票，按投票规则填写投票提交表，提交完成投票
设置及记录服务器地址：即让客户端机器能顺利连接到服务器端，并且该客户端IP地址合法等
个人资料管理：是投票人的个人资料登记、密码设置等，可参考论坛式的注册、登陆、管理模式

1.1.2 投票设置

设置候选人资料：
填写个人信息（包括姓名、性别、年龄、民族、出生年月日、政治面貌、家庭住址、联系方式等……）
编码：由系统自动生成，投票前后需一致
推荐意见：事迹介绍、或者是个人介绍等
设置投票时间：设置该次投票的开始及结束时间，投票人只能在投票有效期间投票
设置投票类型、投票规则：如该次投票是单选、还是多选、（选多少人）、还是评分制（最低分、最高分多少）、是否可投弃权票、是否可投反对票、多选最终选出多少人、评分制最终选出多少人等
设置合法投票者：设置投票机器的IP、投票人的名单等

1.1.3 投票结果分析

排名结果：单选的结果、多选的结果（按得票数排列，胜出人显著显示）、评分制结果（按分数排列，胜出人显著显示）
投票的统计信息：（需要做到实时变化以及最终结果显示）包括投票的剩余时间、投票的人数情况等

1.1.4 投票操作保障

IP验证：验证投票人的机器IP地址是否合法
时间验证：投票时间的控制，时间到即结束该次投票活动（对局域网,可不用考虑延时问题; 但如果是基于internet的投票,要考虑: 即客户端投票时,还在有效投票时间内,但数据传到服务器端, 已经过了有效投票时间, 这时应该如何计算? 如果要使得系统设计得更合理, 希望能实现按投票当时的时间,而不是按数据到达时间, 又要防止客户端在时间上欺骗, 应该如何设计?）
投票人验证：投票人是本系统用户，但要验证其是否享有对某次投票活动的投票权利，并且验证其帐号、密码的正确性，不可多次投票
投票对象验证：所投的人是否存在于候选人列表中，或是否符合本次投票活动规则（因为某些投票活动可另填自己认为可以的候选人），如不符合是否当弃权处理
验证码验证：防止利用软件连续投票，或自动投票

1.2 投票系统的界面组成

投票系统前台界面

投票系统后台界面

1.3 投票系统的算法、数据结构

1.3.1 投票系统前端

前端主要用到了盒子模型，使用到的数据结构主要是数组，集合来用于存储从数据库查询到的投票列表以及候选人信息。

1.3.2 投票系统后台

后台使用到的算法主要是查找算法，例如从数组或集合中查找到该用户，或者查找到用户点击的投票选项。数据结构使用了Map，ArrayList来存储提示信息和用户session。

二、开发过程

2.1 投票系统的设计

2.1.1 数据库设计

根据实验要求，抽取出四个数据库表，分别是用户表(user)，投票活动表(item)，候选人信息表(item_options)，投票结果表(result)。其中投票活动表和候选人表是一对多关系，投票活动表和投票结果表也是一对多关系，用户表和投票活动表是一对一关系。四个表的ER图如下所示：

2.1.2 系统架构设计

本投票系统使用MVC架构，使用JSP+HTML+JQuery+CSS作为视图层，Servlet作为控制器，JDBC+MySQL作为数据模型层。架构图如下：

2.1.3 页面设计

使用盒子模型，分为上中下三个盒子，其中数据显示主要在中间区域。设计如下：

2.2 投票系统的实现

2.2.1 实现技术

利用Java语言，使用JavaWeb技术体系中的：JSP+Servlet+JDBC+MySQL技术，来开发一个web端的投票系统。

2.2.2 数据访问层实现(请看db包和dao包下的所有文件。这里只贴DB.java)

```java public class DB { public static final String DB_DRIVER = "com.mysql.jdbc.Driver"; public static final String DB_URL = "jdbc:mysql://127.0.0.1:3306/db_vote?characterEncoding=utf-8"; public static final String USER = "root"; public static final String PWD = "123456"; private Connection con = null; private Statement stmt = null; private PreparedStatement pstmt = null;

public DB() {
    createConnection();
    try {
        stmt = con.createStatement();
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
public DB(String preparedSql) {
    createConnection();
    try {
        pstmt = con.prepareStatement(preparedSql,Statement.RETURN_GENERATED_KEYS);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
private void createConnection() {
    try {
        Class.forName(DB_DRIVER);
        con = DriverManager.getConnection(DB_URL, USER, PWD);
    } catch (ClassNotFoundException ex) {
        System.err.println("Error: 类不存在!" + ex.getMessage());
    } catch (SQLException ex) {
        System.err.println("Error: 连接数据库失败!" + ex.getMessage());
    }
}
public ResultSet select(String sql) {
    ResultSet rs = null;
    try {
        rs = stmt.executeQuery(sql);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
    return rs;
}
//preparedStatement的查询方法
public ResultSet select() {
    ResultSet rs = null;
    try {
        rs = pstmt.executeQuery();
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
    return rs;
}
public int update(String sql) {
    int result = 0;
    try {
        result = stmt.executeUpdate(sql);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
    return result;
}
//preparedStatement的更新
public int update() {
    int result = 0;
    try {
        result = pstmt.executeUpdate();
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
    return result;
}
public int getInsertId(){
    int autoInckey = -1;
    ResultSet rs = null; // 获取结果
    try {
        rs = pstmt.getGeneratedKeys();
        if (rs.next()){
            autoInckey = rs.getInt(1);
        }
    } catch (SQLException e) {
        e.printStackTrace();
    }

    return autoInckey;
}
//以下方法为使用动态SQL语句方式时，设置prestmt的参数的方法
//其他类型的参数对应的方法,请自行补充
public void setString(int index, String value) {
    try {
        pstmt.setString(index, value);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
public void setInt(int index, int value) {
    try {
        pstmt.setInt(index, value);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
public void setLong(int index, long value) {
    try {
        pstmt.setLong(index, value);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
public void setDouble(int index, double value) {
    try {
        pstmt.setDouble(index, value);
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}
public void close() {
    try {
        if (stmt != null) {
            stmt.close();
        }
        if (pstmt != null) {
            pstmt.close();
        }
        if (con != null) {
            con.close();
        }
    } catch (SQLException ex) {
        System.err.println("Error: " + ex.getMessage());
    }
}

} ```

2.2.3 业务逻辑层实现(请看service包下的所有(14个)文件。这里只贴首页的控制器代码IndexServlet.java以及点击投票的代码IndexVoteIdServlet.java)

IndexServlet.java

```java @WebServlet({"/index","/index/vote/list","/index/vote/search"}) public class IndexServlet extends HttpServlet {

private static final long serialVersionUID = 7209195686057464382L;

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { //由于get传递参数要乱码，所以弄成post，这个问题之后在解决 //System.out.println("搜索投票"); request.setCharacterEncoding("UTF-8"); ItemDao itemDao = new ItemDao(); String path = request.getRequestURI(); List itemList; if (path.indexOf("/search") > -1){ String content = request.getParameter("content").trim(); itemList = itemDao.getSearchItemList(content); request.setAttribute("itemList",itemList); request.setAttribute("active",2); request.getRequestDispatcher("/WEB-INF/view/vote.jsp").forward(request,response); } }

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { HttpSession session = request.getSession(); request.setCharacterEncoding("UTF-8"); ItemDao itemDao = new ItemDao(); String path = request.getRequestURI(); List itemList; if (path.indexOf("vote/list") > -1){ session.setAttribute("active",2); itemList = itemDao.getAllItemList(); request.setAttribute("itemList",itemList); request.getRequestDispatcher("/WEB-INF/view/vote.jsp").forward(request,response); }else { session.setAttribute("active",1); itemList = itemDao.getLimitItemList(5);//获取最新五条 request.setAttribute("itemList",itemList); request.getRequestDispatcher("/WEB-INF/view/index.jsp").forward(request,response); } } } ```

IndexVoteIdServlet.java

```java @WebServlet(name = "IndexVoteIdServlet",urlPatterns = "/index/vote") public class IndexVoteIdServlet extends HttpServlet {

private static final long serialVersionUID = -6818273018879095397L;

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { HttpSession session = request.getSession(); int id = Integer.parseInt(request.getParameter("id")); String[] selectIds = request.getParameterValues("answer"); String ip = this.getRemortIP(request); ResultDao resultDao = new ResultDao(); User user = (User)session.getAttribute("user"); int success = resultDao.add(user.getId(),id,selectIds,ip); if (success > 0){ session.setAttribute("msg","投票成功"); response.sendRedirect(request.getContextPath() + "/index/vote/list"); }else{ session.setAttribute("msg","投票失败，请不要用同一ip投票"); response.sendRedirect(request.getContextPath() + "/index/vote?id=" + id); } }

@SuppressWarnings("rawtypes")

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { HttpSession session = request.getSession(); session.setAttribute("active",2); int id = Integer.parseInt(request.getParameter("id")); ItemDao itemDao = new ItemDao(); OptionDao optionDao = new OptionDao(); Item item = itemDao.getItemById(id); if (itemDao.getVoteStatus(item.getStartTime(),item.getStopTime()) != 2){ //判断是否可以投票，即投票是否结束，防攻击 response.sendRedirect(request.getContextPath() + "/index/vote/list"); return; } List optionList = optionDao.getOptionList(item.getId(),item.getAllVoteCount()); request.setAttribute("item",item); request.setAttribute("optionList",optionList); String isWaiver="不可以弃权"; String isOppose="不可以投反对票"; System.out.println(item.getIsWaiver()); System.out.println(item.getIsOppose()); if( "1".equals(item.getIsWaiver()) ){ isWaiver="可以弃权"; } if( "1".equals(item.getIsOppose()) ){ isOppose="可以投反对票"; } if( "1".equals(item.getType()) ) { request.setAttribute("type","(单选，"+isWaiver+"，"+isOppose+")"); }else if( "2".equals(item.getType()) ){ request.setAttribute("type","(多选，可选人数:"+item.getNumber()+"，"+isWaiver+"，"+isOppose+")"); }else { request.setAttribute("type","(评分制，可选人数:"+item.getNumber()+"，"+isWaiver+"，"+isOppose+")"); } request.getRequestDispatcher("/WEB-INF/view/info.jsp").forward(request,response); } / 获取用户的ip，防止多次投票 / private String getRemortIP(HttpServletRequest request) { if (request.getHeader("x-forwarded-for") == null) { return request.getRemoteAddr(); } return request.getHeader("x-forwarded-for"); } } ```