網(wǎng)絡(luò)試驗6Socket編程實現(xiàn)閑聊程序

本文格式為Word版，下載可任意編輯——網(wǎng)絡(luò)試驗6Socket編程實現(xiàn)閑聊程序

南昌航空大學(xué)試驗報告

課程名稱：計算機網(wǎng)絡(luò)試驗名稱：Socket編程實現(xiàn)閑聊程序班級：090451班學(xué)生姓名：楊望學(xué)號：09045131指導(dǎo)教師評定：簽名：

一、

試驗?zāi)康模?/p>

1、把握網(wǎng)絡(luò)應(yīng)用程序的開發(fā)方法；

2、把握Client/Server結(jié)構(gòu)軟件的設(shè)計與開發(fā)方法3、把握Socket機制的工作原理。

二、

試驗題目：

使用Win32Socket函數(shù)實現(xiàn)閑聊程序：能相互對發(fā)文本消息。

三、服務(wù)端與客戶端連接工作流程圖：

開始監(jiān)聽有新客戶端請求連接服務(wù)器不允許允許連接？提醒錯誤信息允許建立連接更新用戶信息

四、收發(fā)消息工作流程圖：

1

向客戶端B發(fā)送消息監(jiān)聽是用戶B在上線？是用戶B在繁忙？是用戶B在隱身？否發(fā)送給用戶B在離線？客戶端B發(fā)送給服務(wù)器

五、試驗代碼：1、服務(wù)器端：packageyuchen;

importjava.io.BufferedReader;importjava.io.IOException;

importjava.io.InputStreamReader;importjava.io.PrintStream;.ServerSocket;.Socket;

importjava.util.StringTokenizer;importjava.util.Vector;publicclassChatServer{staticintport=5566;//端口號staticVectorclients=newVector(10);//存儲連接客戶信息staticServerSocketserver=null;//建立服務(wù)器socketstaticSocketsocket=null;//套接字連接publicChatServer(){try{System.out.println(\server=newServerSocket(port);//初始化服務(wù)器套接字while(true){socket=server.accept();//等待連接System.out.println(socket.getInetAddress()+\連接\\n\得到客戶機地址Clientclient=newClient(socket);

2

clients.add(client);//增加客戶線程到向量中client.start();//啟動線程notifyChatRoom();//監(jiān)視閑聊室連接變化}}catch(Exceptionex){ex.printStackTrace();//輸出出錯信息}｝publicstaticvoidnotifyChatRoom(){//監(jiān)視客戶端線程StringBuffernewUser=newStringBuffer(\for(inti=0;i0){//遍歷整個VectorClientclient=(Client)clients.firstElement();//得到一個客戶端try{client.socket.close();}catch(IOExceptionex){ex.printStackTrace();//輸出錯誤信息｝clients.removeElement(client);//移出客戶端}}publicstaticvoiddisconnect(Clientc){//斷開客戶端try{System.err.println(c.ip+\斷開連接\\n\}catch(Exceptionex){ex.printStackTrace();}clients.removeElement(c);c.socket=null;}

publicstaticvoidmain(String[]args){newChatServer();}classClientextendsThread{Socketsocket;//連接端口Stringname;//用戶姓名Stringip;//客戶端ip地址BufferedReaderreader;//輸入流PrintStreamps;//輸出流publicClient(Sockets){socket=s;try{reader=newBufferedReader(newInputStreamReader(s.getInputStream()));ps=newPrintStream(s.getOutputStream());//得到輸出流Stringinfo=reader.readLine();//讀取接收到的信息StringTokenizerstinfo=newStringTokenizer(info,\分解字符串Stringhead=stinfo.nextToken();//獲取關(guān)鍵字System.out.println(stinfo.toString());System.out.println(head);

3

if(stinfo.hasMoreTokens()){name=stinfo.nextToken();//獲取用戶名}if(stinfo.hasMoreTokens()){ip=stinfo.nextToken();//獲取IP地址}}catch(IOExceptionex){ex.printStackTrace();}System.out.println(name);System.out.println(ip);}publicvoidsend(StringBuffermsg){ps.println(msg);//輸出信息ps.flush();}publicvoidrun(){while(true){Stringline=null;try{line=reader.readLine();System.out.println(\}catch(IOExceptionex){ex.printStackTrace();//輸出錯誤信息ChatServer.disconnect(this);//斷開連接ChatServer.notifyChatRoom();//更新信息return;}if(line==null){//客戶離開ChatServer.disconnect(this);ChatServer.notifyChatRoom();return;}StringTokenizerst=newStringTokenizer(line,\分解字符串Stringkeyword=st.nextToken();if(keyword.equals(\發(fā)送來的閑聊信息StringBuffermsg=newStringBuffer(\msg.append(name);//在信息上增加用戶名msg.append(st.nextToken(\ChatServer.sendClients(msg);//發(fā)送閑聊語句到各個客戶端System.out.println(msg);}elseif(keyword.equals(\退出命令ChatServer.disconnect(this);//斷開連接ChatServer.notifyChatRoom();//刷新信息}}}｝}2、客戶端：packageyuchen;importjava.awt.BorderLayout;importjava.awt.Button;importjava.awt.Color;importjava.awt.Label;importjava.awt.TextArea;importjava.awt.TextField;

importjava.awt.event.ActionEvent;

4

importjava.awt.event.ActionListener;importjava.io.BufferedReader;importjava.io.IOException;

importjava.io.InputStreamReader;importjava.io.PrintStream;.InetAddress;.Socket;

importjava.util.StringTokenizer;importjavax.swing.JFrame;

importjavax.swing.JOptionPane;importjavax.swing.JPanel;

publicclassChatClientextendsJFrameimplementsActionListener,RunnableTextFieldtfName=newTextField(15);//姓名輸入文本域ButtonbtConnect=newButton(\連接\連接按鈕ButtonbtDisconnect=newButton(\斷開連接\斷開連接按鈕TextAreatfChat=newTextArea(8,27);//顯示閑聊信息文本域ButtonbtSend=newButton(\發(fā)送\TextFieldtfMessage=newTextField(30);//閑聊輸入java.awt.Listlist1=newjava.awt.List(9);//顯示在線用戶信息Socketsocket=null;//連接端口PrintStreamps=null;//輸出流Listenlisten=null;classListenextendsThread{BufferedReaderreader;PrintStreamps;Stringcname;Socketsocket;ChatClientchatClient;publicListen(ChatClientclient,Stringname,Socketsocket){try{this.chatClient=client;this.socket=socket;ame=name;reader=newBufferedReader(newInputStreamReader(socket.getInputStream()));ps=newPrintStream(socket.getOutputS