Socket和多線程編程的聊天程序?qū)崿F(xiàn)

1、濱江學院課 程 設 計任務書 學年學期 2012-2013學年第二學期 課程名稱 用socket實現(xiàn)聊天程序 院 系 計算機系專 業(yè) 計科 姓 名 周洲 指導教師 朱節(jié)中二一三 年 七月 七 日用Socket 的編程機制實現(xiàn)聊天程序10計科 周洲 20092308065摘要: Socket 是基于TCP/ IP 的網(wǎng)絡上運行的兩個程序間雙向通訊的一種連接機制, 包中包含Socket 類, 用以快速地開發(fā)網(wǎng)絡通信程序。通過實例模型探討基于Java 的Socket 通信程序的一般結(jié)構(gòu)。對開發(fā)一般性的通信軟件, 有一定的參考價值。關(guān)鍵詞: Java; 網(wǎng)絡; SocketSocket Program

2、ming Based on TCP/IP in JavaAbstract :Socket is one of the two- way communication' s end between two procedures that are operated on the network based on TCP/IP. J bag includes Sockets, which is used to develop the network communication procedure fast.This paper probes into the general structure

3、based on Socket communication procedure of Java through the instance model.The general communication software can be developed basedon this one,so there is certain reference value.Key words : ava;network;Socket;communication一、課題內(nèi)容和要求1.課題內(nèi)容基于Socket和多線程編程的聊天程序?qū)崿F(xiàn)2.課題要求網(wǎng)絡聊天程序設計非常復雜，允許多個人同時聊天更加需要多線程技術(shù)的支持

4、，請實現(xiàn)一個簡單的多線程網(wǎng)絡聊天程序模擬。二、設計思路分析1. 在網(wǎng)絡越來越發(fā)達的今天，人們對網(wǎng)絡的依賴越來越強，網(wǎng)絡聊天已經(jīng)成了許多人生活中必不可少的一部分，基于這樣的需求，出現(xiàn)了許多網(wǎng)絡聊天通信工具，像QQ，MSN等等，但是人們已經(jīng)不再滿足于單一的兩個人之間的聊天，而是對多人同時聊天產(chǎn)生了興趣，于是出現(xiàn)了網(wǎng)絡聊天室，不同地方的人可以在那個虛擬的聊天室里面熱烈聊天。基于這樣的想法，我們用JAVA設計一個多人同時聊天的小程序，用Socket編程實現(xiàn)網(wǎng)絡通訊，面向連接的，采用多線程的實現(xiàn)技術(shù)。2. 在程序中，可以設置加入連接的最大數(shù)目，通過更改IP地址和端口號，成為不同的客戶端，與服務器端連接，

5、進行多用戶聊天。3.為方便用戶交互，我們采用圖形化的用戶界面。實現(xiàn)了好友添加，消息收發(fā)、顯示等基本功能。三、概要設計該網(wǎng)絡聊天程序大致分為三個主要部分：客戶端、服務器端和用戶圖形界面。各個部分的初步設計思想、流程及存儲結(jié)構(gòu)如下：1. 程序整體框架：主程序監(jiān)聽一端口，等待客戶接入；同時構(gòu)造一個線程類，準備接管會話。當一個Socket會話產(chǎn)生后，將這個會話交給線程處理，然后主程序繼續(xù)監(jiān)聽。 打開Socket命 名監(jiān)聽端口建立連接收發(fā)消息關(guān)閉連接打開Socket 連接服務器收發(fā)消息關(guān)閉連接服務器端程序客戶端程序 2.客戶端（Client）客戶端，使用Socket對網(wǎng)絡上

6、某一個服務器的某一個端口發(fā)出連接請求，一旦連接成功，打開會話；會話完成后，關(guān)閉Socket?？蛻舳瞬恍枰付ù蜷_的端口，通常臨時的、動態(tài)的分配一個端口。3.服務器端（Server）服務器端，使用ServerSocket監(jiān)聽指定的端口，端口可以隨意指定（由于1024以下的端口通常屬于保留端口，在一些操作系統(tǒng)中不可以隨意使用，所以建議使用大于1024的端口），等待客戶連接請求，客戶連接后，會話產(chǎn)生；在完成會話后，關(guān)閉連接。4.用戶圖形界面用戶圖形界面方便程序與用戶的交互，多個用戶參加，完成會話功能，具體的設計要方便用戶的使用，直觀清晰，簡潔明了，友好美觀。5.存儲結(jié)構(gòu)下面列出主要存儲結(jié)構(gòu)或變量：存

