JSP前端+Java后台ChatRoom

3297阅读　0评论2012-09-05　高傲的活着
分类：Java

Model：用户信息

点击(此处)折叠或打开

  1. package com.chat.model;
  2. import java.util.Vector;
  3. /**
  4.  *采用单例模式来管理用户信息
  5.  * @author Tom
  6.  */
  7. public class UserInfo {
  8.     private static UserInfo user=new UserInfo();
  9.     private Vector vector=null;
  10.     
  11.     private UserInfo(){
  12.         this.vector=new Vector();
  13.     }
  14.     public static UserInfo getInstance(){
  15.         return user;
  16.     }
  17.     
  18.     public boolean addUser(String user){
  19.          if(user!=null){
  20.              this.vector.add(user);
  21.              return true;
  22.          }else{
  23.              return false;
  24.          }
  25.     }
  26.     
  27.     //获取用户列表

  29.     public Vector getList(){
  30.         return this.vector;
  31.     }
  32.     //移除用户

  34.     public void removeUser(String user){
  35.        if(user!=null){
  36.            vector.removeElement(user);
  37.        }
  38.     }
  39.     
  40. }

业务处理类：

点击(此处)折叠或打开

  1. package com.chat.servlet;
  2. import com.chat.model.UserInfo;
  3. import javax.servlet.http.HttpSessionBindingEvent;

  5. public class UserListener implements javax.servlet.http.HttpSessionBindingListener {
  6.    
  7.     private String user;
  8.     private UserInfo container=UserInfo.getInstance();
  9.     
  10.     public UserListener(){
  11.          user="";
  12.     }
  13.     //设置在线监听人员

  15.     public void setUser(String user){
  16.         this.user=user;
  17.     }
  18.     //获取在线监听

  20.      public String getUser(){
  21.          return this.user;
  22.      }
  23.      //当session有对象加入时执行的方法

  25.     public void valueBound(HttpSessionBindingEvent event) {
  26.             System.out.println("上线用户："+this.user);
  27.     }
  28.     //当session对象有用户移除的时候执行的方法

  30.     public void valueUnbound(HttpSessionBindingEvent event) {
  31.       System.out.println("下线用户："+this.user);
  32.       if(user!=""){
  33.           container.removeUser(user);
  34.       }
  35.     }
  36.     
  37. }

消息处理类：

点击(此处)折叠或打开

  1. package com.chat.servlet;
  2. import java.util.*;
  3. import com.chat.model.UserInfo;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  6. import java.util.Vector;
  7. import java.util.logging.Level;
  8. import java.util.logging.Logger;
  9. import javax.servlet.ServletContext;
  10. import javax.servlet.ServletException;
  11. import javax.servlet.http.HttpServlet;
  12. import javax.servlet.http.HttpServletRequest;
  13. import javax.servlet.http.HttpServletResponse;
  14. import javax.servlet.http.HttpSession;

  16. public class Messages extends HttpServlet {
  17.     
  18.     protected void processRequest(HttpServletRequest request, HttpServletResponse response)
  19.             throws ServletException, IOException {
  20.         response.setContentType("text/html;charset=UTF-8");
  21.         String action=request.getParameter("action");
  22.        
  23.         try {
  24.             if("loginRoom".equals(action)){ //登录时，写入系统公告

  26.                 this.loginRoom(request, response);
  27.             }else if("sendMessage".equals(action)){ //发送聊天信息

  29.                 this.sendMessages(request, response);
  30.             }else if("getMessages".equals(action)){ //从XML文件中读取聊天信息

  32.                  this.getMessages(request, response);
  33.             }
  34.         } finally {
  35.           
  36.         }
  37.     }
  38.     
  39.     //将页面重定向到显示聊天信息的页面

  41.     public void getMessages(HttpServletRequest request,HttpServletResponse response) {
  42.             response.setContentType("text/html;charset=UTF-8");
  43.             try{
  44.                 request.getRequestDispatcher("content.jsp").forward(request, response);
  45.             }catch(Exception ex){
  46.                  Logger.getLogger(Messages.class.getName()).log(Level.SEVERE, null, ex);
  47.             }
  48.     }
  49.     
  50.     // 登录时，写入系统公告

  52.      public void loginRoom(HttpServletRequest request, HttpServletResponse response)
  53.             throws ServletException, IOException {
  54.          response.setContentType("text/html;charset=UTF-8");
  55.          HttpSession session=request.getSession();
  56.          String username=request.getParameter("username");    //获得登录用户名

  58.      UserInfo user=UserInfo.getInstance();        //获得UserInfo类的对象

  60.      session.setMaxInactiveInterval(600);        //设置Session的过期时间为10分钟

  62.           Vector vector = user.getList();
  63.          boolean flag = true; //标记是否登录的变量

  65.          //判断用户是否登录

  67.          System.out.println("vector的size:" + vector.size());
  68.          
  69.          if(vector!=null && vector.size()>0){
  70.              for(int i=0;i<vector.size();i++){
  71.                  System.out.println("vector"+i+""+vector.elementAt(i)+" user"+username);
  72.                  if(username.equals(vector.elementAt(i))){
  73.                      PrintWriter out;
  74.                      try{
  75.                          out = response.getWriter();
  76.                          out.println("");
  77.                      }catch(IOException e){
  78.                          e.printStackTrace();
  79.                      }
  80.                      flag=false;
  81.                      break;
  82.                  }
  83.              }
  84.          }
  85.          
  86.          //保存用户信息

  88.          if(flag){
  89.              UserListener ul=new UserListener();    //创建UserListener的对象

  91.              ul.setUser(username); //添加用户

  93.              user.addUser(ul.getUser());
  94.              session.setAttribute("user", ul); //将UserListener对象绑定到session对象中

  96.              session.setAttribute("username",username); //保存当前登录的用户名

  98.              session.setAttribute("loginTime",new Date().toLocaleString()); //保存登录时间

  100.              
  101.              ServletContext application =getServletContext();
  102.              
  103.              String sourceMessage="";
  104.              if(null!=application.getAttribute("message")){
  105.                  sourceMessage=application.getAttribute("message").toString();
  106.              }
  107.              
  108.              sourceMessage+="系统公告:" + username + "走进聊天室!
    ";
  109.               application.setAttribute("message",sourceMessage);
  110.               try{
  111.                   request.getRequestDispatcher("login_ok.jsp").forward(request, response);
  112.               }catch(Exception ex){
  113.                   Logger.getLogger(Messages.class.getName()).log(Level.SEVERE, null,ex);
  114.               }
  115.          }
  116.      }
  117.      // 发送聊天信息

  119.       public void sendMessages(HttpServletRequest request, HttpServletResponse response)
  120.             throws ServletException, IOException {
  121.             response.setContentType("text/html;charset=UTF-8");
  122.             request.setCharacterEncoding("UTF-8");
  123.             Random random=new Random();
  124.             String from = request.getParameter("from"); //发言人

  126.             String face =request.getParameter("face"); //表情

  128.             String to =request.getParameter("to"); //接收者

  130.              String color = request.getParameter("color"); //字体颜色

  132.             String content = request.getParameter("content"); //发言内容

  134.             String sendTime = new Date().toLocaleString(); //发言时间

  136.             ServletContext application = getServletContext();
  137.             String sourceMessage = application.getAttribute("message").toString();
  138.             
  139.               try {
  140.                 //发言时间

  142.                 sourceMessage += "" + from + "" + face + "对[" + to + "]说：" + "" + content + "（" + sendTime + "）
    "    ;
  143.                 application.setAttribute("message", sourceMessage);
  144.                 request.getRequestDispatcher("Messages?action=getMessages&nocache=" + random.nextInt(10000)).forward(request, response);
  145.             } catch (Exception ex) {
  146.                 Logger.getLogger(Messages.class.getName()).log(Level.SEVERE, null, ex);
  147.             }

  149.             
  150.           
  151.           
  152.       }
  153.    
  154.     
  155.     
  156.     
  157.     @Override
  158.     protected void doGet(HttpServletRequest request, HttpServletResponse response)
  159.             throws ServletException, IOException {
  160.         processRequest(request, response);
  161.     }

  163.     /**
  164.      * Handles the HTTP POST method.
  165.      * @param request servlet request
  166.      * @param response servlet response
  167.      * @throws ServletException if a servlet-specific error occurs
  168.      * @throws IOException if an I/O error occurs
  169.      */
  170.     @Override
  171.     protected void doPost(HttpServletRequest request, HttpServletResponse response)
  172.             throws ServletException, IOException {
  173.         processRequest(request, response);
  174.     }


  177.     @Override
  178.     public String getServletInfo() {
  179.         return "Short description";
  180.     }//

  182. }

