Java聊天系統(tǒng)實訓報告

Java聊天系統(tǒng)實訓報告一、實訓目的：1、理解C/S模式的軟件系統(tǒng)結(jié)構(gòu)，掌握網(wǎng)絡(luò)編程的基本概念；

2、了解Java的多線程機制，掌握Java多線程技術(shù)的應(yīng)用；

3、熟練掌握基于TCP協(xié)議的Socket編程；

4、熟練掌握基于UDP協(xié)議的Socket編程；

5、了解Socket編程的協(xié)議約定以及信息交互方法；二、實訓要求：使用JBuilder提供的組件及網(wǎng)絡(luò)包，開發(fā)一個實用的C/S模式聊天室系統(tǒng)。功能要求

要求該系統(tǒng)由客戶端及服務(wù)器端兩部分組成。系統(tǒng)界面要求：要求系統(tǒng)具有友好的用戶界面，界面簡潔、操作方便；本程序客戶端主要完成了：

1.客戶端發(fā)送信息可以廣播客戶。

2.廣播客戶，則將信息轉(zhuǎn)發(fā)到所有客戶端。

服務(wù)器主要完成了：客戶-服務(wù)器之間信息的交互。例如hello發(fā)送信息到服務(wù)器，服務(wù)器將信息轉(zhuǎn)發(fā)到所有與之連接的客戶（hello、boy），通過這種形式，就可以實現(xiàn)客戶之間的信息廣播。

本程序可以實現(xiàn)發(fā)送信息廣播，只要進入客戶端都可以看到消息，本程序采用了流的概念，java多線程，Socket應(yīng)用程序中用到的代碼如下客戶端代碼：importjava.awt.*;importjava.awt.event.*;importjava.io.*;import.*;publicclassLoginimplementsActionListener{privatestaticfinalActionListenerWindowAdapter=null; privateFramef;privateTextFieldtf;privateLabell;privateStringtfContent="";publicLogin(){ f=newFrame("歡迎登陸本程序...按enter鍵直接登錄");l=newLabel("請輸入你的名字");tf=newTextField(20);f.setLayout(newFlowLayout());f.add(l);f.add(tf);f.pack();f.show();tf.addActionListener(this);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){System.exit(0);}});} publicvoidactionPerformed(ActionEvente){System.out.println("ftclicked");tfContent=tf.getText();ClientFramecf=newClientFrame(tfContent);f.dispose();}publicstaticvoidmain(String[]args){newLogin();}}classClientFrameextendsThreadimplementsActionListener{privateFramef;privateTextFieldtf;privateButtonbtn;TextAreata;privatePanelpup;Stringdata;BufferedReaderInputS;PrintStreamOutputS;Stringname;ClientFrame(Stringstr){name=str; Socketclient;try{client=newSocket("localhost",6000);InputS=newBufferedReader(newInputStreamReader(client.getInputStream()));OutputS=newPrintStream(client.getOutputStream(),true);}catch(Exceptionex){ex.printStackTrace();} OutputS.println("歡迎"+name+"光臨");f=newFrame("客戶端");tf=newTextField(30);tf.addActionListener(this);btn=newButton("發(fā)送");ta=newTextArea();pup=newPanel();f.setLayout(newBorderLayout());f.add(pup,BorderLayout.NORTH);pup.add(tf);pup.add(btn);f.add(ta);f.pack();f.setSize(400,300);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){OutputS.println(name+"已經(jīng)離開");System.exit(0);}});btn.addActionListener(this);f.show();this.start(); } publicvoidrun(){ try{ while(true){ System.out.println("正在監(jiān)聽端口..."); OutputS.println("\u0001"); ta.setText(InputS.readLine().replaceAll("\u0001","\n")); Thread.sleep(1000); } } catch(Exceptionex){ ex.printStackTrace(); } }publicvoidactionPerformed(ActionEvente){Stringcmd=e.getActionCommand();if(cmd.equals("發(fā)送")){System.out.println("發(fā)送clicked");data=tf.getText();try{OutputS.println(name+"說:"+data);ta.setText(InputS.readLine().replaceAll("\u0001","\n"));}catch(Exceptionex){ex.printStackTrace();}tf.setText("");}else{ System.out.println("發(fā)送clicked");data=tf.getText();try{OutputS.println(name+"說:"+data);ta.setText(InputS.readLine().replaceAll("\u0001","\n"));}catch(Exceptionex){ex.printStackTrace();}tf.setText("");}}}運行結(jié)果如下圖：服務(wù)器代碼如下:importjava.io.*;importjava.awt.*;importjava.awt.event.*;import.*;importjava.util.ArrayList;publicclassServerFrameimplementsActionListener{privateFramef;privateTextAreata;privateMenuBarmb;privateMenuItemstart;privateMenum;booleanisStop;staticArrayListclients;ServerFrame(){f=newFrame("java聊天系統(tǒng)服務(wù)器");ta=newTextArea();mb=newMenuBar();m=newMenu("服務(wù)器管理");start=newMenuItem("啟動服務(wù)器");mb.add(m);m.add(start);start.addActionListener(this);f.setMenuBar(mb);f.add(ta);f.setSize(260,60);f.addWindowListener(newWindowAdapter(){publicvoidwindowClosing(WindowEvente){System.exit(0);}});f.show();}publicvoidactionPerformed(ActionEvente)//該方法用來對發(fā)生在按鈕上的事件進行處理{Stringcmd=e.getActionCommand();if(cmd.equals("啟動服務(wù)器")){System.out.println("初始化中...");try{System.out.println("服務(wù)器已經(jīng)啟動");ServerSocketserver=newServerSocket(6000);while(!isStop){SocketClient=server.accept();Servicess=newService(Client);}}catch(Exceptionex){ex.printStackTrace();}}}publicstaticvoidmain(String[]args){newServerFrame();}}classServiceextendsThread{Stringdata;BufferedReaderInputS;PrintStreamOutputS;SocketClient;staticStringContent="";publicService(SocketClientSocket)throwsException{Client=ClientSocket;try{InputS=newBufferedReader(newInputStreamReader(Client.getInputStream()));OutputS=newPrintStream(Client.getOutputStream(),true);}catch(Exceptionex){System.out.println("不能連接客戶端!");return;}this.start();}publicvoidrun(){System.out.println(this);try{while(true){data=InputS.readLine();if(data.equals("\u0001")){ OutputS.println(Content);}else{ Content=data+"\u0001"+Content;System.out.println(Content);if(Content==null)break;else{OutputS.println(Content);System.out.println("FromClient:"+Content);}}}Client.close();