黑马程序员技术交流社区

标题: 用TCP实现聊天室功能，请完成程序的空余部分，期末试题 [打印本页]

---

作者: 黎健东    时间: 2012-7-21 20:31
标题: 用TCP实现聊天室功能，请完成程序的空余部分，期末试题
发一个我大三java期末考试的时候的上机试题，本题25分，全卷100分。
1．JAVA编程：用TCP实现聊天室功能，程序有两个文件Server.java和Client.java，请完成程序的空余部分。

1. //Server.java
   
2. import java.awt.*;
   
3. import java.awt.event.*;
   
4. import java.io.*;
   
5. import java.net.*;
   
6. import java.util.*;
   
7. import javax.swing.*;
   
8. class RecvMegSock extends Thread
   
9. {
   
10.     LinkedList SocketList = null;
    
11.     Socket ClientSock = null;
    
12.     JTextArea jTextArea1;
    
13.    
    
14.     RecvMegSock(LinkedList list,Socket s,JTextArea t)
    
15.     {
    
16.         SocketList = list;
    
17.         jTextArea1 = t;
    
18.         ClientSock = s;
    
19.         start();
    
20.     }
    
21.     public void run()
    
22.     {
    
23.         while(true)
    
24.         {
    
25.             try
    
26.             {
    
27.                 DataInputStream in =  代码1         
    
28.                 String word = in.readUTF();
    
29.                 jTextArea1.setText(jTextArea1.getText() + word + "\n");
    
30.                
    
31.                 for(int i = 0;i < SocketList.size();i++)
    
32.                 {
    
33.                     Socket s = (Socket)SocketList.get(i);
    
34.                     DataOutputStream out =    代码2      
    
35.                     out.writeUTF(   代码3       );
    
36.                 }
    
37.             }
    
38.             catch (IOException ex)
    
39.             {              
    
40.                 for(int i = 0;i < SocketList.size();i++)
    
41.                 {
    
42.                     Socket s = (Socket)SocketList.get(i);
    
43.                     if(s == ClientSock)
    
44.                         SocketList.remove(s);
    
45.                 }
    
46.                 for(int i = 0;i < SocketList.size();i++)
    
47.                 {
    
48.                     Socket s = (Socket)SocketList.get(i);
    
49.                     try
    
50.                     {
    
51.                         DataOutputStream out = new DataOutputStream(s.getOutputStream());
    
52.                         out.writeUTF(ClientSock.getInetAddress() + "已经退出!!\n");
    
53.                     }
    
54.                     catch (IOException ex1)
    
55.                     {   }
    
56.                 }
    
57.                 jTextArea1.setText(jTextArea1.getText() + ClientSock.getInetAddress() + "已经退出!!" + "\n");
    
58.                 return;
    
59.             }
    
60.         }
    
61.     }
    
62. }
    
63. 
    
64. class AcceptSockThread extends   代码4  
    
65. {
    
66.     ServerSocket ServerSock = null;   
    
67.     LinkedList SocketList = null;
    
68.     JTextArea TextArea;
    
69.     AcceptSockThread(ServerSocket s,LinkedList list,JTextArea t)
    
70.     {
    
71.         ServerSock = s;
    
72.         SocketList = list;
    
73.         TextArea = t;
    
74.         start();
    
75.     }
    
76.     public void run()
    
77.     {
    
78.         while(true)
    
79.         {
    
80.             Socket ClientSock = null;
    
81.             try
    
82.             {
    
83.                 boolean same = false;
    
84.                 ClientSock = ServerSock.   代码5     
    
85.                 new RecvMegSock(SocketList,ClientSock,TextArea);
    
86.                 SocketList.add(ClientSock);   
    
87.                
    
88.                 for(int i = 0;i < SocketList.size();i++)
    
89.                 {
    
90.                     Socket s = (Socket)SocketList.get(i);
    
91.                     DataOutputStream out = new DataOutputStream(s.getOutputStream());
    
92.                     out.writeUTF(ClientSock.getInetAddress() + "成功连接服务器\n");
    
93.                 }
    
94.                 TextArea.setText(TextArea.getText() + ClientSock.getInetAddress() + "连接到服务器\n");
    
95.             }
    
96.             catch (IOException ex)
    
97.             {   }            
    
98.         }
    
99.     }
    
100. }
     
