1 package com.loveincode.socket;
 2 
 3 import java.io.DataInputStream;
 4 import java.io.DataOutputStream;
 5 import java.io.IOException;
 6 import java.net.ServerSocket;
 7 import java.net.Socket;
 8 import java.net.SocketTimeoutException;
 9 
10 public class MyServer extends Thread{
11 
12        private ServerSocket serverSocket;
13        
14        public MyServer(int port) throws IOException
15        {
16           //服务器实例化一个 ServerSocket 对象，表示通过服务器上的端口通信。
17           serverSocket = new ServerSocket(port);
18           //10s中没有连接，则关闭
19           serverSocket.setSoTimeout(10000);
20        }
21      
22        public void run()
23        {
24           while(true)
25           {
26              try
27              {
28                 System.out.println("Server：等待远程连接，端口号为：" + serverSocket.getLocalPort() + "...");
29                 //服务器调用 ServerSocket 类的 accept() 方法，该方法将一直等待，直到客户端连接到服务器上给定的端口。
30                 //在服务器端，accept() 方法返回服务器上一个新的 socket 引用，该 socket 连接到客户端的 socket。
31                 Socket server = serverSocket.accept();
32                 System.out.println("Server：远程主机地址：" + server.getRemoteSocketAddress());
33                 DataInputStream in = new DataInputStream(server.getInputStream());
34                 System.out.println(in.readUTF());
35                 DataOutputStream out = new DataOutputStream(server.getOutputStream());
36                 out.writeUTF("Server：谢谢连接我：" + server.getLocalSocketAddress() + "\nGoodbye!");
37                 server.close();
38              }catch(SocketTimeoutException s)
39              {
40                 System.out.println("Server：Socket timed out!");
41                 break;
42              }catch(IOException e)
43              {
44                 e.printStackTrace();
45                 break;
46              }
47           }
48        }
49        
50 }

 1 package com.loveincode.socket;
 2 
 3 import java.io.IOException;
 4 
 5 public class Test {
 6     public static void main(String[] args) throws IOException, InterruptedException {
 7         
 8         MyServer server = new MyServer(5209);
 9         server.start();
10         
11         Thread.sleep(1000);
12         String[] arg = {"localhost","5209"};
13         //服务器正在等待时，一个客户端实例化一个 Socket 对象，指定服务器名称和端口号来请求连接。
14         MyClient.main(arg);
15         
16         MyClient.main(arg);
17         
18     }
19 }