快捷導(dǎo)航

Java多線程編程實(shí)現(xiàn)socket通信示例代碼

更新時間：2017年10月24日 11:07:53 作者：小柳愛吃肉

這篇文章主要介紹了Java多線程編程實(shí)現(xiàn)socket通信示例代碼，詳細(xì)介紹了tcp、udp協(xié)議，以及基于socket的Java網(wǎng)絡(luò)編程的相關(guān)內(nèi)容及代碼示例，代碼測試可用，供大家參考。

流傳于網(wǎng)絡(luò)上有關(guān)Java多線程通信的編程實(shí)例有很多，這一篇還算比較不錯，代碼可用。下面看看具體內(nèi)容。

TCP是Tranfer Control Protocol的簡稱，是一種面向連接的保證可靠傳輸?shù)膮f(xié)議。通過TCP協(xié)議傳輸，得到的是一個順序的無差錯的數(shù)據(jù)流。發(fā)送方和接收方的成對的兩個socket之間必須建立連接，以便在TCP協(xié)議的基礎(chǔ)上進(jìn)行通信，當(dāng)一個socket（通常都是server socket）等待建立連接時，另一個socket可以要求進(jìn)行連接，一旦這兩個socket連接起來，它們就可以進(jìn)行雙向數(shù)據(jù)傳輸，雙方都可以進(jìn)行發(fā)送或接收操作。

UDP是User Datagram Protocol的簡稱，是一種無連接的協(xié)議，每個數(shù)據(jù)報(bào)都是一個獨(dú)立的信息，包括完整的源地址或目的地址，它在網(wǎng)絡(luò)上以任何可能的路徑傳往目的地，因此能否到達(dá)目的地，到達(dá)目的地的時間以及內(nèi)容的正確性都是不能被保證的。

比較：

UDP：1，每個數(shù)據(jù)報(bào)中都給出了完整的地址信息，因此無需要建立發(fā)送方和接收方的連接。
2，UDP傳輸數(shù)據(jù)時是有大小限制的，每個被傳輸?shù)臄?shù)據(jù)報(bào)必須限定在64KB之內(nèi)。
3，UDP是一個不可靠的協(xié)議，發(fā)送方所發(fā)送的數(shù)據(jù)報(bào)并不一定以相同的次序到達(dá)接收方

TCP：1，面向連接的協(xié)議，在socket之間進(jìn)行數(shù)據(jù)傳輸之前必然要建立連接，所以在TCP中需要連接
                時間。
            2，TCP傳輸數(shù)據(jù)大小限制，一旦連接建立起來，雙方的socket就可以按統(tǒng)一的格式傳輸大的
                    數(shù)據(jù)。
             3，TCP是一個可靠的協(xié)議，它確保接收方完全正確地獲取發(fā)送方所發(fā)送的全部數(shù)據(jù)。

應(yīng)用：

1，TCP在網(wǎng)絡(luò)通信上有極強(qiáng)的生命力，例如遠(yuǎn)程連接（Telnet）和文件傳輸（FTP）都需要不定長度的數(shù)據(jù)被可靠地傳輸。但是可靠的傳輸是要付出代價的，對數(shù)據(jù)內(nèi)容正確性的檢驗(yàn)必然占用計(jì)算機(jī)的處理時間和網(wǎng)絡(luò)的帶寬，因此TCP傳輸?shù)男什蝗鏤DP高。

2，UDP操作簡單，而且僅需要較少的監(jiān)護(hù)，因此通常用于局域網(wǎng)高可靠性的分散系統(tǒng)中client/server應(yīng)用程序。例如視頻會議系統(tǒng)，并不要求音頻視頻數(shù)據(jù)絕對的正確，只要保證連貫性就可以了，這種情況下顯然使用UDP會更合理一些。

二.基于Socket的java網(wǎng)絡(luò)編程

1.什么是Socket

網(wǎng)絡(luò)上的兩個程序通過一個雙向的通訊連接實(shí)現(xiàn)數(shù)據(jù)的交換，這個雙向鏈路的一端稱為一個Socket。Socket通常用來實(shí)現(xiàn)客戶方和服務(wù)方的連接。Socket是TCP/IP協(xié)議的一個十分流行的編程界面，一個Socket由一個IP地址和一個端口號唯一確定。
但是，Socket所支持的協(xié)議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯(lián)系的。在Java環(huán)境下，Socket編程主要是指基于TCP/IP協(xié)議的網(wǎng)絡(luò)編程。

2.Socket通訊的過程

Server端Listen(監(jiān)聽)某個端口是否有連接請求，Client端向Server 端發(fā)出Connect(連接)請求，Server端向Client端發(fā)回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。
對于一個功能齊全的Socket，都要包含以下基本結(jié)構(gòu)，其工作過程包含以下四個基本的步驟：

　　（1）創(chuàng)建Socket；
　　（2）打開連接到Socket的輸入/出流；
　?。?）按照一定的協(xié)議對Socket進(jìn)行讀/寫操作；
　?。?）關(guān)閉Socket.

3.創(chuàng)建Socket

java在包java.net中提供了兩個類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務(wù)端。這是兩個封裝得非常好的類，使用很方便。其構(gòu)造方法如下：

　Socket(InetAddress address, int port);
　　Socket(InetAddress address, int port, boolean stream);
　　Socket(String host, int prot);
　　Socket(String host, int prot, boolean stream);
　　Socket(SocketImpl impl)
　　Socket(String host, int port, InetAddress localAddr, int localPort)
　　Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
　　ServerSocket(int port);
　　ServerSocket(int port, int backlog);
　　ServerSocket(int port, int backlog, InetAddress bindAddr)