7、儲結(jié)構(gòu)、變量、對象類型說明postInetAddress標識IP地址Portint標識端口Server ServerThread服務器端連接數(shù)Client Socket客戶端連接數(shù)Client(String ip,int p,Face chat)publicClient類成員函數(shù)Public void run()VoidClient、Server類成員函數(shù)Server(int port,Face chat)publicServer類成員函數(shù)Face()PublicFace類成員函數(shù) 四、詳細設計    代碼分服務器端、客戶端、和用戶圖形界面三部分，分別如

8、下：1.服務器端服務器端主要是使用ServerSocket類，相當于服務器Socket，用來監(jiān)聽試圖進入的連接，當新的連接建立后，該類為他們實例化一個Socket對象，同時得到輸入輸出流，調(diào)用相應方法完成會話。具體代碼如下：package nupt.java.socket;import java.awt.*;import .*;import java.io.*;public class Server extends Thread ServerSocket skt;   / ServerSocket類監(jiān)聽進入的連接，為每個新的連接產(chǎn)生一個Socket對象  

9、;        Socket Client =new Socket10;    Socket Client1=null;    int i = 0;    TextArea in;    int port,k=0,l=0;    PrintStream theOutputStream;    Face chat;   

10、; public Server(int port, Face chat)         try             this.port = port;            skt = new ServerSocket(port);      

