import java.net.*;
import java.io.*;
public class TestServerSocket{
    public static void main(String args[]) throws Exception{
        ServerSocket ss = new ServerSocket(6666);
        /*創(chuàng)建一個ServerSocket對象時往往會給它指定一個端口號
        指定端口號的意思是這個new出來的ServerSocket對象要使用的
        是哪一個端口號，通過哪一個端口號來監(jiān)聽客戶端的連接
        因此指定一個端口號的意義就是為了告訴計算機ServerSocket對象
        在哪個地方監(jiān)聽客戶端的連接*/
        /*服務器端接收客戶端連接的請求是不間斷地接收的，所以服務器端的
        編程一般都是死循環(huán)，永不休止地運行著。*/
        while(true){
              Socket s = ss.accept();
              /*在服務器端調用accept()方法接受客戶端的連接對象,accept()方法是
              一個阻塞式方法，一直在傻傻地等待著是否有客戶端申請連接上來
              然后服務器端的Socket插座就和客戶端的Socket插座建立了連接了*/
              /*客戶端能否連接上服務器端，取決于服務器端是否接受客戶端的連接請求
              如果接受了客戶端的連接請求，那么在服務器端就安裝上一個Socket插座
              通過這個插座與連接上的客戶端就可以建立連接，互相通信了*/
              System.out.println("A Client Connected!");
              /*使用InputStream流接收從客戶端發(fā)送過來的信息，使用DataInputStream數據流處理接收到的信息*/
        DataInputStream dis = new DataInputStream(s.getInputStream());
              /*使用readUTF(方法將接收到的信息全部讀取出來，存儲到變量str里面
              readUTF()方法也是一個阻塞式方法，會傻傻地等待客戶端發(fā)送信息過來，然后將接收到的信息讀取出來
              如果客戶端不寫東西過來，它就一直在服務器端傻傻地等待著，直到客戶端寫東西過來為止
              堵塞式的方法效率往往是不高的,比如說一個客戶端連接上來了，但是它遲遲不發(fā)送信息，
              那么服務器端的程序就阻塞住了，這樣另外一個客戶端就連接不上來了，因為另外一個客戶端要想連接
              上服務器端，就必須得在服務器端調用accept()方法，可accept()方法必須得在下一次循環(huán)時才能夠被
              調用，現在服務器端的程序運行到調用readUTF()這個方法時就阻塞住了，它要等待著已經連接上來的
              那個客戶端發(fā)送信息過來后將信息讀取出來，如果客戶端一直不發(fā)信息到服務器端，那么readUTF()方法
              就一直無法讀取到信息，那么服務器端的程序會阻塞在這里，無法進行下次循環(huán)，這樣其他的客戶端就
              無法連接到服務器端了*/
              String str = dis.readUTF();
              System.out.println(str);
          }
      }
  }

import java.net.*;
import java.io.*;
public class TestClientSocket{
  public static void main(String args[]) throws Exception{
    Socket s = new Socket("127.0.0.1",6666);
    /*Client申請連接到Server端上*/
    /*連接上服務器端以后，就可以向服務器端輸出信息和接收從服務器端返回的信息
    輸出信息和接收返回信息都要使用流式的輸入輸出原理進行信息的處理*/
    /*這里是使用輸出流OutputStream向服務器端輸出信息*/
    OutputStream os = s.getOutputStream();
    DataOutputStream dos = new DataOutputStream(os);
    Thread.sleep(30000);/*客戶端睡眠30秒后再向服務器端發(fā)送信息*/
    dos.writeUTF("Hello Server!");
  }
}