先寫服務端，一定要先執行服務端

package wangluobiancheng;

import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
/*
?* TCP通信嚴格區分客戶端和服務器端，在通信時必須先由客戶端去連接服務器端才能實現通信，服務器端不能主動連接客戶端
?* 并且服務器端程序要先啟動，等待客戶端的連接
?* ServerSocket類，用于表示服務器端，通信時要先創建代表服務器端的ServerSocket對象，相當于開啟一個服務，此服務會等待客戶端的連接。
?* Server類，表示客戶端，創建Server對象，使用該對象向服務器端發出連接請求，服務器端響應后，客戶端再次向服務器端發送確認信息，確認連接
?* ServerSocket()使用該構造方法在創建ServerSocket對象時，并沒有綁定端口號，這樣的對象創建的服務器端沒有監聽任何端口，不能直接使用
?* *最常用ServerSocket(int port)可以將其綁定到一個指定的端口號上（參數port就是端口號）。客戶端需要指定的端口號來訪問服務器端程序
?* ServerSocket(int port,int backlog)可以將其綁定到一個指定的端口號上（參數port就是端口號）?？蛻舳诵枰付ǖ亩丝谔杹碓L問服務器端程序,backlog用于指定在
?* 服務器忙時，可以與之保持連接請求的等待客戶數量，如果沒有指定這個參數，默認為50
?* ServerSocket(int port,int backlog,InetAddress bindAddr)bindAddr用于指定相關的IP地址，該構造方法的使用適用于計算機上有多塊網卡和多個IP的情況
?* 使用時可以明確規定ServerSocket在哪塊網卡或IP地址上等待客戶的連接請求。
?*/
?? ?public static void main(String[] args) throws Exception {
//?? ??? ?創建TCPServer對象，并調用listen()方法
?? ??? ?TCPServer tcpss=new TCPServer();
?? ??? ?tcpss.listen();
?? ?}

}

/*//TCP服務端
class TCPServer{
?? ?private static final int PORT = 7788;//定義一個端口號
?? ?public void listen() throws Exception {
//?? ??? ?創建ServerSocket(服務器)對象,指定端口PORT，即7788
?? ??? ?ServerSocket s = new ServerSocket(PORT);
//?? ??? ?Socket accept()該方法用于等待客戶端的連接，在客戶端連接之前會一直處于阻塞狀態，如果有客戶端連接，就會返回一個與之對應的Socket對象，就是服務器也會創建一個Socket對象，去和客戶端的Socket對象對應
//?? ??? ?調用ServerSocket的accept()方法接受客戶端的請求，執行accept()方法之后程序會發生阻塞，直到客戶端發出連接請求時，accept()會返回一個與之對應的Socket對象,用于和客戶端實現通信
?? ??? ?Socket client = s.accept();
?? ??? ?OutputStream os = client.getOutputStream();//創建輸出流對象，向客戶端輸出數據
?? ??? ?System.out.println("開始與客戶端交互數據");
//?? ??? ?當客戶端連接到服務端時，向客戶端輸出數據。("傳智博客歡迎你！").getBytes()將定義的字符串轉換為字節數組
?? ??? ?os.write( ("傳智博客歡迎你！").getBytes() );
?? ??? ?Thread.sleep(5000);//模擬執行其他功能占用的時間
?? ??? ?System.out.println("結束與客戶端交互數據");
?? ??? ?os.close();//關閉緩沖區
?? ??? ?client.close();//關閉客戶端與服務器的連接
?? ?}
}*/

