網(wǎng)絡(luò)SOCKET編程報告

1、XX 大 學(xué) 實 驗 報 告年 月 日 課題名稱： 計算機網(wǎng)絡(luò)實驗名稱：SOCKET編程實現(xiàn)聊天程序 班級：姓名： 同組人： 指導(dǎo)老師評定： 簽名： 一、實驗?zāi)康?、掌握網(wǎng)絡(luò)應(yīng)用程序的開發(fā)方法；2、掌握Client/ Server結(jié)構(gòu)軟件的設(shè)計與開發(fā)方法；3、掌握Socket機制的工作原理；4、會利用編程的方法實現(xiàn)Socket的工作機制，實現(xiàn)聊天程序。二、實驗前的準(zhǔn)備 1、閱讀教材關(guān)于TCP/IP協(xié)議和Socket的相關(guān)內(nèi)容；2、閱讀WinSock編程指南；3、閱讀本實驗所附內(nèi)容； 4、熟悉Eclipse開發(fā)工具。三、實驗內(nèi)容使用Win32 Socket 函數(shù)實現(xiàn)聊天程序：能相互對發(fā)文本消息。

2、四、實驗步驟和實驗源程序 實驗步驟： 1、打開java設(shè)計軟件Elipse，分別建立兩個新工程，取名為TalkProject； 2、在剛建立的工程下建里兩個類ChatServer和ChatClient； 3、在兩個類下分別編寫源程序，利用Socket實現(xiàn)聊天軟件； 4、運行服務(wù)器程序后，再運行客戶端程序，就可以實現(xiàn)聊天了。實驗源代碼： ChatServer：import java.io.*;import .*;import java.util.*;public class ChatServer boolean started = false;ServerSocket ss = null;Lis

3、t clients =Collections.synchronizedList(new ArrayList();/List clients =Collections.synchronized(new ArrayList();/clients是共享變量,通過Collections.synchronized()做同步化處理public static void main(String args) new ChatServer().start();public void start() try ss = new ServerSocket(8888); / 創(chuàng)建一個監(jiān)聽Socket對象started =

4、 true; catch (IOException e) e.printStackTrace();try while (started) Socket s = ss.accept(); / 等待客戶端發(fā)起連接Client c = new Client(s);System.out.println(a client connected!);new Thread(c).start(); / 啟動線程clients.add(c); / 向共享變量中添加ss.close(); / 關(guān)閉Socket catch (IOException e) e.printStackTrace();class Clien

5、t implements Runnable / 實現(xiàn)Runnable接口private Socket s;private DataInputStream dis = null;private DataOutputStream dos = null;private boolean Connected = false;public Client(Socket s) this.s = s;try dis = new DataInputStream(s.getInputStream(); / 創(chuàng)建輸入流dos = new DataOutputStream(s.getOutputStream(); /

6、創(chuàng)建輸出流Connected = true; catch (IOException e) e.printStackTrace();public void send(String str) try dos.writeUTF(str); / 向輸入流中寫入數(shù)據(jù) catch (IOException e) clients.remove(this); / 出錯時(客戶可能已斷線)，移除一個客戶端public void run() try while (Connected) String str = dis.readUTF(); / 從輸出流中讀取數(shù)據(jù) synchronized(clients) / 對

7、共享的列表進行遍歷時必須要同步化Iterator it = clients.iterator();/ 返回一個迭代器while(it.hasNext() Client c = it.next();c.send(str);/ 將數(shù)據(jù)發(fā)送出去/while /synchronized /while(Connected)dis.close();/ 關(guān)閉輸入流dos.close();/ 關(guān)閉輸出流s.close();/ 關(guān)閉Socket catch (Exception e) System.out.println(Client closed!); finally clients.remove(this)

8、; / 確保線程結(jié)束時從共享變量中刪除自己(比如從客戶機讀數(shù)據(jù)時出錯， / 客戶機可能已掉線，線程會結(jié)束) /try/runChatClient：import java.awt.*;import java.awt.event.*;import java.io.*;import .*;import javax.swing.Icon;import javax.swing.ImageIcon;import javax.swing.JButton;public class ChatClient extends Frame Socket s = null;DataOutputStream dos = n

9、ull;DataInputStream dis = null;private boolean Connected = false;TextField tf = new TextField();TextArea ta1 = new TextArea();TextArea ta2 = new TextArea();Button bt1 = new Button(發(fā)送);Thread thread = new Thread(new ClientThread();/ 創(chuàng)建線程public static void main(String args) new ChatClient().call();pub

10、lic void call() bt1.setBackground(Color.cyan);setLocation(400, 300);setSize(400, 300);setLayout(null);/ 取消布局管理器setBackground(Color.cyan);tf.setBounds(250, 40, 70, 25);ta1.setBounds(30, 40, 200, 80);ta2.setBounds(30, 140, 200, 80);bt1.setBounds(265, 250, 70, 30);tf.setBounds(30, 240, 200, 35);tf.addA

11、ctionListener(new MyListener();/ 注冊事件監(jiān)聽器add(tf);add(bt1);add(ta1);add(ta2);add(tf);this.addWindowListener(new WindowAdapter() / 關(guān)閉窗口public void windowClosing(WindowEvent e) disconnect();System.exit(0););bt1.addActionListener(new MyListener();/ 注冊事件監(jiān)聽器setVisible(true);connect();thread.start();/ 啟動線程p

12、ublic void connect() try s = new Socket(127.0.0.1, 8888);dos = new DataOutputStream(s.getOutputStream();/ 返回一個輸出流dis = new DataInputStream(s.getInputStream();/ 返回一個輸入流System.out.println(connected!);Connected = true; catch (Exception e) e.printStackTrace(); public void disconnect() try dos.close();/

13、關(guān)閉輸出流dis.close();/ 關(guān)閉輸入流s.close();/ 關(guān)閉Socket catch (IOException e) e.printStackTrace();private class MyListener implements ActionListener public void actionPerformed(ActionEvent e) String str = tf.getText().trim();/ 獲取文本框中的數(shù)據(jù)tf.setText();ta2.append(str+n);/ 將文本框中的數(shù)據(jù)添加到文本區(qū)中try dos.writeUTF(str);/ 向輸出流中寫入數(shù)據(jù)dos.flush();/ 刷空流 catch (IOException e1) e1.pr