快捷導(dǎo)航

Java網(wǎng)絡(luò)編程之TCP通信完整代碼示例

更新時間：2017年12月08日 15:10:32 作者：溫布利往事

這篇文章主要介紹了Java網(wǎng)絡(luò)編程之TCP通信完整代碼示例，具有一定借鑒價值，需要的朋友可以了解下。

一、概述

　　Socket類是Java執(zhí)行客戶端TCP操作的基礎(chǔ)類，這個類本身使用代碼通過主機(jī)操作系統(tǒng)的本地TCP棧進(jìn)行通信。Socket類的方法會建立和銷毀連接，設(shè)置各種Socket選項。

　　ServerSocket類是Java執(zhí)行服務(wù)器端操作的基礎(chǔ)類，該類運行于服務(wù)器，監(jiān)聽入站TCP連接，每個socket服務(wù)器監(jiān)聽服務(wù)器的某個端口，當(dāng)遠(yuǎn)程主機(jī)的客戶端嘗試連接此端口時，服務(wù)器就被喚醒，并返回一個表示兩臺主機(jī)之間socket的正常Socket對象。

二、什么是TCP？　　

　　TCP是一種面向連接的、可靠的、基于字節(jié)流的傳輸層通信協(xié)議。TCP通信分為客戶端和服務(wù)器端，對應(yīng)的對象是分別是Socket和ServerSocket。

　　當(dāng)一臺計算機(jī)需要與另一臺遠(yuǎn)程計算機(jī)連接時，TCP協(xié)議會讓他們建立一個連接：用于發(fā)送和接收數(shù)據(jù)的虛擬鏈路。TCP協(xié)議負(fù)責(zé)收集信息包，并將其按適當(dāng)?shù)拇涡蚍藕脗魉?，在接收端收到后再將其正確的還原。為了保證數(shù)據(jù)包在傳送中準(zhǔn)確無誤，TCP使用了重發(fā)機(jī)制：當(dāng)一個通信實體發(fā)送一個消息給另一個通信實體后需要收到另一個實體的確認(rèn)信息，如果沒有收到確認(rèn)信息，則會再次重發(fā)剛才發(fā)送的信息。

三、TCP通信

　　1、構(gòu)造函數(shù)

　　Socket類實現(xiàn)客戶端套接字，通過構(gòu)造函數(shù)可以指定希望連接的主機(jī)和端口。主機(jī)可以指定為InetAddress或String，端口始終指定為0到65535之間的int值。

Socket s=new Socket("127.0.0.1", 10001);//創(chuàng)建一個流套接字并將其連接到指定主機(jī)上的指定端口號

ServerSocket類實現(xiàn)服務(wù)器套接字。服務(wù)器套接字等待請求通過網(wǎng)絡(luò)傳入，它基于該請求執(zhí)行某些操作，然后向請求者返回結(jié)果。

ServerSocket ss=new ServerSocket(10001);//創(chuàng)建綁定到特定端口的服務(wù)器套接字

2、例子:TCP文件復(fù)制

　　客戶端：

public class ClientDemo
{
	public static void main(String[] args) throws UnknownHostException, IOException
	  {
		Socket s=new Socket("127.0.0.1", 10004);
		BufferedReader buf = new BufferedReader(new FileReader("C:\\Users\\Administrator\\Desktop\\1.txt"));
		String line=null;
		/*PrintWriter out=new PrintWriter(s.getOutputStream(),true);
    while((line=buf.readLine())!=null)
    {
      out.println(line);
    }
    */
		BufferedWriter out=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
		while((line=buf.readLine())!=null)
		    {
			out.write(line);
			out.newLine();
			out.flush();
		}
		s.shutdownOutput();
		BufferedReader in=new BufferedReader(new InputStreamReader(s.getInputStream()));
		String str=in.readLine();
		System.out.println(str);
		s.close();
		buf.close();
	}
}

服務(wù)器端：

public class ServerDemo
{
	public static void main(String[] args) throws IOException
	  {
		ServerSocket ss=new ServerSocket(10004);
		Socket s=ss.accept();
		BufferedReader in=new BufferedReader(new InputStreamReader(s.getInputStream()));
		String line=null;
		/*PrintWriter buf=new PrintWriter(new FileWriter("C:\\Users\\Administrator\\Desktop\\2.txt"),true);
    while((line=in.readLine())!=null)
    {  
      buf.println(line);
    }*/
		BufferedWriter buf=new BufferedWriter(new FileWriter("C:\\Users\\Administrator\\Desktop\\2.txt"));
		while((line=in.readLine())!=null)
		    {
			buf.write(line);
			buf.newLine();
			buf.flush();
		}
		PrintWriter out=new PrintWriter(s.getOutputStream(),true);
		out.println("傳輸成功！");
		ss.close();
		buf.close();
	}
}

四、Socket在瀏覽上的應(yīng)用

　　我們可以在Eclipse中編寫服務(wù)器端，然后利用瀏覽器進(jìn)行訪問。

　　eg、服務(wù)器端代碼為：

public class SocketServer
{
  public static void main(String[] args) throws IOException 
  {
    ServerSocket server=new ServerSocket(11000);
    Socket client=server.accept();
    PrintWriter out=new PrintWriter(client.getOutputStream(),true);
    out.println("你好！");
    server.close();
  }
}

然后打開IE瀏覽器，在地址中輸入http://192.168.1.120:11000/(192.168.1.120為本機(jī)IP地址)，結(jié)果顯示為

在正常的應(yīng)用中，瀏覽器是向Tomacat服務(wù)器發(fā)出請求，以得到網(wǎng)頁圖片等資源。而tomca就是用Java寫的服務(wù)器端軟件。

　　現(xiàn)在我們編寫服務(wù)器端為：

public class SocketServer
{
  public static void main(String[] args) throws IOException 
  {
    ServerSocket server=new ServerSocket(11000);
    Socket client=server.accept();
    PrintWriter out=new PrintWriter(client.getOutputStream(),true);
    BufferedReader in=new BufferedReader(new InputStreamReader(client.getInputStream()));
    String line=null;
    while((line=in.readLine())!=null)
      System.out.println(line);
    out.println("你好！");
    server.close();
  }
}

然后在利用瀏覽器訪問，可以看到瀏覽器(客戶端)發(fā)給服務(wù)器端的請求頭數(shù)據(jù)為：

利用上述原理，我們可以自己編寫類似IE的瀏覽器端(客戶端)軟件。首先在Tomcat的安裝目錄C:\apache-tomcat-7.0.62\webapps\myweb中添加一個demo.html資源，然后編寫客戶端，代碼如下：

public class ClientDemo
{
	public static void main(String[] args) throws UnknownHostException, IOException
	  {
		Socket s=new Socket("192.168.1.120",8080);
		PrintWriter out=new PrintWriter(s.getOutputStream(),true);
		//將請求頭發(fā)給服務(wù)器
		out.println("GET /myweb/demo.html HTTP/1.1");
		out.println("Accept:*/*");
		out.println("Host: 192.168.1.120:11000");
		out.println("Connection: Keep-Alive");
		//輸出空行，此步驟不可少
		out.println();
		BufferedReader in=new BufferedReader(new InputStreamReader(s.getInputStream()));
		String line=null;
		//返回服務(wù)器的響應(yīng)文件
		while((line=in.readLine())!=null)
		    {
			System.out.println(line);
		}
		s.close();
	}
}

接下來，啟動Tomcat。即雙擊C:\apache-tomcat-7.0.62\bin中startup.bat文件。然后運行上述客戶端代碼，此時可以看到Tomacat返回的響應(yīng)數(shù)據(jù)：