您好,登錄后才能下訂單哦!
這篇文章主要講解了“TCP Socket如何使用”,文中的講解內容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“TCP Socket如何使用”吧!
Java為TCP協議提供了兩個類,分別在客戶端編程和服務器端編程中使用它們。在應用程序開始通信之前,需要先創建一個連接,由客戶端程序發起;而服務器端的程序需要一直監聽著主機的特定端口號,等待客戶端的連接。在客戶端中我們只需要使用Socket實例,而服務端要同時處理ServerSocket實例和Socket實例;二者并且都使用OutputStream和InpuStream來發送和接收數據。
學習一種知識***的方式就是使用它,通過前面的筆記,我們已經知道如何獲取主機的地址信息,現在我們通過一個簡單的程序來初步學習傳輸層使用了TCP協議的Socket編程。
TCP服務器端
在Socket編程中,服務器端遠比客戶端要復雜得多。服務器端的工作就是建立一個通信終端,被動的等待客戶端的連接。下面這個服務器端程序的示例的作用是:監聽從控制臺輸入獲取的端口號,并且將客戶端發送過來的消息,再發送回去。
import java.net.*; import java.text.MessageFormat; import java.io.*; public class TCPEchoServer { private static final int BUFSIZE = 32; /** * @param args */ public static void main(String[] args) throws IOException { // TODO Auto-generated method stub // 從控制臺獲取需要監聽的端口號 if (args.length != 1) throw new IllegalArgumentException("Parameter(s):<Port>"); // 獲取端口號 int servPort = Integer.parseInt(args[0]); // 實例化一個ServerSocket對象實例 ServerSocket servSocket = new ServerSocket(servPort); System.out.println(MessageFormat.format("開始啟動監聽,端口號:{0}", args[0])); // 初始接收數據的總字節數 int recvMsgSize; // 接收數據的緩沖區 byte[] receiveBuf = new byte[BUFSIZE]; // 循環迭代,監聽端口號,處理新的連接請求 while (true) { // 阻塞等待,每接收到一個請求就創建一個新的連接實例 Socket clntSocket = servSocket.accept(); // 獲取連接的客戶端的 SocketAddress SocketAddress clientAddress = clntSocket.getRemoteSocketAddress(); // 打印輸出連接客戶端地址信息 System.out.println("Handling client at" + clientAddress); // 從客戶端接收數據的對象 InputStream in = clntSocket.getInputStream(); // 向客戶端發送數據的對象 OutputStream out = clntSocket.getOutputStream(); // 讀取客戶端發送的數據后,再發送到客戶端 while ((recvMsgSize = in.read(receiveBuf)) != -1) { out.write(receiveBuf, 0, recvMsgSize); } // 客戶端關閉連接時,關閉連接 System.out.println(" 客戶端關閉連接"); clntSocket.close(); } } }
TCP客戶端
在Socket編程中,首先客戶端需要向服務器端發送,然后被動的等待服務器端的響應。下面的示例中:我們向服務器端發送信息,等待服務器端發送的消息,并打印顯示出來。
import java.io.*; import java.net.Socket; import java.net.SocketException; public class TCPEchoClient { /** * @param args * @throws IOException */ public static void main(String[] args) throws IOException { // TODO Auto-generated method stub // 判斷從控制臺接受的參數是否正確 if ((args.length < 2) || (args.length > 3)) throw new IllegalArgumentException( "Parameter(s):<Server><Word>[<Port>]]"); // 獲取服務器地址 String server = args[0]; // 獲取需要發送的信息 byte[] data = args[1].getBytes(); // 如果有三個從參數那么就獲取發送信息的端口號,默認端口號為8099 int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099; // 根據服務器地址和端口號實例化一個Socket實例 Socket socket = new Socket(server, servPort); System.out.println("Connected to server...sending echo string"); // 返回此套接字的輸入流,即從服務器接受的數據對象 InputStream in = socket.getInputStream(); // 返回此套接字的輸出流,即向服務器發送的數據對象 OutputStream out = socket.getOutputStream(); // 向服務器發送從控制臺接收的數據 out.write(data); // 接收數據的計數器,將寫入數據的初始偏移量 int totalBytesRcvd = 0; // 初始化接收數據的總字節數 int bytesRcvd; while (totalBytesRcvd < data.length) { // 服務器關閉連接,則返回 -1,read方法返回接收數據的總字節數 if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length - totalBytesRcvd)) == -1) throw new SocketException("與服務器的連接已關閉"); totalBytesRcvd += bytesRcvd; } // 打印服務器發送來的數據 System.out.println("Received:" + new String(data)); // 關閉連接 socket.close(); } }
首先運行服務器端,監聽8099端口:
接著運行客戶端程序,并且向服務器端發送消息:
再次查看我們的服務器端控制臺,我們可以看到前面客戶端連接的地址信息:
感謝各位的閱讀,以上就是“TCP Socket如何使用”的內容了,經過本文的學習后,相信大家對TCP Socket如何使用這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關知識點的文章,歡迎關注!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。