101. public class Server extends javax.swing.JDialog implements ActionListener
     
102. {        
     
103.     ServerSocket server = null;
     
104.     LinkedList SocketList = null;
     
105.     private javax.swing.JButton jButton1;
     
106.     private javax.swing.JScrollPane jScrollPane1;
     
107.     private javax.swing.JTextArea jTextArea1;
     
108.     private javax.swing.JTextField jTextField1;
     
109.     public Server(java.awt.Frame parent, boolean modal)
     
110.     {
     
111.         super(parent, modal);
     
112.         initComponents();
     
113.         try
     
114.         {
     
115.             server = new ServerSocket(8888);
     
116.             SocketList = new LinkedList();
     
117.             new AcceptSockThread(server,SocketList,jTextArea1);
     
118.         }
     
119.         catch (IOException ex)
     
120.         {    }
     
121.     }
     
122.     @SuppressWarnings("unchecked")
     
123.     private void initComponents() {
     
124.         jScrollPane1 = new javax.swing.JScrollPane();
     
125.         jTextArea1 = new javax.swing.JTextArea();
     
126.         jTextField1 = new javax.swing.JTextField();
     
127.         jButton1 = new javax.swing.JButton();
     
128.         setDefaultCloseOperation(javax.swing.WindowConstants.DISPOSE_ON_CLOSE);
     
129.         getContentPane().setLayout(null);
     
130.         jTextArea1.setColumns(20);
     
131.         jTextArea1.setEditable(false);
     
132.         jTextArea1.setRows(5);
     
133.         jScrollPane1.setViewportView(jTextArea1);
     
134.         getContentPane().add(jScrollPane1);
     
135.         jScrollPane1.setBounds(10, 10, 380, 250);
     
136.         getContentPane().add(jTextField1);
     
137.         jTextField1.setBounds(10, 270, 290, 21);
     
138.         jButton1.setText("发送");
     
139.         jButton1.addActionListener(this);
     
140.         jTextField1.addActionListener(this);
     
141.         getContentPane().add(jButton1);
     
142.         jButton1.setBounds(310, 270, 80, 25);
     
143.         pack();
     
144.     }
     
145. public void actionPerformed(java.awt.event.ActionEvent evt) {
     
146.     if(SocketList.size() == 0)
     
147.     {
     
148.         jTextArea1.setText(jTextArea1.getText() + "没有人连接!!" + "\n");
     
149.         return;
     
150.     }
     
151.     for(int i = 0;i < SocketList.size();i++)
     
152.     {
     
153.         DataOutputStream out;
     
154.         try
     
155.         {
     
156.             out = new DataOutputStream(((Socket) SocketList.get(i)).getOutputStream());
     
157.             if(jTextField1.getText() != null)
     
158.                 out.writeUTF("服务器: "+jTextField1.getText());            
     
159.         }
     
160.         catch (IOException ex)
     
161.         {   }        
     
162.     }   
     
163.     jTextArea1.setText(jTextArea1.getText() + "服务器: "+ jTextField1.getText() + "\n");
     
164. }
     
165. public static void main(String args[])
     
166.     {
     
167.         Server dlg = new Server(null,true);
     
168.         dlg.setBounds(300, 200, 400, 325);
     
169.         dlg.addWindowListener(new WindowAdapter() {
     
170.             public void windowClosing(WindowEvent e) {
     
171.                     System.exit(0);
     
172.             }
     
173.         });
     
174.         dlg.setVisible(true);
     
175.     }
     
176. }
     

复制代码

---

作者: 黎健东    时间: 2012-7-21 20:31

1. 
   
2. //Client.java
   
3. import java.awt.event.*;
   
4. import java.io.*;
   
5. import java.net.*;
   