/*
?* 上面的程序分別實現了服務器端程序和客戶端程序，當一個客戶端程序請求服務器端時，服務器端就會結束阻塞狀態，完成程序的運行
?* 實際上，很多服務器端程序都是允許被多個應用程序訪問的，例如門戶網站可以被多個用戶同時訪問，因此服務器都是多線程的
?* 多個客戶端訪問同一個服務器端，服務器端為每個客戶創建一個對應的Socket,并且開啟一個新的線程使兩個Socket(一個是客戶端的，一個是服務器端的)建立專線進行通信
?*/
//TCP服務端
class TCPServer{
?? ?private static final int PORT = 7788;//定義一個端口號
?? ?public void listen() throws Exception {
//?? ??? ?創建ServerSocket(服務器)對象,指定端口PORT，即7788
?? ??? ?ServerSocket s = new ServerSocket(PORT);
//?? ??? ?使用while循環不停的接受客戶端發送的請求
?? ??? ?while(true) {
//?? ??? ?Socket accept()該方法用于等待客戶端的連接，在客戶端連接之前會一直處于阻塞狀態，如果有客戶端連接，就會返回一個與之對應的Socket對象
//?? ??? ?調用ServerSocket的accept()方法接受客戶端的請求，執行accept()方法之后程序會發生阻塞，直到客戶端發出連接請求時，accept()會返回一個與之對應的Socket對象,用于和客戶端實現通信
?? ??? ?Socket client = s.accept();
//?? ??? ?下面的代碼用來開啟一個新的線程
?? ??? ?new Thread() {
?? ??? ??? ?public void run() {
?? ??? ??? ??? ?OutputStream os;//定義一個輸出流對象
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?os = client.getOutputStream();//獲取客戶端的輸出流
?? ??? ??? ??? ??? ?System.out.println("開始與客戶端交互數據");
?? ??? ??? ??? ??? ?os.write(("傳智播客歡迎您！").getBytes());
?? ??? ??? ??? ??? ?Thread.sleep(5000);//使線程休眠5000毫秒
?? ??? ??? ??? ??? ?System.out.println("結束與客戶端交互數據");
?? ??? ??? ??? ??? ?os.close();//關閉輸出流
?? ??? ??? ??? ??? ?client.close();//關閉Socket對象
?? ??? ??? ??? ?}catch(Exception e) {
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ?}
?? ??? ???? }.start();
?? ??? ?}
?? ?}
}

再寫客戶端。（就是再建一個java文件）

package wangluobiancheng;

import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;

public class Client {
/*
?* Socket用于實現TCP客戶端程序
?* Socket()該構造方法在創建Socket對象時，并沒有指定IP地址和端口號，也就意味著只創建了客戶端對象，并沒有連接任何服務器。
?* 通過該構造方法創建對象后還需調用connect(SocketAddress endpoint)方法，才能完成與指定服務器端的連接。其中參數endpoint用于封裝IP地址和端口號
?*/
?? ?public static void main(String[] args) throws Exception {
?? ??? ?TCPClient tcpc = new TCPClient();
?? ??? ?tcpc.connect();//創建TCPClient對象，并調用connect()方法
?? ?}
}
class TCPClient{
?? ?private static final int PORT = 7788;//服務端的端口號
?? ?public void connect() throws Exception {
//?? ??? ?Socket(InetAddress address,int port)該構造方法在創建Socket對象時,指明IP地址和端口號
//?? ??? ?創建一個Socket(客戶端)并連接到給出地址和端口號的計算機
?? ??? ?Socket client = new Socket(InetAddress.getLocalHost(),PORT);
?? ??? ?InputStream is = client.getInputStream();//創建輸入流對象，client.getInputStream()用來接受服務器發來的數據
//?? ??? ?定義1024個字節數組
?? ??? ?byte[] buf = new byte[1024];
?? ??? ?int len = is.read(buf);//將數據讀取到緩沖區
?? ??? ?System.out.println( new String(buf,0,len) );//將緩沖區中的數據打印
//?? ??? ?關閉Socket對象，即關閉連接，釋放資源
?? ??? ?client.close();
?? ?}
}

服務器文件執行后

客戶端執行后

?

總結

以上是生活随笔為你收集整理的TCP客户端和服务端的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。