java課程設(shè)計實驗報告

《Java語言程序設(shè)計》綜合試驗匯報系別:計算機科學與技術(shù)系學科專業(yè):信息管理與信息系統(tǒng)課題題目：qq聊天系統(tǒng)人員及分工：白娟(100605)張丹(100607)張富利(100608)指導老師：盧照6月13日目錄TOC\o"1-3"\h\u一、課程設(shè)計目標 3二、課程內(nèi)容 3三、實當代碼（部分主要代碼，不需要全粘） 31.服務(wù)器： 42.客戶端： 43.功效實現(xiàn)： 74.圖形化界面轉(zhuǎn)換： 75.連接數(shù)據(jù)庫代碼： 8四、運行結(jié)果（有必要截圖） 111.服務(wù)器開啟： 112.客戶端開啟： 123.登入界面： 124.摯友列表： 125.聊天界面： 136.數(shù)據(jù)庫信息： 13五、課程總結(jié) 14六、小組分工 14課程設(shè)計目標 利用本學期java課程所學知識制作一個小型比較完整小系統(tǒng)，意在使學生對所學知識有一個整體利用，了解java功效強大，對學習java產(chǎn)生興趣。課程內(nèi)容 基本頁面：登入頁面，注冊頁面，摯友列表頁面，聊天頁面，查詢摯友界面 基本功效：注冊信息，添加摯友，查找摯友，聊天三、實當代碼（部分主要代碼，不需要全粘）1.服務(wù)器代碼：packagecom.sram.server;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStreamReader;importjava.io.ObjectInputStream;importjava.io.ObjectOutputStream;importjava.io.OutputStream;importjava.io.PrintStream;.ServerSocket;.Socket;importjava.util.HashMap;importjava.util.List;importjava.util.Map;importcom.sram.bean.User;importcom.sram.dao.UserDao;publicclassServer{ publicstaticMapsocketMap=newHashMap(); publicstaticvoidmain(String[]args){ try{ ServerSocketss=newServerSocket(1); System.out.println("服務(wù)器已開啟,準備接收數(shù)據(jù)"); while(true){ Socketsoc=ss.accept(); ServerSocketThreadsst=newServerSocketThread(soc); Threadthr=newThread(sst); thr.start(); } }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } }}classServerSocketThreadimplementsRunnable{ privateSocketsoc; publicServerSocketThread(Socketsoc){ this.soc=soc; } publicvoidrun(){ System.out.println("接收到數(shù)據(jù)"); UserDaoud=newUserDao(); try{ BufferedReaderbr=newBufferedReader(newInputStreamReader(soc.getInputStream())); Stringstr=""; while((str=br.readLine())!=null){ String[]strs=str.split(","); //1代表 if(strs[0].equals("1")){ Stringqq=strs[1]; Stringpass=strs[2]; Useru=ud.findUser(qq,pass); OutputStreamos=soc.getOutputStream(); PrintStreamps=newPrintStream(os); if(u!=null){ System.out.println("登陸成功"); Server.socketMap.put(u.getQqNum(),soc); ps.println("1,yes,"+u.getNickName()); ps.flush(); List<User>li=ud.FriendList(u); li.add(u); ObjectOutputStreamoos=newObjectOutputStream(soc.getOutputStream()); oos.writeObject(li); oos.flush(); }else{ System.out.println("登陸失敗"); ps.println("1,no"); } } if(strs[0].equals("2")){ ObjectInputStreamois=newObjectInputStream(soc.getInputStream()); try{ Useru=(User)ois.readObject(); Stringqqnum=ud.insertUser(u); OutputStreamos=soc.getOutputStream(); PrintStreamps=newPrintStream(os); ps.println("2,ok,"+qqnum); }catch(ClassNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } if(strs[0].equals("3")){ StringfriendNum=strs[1]; StringuserNum=strs[2]; Stringmessage=strs[3]; System.out.println("摯友號碼:"+friendNum+",用戶號碼:"+userNum+",信息:"+message); SocketfriendSoc=(Socket)Server.socketMap.get(friendNum); PrintStreamps=newPrintStream(friendSoc.getOutputStream()); ps.println(str); ps.flush(); } if(strs[0].equals("4")){ Stringqqnum=strs[1]; Usernu=ud.findUserfromQQ(qqnum); OutputStreamos=soc.getOutputStream(); PrintStreamps=newPrintStream(os); if(nu!=null){ ps.println("4,ok"); ps.flush(); ObjectOutputStreamoos=newObjectOutputStream(soc.getOutputStream()); oos.writeObject(nu); oos.flush(); }else{ ps.println("4,no"); ps.flush(); } } if(strs[0].equals("5")){ Stringqqnum=strs[1]; ObjectInputStreamois=newObjectInputStream(soc.getInputStream()); Useru=(User)ois.readObject(); Usernu=ud.findUserfromQQ(qqnum); ud.addFriend(u.getId(),nu.getId()); OutputStreamos=soc.getOutputStream(); PrintStreamps=newPrintStream(os); ps.println("5,ok,"+u.getQqNum()+","+u.getPass()); ps.flush(); } } }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }catch(ClassNotFoundExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } }}2.客戶端：packagecom.sram.client;importjava.io.BufferedReader;importjava.io.IOException;importjava.io.InputStreamReader;.Socket;importjava.util.List;importcom.sram.bean.User;importcom.sram.util.MessageIO;importcom.sram.view.ChatUI;importcom.sram.view.FriendListUI;importcom.sram.view.LoginUI;importcom.sram.view.RegisterSuccessUI;importcom.sram.view.SearchFriendUI;importcom.sram.view.UIList;publicclassClient{ publicstaticSocketsoc; publicstaticvoidmain(String[]args){ LoginUIlu=newLoginUI(); UIList.UIlist.put("login",lu); ClientThreadct=newClientThread(); newThread(ct).start(); }}classClientThreadimplementsRunnable{ publicvoidrun(){ try{ BufferedReaderbr=newBufferedReader(newInputStreamReader(Client.soc.getInputStream())); Stringstr=""; while((str=br.readLine())!=null){ String[]strs=str.split(","); if(strs[0].equals("1")){ if(strs[1].equals("yes")){ List<User>li=(List<User>)MessageIO.getObject(); FriendListUIfui=newFriendListUI(li); UIList.UIlist.put("friend",fui); UIList.UIlist.get("login").setVisible(false); } } if(strs[0].equals("2")){ if(strs[1].equals("ok")){ UIList.UIlist.get("register").setVisible(false);// UIList.UIlist.get("login").setVisible(true); newRegisterSuccessUI(strs[2]); } } if(strs[0].equals("3")){ ChatUIcu=(ChatUI)UIList.UIlist.get("chatui"); cu.jta1.setText(strs[3]); } if(strs[0].equals("4")){ SearchFriendUIsfui=(SearchFriendUI)UIList.UIlist.get("search"); if(strs[1].equals("ok")){ Useru=(User)MessageIO.getObject(); sfui.jl2.setText(u.getNickName()); }else{ sfui.jl2.setText("QQ號碼錯誤"); } } if(strs[0].equals("5")){ if(strs[1].equals("ok")){ UIList.UIlist.get("friend").setVisible(false); Stringqq=strs[2]; Stringpass=strs[3]; MessageIO.printlnString("1,"+qq+","+pass); } } } }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } }}3．數(shù)據(jù)庫連接以及實現(xiàn)功效packagecom.sram.util;publicclassMessageIO{ privatestaticSocketsoc; publicMessageIO(Socketsoc){ this.soc=soc; } publicstaticvoidprintlnString(Stringmessege){ try{ PrintStreamps=newPrintStream(soc.getOutputStream()); ps.println(messege); ps.flush(); }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } publicstaticvoidprintObject(Objectobj){ OutputStreamos; try{ os=soc.getOutputStream(); ObjectOutputStreamoos=newObjectOutputStream(os); oos.writeObject(obj); oos.flush(); }catch(IOExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } }packagecom.sram.dao;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;importjava.util.ArrayList;importjava.util.List;importcom.sram.bean.User;importcom.sram.util.GetConnection;publicclassUserDao{ publicUserfindUser(Stringname,Stringpass){ Connectionconn=null; Statementstmt=null; ResultSetrs=null; try{ conn=GetConnection.getConnection(); stmt=conn.createStatement(); rs=stmt.executeQuery("select*fromt_userwhereqqnum='"+name+"'andpassword='"+pass+"'"); rs.next(); Useru=newUser(); u.setId(rs.getInt("id")); u.setNickName(rs.getString("nickname")); u.setPass(rs.getString("password")); u.setQqNum(rs.getString("qqnum")); returnu; }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }finally{ try{ if(rs!=null){ rs.close(); } if(stmt!=null){ stmt.close(); } if(conn!=null){ conn.close(); } }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } returnnull; } publicStringinsertUser(Useru){ Connectionconn=null; PreparedStatementptmt=null; ResultSetrs=null; Stringqqnum=null; try{ conn=GetConnection.getConnection(); ptmt=conn.prepareStatement("insertintot_user(qqnum,nickname,password)values(?,?,?)"); inti=findLastId(); qqnum=(0+i+1)+""; ptmt.setString(1,qqnum); ptmt.setString(2,u.getNickName()); ptmt.setString(3,u.getPass()); booleanb=ptmt.execute(); System.out.println(b); returnqqnum; }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }finally{ try{ if(rs!=null){ rs.close(); } if(ptmt!=null){ ptmt.close(); } if(conn!=null){ conn.close(); } }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } returnqqnum; } publicintfindLastId(){ Connectionconn=null; Statementstmt=null; ResultSetrs=null; try{ conn=GetConnection.getConnection(); stmt=conn.createStatement(); rs=stmt.executeQuery("selectidfromt_userorderbyiddesclimit1"); if(rs.next()){ returnrs.getInt("id"); }else{ return0; } }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }finally{ try{ if(rs!=null){ rs.close(); } if(stmt!=null){ stmt.close(); } if(conn!=null){ conn.close(); } }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } return0; } publicList<User>FriendList(Useru){ Connectionconn=null; Statementstmt=null; ResultSetrs=null; try{ conn=GetConnection.getConnection(); stmt=conn.createStatement(); intid=u.getId(); List<User>li=newArrayList<User>(); rs=stmt.executeQuery("selectid,qqnum,nicknamefromt_userwhereidin(selectfriendnumfromt_friendwheremynum="+id+")"); while(rs.next()){ Usernu=newUser(); nu.setId(rs.getInt("id")); nu.setQqNum(rs.getString("qqnum")); nu.setNickName(rs.getString("nickname")); li.add(nu); } returnli; }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }finally{ try{ if(rs!=null){ rs.close(); } if(stmt!=null){ stmt.close(); } if(conn!=null){ conn.close(); } }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } returnnull; } publicUserfindUserfromQQ(Stringqqnum){ Connectionconn=null; Statementstmt=null; ResultSetrs=null; try{ conn=GetConnection.getConnection(); stmt=conn.createStatement(); rs=stmt.executeQuery("select*fromt_userwhereqqnum="+qqnum); Usernu=newUser(); while(rs.next()){ nu.setId(rs.getInt("id")); nu.setQqNum(rs.getString("qqnum")); nu.setNickName(rs.getString("nickname")); } returnnu; }catch(SQLExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); }fin