6. class RecvMegThread extends Thread
   
7. {
   
8.     DataInputStream in;
   
9.     DataOutputStream out;
   
10.     Socket ServerSock;
    
11.     javax.swing.JTextArea TextArea;
    
12.     Client MainDialog;
    
13.     RecvMegThread(Client dlg)
    
14.     {
    
15.         MainDialog = dlg;
    
16.         ServerSock = dlg.ServerSock;
    
17.         TextArea = dlg.jTextArea1;
    
18.         try
    
19.         {
    
20.             in = new DataInputStream(ServerSock.getInputStream());
    
21.             out = new DataOutputStream(ServerSock.getOutputStream());
    
22.         }
    
23.         catch (IOException ex)
    
24.         {     }        
    
25.         start();
    
26.     }
    
27.     public void run()
    
28.     {
    
29.         while(true)
    
30.         {
    
31.             try
    
32.             {
    
33.                 String word = in.readUTF();
    
34.                 TextArea.setText(TextArea.getText() + word + "\n");
    
35.             }
    
36.             catch (IOException ex)
    
37.             {
    
38.                 TextArea.setText(TextArea.getText() + "和服务器失去了联系！！" + "\n");
    
39.                 MainDialog.ServerSock = null;
    
40.                 return;
    
41.             }
    
42.         }
    
43.     }
    
44. }
    
45. public class Client extends javax.swing.JDialog  implements ActionListener
    