Filter：

点击(此处)折叠或打开

  1. package com.chat.filter;
  2. import java.io.IOException;
  3. import javax.servlet.*;
  4. /**
  5.  *
  6.  * @author Tom
  7.  */
  8. public class CharacterEncodingFilter implements Filter{
  9.     
  10.     protected String encoding=null;
  11.     protected FilterConfig filterConfig=null;
  12.     public void init(FilterConfig filterConfig) throws ServletException {
  13.         this.filterConfig=filterConfig;
  14.         this.encoding=filterConfig.getInitParameter("encoding"); //从web.xml中获取编码格式参数

  16.     }

  18.     public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
  19.         if(encoding!=null){
  20.             request.setCharacterEncoding(encoding); //设置请求编码

  22.             response.setContentType("text/html;charset="+encoding); //设置响应编码

  24.         }
  25.         chain.doFilter(request, response);
  26.     }

  28.     public void destroy() {
  29.         this.encoding=null;
  30.         this.filterConfig=null;
  31.     }
  32. }

web.xml:

点击(此处)折叠或打开

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app version="2.5" xmlns="" xmlns:xsi="" xsi:schemaLocation=" /web-app_2_5.xsd">
  3.     <servlet>
  4.         <servlet-name>Messages</servlet-name>
  5.         <servlet-class>com.chat.servlet.Messages</servlet-class>
  6.     </servlet>
  7.     <servlet-mapping>
  8.         <servlet-name>Messages</servlet-name>
  9.         <url-pattern>/Messages</url-pattern>
  10.     </servlet-mapping>
  11.     <session-config>
  12.         <session-timeout>
  13.             30
  14.         </session-timeout>
  15.     </session-config>
  16.     <welcome-file-list>
  17.         <welcome-file>index.jsp</welcome-file>
  18.     </welcome-file-list>
  19.     <filter>
  20.         <filter-name>CharacterEncodingFilter</filter-name>
  21.         <filter-class>com.chat.filter.CharacterEncodingFilter</filter-class>
  22.         <init-param>
  23.             <param-name>encoding</param-name>
  24.             <param-value>UTF-8</param-value>
  25.         </init-param>
  26.     </filter>
  27.     <filter-mapping>
  28.         <filter-name>CharacterEncodingFilter</filter-name>
  29.         <url-pattern>/*</url-pattern>
  30.         <dispatcher>REQUEST</dispatcher>
  31.         <dispatcher>FORWARD</dispatcher>
  32.     </filter-mapping>
  33.     
  34. </web-app>

附件：

 chatroom.rar   

上一篇：java 集合ArrayList及LinkList源码分析
下一篇：数据结构学习连载(一)