Java Socket简单应用

skylar

Server.java

1. package chat.ui;
   
2. 
   
3. import java.awt.Dimension;
   
4. import java.awt.event.WindowAdapter;
   
5. import java.awt.event.WindowEvent;
   
6. import java.io.DataInputStream;
   
7. import java.io.DataOutputStream;
   
8. import java.io.IOException;
   
9. import java.net.ServerSocket;
   
10. import java.net.Socket;
    
11. import java.util.ArrayList;
    
12. import java.util.Date;
    
13. import java.util.List;
    
14. import java.util.concurrent.ExecutorService;
    
15. import java.util.concurrent.Executors;
    
16. 
    
17. import javax.swing.JFrame;
    
18. import javax.swing.JScrollPane;
    
19. import javax.swing.JTextArea;
    
20. 
    
21. @SuppressWarnings("serial")
    
22. public class Server extends JFrame {
    
23. 
    
24.     private JScrollPane pane;
    
25.     private JTextArea textAreaShow;
    
26.     private ServerSocket serverSocket;
    
27.     private List<Socket> connectedSockets = new ArrayList<Socket>();
    
28. 
    
29.     public Server() {
    
30.         initFrame();
    
31.         int port = 8888;
    
32.         try {
    
33.             startServer(port);
    
34.         } catch (IOException e) {
    
35.             String text = "以端口号" + port + "启动Socket服务失败,检查端口是否被占用，并重新启动服务";
    
36.             textAreaShow.append(text);
    
37.         }
    
38.     }
    
39. 
    
40.     // 窗口初始化
    
41.     private void initFrame() {
    
42. 
    
43.         setTitle("服务端");
    
44.         setSize(500, 400);
    
45.         setMinimumSize(new Dimension(250, 200));
    
46. 
    
47.         setDefaultCloseOperation(DO_NOTHING_ON_CLOSE);
    
48.         addWindowListener(new WindowAdapter() {
    
49.             @Override
    
50.             public void windowClosing(WindowEvent event) {
    
51.                 if (serverSocket != null) {
    
52.                     try {
    
53.                         serverSocket.close();
    
54.                     } catch (IOException e) {
    
55.                         e.printStackTrace();
    
56.                         System.exit(1);
    
57.                     }
    
58.                     System.exit(0);
    
59.                 }
    
60.             }
    
61.         });
    
62. 
    
63.         // 重写JTextArea的append方法
    
64.         textAreaShow = new JTextArea() {
    
65.             @Override
    
66.             public void append(String str) {
    
67.                 str = (new Date().toString()) + "  " + str + "\n";
    
68.                 super.append(str);
    
69.             }
    
70.         };
    
71.         textAreaShow.setEditable(false);
    
72.         textAreaShow.setLineWrap(true);
    
73.         textAreaShow.setWrapStyleWord(true);
    
74. 
    
75.         pane = new JScrollPane(textAreaShow,
    
76.                 JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED,
    
77.                 JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    
78. 
    
79.         add(pane);
    
80. 
    
81.         setVisible(true);
    
82.     }
    
83. 
    
84.     // 启动服务，等待客户端连接
    
85.     private void startServer(int port) throws IOException {
    
86.         ExecutorService executorService = Executors.newCachedThreadPool();
    
87.         serverSocket = new ServerSocket(port);
    
88.         Socket socket;
    
89.         textAreaShow.append("服务已启动，端口号" + port);
    
90.         while (true) {
    
91.             socket = serverSocket.accept();
    
92.             String connectedMsg = "端口号" + socket.getPort() + " 已连接";
    
93.             textAreaShow.append(connectedMsg);
    
94.             dispatchMessage(connectedMsg);
    
95.             connectedSockets.add(socket);
    
96.             executorService.execute(new ServerThread(socket));
    
97.         }
    
98.     }
    
99. 
    
100.     // 向各客个连接转发发送消息
     
101.     private void dispatchMessage(String str) {
     
102.         DataOutputStream dos;
     
103.         for (Socket soc : connectedSockets) {
     
104.             try {
     
105.                 dos = new DataOutputStream(soc.getOutputStream());
     
106.                 dos.writeUTF(str);
     
107.             } catch (IOException e) {
     
108.                 e.printStackTrace();
     
109.             }
     
110.         }
     
111.     }
     
112. 
     
113.     // 处理各连接的线程
     
114.     private class ServerThread implements Runnable {
     
115. 
     
116.         private Socket socket;
     
117.         private DataInputStream in;
     
118. 
     
119.         public ServerThread(Socket socket) {
     
120.             this.socket = socket;
     
121.             try {
     
122.                 in = new DataInputStream(socket.getInputStream());
     
123.             } catch (IOException e) {
     
124.                 textAreaShow.append(e.getMessage());
     
125.             }
     
126.         }
     
127. 
     
128.         @Override
     
129.         public void run() {
     
130.             try {
     
131.                 String str;
     
132.                 while ((str = in.readUTF()) != null) {
     
133.                     str = socket.getPort() + "说：" + str;
     
134.                     textAreaShow.append(str);
     
135.                     dispatchMessage(str);
     
136.                 }
     
137.             } catch (IOException e) {
     
138.                 textAreaShow.append("Port " + socket.getPort() + " 已断开连接");
     
139.                 connectedSockets.remove(socket);
     
140.                 closeSocket();
     
141.             }
     
142.         }
     
143. 
     
144.         private void closeSocket() {
     
145.             if (in != null) {
     
146.                 try {
     
147.                     in.close();
     
148.                 } catch (IOException e) {
     
149.                     e.printStackTrace();
     
150.                 }
     
151.             }
     
152.             if (socket != null) {
     
153.                 try {
     
154.                     socket.close();
     
155.                 } catch (IOException e) {
     
156.                     e.printStackTrace();
     
157.                 }
     
158.             }
     
159.         }
     
160.     }
     
161. 
     
162.     public static void main(String[] args) {
     
163.         new Server();
     
164.     }
     
165. }

复制代码

Client.java

1. package chat.ui;
   
2. 
   
3. import java.awt.BorderLayout;
   
4. import java.awt.Dimension;
   
5. import java.awt.event.ActionEvent;
   
6. import java.awt.event.ActionListener;
   
7. import java.awt.event.WindowAdapter;
   
8. import java.awt.event.WindowEvent;
   
9. import java.io.DataInputStream;
   
10. import java.io.DataOutputStream;
    
11. import java.io.IOException;
    
12. import java.net.Socket;
    
13. import java.util.Date;
    
14. 
    
15. import javax.swing.JButton;
    
16. import javax.swing.JFrame;
    
17. import javax.swing.JPanel;
    
18. import javax.swing.JScrollPane;
    
19. import javax.swing.JTextArea;
    
20. import javax.swing.JTextField;
    
21. 
    
22. @SuppressWarnings("serial")
    
23. public class Client extends JFrame {
    
24. 
    
25.     private JTextArea textAreaShow;
    
26.     private JTextField textFieldInput;
    
27.     private JButton buttonSend;
    
28.     private JScrollPane paneTop;
    
29.     private JPanel paneBottom;
    
30.     private Socket socket;
    
31.     private DataInputStream in;
    
32.     private DataOutputStream out;
    
33.     private String str;
    
34.     SendActionListener sendActionListener;
    
35. 
    
36.     public Client() {
    
37.         initFrame();
    
38.         connect();
    
39.     }
    
40. 
    
41.     private void initFrame() {
    
42. 
    
43.         setTitle("客户端");
    
44.         setSize(500, 400);
    
45.         setMinimumSize(new Dimension(250, 200));
    
46.         setDefaultCloseOperation(DO_NOTHING_ON_CLOSE);
    
47.         addWindowListener(new WindowExitListener());
    
48. 
    
49.         // 重写append方法，在前面加上日期和在末尾加上换行
    
50.         textAreaShow = new JTextArea() {
    
51.             @Override
    
52.             public void append(String str) {
    
53.                 str = new Date().toString() + "   " + str + "\n";
    
54.                 super.append(str);
    
55.             }
    
56.         };
    
57.         textAreaShow.setEditable(false);
    
58.         textAreaShow.setLineWrap(true);
    
59.         textAreaShow.setWrapStyleWord(true);
    
60. 
    
61.         SendActionListener sendActionListener = new SendActionListener();
    
62.         textFieldInput = new JTextField();
    
63.         textFieldInput.addActionListener(sendActionListener);
    
64.         buttonSend = new JButton("发送");
    
65.         buttonSend.addActionListener(new SendActionListener());
    
66. 
    
67.         paneTop = new JScrollPane(textAreaShow,
    
68.                 JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED,
    
69.                 JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    
70. 
    
71.         paneBottom = new JPanel(new BorderLayout());
    
72.         paneBottom.add(textFieldInput, BorderLayout.CENTER);
    
73.         paneBottom.add(buttonSend, BorderLayout.EAST);
    
74. 
    
75.         add(paneTop, BorderLayout.CENTER);
    
76.         add(paneBottom, BorderLayout.SOUTH);
    
77. 
    
78.         setVisible(true);
    
79.     }
    
80. 
    
81.     // 连接到服务，并得到输入输出流
    
82.     private void connect() {
    
83.         int port = 8888;
    
84.         try {
    
85.             socket = new Socket("localhost", port);
    
86.             textAreaShow.append("连接到服务,本地端口号" + socket.getLocalPort());
    
87.             setTitle("客户端" + socket.getLocalPort());
    
88.             in = new DataInputStream(socket.getInputStream());
    
89.             out = new DataOutputStream(socket.getOutputStream());
    
90. 
    
91.             String message;
    
92.             while ((message = in.readUTF()) != null) {
    
93.                 textAreaShow.append(message);
    
94.             }
    
95.         } catch (IOException e) {
    
96.             textAreaShow.append("连接异常");
    
97.             close();
    
98.         }
    
99.     }
    
100. 
     
101.     // 释放资源
     
102.     private int close() {
     
103.         int exitCode = 0;
     
104.         if (out != null) {
     
105.             try {
     
106.                 out.close();
     
107.             } catch (IOException e) {
     
108.                 e.printStackTrace();
     
109.                 exitCode = 1;
     
110.             }
     
111.         }
     
112.         if (in != null) {
     
113.             try {
     
114.                 in.close();
     
115.             } catch (IOException e) {
     
116.                 e.printStackTrace();
     
117.                 exitCode = 1;
     
118.             }
     
119. 
     
120.         }
     
121.         if (socket != null) {
     
122.             try {
     
123.                 socket.close();
     
124.             } catch (IOException e) {
     
125.                 exitCode = 1;
     
126.                 e.printStackTrace();
     
127.             }
     
128.         }
     
129.         return exitCode;
     
130.     }
     
131. 
     
132.     // 响应关闭操作
     
133.     private class WindowExitListener extends WindowAdapter {
     
134.         @Override
     
135.         public void windowClosing(WindowEvent event) {
     
136.             System.exit(close());
     
137.         }
     
138.     }
     
139. 
     
140.     // 响应发送操作
     
141.     private class SendActionListener implements ActionListener {
     
142. 
     
143.         @Override
     
144.         public void actionPerformed(ActionEvent event) {
     
145.             str = textFieldInput.getText();
     
146.             try {
     
147.                 out.writeUTF(str);
     
148.                 textFieldInput.setText("");
     
149.             } catch (IOException e) {
     
150.                 e.printStackTrace();
     
151.             }
     
152.         }
     
153. 
     
154.     }
     
155. 
     
156.     public static void main(String[] args) {
     
157.         new Client();
     
158.     }
     
159. 
     
160. }

复制代码

捕获.PNG