11、      this.chat = chat;        catch (IOException e)             chat.ta.append(e.toString();                public void

12、 run()         chat.ta.append("等待連線.");        while (true)             try             Clientk = skt.accept()

13、;                                              /當有客戶端連接時就新建一個子線程  

14、0;         if (i < 2)               ServerThread server = new ServerThread10;              serverk= new ServerThread(Clientk, t

15、his.chat, i);                 l=server.length;                 serverk.start();          &

16、#160;     chat.ta.append(“客戶端“+ Clientk.getInetAddress() + "已連線n");                               /for(int j=0;j<serv

17、er.length;j+)                theOutputStream = new PrintStream(serverk.getClient().getOutputStream();                i = serverk.getI();  &#

18、160;             k+;             else                 /theOutputStream = new PrintStream(null);  

19、60;                 catch (SocketException e)             catch (IOException e)                

20、 chat.ta.append(e.toString();                            public void dataout(String data)         /for(int j=0;j<l;j+)    

21、    theOutputStream.println(data);    class ServerThread extends Thread     ServerSocket skt;    Socket Client;    TextArea in;    int port，i;    BufferedReader theInputStream;   

22、PrintStream theOutputStream;    String readin;    Face chat;/服務端子線程    public ServerThread(Socket s, Face chat, int i)         this.i = +i;        Client = s;    

23、60;   this.chat = chat;        public int getI()         return this.i;        public Socket getClient()         return this.Client;     

24、60;  public void run()           try             theInputStream = new BufferedReader(new InputStreamReader(Client             

25、0;      .getInputStream();            theOutputStream = new PrintStream(Client.getOutputStream();            while (true)        &

26、#160;        readin = theInputStream.readLine();                chat.ta.append(readin + "n");               &#

27、160;    catch (SocketException e)             chat.ta.append("連線中斷！n");                         

28、;  / 設置組件可用性            chat.clientBtn.setEnabled(true);            chat.serverBtn.setEnabled(true);            chat.tfaddress.set

29、Enabled(true);            chat.tfport.setEnabled(true);            try                 i - -;   

30、0;            skt.close();                Client.close();            catch (IOException err)    

31、0;            chat.ta.append(err.toString();                    catch (IOException e)             ch

32、at.ta.append(e.toString();                public void dataout(String data)         theOutputStream.println(data);    2.客戶端客戶端主要是使用Socket類，該類是JAVA實現(xiàn)網(wǎng)絡編程重要的基礎(chǔ)類，實現(xiàn)程序間雙向的面向連接的通信。調(diào)用public So

33、cket(String host,int port)方法設定IP和端口。建好連接后，用戶通過得到Socket的輸入輸出流對象后，利用流的方法實現(xiàn)數(shù)據(jù)的傳輸。調(diào)用public InputStream getInputStream()和public OutputStream getOutputStream()方法,分別得到Socket對象的輸入輸出流;具體實現(xiàn)代碼如下：package nupt.java.socket;import .*;import java.io.*;import javax.swing.Timer;public class Client extends Thread 

34、0;     Socket skt;       / 用于客戶端的連接    InetAddress host;        / 主機地址 int port;               / 端口號    BufferedRea

35、der theInputStream;    PrintStream theOutputStream;    String readin;    Face chat;    public Client(String ip, int p, Face chat)         try     host = InetAddress.getByName(ip);  

36、;  / 獲取IP地址   port = p;                                           

37、0;      / 獲取端口號            this.chat = chat;        catch (IOException e)             chat.ta.append(e.toString();  

38、0;             public void run()         try             chat.ta.append("準備連線，稍后！");           

39、 skt = new Socket(host, port);                / 新建Socket對象            chat.ta.append("成功n");          

40、60;    / 緩沖區(qū)末尾添加字符串            theInputStream = new BufferedReader(new InputStreamReader(skt.getInputStream();            theOutputStream = new PrintStream(skt.getOutputStream

41、();            while (true)                 readin = theInputStream.readLine();               

42、chat.ta.append(readin + "n");                    catch (SocketException e)             chat.ta.append("未連上！n");    

43、        chat.clientBtn.setEnabled(true);            chat.serverBtn.setEnabled(true);            chat.tfaddress.setEnabled(true);    

44、60;       chat.tfport.setEnabled(true);            try                 skt.close();         

45、60;  catch (IOException err)                 chat.ta.append(err.toString();                    catch (IOException e)   &

46、#160;         chat.ta.append(e.toString();                public void dataout(String data)         theOutputStream.println(data);    3.用戶圖形界面該部分主

47、要是完成界面的初始化，合理布局組件，方便用戶交互。主要是JAVA按鈕，文本域，標簽，布局管理器的使用。主要處理了鍵盤Enter消息接受，下面是實現(xiàn)代碼：package nupt.java.socket;import java.awt.*;import java.awt.event.*;public class Face extends Frame            private static final long serialVersionUID = 1L;  

48、0; Button clientBtn, serverBtn;    TextArea ta;    TextField tfaddress, tfport, tftype;    Label lbl1,lbl2,lbl3;    int port;    Client client;    Server server;    boolean iamserver;  

49、  static Face frm;    public Face()           / 實例化組件        clientBtn = new Button("客戶端");        serverBtn = new Button("服務器");   

50、60;    ta = new TextArea("", 10, 50, TextArea.SCROLLBARS_BOTH);        lbl1 = new Label("IP地址:");        tfaddress = new TextField("192.168.1.104", 10);     

51、60;  lbl2 = new Label("端口:");        tfport = new TextField("8080");        lbl3 = new Label("發(fā)送內(nèi)容:");        tftype = new TextField(40);    

52、;    tftype.addKeyListener(new TFListener();        ta.setEditable(false);        /向容器中加入以上組件        setLayout(new   FlowLayout();      

53、0; add(lbl1);        add(tfaddress);        add(lbl2);        add(tfport);        add(clientBtn);        add(serverBtn); 

54、;       add(ta);        add(lbl3);        add(tftype);        /設置格式        setLocation(400, 250);     

55、60; /窗口顯示再屏幕的位置坐標        setSize(400, 300);         /設置窗體大小        setTitle("基于Socket和多線程編程的聊天程序");        this.setVisible(true);  

56、;    /設置窗體可見        /事件響應        clientBtn.addActionListener(new ActionListener()             public void actionPerformed(ActionEvent e)    

57、             port = Integer.parseInt(tfport.getText();                client = new Client(tfaddress.getText(), port, frm);       &

58、#160;        client.start();                tfaddress.setEnabled(false);                tfport.setEnabled(false);&#

59、160;               serverBtn.setEnabled(false);                clientBtn.setEnabled(false);          

60、0;         );        serverBtn.addActionListener(new ActionListener()             public void actionPerformed(ActionEvent e)         &#

61、160;       port = Integer.parseInt(tfport.getText();                server = new Server(port, frm);                serve

62、r.start();                iamserver = true;                tfaddress.setText("成為服務器");         

63、       tfaddress.setEnabled(false);                tfport.setEnabled(false);                serverBtn.setEnabled(false);

64、                clientBtn.setEnabled(false);                    );        addWindowListener(new Wind

65、owAdapter()             public void windowClosing(WindowEvent e)                 System.exit(0);             &

66、#160;      );          public static void main(String args)         /主方法             / TODO Auto-generated method stub   

67、0;                     frm = new Face();            private class TFListener implements KeyListener         public

68、void keyPressed(KeyEvent e)      if (e.getKeyCode() = KeyEvent.VK_ENTER) /按Enter輸出顯示聊天內(nèi)容                ta.append(">" + tftype.getText() + "n");