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