這篇文章主要講解了“TCP Socket如何使用”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來(lái)研究和學(xué)習(xí)“TCP Socket如何使用”吧!
成都創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站、??稻W(wǎng)絡(luò)推廣、小程序制作、??稻W(wǎng)絡(luò)營(yíng)銷、??灯髽I(yè)策劃、??灯放乒P(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等,從售前售中售后,我們都將竭誠(chéng)為您服務(wù),您的肯定,是我們最大的嘉獎(jiǎng);成都創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供??到ㄕ?/a>搭建服務(wù),24小時(shí)服務(wù)熱線:13518219792,官方網(wǎng)址:jinyejixie.com
Java為TCP協(xié)議提供了兩個(gè)類,分別在客戶端編程和服務(wù)器端編程中使用它們。在應(yīng)用程序開始通信之前,需要先創(chuàng)建一個(gè)連接,由客戶端程序發(fā)起;而服務(wù)器端的程序需要一直監(jiān)聽(tīng)著主機(jī)的特定端口號(hào),等待客戶端的連接。在客戶端中我們只需要使用Socket實(shí)例,而服務(wù)端要同時(shí)處理ServerSocket實(shí)例和Socket實(shí)例;二者并且都使用OutputStream和InpuStream來(lái)發(fā)送和接收數(shù)據(jù)。
學(xué)習(xí)一種知識(shí)***的方式就是使用它,通過(guò)前面的筆記,我們已經(jīng)知道如何獲取主機(jī)的地址信息,現(xiàn)在我們通過(guò)一個(gè)簡(jiǎn)單的程序來(lái)初步學(xué)習(xí)傳輸層使用了TCP協(xié)議的Socket編程。
TCP服務(wù)器端
在Socket編程中,服務(wù)器端遠(yuǎn)比客戶端要復(fù)雜得多。服務(wù)器端的工作就是建立一個(gè)通信終端,被動(dòng)的等待客戶端的連接。下面這個(gè)服務(wù)器端程序的示例的作用是:監(jiān)聽(tīng)從控制臺(tái)輸入獲取的端口號(hào),并且將客戶端發(fā)送過(guò)來(lái)的消息,再發(fā)送回去。
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 // 從控制臺(tái)獲取需要監(jiān)聽(tīng)的端口號(hào) if (args.length != 1) throw new IllegalArgumentException("Parameter(s):<Port>"); // 獲取端口號(hào) int servPort = Integer.parseInt(args[0]); // 實(shí)例化一個(gè)ServerSocket對(duì)象實(shí)例 ServerSocket servSocket = new ServerSocket(servPort); System.out.println(MessageFormat.format("開始啟動(dòng)監(jiān)聽(tīng),端口號(hào):{0}", args[0])); // 初始接收數(shù)據(jù)的總字節(jié)數(shù) int recvMsgSize; // 接收數(shù)據(jù)的緩沖區(qū) byte[] receiveBuf = new byte[BUFSIZE]; // 循環(huán)迭代,監(jiān)聽(tīng)端口號(hào),處理新的連接請(qǐng)求 while (true) { // 阻塞等待,每接收到一個(gè)請(qǐng)求就創(chuàng)建一個(gè)新的連接實(shí)例 Socket clntSocket = servSocket.accept(); // 獲取連接的客戶端的 SocketAddress SocketAddress clientAddress = clntSocket.getRemoteSocketAddress(); // 打印輸出連接客戶端地址信息 System.out.println("Handling client at" + clientAddress); // 從客戶端接收數(shù)據(jù)的對(duì)象 InputStream in = clntSocket.getInputStream(); // 向客戶端發(fā)送數(shù)據(jù)的對(duì)象 OutputStream out = clntSocket.getOutputStream(); // 讀取客戶端發(fā)送的數(shù)據(jù)后,再發(fā)送到客戶端 while ((recvMsgSize = in.read(receiveBuf)) != -1) { out.write(receiveBuf, 0, recvMsgSize); } // 客戶端關(guān)閉連接時(shí),關(guān)閉連接 System.out.println(" 客戶端關(guān)閉連接"); clntSocket.close(); } } }
TCP客戶端
在Socket編程中,首先客戶端需要向服務(wù)器端發(fā)送,然后被動(dòng)的等待服務(wù)器端的響應(yīng)。下面的示例中:我們向服務(wù)器端發(fā)送信息,等待服務(wù)器端發(fā)送的消息,并打印顯示出來(lái)。
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 // 判斷從控制臺(tái)接受的參數(shù)是否正確 if ((args.length < 2) || (args.length > 3)) throw new IllegalArgumentException( "Parameter(s):<Server><Word>[<Port>]]"); // 獲取服務(wù)器地址 String server = args[0]; // 獲取需要發(fā)送的信息 byte[] data = args[1].getBytes(); // 如果有三個(gè)從參數(shù)那么就獲取發(fā)送信息的端口號(hào),默認(rèn)端口號(hào)為8099 int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 8099; // 根據(jù)服務(wù)器地址和端口號(hào)實(shí)例化一個(gè)Socket實(shí)例 Socket socket = new Socket(server, servPort); System.out.println("Connected to server...sending echo string"); // 返回此套接字的輸入流,即從服務(wù)器接受的數(shù)據(jù)對(duì)象 InputStream in = socket.getInputStream(); // 返回此套接字的輸出流,即向服務(wù)器發(fā)送的數(shù)據(jù)對(duì)象 OutputStream out = socket.getOutputStream(); // 向服務(wù)器發(fā)送從控制臺(tái)接收的數(shù)據(jù) out.write(data); // 接收數(shù)據(jù)的計(jì)數(shù)器,將寫入數(shù)據(jù)的初始偏移量 int totalBytesRcvd = 0; // 初始化接收數(shù)據(jù)的總字節(jié)數(shù) int bytesRcvd; while (totalBytesRcvd < data.length) { // 服務(wù)器關(guān)閉連接,則返回 -1,read方法返回接收數(shù)據(jù)的總字節(jié)數(shù) if ((bytesRcvd = in.read(data, totalBytesRcvd, data.length - totalBytesRcvd)) == -1) throw new SocketException("與服務(wù)器的連接已關(guān)閉"); totalBytesRcvd += bytesRcvd; } // 打印服務(wù)器發(fā)送來(lái)的數(shù)據(jù) System.out.println("Received:" + new String(data)); // 關(guān)閉連接 socket.close(); } }
首先運(yùn)行服務(wù)器端,監(jiān)聽(tīng)8099端口:
接著運(yùn)行客戶端程序,并且向服務(wù)器端發(fā)送消息:
再次查看我們的服務(wù)器端控制臺(tái),我們可以看到前面客戶端連接的地址信息:
感謝各位的閱讀,以上就是“TCP Socket如何使用”的內(nèi)容了,經(jīng)過(guò)本文的學(xué)習(xí)后,相信大家對(duì)TCP Socket如何使用這一問(wèn)題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
名稱欄目:TCPSocket如何使用
URL鏈接:http://jinyejixie.com/article10/pgidgo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站維護(hù)、企業(yè)網(wǎng)站制作、網(wǎng)站導(dǎo)航、手機(jī)網(wǎng)站建設(shè)、全網(wǎng)營(yíng)銷推廣、品牌網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)