黑马程序员技术交流社区

标题: JavaWeb聊天室（自学Web编写聊天室 出现问题） [打印本页]

---

作者: 秦驰    时间: 2011-7-25 15:12
标题: JavaWeb聊天室（自学Web编写聊天室 出现问题）
自己写了一个聊天室 后来觉得没有那么多的必要也能聊天  不知道错在哪里了

package com.cqwu.chat.bean;
import java.sql.*;

public class DBBean {

        private Connection con;
        private Statement stmt;
        private ResultSet rs;
        public DBBean(){}
        public Connection getConnection()throws Exception
        {
               
                String url ="jdbc:mysql://localhost/user";
                String dbuser ="root";
                String dbpass="root";
                if(con==null)
                {
                        Class.forName("com.mysql.jdbc.Driver");
                        con=DriverManager.getConnection(url, dbuser, dbpass);
                }
                return con;
               
        }
        //
        public ResultSet executeQuery(String sql)throws Exception
        {
                if(con==null)throw new Exception("没有连接对象可用");
                stmt = con.createStatement();
                rs = stmt.executeQuery(sql);
                return rs;
               
        }
        //更新
        public int excuteUpdate(String sql)throws Exception{
               
                if(con==null)throw new Exception("没有连接对象");
                stmt = con.createStatement();
                return stmt.executeUpdate(sql);
                       
        }
        public void close(){
                try{if(rs!=null)rs.close();}catch(Exception e){}
                try{stmt.close();}catch(Exception e){}
                try{con.close();}catch(Exception e){}
        }
       
}
===================================================================
package com.cqwu.chat.bean;
import java.sql.*;


public class UserBean {
        private String userid;
        private String userpass;
        private String userrepass;
        private String usertype="0";
                public String getUserid() {
                return userid;
        }
        public void setUserid(String userid) {
                this.userid = userid;
        }
        public String getUserpass() {
                return userpass;
        }
        public void setUserpass(String userpass) {
                this.userpass = userpass;
        }
        public String getUserrepass() {
                return userrepass;
        }
        public void setUserrepass(String userrepass) {
                this.userrepass = userrepass;
        }
        public String getUsertype() {
                return usertype;
        }
        public void setUsertype(String usertype) {
                this.usertype = usertype;
        }
        //添加用户
        public boolean add(String userid,String userpass,String userrepass,String usertype) throws Exception
        {
                Connection con=null;
                DBBean db = new DBBean();
                StringBuffer sql =new StringBuffer();
                sql.append("insert into usertable values('");
                sql.append(userid);
                sql.append("','");
                sql.append(userpass);
                sql.append("','");
                sql.append(usertype);
                sql.append("')");
                try{
                        con =db.getConnection();
                        db.excuteUpdate(sql.toString());
               
                       
                }catch(Exception e)
                {
                        System.out.println(e.toString());
                }
                finally{
                       
                        db.close();
                }
                return true;
               
        }
        //查询用户
                public int validate(String userid,String userpass,String usertype)
                {       
                        int find =0;
                        Connection con =null;
                        ResultSet rs =null;
                        DBBean db = new DBBean();
                        StringBuffer sql =new StringBuffer();
                        sql.append("select from usertable where userid='");
                        sql.append(userid);
                        sql.append("'");
                        try{
                                con =db.getConnection();
                                db.excuteUpdate(sql.toString());
                                if(rs.next())
                                {
                                        String tmpuserid=rs.getString(1);
                                        tmpuserid = new String(tmpuserid.getBytes("8859_1"));
                                        String tmpuserpass=rs.getString(2);
                                        tmpuserpass = new String(tmpuserpass.getBytes("8859_1"));
                                        String tmpusertype=rs.getString(3);
                                        tmpusertype= new String(tmpusertype.getBytes("8859_1"));
                                        //
                                        UserBean user =new UserBean();
                                        user.setUserid(tmpuserid);
                                        user.setUserpass(tmpuserpass);
                                        user.setUsertype(tmpusertype);
                                        if(userpass.equals(tmpuserpass)&&userid.equals(tmpuserid)&&usertype.equals(tmpusertype)){
                                                find= 1;
                                        }
                                        if(userpass.equals(tmpuserpass)&&userid.equals(tmpuserid)&&!usertype.equals(tmpusertype)){
                                                find= 2;
                                        }
                                        else{find=3;}
                       
                        }
                               
                        }catch(Exception e)
                        {
                                System.out.println(e.toString());
                        }
                        finally{
                               
                                db.close();
                        }
                        return find;
               
                       
                }
       
        //删除用户
        public int delete(String username)throws Exception
        {
                Connection con=null;
                DBBean db = new DBBean();
                StringBuffer sql =new StringBuffer();
                sql.append("delete from usertable where userid='");
                sql.append(userid);
                sql.append("'");
                try{
                        con =db.getConnection();
                        db.excuteUpdate(sql.toString());
                       
                }catch(Exception e)
                {
                        System.out.println(e.toString());
                }
                finally{
                       
                        db.close();
                }
                return 0;
        }
        //
       
}
=========================================================================
package com.cqwu.chat.contoller;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.cqwu.chat.service.MessageService;
import com.cqwu.chat.vo.Message;
public class AddMessageServlet extends HttpServlet {
        public void doGet(HttpServletRequest request, HttpServletResponse response)
                        throws ServletException, IOException {
                //取出用户信息
                HttpSession session =request.getSession(true);
                String userid=(String)session.getAttribute("userid");

                //取出新增聊天信息
                String info=request.getParameter("info");
                info=new String(info.getBytes("8859_1"));
                //取出所有聊天信息
                ServletContext application = this.getServletContext();
                ArrayList<Message>allMessage = (ArrayList<Message>)application.getAttribute("allMessage");
                //创建消息对象
                Message message =new Message(info, userid);
                //创建业务对象
                MessageService service = new MessageService(allMessage);
                //调用业务逻辑
                service.addMessage(message);
                //保存更新后的信息
                application.setAttribute("allMessage", service.getAllMessage());
                //转向聊天界面
                response.sendRedirect("content.jsp");
        }

        public void doPost(HttpServletRequest request, HttpServletResponse response)
                        throws ServletException, IOException {
                doGet(request,response);
        }

}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2