Java—— TCP協議(相關代碼實現以及相關優化)

代碼運行的時候先運行服務端，然后在運行客戶端

 * TCP協議：* 1，客戶端*      創建Socket連接服務器(指定IP地址，端口號)通過IP地址找到對應的服務器*      調用Socket的getInputStream()和getOutputStream()方法獲取和服務器端相連的IO流*      輸入流可以讀取服務器端輸出流寫出的數據*      輸出流可以寫出數據到服務端的輸入流* * 2，服務端*      創建ServerSocket(需要指定端口號)*      調用ServerSocket的accept()方法接受一個客戶端請求，得到一個Socket*      調用Socket的getInputStream()和getOutputStream()方法獲取和客戶端相連的IO流*      輸入流可以讀取客戶端輸出流寫出的數據*      輸出流可以寫出數據到客戶端的輸入流

package com.wsq.tcp;
//java com.wsq.tcp.Demo1_Client
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;public class Demo1_Client {
/*** 1，客戶端*      創建Socket連接服務器(指定IP地址，端口號不超過65535)通過IP地址找到對應的服務器*      調用Socket的getInputStream()和getOutputStream()方法獲取和服務器端相連的IO流*      輸入流可以讀取服務器端輸出流寫出的數據*      輸出流可以寫出數據到服務端的輸入流* @throws IOException * @throws UnknownHostException * * * */public static void main(String[] args) throws UnknownHostException, IOException {Socket wsq = new Socket("192.168.1.182",1014);  //創建Socket集裝箱對象wsq，并且指定想要發送他人的IP，和對應的端口號，連接服務器InputStream is = wsq.getInputStream();          //獲取客戶端輸入流OutputStream os = wsq.getOutputStream();        //獲取客戶端輸入流  byte [] arr = new byte [1024];                  //創建字節數組用于讀取服務器發來的數據int len = is.read(arr);                         //讀取服務器發過來的數據System.out.println(new String (arr,0,len));     //將數據轉換成字符串打印os.write("客戶端對服務端發送請求：傻孩紙，還在睡呢？".getBytes());//客戶端向服務器寫數據wsq.close();                                    //關閉集裝箱對象wsq}
}

package com.wsq.tcp;
//java com.wsq.tcp.Demo2_Server
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Demo2_Server {
/***  * 2，服務端*      創建ServerSocket(需要指定端口號)*      調用ServerSocket的accept()方法接受一個客戶端請求，得到一個Socket*      調用Socket的getInputStream()和getOutputStream()方法獲取和客戶端相連的IO流*      輸入流可以讀取客戶端輸出流寫出的數據*      輸出流可以寫出數據到客戶端的輸入流* @throws IOException * * */public static void main(String[] args) throws IOException {ServerSocket server = new ServerSocket(1014);   //創建ServerSocket并且指定端口號 Socket wsq= server.accept();                    //接收客戶端的請求，創建集裝箱對象wsq，調用accept方法來接收客戶端向服務端發出的請求InputStream is = wsq.getInputStream();          //獲取客戶端輸入流OutputStream os = wsq.getOutputStream();        //獲取客戶端輸入流  os.write("服務端響應客戶端沒，剛睡醒，不想理你".getBytes());//服務端想客戶寫出數據byte [] arr = new byte [1024];                  //創建字節數組用于接收服務器發來的數據int len = is.read(arr);                         //讀取服務器發過來的數據System.out.println(new String (arr,0,len));     //將數據轉換成字符串打印wsq.close();                                    //關閉socket集裝箱}
}

由上面的例子可以看出，該程序有點弊端，例如：讀寫的時候特別費勁，寫的時候得把字符串轉成字節數組給寫出去，讀取的時候，需要創建一個字節數組，然后才能讀進來，然后再轉換成字符串

優化：讀的時候是字符串，寫的時候也是字符串，這樣會簡便很多

優化代碼如下：

package www.wsq.TCP;
import java.io.BufferedReader;
//java com.wsq.tcp.Demo1_Client
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;public class Demo1_Client {
/*** 1，客戶端*      創建Socket連接服務器(指定IP地址，端口號不超過65535)通過IP地址找到對應的服務器*      調用Socket的getInputStream()和getOutputStream()方法獲取和服務器端相連的IO流*      輸入流可以讀取服務器端輸出流寫出的數據*      輸出流可以寫出數據到服務端的輸入流* @throws IOException * @throws UnknownHostException * * * */public static void main(String[] args) throws UnknownHostException, IOException {Socket wsq = new Socket("192.168.1.182",1014);  //創建Socket集裝箱對象wsq，并且指定想要發送他人的IP，和對應的端口號，連接服務器BufferedReader br = new BufferedReader(new InputStreamReader(wsq.getInputStream()));        //將字節流包裝成為字符流PrintStream ps = new PrintStream(wsq.getOutputStream());        //PrintStream中有寫出換行的方法  //將getInputStream()這個輸入字節流和getOutputStream()這個輸出字節流進行包裝，包裝之后，就可以直接讀一行，也可以直接寫出字符串，這樣的話，效率會更高//對于getInputStream()這個輸入字節流，輸入想整行讀，用BufferedReader，因為BufferedReader里面有ReadLine方法//對于getOutputStream()這個輸出字節流，這里不建議用BufferedWriter進行包裝，因為，BufferedWriter里面有個ReadLine方法，這個方法是以/r/n進行結束的，寫完之后還得調用newLine方法//這里建議用一個更好的流PrintStream，對getOutputStream()這個輸出字節流進行包裝，該流里面有個printLine方法，這個方法使你在寫出的時候直接加換行的，而且這個PrintLine方法也可以直接寫字符串System.out.println(br.readLine());              //讀出內容ps.println("滾，mmp");System.out.println(br.readLine());              //讀出內容ps.println("呵呵，你該唄兒厲害了~");wsq.close();                                    //關閉集裝箱對象wsq}}

有常識可知，服務端是多線程的

package www.wsq.TCP;
import java.io.BufferedReader;
//java com.wsq.tcp.Demo2_Server
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;public class Demo2_Server {
/***  * 2，服務端*      創建ServerSocket(需要指定端口號)*      調用ServerSocket的accept()方法接受一個客戶端請求，得到一個Socket*      調用Socket的getInputStream()和getOutputStream()方法獲取和客戶端相連的IO流*      輸入流可以讀取客戶端輸出流寫出的數據*      輸出流可以寫出數據到客戶端的輸入流* @throws IOException * * */public static void main(String[] args) throws IOException {demo1();ServerSocket server = new ServerSocket(1014);   //創建ServerSocket并且指定端口號 while(true){                                    //不斷地接收客戶端的請求final Socket wsq= server.accept();              //接收客戶端的請求，創建集裝箱對象wsq，調用accept方法來接收客戶端向服務端發出的請求//匿名內部類具備變量，必須被final修飾new Thread(){                                   //每接收到客戶一條請求就開啟一條線程，運用匿名內部類進行開啟線程public void run(){try {BufferedReader br = new BufferedReader(new InputStreamReader(wsq.getInputStream()));        //將字節流包裝成為字符流PrintStream ps = new PrintStream(wsq.getOutputStream());        //PrintStream中有寫出換行的方法  ps.println("歡迎來到哈哈哈哈我也不知道這是哪~~");System.out.println(br.readLine());              //readLine是以"\r\n"為結束標志的，沒有換行該行代碼就不會結束ps.println("你讓我怎樣我就怎樣，我的面子往哪放？我就不");System.out.println(br.readLine());              //讀出信息內容} catch (IOException e) {e.printStackTrace();}}}.start();wsq.close();                                    //關閉socket集裝箱}}private static void demo1() throws IOException {ServerSocket server = new ServerSocket(1014);   //創建ServerSocket并且指定端口號 Socket wsq= server.accept();                    //接收客戶端的請求，創建集裝箱對象wsq，調用accept方法來接收客戶端向服務端發出的請求BufferedReader br = new BufferedReader(new InputStreamReader(wsq.getInputStream()));        //將字節流包裝成為字符流PrintStream ps = new PrintStream(wsq.getOutputStream());        //PrintStream中有寫出換行的方法  ps.println("歡迎來到哈哈哈哈我也不知道這是哪~~");System.out.println(br.readLine());              //readLine是以"\r\n"為結束標志的，沒有換行該行代碼就不會結束ps.println("你讓我怎樣我就怎樣，我的面子往哪放？我就不");System.out.println(br.readLine());wsq.close();                                    //關閉socket集裝箱
}}