46. {
    
47.     private javax.swing.JTextField IP;
    
48.     private javax.swing.JTextField Port;
    
49.     private javax.swing.JTextField Username;
    
50.     private javax.swing.JButton jButton1;
    
51.     private javax.swing.JButton jButton2;
    
52.     private javax.swing.JLabel jLabel1;
    
53.     private javax.swing.JLabel jLabel2;
    
54.     private javax.swing.JLabel jLabel3;
    
55.     private javax.swing.JScrollPane jScrollPane1;
    
56.     public javax.swing.JTextArea jTextArea1;
    
57.     private javax.swing.JTextField jTextField1;
    
58.     Socket ServerSock;        
    
59.     String username;
    
60.     public Client(java.awt.Frame parent, boolean modal)
    
61.     {
    
62.         super(parent, modal);
    
63.         initComponents();               
    
64.     }
    
65.    @SuppressWarnings("unchecked")
    
66.     private void initComponents() {
    
67.         jScrollPane1 = new javax.swing.JScrollPane();
    
68.         jTextArea1 = new javax.swing.JTextArea();
    
69.         jTextField1 = new javax.swing.JTextField();
    
70.         jButton1 = new javax.swing.JButton();
    
71.         jLabel1 = new javax.swing.JLabel();
    
72.         IP = new javax.swing.JTextField();
    
73.         jLabel2 = new javax.swing.JLabel();
    
74.         Port = new javax.swing.JTextField();
    
75.         jLabel3 = new javax.swing.JLabel();
    
76.         Username = new javax.swing.JTextField();
    
77.         jButton2 = new javax.swing.JButton();
    
78.         setDefaultCloseOperation(javax.swing.WindowConstants.DISPOSE_ON_CLOSE);
    
79.         getContentPane().setLayout(null);
    
80.         jTextArea1.setColumns(20);
    
81.         jTextArea1.setEditable(false);
    
82.         jTextArea1.setRows(5);
    
83.         jScrollPane1.setViewportView(jTextArea1);
    
84.         getContentPane().add(jScrollPane1);
    
85.         jScrollPane1.setBounds(10, 40, 570, 220);
    
86.         getContentPane().add(jTextField1);
    
87.         jTextField1.setBounds(10, 270, 460, 21);
    
88.         jButton1.setText("发送");
    
89.         jButton1.addActionListener(this);
    
90.         getContentPane().add(jButton1);
    
91.         jButton1.setBounds(495, 270, 80, 25);
    
92.         jLabel1.setText("服务器IP：");
    
93.         getContentPane().add(jLabel1);
    
94.         jLabel1.setBounds(10, 10, 70, 20);
    
95.         IP.setText("127.0.0.1");
    
96.         getContentPane().add(IP);
    
97.         IP.setBounds(70, 10, 100, 21);
    
98.         jLabel2.setText("端口：");
    
99.         getContentPane().add(jLabel2);
    
100.         jLabel2.setBounds(180, 10, 50, 20);
     
101.         Port.setText("8888");
     
102.         getContentPane().add(Port);
     
103.         Port.setBounds(220, 10, 70, 21);
     
104.         jLabel3.setText("用户名：");
     
105.         getContentPane().add(jLabel3);
     
106.         jLabel3.setBounds(300, 10, 70, 20);
     
107.         Username.setText("无名氏");
     
108.         getContentPane().add(Username);
     
109.         Username.setBounds(360, 10, 100, 21);
     
110.         jButton2.setText("连接");
     
111.         jButton2.addActionListener(this);
     
112.         jTextField1.addActionListener(this);
     
113.         getContentPane().add(jButton2);
     
114.         jButton2.setBounds(490, 10, 90, 25);
     
115.         pack();
     
116.     }
     
117. 
     
118. public void actionPerformed(java.awt.event.ActionEvent evt) {
     
119.     if ((evt.getSource()==jButton1)||(evt.getSource()==jTextField1))
     
120.     {
     
121.         if(ServerSock == null)
     
122.         {
     
123.             jTextArea1.setText(jTextArea1.getText() + "没有连接服务器！！" + "\n");
     
124.             return;
     
125.         }
     
126.         try
     
127.         {
     
128.             DataOutputStream out = new DataOutputStream(ServerSock.getOutputStream());
     
129.             if(jTextField1.getText() != null)
     
130.                 out.writeUTF(username + ": " + jTextField1.getText());
     
131.         }
     
132.         catch (IOException ex)
     
133.         {    }
     
134.     }
     
135.    if( evt.getSource()==jButton2 )
     
136.    {
     
137.         if(IP.getText().equals("") || Port.getText().equals("") )
     
138.         {
     
139.             this.jTextArea1.setText(this.jTextArea1.getText() + "IP 和 端口不能为空！！\n");
     
140.             return;
     
141.         }
     
142.         try
     
143.         {
     
144.             Integer.parseInt(Port.getText());
     
145.         }
     
146.         catch(Exception e)
     
147.         {
     
148.             this.jTextArea1.setText(this.jTextArea1.getText() + "端口号应为数字！！\n");
     
149.             return;
     
150.         }
     
151.         try
     
152.         {
     
153.             if(ServerSock != null)
     
154.             {
     
155.                 String str = "" + ServerSock.getInetAddress() + ServerSock.getPort();
     
156.                 System.out.println(str);
     
157.                 System.out.println("/" + IP.getText() + Port.getText());
     
158.                 if(str.equals("/" + IP.getText() + Port.getText()))
     
159.                 {
     
160.                     this.jTextArea1.setText(this.jTextArea1.getText() + "已经连接了服务器！！\n");
     
161.                     return;
     
162.                 }
     
163.             }
     
164.             ServerSock = new Socket(IP.getText(), Integer.parseInt(Port.getText()));
     
165.             username = Username.getText();
     
166.             new RecvMegThread(this);
     
167.         }
     
168.         catch (Exception ex)
     
169.         {
     
170.             jTextArea1.setText(jTextArea1.getText() + "连接不上服务器！！\n");
     
171.             return;
     
172.         }
     
173.   }
     
174. }
     
175. 
     
176.     public static void main(String args[])
     
177.     {
     
178.       
     
179.         Client dlg = new Client(null,true);
     
180.         dlg.setBounds(300, 200, 605, 340);
     
181.         dlg.addWindowListener(new WindowAdapter() {
     
182.             public void windowClosing(WindowEvent e) {
     
183.                     System.exit(0);
     
184.             }
     
185.         });
     
186.         dlg.setVisible(true);        
     
187.     }
     
188. }
     
189. 
     

复制代码

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2