/**
* 測(cè)試ServerSocket類(lèi)和Socket類(lèi)
* Socket為傳輸層供給應(yīng)用層的編程接口，用于應(yīng)用層與傳輸層之間的數(shù)據(jù)通信
* Socket類(lèi)使用TCP協(xié)議，客戶端向服務(wù)端發(fā)出連接請(qǐng)求，經(jīng)過(guò)三次握手后客戶端和服務(wù)端不再有區(qū)別，都可收發(fā)數(shù)據(jù)
* ServerSocket為服務(wù)端，“請(qǐng)求-響應(yīng)”模式需要先運(yùn)行服務(wù)端監(jiān)聽(tīng)端口，再通過(guò)客戶端進(jìn)行訪問(wèn)
*/
public class TestServerSocket extends Thread{
? ?public void server(){
? ? ? ?//創(chuàng)建服務(wù)器線程
? ? ? ?ServerSocket ss=null;
? ? ? ?Socket client=null;
? ? ? ?BufferedReader br = null;
? ? ? ?BufferedOutputStream bos = null;
? ? ? ?try {
? ? ? ? ? ?ss = new ServerSocket(8888);
? ? ? ? ? ?//創(chuàng)建服務(wù)端，構(gòu)造器傳參端口號(hào)port，設(shè)定為8888端口，這時(shí)服務(wù)端尚未運(yùn)行
? ? ? ? ? ?client = ss.accept();
? ? ? ? ? ?//.accept()方法監(jiān)聽(tīng)端口，線程進(jìn)入阻塞狀態(tài)，直到accept接收到連接，返回Socket對(duì)象，這個(gè)對(duì)象象征客戶端，通過(guò)這個(gè)對(duì)象來(lái)與客戶端收發(fā)數(shù)據(jù)
? ? ? ? ? ?br = new BufferedReader(new InputStreamReader(client.getInputStream()));
? ? ? ? ? ?//.getInputStream()返回輸入流，數(shù)據(jù)源為客戶端通過(guò)輸出流發(fā)送的內(nèi)容，如果是http請(qǐng)求，發(fā)送的內(nèi)容包括請(qǐng)求首行、請(qǐng)求頭、空行、請(qǐng)求體
? ? ? ? ? ?for (String text = br.readLine();text!=null;text = br.readLine()){
? ? ? ? ? ? ? ?System.out.println(text);
? ? ? ? ? ? ? ?//使用緩沖字符流輸出整行內(nèi)容，當(dāng)讀完客戶端當(dāng)前發(fā)送的所有內(nèi)容后.read()會(huì)繼續(xù)阻塞等待接收新的內(nèi)容，這使得.readLine()并不會(huì)返回null。只有當(dāng)客戶端關(guān)閉輸出流時(shí).readLine()才會(huì)返回null表示讀完了
? ? ? ? ? ?}
? ? ? ? ? ?bos = new BufferedOutputStream(client.getOutputStream());
? ? ? ? ? ?//.getOutputStream()返回字節(jié)輸出流，用于向客戶端發(fā)數(shù)據(jù)，在建立連接之后雙方都可以收和發(fā)
? ? ? ? ? ?bos.write("HTTP/1.1 200 OK\r\n\r\nHello World\r\n".getBytes());
? ? ? ? ? ?//字節(jié)緩沖流發(fā)送字節(jié)數(shù)組
? ? ? ? ? ?bos.flush();
? ? ? ? ? ?//數(shù)據(jù)寫(xiě)完必須要flush()
? ? ? ? ? ?client.shutdownOutput();
? ? ? ? ? ?//發(fā)送完數(shù)據(jù)關(guān)閉輸出流，以解除接收方.read()造成的阻塞
? ? ? ?} catch (IOException e) {
? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ?}finally {
? ? ? ? ? ?if (br != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?br.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ? ? ?if (client != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?client.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ? ? ?if (ss != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?ss.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ? ? ?if (bos != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?bos.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ?}
? ?}

? ?public void client(){
? ? ? ?//創(chuàng)建客戶端線程
? ? ? ?Socket socket=null;
? ? ? ?PrintWriter pw =null;
? ? ? ?BufferedInputStream bis = null;
? ? ? ?try {
? ? ? ? ? ?socket = new Socket("127.0.0.1",8888);
? ? ? ? ? ?//創(chuàng)建Socket對(duì)象，需要指定域名/ip地址和端口號(hào)，構(gòu)造器返回的對(duì)象象征服務(wù)端，通過(guò)這個(gè)對(duì)象即可與服務(wù)端收發(fā)數(shù)據(jù)
? ? ? ? ? ?pw = new PrintWriter(socket.getOutputStream(),true);
? ? ? ? ? ?//.getOutputStream()返回字節(jié)輸出流，通過(guò)這個(gè)字節(jié)輸出流可以向服務(wù)端發(fā)送數(shù)據(jù)
? ? ? ? ? ?//PrintWriter作為處理流包裹字節(jié)流時(shí)設(shè)定boolean autoFlush=true會(huì)套緩沖流并且自動(dòng)flush
? ? ? ? ? ?//PrintWriter構(gòu)造器中不設(shè)定autoFlush時(shí)默認(rèn)false，且autoFlush只有在println自動(dòng)換行中生效，使用print()不會(huì)flush
? ? ? ? ? ?pw.println("GET / HTTP/1.1\r\n\r\n");
? ? ? ? ? ?socket.shutdownOutput();
? ? ? ? ? ?//發(fā)送完數(shù)據(jù)需要關(guān)閉輸出流 ，這樣對(duì)方才能read()=-1，一旦關(guān)閉輸出流無(wú)法再打開(kāi)
? ? ? ? ? ?bis = new BufferedInputStream(socket.getInputStream());
? ? ? ? ? ?//接收服務(wù)器返回的數(shù)據(jù)
? ? ? ? ? ?int b;
? ? ? ? ? ?while ((b=bis.read())!=-1){
? ? ? ? ? ? ? ?//也可以規(guī)定發(fā)送一段符號(hào)代表數(shù)據(jù)結(jié)尾，或者數(shù)據(jù)開(kāi)頭標(biāo)明字節(jié)數(shù)，讀到一定數(shù)量結(jié)束循環(huán)
? ? ? ? ? ? ? ?System.out.write(b);
? ? ? ? ? ?}
? ? ? ?} catch (IOException e) {
? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ?}finally {
? ? ? ? ? ?if (pw != null) {
? ? ? ? ? ? ? ?pw.close();
? ? ? ? ? ?}
? ? ? ? ? ?if (socket != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?socket.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ? ? ?if (bis != null) {
? ? ? ? ? ? ? ?try {
? ? ? ? ? ? ? ? ? ?bis.close();
? ? ? ? ? ? ? ?} catch (IOException e) {
? ? ? ? ? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ? ? ? ? ?}
? ? ? ? ? ?}
? ? ? ?}
? ?}

? ?boolean isServer;
? ?//構(gòu)造器區(qū)分客戶端和服務(wù)端

? ?public TestServerSocket(String name, boolean isServer) {
? ? ? ?super(name);
? ? ? ?this.isServer = isServer;
? ?}

? ?@Override
? ?public void run() {
? ? ? ?if (isServer){
? ? ? ? ? ?server();
? ? ? ?}else {
? ? ? ? ? ?client();
? ? ? ?}
? ?}

? ?public static void main(String[] args) {
? ? ? ?new TestServerSocket("服務(wù)端",true).start();
? ? ? ?try {
? ? ? ? ? ?Thread.sleep(300);
? ? ? ?} catch (InterruptedException e) {
? ? ? ? ? ?throw new RuntimeException(e);
? ? ? ?}
? ? ? ?new TestServerSocket("客戶端",false).start();

? ? ? ?//結(jié)果：服務(wù)端線程打印GET / HTTP/1.1
? ? ? ?//客戶端打印HTTP/1.1 200 OK ?Hello World

? ?}
}