1 import java.net.*;
 2 import java.io.*;
 3 public class TestServerSocket{
 4         public static void main(String args[]) throws Exception{
 5                 ServerSocket ss = new ServerSocket(6666);
 6                 /*创建一个ServerSocket对象时往往会给它指定一个端口号
 7                 指定端口号的意思是这个new出来的ServerSocket对象要使用的
 8                 是哪一个端口号，通过哪一个端口号来监听客户端的连接
 9                 因此指定一个端口号的意义就是为了告诉计算机ServerSocket对象
10                 在哪个地方监听客户端的连接*/
11                 /*服务器端接收客户端连接的请求是不间断地接收的，所以服务器端的
12                 编程一般都是死循环，永不休止地运行着。*/
13                 while(true){
14                             Socket s = ss.accept();
15                             /*在服务器端调用accept()方法接受客户端的连接对象,accept()方法是
16                             一个阻塞式方法，一直在傻傻地等待着是否有客户端申请连接上来
17                             然后服务器端的Socket插座就和客户端的Socket插座建立了连接了*/
18                             /*客户端能否连接上服务器端，取决于服务器端是否接受客户端的连接请求
19                             如果接受了客户端的连接请求，那么在服务器端就安装上一个Socket插座
20                             通过这个插座与连接上的客户端就可以建立连接，互相通信了*/
21                             System.out.println("A Client Connected!");
22                             /*使用InputStream流接收从客户端发送过来的信息，使用DataInputStream数据流处理接收到的信息*/
23                 DataInputStream dis = new DataInputStream(s.getInputStream());
24                             /*使用readUTF(方法将接收到的信息全部读取出来，存储到变量str里面
25                             readUTF()方法也是一个阻塞式方法，会傻傻地等待客户端发送信息过来，然后将接收到的信息读取出来
26                             如果客户端不写东西过来，它就一直在服务器端傻傻地等待着，直到客户端写东西过来为止
27                             堵塞式的方法效率往往是不高的,比如说一个客户端连接上来了，但是它迟迟不发送信息，
28                             那么服务器端的程序就阻塞住了，这样另外一个客户端就连接不上来了，因为另外一个客户端要想连接
29                             上服务器端，就必须得在服务器端调用accept()方法，可accept()方法必须得在下一次循环时才能够被
30                             调用，现在服务器端的程序运行到调用readUTF()这个方法时就阻塞住了，它要等待着已经连接上来的
31                             那个客户端发送信息过来后将信息读取出来，如果客户端一直不发信息到服务器端，那么readUTF()方法
32                             就一直无法读取到信息，那么服务器端的程序会阻塞在这里，无法进行下次循环，这样其他的客户端就
33                             无法连接到服务器端了*/
34                             String str = dis.readUTF();
35                             System.out.println(str);
36                     }
37             }
38     }

 1 import java.net.*;
 2 import java.io.*;
 3 public class TestClientSocket{
 4     public static void main(String args[]) throws Exception{
 5         Socket s = new Socket("127.0.0.1",6666);
 6         /*Client申请连接到Server端上*/
 7         /*连接上服务器端以后，就可以向服务器端输出信息和接收从服务器端返回的信息
 8         输出信息和接收返回信息都要使用流式的输入输出原理进行信息的处理*/
 9         /*这里是使用输出流OutputStream向服务器端输出信息*/
10         OutputStream os = s.getOutputStream();
11         DataOutputStream dos = new DataOutputStream(os);
12         Thread.sleep(30000);/*客户端睡眠30秒后再向服务器端发送信息*/
13         dos.writeUTF("Hello Server!");
14     }
15 }