Java中的TCP通信程序

TCP可以實現(xiàn)兩臺計算機之間的數據交互通信的兩端，要嚴格區(qū)分客戶端與服務端兩端通信時的步驟：1.服務端程序，需要事先啟動，等待客戶端連接2.客戶端主動連接服務器端，才能成功通信，服務器端不可以主動鏈接客戶端

在java中兩個類用于實現(xiàn)TCP通信程序：

客戶端： java.net.Socket 類表示。創(chuàng)建 Socket 對象，向服務端發(fā)出連接請求，服務端響應請求，兩者建 立連接開始通信。 服務端： java.net.ServerSocket 類表示。創(chuàng)建 ServerSocket 對象，相當于開啟一個服務，并等待客戶端 的連接。

Socket類

socket類：該類實現(xiàn)客戶端套接字，套接字是指兩臺設備之間的端點

構造方法：public Socket（String host，int port）：創(chuàng)建套接字對象并將其連接到指定對象的主機上，如果指定的host為NULL，則相當于指定的地址為回送地址回送地址回送地址(127.x.x.x) 是本機回送地址（Loopback Address），主要用于網絡軟件測試以及本 地機進程間通信，無論什么程序，一旦使用回送地址發(fā)送數據，立即返回，不進行任何網絡傳輸。構造舉例

Socket client=new Socket（“127.0.0.1”，666）

成員方法：public InputStream getInputStream() ： 返回此套接字的輸入流。 如果此Scoket具有相關聯(lián)的通道，則生成的InputStream 的所有操作也關聯(lián)該通道。 關閉生成的InputStream也將關閉相關的Socket。

public OutputStream getOutputStream() ： 返回此套接字的輸出流。 如果此Scoket具有相關聯(lián)的通道，則生成的OutputStream 的所有操作也關聯(lián)該通道。 關閉生成的OutputStream也將關閉相關的Socket

public void close() ：關閉此套接字。 一旦一個socket被關閉，它不可再使用。 關閉此socket也將關閉相關的InputStream和OutputStream 。public void shutdownOutput() ： 禁用此套接字的輸出流。 任何先前寫出的數據將被發(fā)送，隨后終止輸出流。

ServerSocket類

public ServerSocket(int port) ：使用該構造方法在創(chuàng)建ServerSocket對象時，就可以將其綁定到一個指 定的端口號上，參數port就是端口號構造舉例代碼如下：

ServerSocket server=new ServerSocket（666）

成員方法 public Socket accept() ：偵聽并接受連接，返回一個新的Socket對象，用于和客戶端實現(xiàn)通信。兩個需要明確的事情1多個服務器端與客戶進行交互，服務器必須明確是和哪個客戶端進行交互，這個accept（）方法用與獲取請求的客戶端對象2.多個客戶端同時與服務器進行交互就需要使用多個io流對象服務器是沒有io流的，服務器可以獲取到請求的客戶端對象的scoket，使用每一個客戶端Socket中提供的io流對象進行交互。服務器端使用客戶端的字節(jié)輸入流讀取客戶端發(fā)送的數據，服務器端使用客戶端的字節(jié)輸出流給客戶端回寫數據即服務器端使用客戶端流與客戶端交互好比生活中的我請客你買單

簡單的TCP網絡程序圖解

【服務端】啟動,創(chuàng)建ServerSocket對象，等待連接。 Socket client = new Socket('127.0.0.1', 6666); ServerSocket server = new ServerSocket(6666); 【客戶端】啟動,創(chuàng)建Socket對象，請求連接。 【服務端】接收連接,調用accept方法，并返回一個Socket對象 【客戶端】Socket對象，獲取OutputStream，向服務端寫出數據 【服務端】Scoket對象，獲取InputStream，讀取客戶端發(fā)送的數據。 【服務端】Socket對象，獲取OutputStream，向客戶端回寫數據。 【客戶端】Scoket對象，獲取InputStream，解析回寫數據 【客戶端】釋放資源，斷開連接。

該方法 會一直阻塞直到建立連接。

下面寫一段簡單的客戶端與服務器端交互的代碼

服務器端代碼

package Socket;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class Server { public static void main(String[] args) throws IOException { System.out.println('服務器啟動等待連接：'); //創(chuàng)建服務器端對象 ServerSocket serverSocket = new ServerSocket(8888); //使用accept方法接受socket對象 Socket accept = serverSocket.accept(); //通過socket獲取輸入流 InputStream inputStream = accept.getInputStream(); //會不會阻塞 System.out.println('XXXXXXXXXXXXXXXXX'); byte[] bytes = new byte[1024]; int read = inputStream.read(bytes); //通過字節(jié)數組生成字符串 String s = new String(bytes,0,read); //輸出 System.out.println(s); //向客戶端返回信息 OutputStream outputStream = accept.getOutputStream(); //返回內容 outputStream.write('內容已經收到'.getBytes()); //關閉資源 inputStream.close(); serverSocket.close(); }}

客戶端代碼

package Socket;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.net.Socket;public class Client { public static void main(String[] args) throws IOException { //創(chuàng)建Socket對象 Socket socket = new Socket('127.0.0.1', 8888); //獲取輸出流 OutputStream outputStream = socket.getOutputStream(); //給服務端發(fā)送消息 outputStream.write('你好'.getBytes()); //創(chuàng)建輸入流對象 InputStream inputStream = socket.getInputStream(); //創(chuàng)建讀取的數組 byte[] bytes = new byte[1024]; //獲取字節(jié)數組的長度 int read = inputStream.read(bytes); //輸出結果 System.out.println(new String(bytes,0,read)); //關閉流 outputStream.close(); //關閉Socket對象 socket.close(); }}

結果

服務器端

客戶端

以上就是Java中的TCP通信程序的一些基本操作，喜歡我的可以點贊收藏一波，我會不定期跟新文章，喜歡我的可以關注呀

到此這篇關于Java實現(xiàn)基于TCP的通訊程序實例解析的文章就介紹到這了,更多相關Java TCP通信程序內容請搜索好吧啦網以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網！