其中address、host和port分別是雙向連接中另一方的IP地址、主機(jī)名和端口號，stream指明socket是流socket還是數(shù)據(jù)報(bào)socket，localPort表示本地主機(jī)的端口號，localAddr和 bindAddr是本地機(jī)器的地址（ServerSocket的主機(jī)地址），impl是socket的父類，既可以用來創(chuàng)建serverSocket又可以用來創(chuàng)建Socket。count則表示服務(wù)端所能支持的最大連接數(shù)。

　　Socket client = new Socket("127.0.01.", 80);

　　ServerSocket server = new ServerSocket(80);

　　注意，在選擇端口時，必須小心。每一個端口提供一種特定的服務(wù)，只有給出正確的端口，才能獲得相應(yīng)的服務(wù)。

0~1023的端口號為系統(tǒng)所保留，例如http服務(wù)的端口號為80,telnet服務(wù)的端口號為21,ftp服務(wù)的端口號為23, 所以我們在選擇端口號時，最好選擇一個大于1023的數(shù)以防止發(fā)生沖突。

　　在創(chuàng)建socket時如果發(fā)生錯誤，將產(chǎn)生IOException，在程序中必須對之作出處理。所以在創(chuàng)建Socket或ServerSocket是必須捕獲或拋出例外。

三.服務(wù)端與客戶端代碼

1.首先實(shí)現(xiàn)服務(wù)類(代碼中有詳細(xì)的注釋,不再一一贅述)

package me.socketthread;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class MultiSocketServer {
	public static void main(String[] args) {
		ServerSocket s = null;
		Socket socket = null;
		try {
			s=new ServerSocket(4567);
			System.out.println("ServerSocket Start:"+s);
			//等待請求,此方法會一直阻塞,直到獲得請求才往下走 
			socket=s.accept();
			System.out.println("得到客戶端地址:"+socket.getInetAddress());
			//調(diào)用線程類
			new ServerSocketThread(socket).start();
		}
		catch (Exception e) {
			try {
				socket.close();
			}
			catch (IOException e1) {
				// TODO Auto-generated catch block 
				e1.printStackTrace();
			}
		}
		finally{
			try {
				s.close();
			}
			catch (IOException e) {
				// TODO Auto-generated catch block 
				e.printStackTrace();
			}
		}
	}
}

2.服務(wù)端響應(yīng)請求的線程類

package me.socketthread;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class ServerSocketThread extends Thread{
	private Socket socket = null;
	private BufferedReader br = null;
	private PrintWriter pw = null;
	//聲明構(gòu)造函數(shù),接收客戶端請求socket
	public ServerSocketThread(Socket s)
	 {
		this.socket=s;
	}
	@Override
	 public void run() {
		//while(true){ 
		try {
			//注意此處得到的socket的輸入流為socket的輸入流即上方的(private Socket socket = null; )
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			//向客戶端返回消息的PrintWriter對象
			pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			String str = br.readLine();
			/* if(str.equals("END")){ 
     br.close(); 
     pw.close(); 
     socket.close(); 
     break; 
    } */
			System.out.println("Client Socket Message:"+str);
			pw.println("Message Received");
			pw.flush();
		}
		catch (Exception e) {
			try {
				br.close();
				pw.close();
				socket.close();
			}
			catch (IOException e1) {
				// TODO Auto-generated catch block 
				e1.printStackTrace();
			}
		}
		// }
	}
}

3.客戶端請求socket類

package me.socketthread;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class MultiClientSocket {
	public static void main(String[] args) {
		Socket socket = null;
		BufferedReader br = null;
		PrintWriter pw = null;
		try {
			socket=new Socket("127.0.0.1",4567);
			System.out.println("Socket=" + socket);
			//用于發(fā)送給server端的信息
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			//用于接收Server端發(fā)來的信息 
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			// for (int i = 0; i < 10; i++) {
			//注意首先向服務(wù)端發(fā)送消息,再接收服務(wù)端返回的休息,不要寫反了
			pw.println("howdy ");
			pw.flush();
			//flush()一般用于處理中時需要將數(shù)據(jù)立即寫出。將緩沖區(qū)的內(nèi)容輸出
			String str = br.readLine();
			System.out.println("拿到server返回的消息:"+str);
			// } 
			// pw.println("END"); 
			// pw.flush();
		}
		catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally {
			try {
				System.out.println("close......");
				br.close();
				pw.close();
				socket.close();
			}
			catch (IOException e) {
				// TODO Auto-generated catch block 
				e.printStackTrace();
			}
		}
	}
}

四.測試

1,首先啟動服務(wù)端MultiSocketServer ,等待請求

ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]

2.啟動客戶端MultiClientSocket ,向服務(wù)端發(fā)送請求,已經(jīng)拿到服務(wù)端返回的信息

Socket=Socket[addr=/127.0.0.1,port=4567,localport=55258]
拿到server返回的消息:Message Received
close......

3.再看看服務(wù)端的響應(yīng)結(jié)果

ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]
得到客戶端地址:/127.0.0.1
Client Socket Message:howdy

成功了！

總結(jié)

以上就是本文關(guān)于Java多線程編程實(shí)現(xiàn)socket通信示例代碼，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站：Java網(wǎng)絡(luò)編程基礎(chǔ)篇之單向通信、Java使用代理進(jìn)行網(wǎng)絡(luò)連接方法示例等，有什么問題可以隨時留言，小編會及時回復(fù)大家的。感謝朋友們對本站的支持。

您可能感興趣的文章: