流傳于網絡上有關Java多線程通信的編程實例有很多，這一篇還算比較不錯，代碼可用。下面看看具體內容。
目前成都創(chuàng)新互聯(lián)公司已為數(shù)千家的企業(yè)提供了網站建設、域名、虛擬空間、網站托管維護、企業(yè)網站設計、丁青網站維護等服務，公司將堅持客戶導向、應用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。
TCP是Tranfer Control Protocol的 簡稱，是一種面向連接的保證可靠傳輸?shù)膮f(xié)議。通過TCP協(xié)議傳輸，得到的是一個順序的無差錯的數(shù)據(jù)流。發(fā)送方和接收方的成對的兩個socket之間必須建 立連接，以便在TCP協(xié)議的基礎上進行通信，當一個socket（通常都是server socket）等待建立連接時，另一個socket可以要求進行連接，一旦這兩個socket連接起來，它們就可以進行雙向數(shù)據(jù)傳輸，雙方都可以進行發(fā)送 或接收操作。
UDP是User Datagram Protocol的簡稱，是一種無連接的協(xié)議，每個數(shù)據(jù)報都是一個獨立的信息，包括完整的源地址或目的地址，它在網絡上以任何可能的路徑傳往目的地，因此能否到達目的地，到達目的地的時間以及內容的正確性都是不能被保證的。
比較：
UDP：1，每個數(shù)據(jù)報中都給出了完整的地址信息，因此無需要建立發(fā)送方和接收方的連接。
2，UDP傳輸數(shù)據(jù)時是有大小限制的，每個被傳輸?shù)臄?shù)據(jù)報必須限定在64KB之內。
3，UDP是一個不可靠的協(xié)議，發(fā)送方所發(fā)送的數(shù)據(jù)報并不一定以相同的次序到達接收方
TCP：1，面向連接的協(xié)議，在socket之間進行數(shù)據(jù)傳輸之前必然要建立連接，所以在TCP中需要連接
時間。
2，TCP傳輸數(shù)據(jù)大小限制，一旦連接建立起來，雙方的socket就可以按統(tǒng)一的格式傳輸大的
數(shù)據(jù)。
3，TCP是一個可靠的協(xié)議，它確保接收方完全正確地獲取發(fā)送方所發(fā)送的全部數(shù)據(jù)。
應用：
1，TCP在網絡通信上有極強的生命力，例如遠程連接（Telnet）和文件傳輸（FTP）都需要不定長度的數(shù)據(jù)被可靠地傳輸。但是可靠的傳輸是要付出代價的，對數(shù)據(jù)內容正確性的檢驗必然占用計算機的處理時間和網絡的帶寬，因此TCP傳輸?shù)男什蝗鏤DP高。
2，UDP操作簡單，而且僅需要較少的監(jiān)護，因此通常用于局域網高可靠性的分散系統(tǒng)中client/server應用程序。例如視頻會議系統(tǒng)，并不要求音頻視頻數(shù)據(jù)絕對的正確，只要保證連貫性就可以了，這種情況下顯然使用UDP會更合理一些。
二.基于Socket的java網絡編程
1.什么是Socket
網絡上的兩個程序通過一個雙向的通訊連接實現(xiàn)數(shù)據(jù)的交換，這個雙向鏈路的一端稱為一個Socket。Socket通常用來實現(xiàn)客戶方和服務方的連接。Socket是TCP/IP協(xié)議的一個十分流行的編程界面，一個Socket由一個IP地址和一個端口號唯一確定。
但是，Socket所支持的協(xié)議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯(lián)系的。在Java環(huán)境下，Socket編程主要是指基于TCP/IP協(xié)議的網絡編程。
2.Socket通訊的過程
Server端Listen(監(jiān)聽)某個端口是否有連接請求，Client端向Server 端發(fā)出Connect(連接)請求，Server端向Client端發(fā)回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。
對于一個功能齊全的Socket，都要包含以下基本結構，其工作過程包含以下四個基本的步驟：
?。?） 創(chuàng)建Socket；
?。?） 打開連接到Socket的輸入/出流；
?。?） 按照一定的協(xié)議對Socket進行讀/寫操作；
（4） 關閉Socket.
3.創(chuàng)建Socket
java在包java.net中提供了兩個類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務端。這是兩個封裝得非常好的類，使用很方便。其構造方法如下：
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地址、主機名和端 口號，stream指明socket是流socket還是數(shù)據(jù)報socket，localPort表示本地主機的端口號，localAddr和 bindAddr是本地機器的地址（ServerSocket的主機地址），impl是socket的父類，既可以用來創(chuàng)建serverSocket又可 以用來創(chuàng)建Socket。count則表示服務端所能支持的最大連接數(shù)。
Socket client = new Socket("127.0.01.", 80);
ServerSocket server = new ServerSocket(80);
注意，在選擇端口時，必須小心。每一個端口提供一種特定的服務，只有給出正確的端口，才 能獲得相應的服務。
0~1023的端口號為系統(tǒng)所保留，例如http服務的端口號為80,telnet服務的端口號為21,ftp服務的端口號為23, 所以我們在選擇端口號時，最好選擇一個大于1023的數(shù)以防止發(fā)生沖突。
在創(chuàng)建socket時如果發(fā)生錯誤，將產生IOException，在程序中必須對之作出處理。所以在創(chuàng)建Socket或ServerSocket是必須捕獲或拋出例外。
三.服務端與客戶端代碼
1.首先實現(xiàn)服務類(代碼中有詳細的注釋,不再一一贅述)
重慶分公司
重慶分公司
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());
//調用線程類
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.服務端響應請求的線程類
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;
//聲明構造函數(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++) {
//注意首先向服務端發(fā)送消息,再接收服務端返回的休息,不要寫反了
pw.println("howdy ");
pw.flush();
//flush()一般用于處理中時需要將數(shù)據(jù)立即寫出。將緩沖區(qū)的內容輸出
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,首先啟動服務端MultiSocketServer ,等待請求
ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]
2.啟動客戶端MultiClientSocket ,向服務端發(fā)送請求,已經拿到服務端返回的信息
Socket=Socket[addr=/127.0.0.1,port=4567,localport=55258] 拿到server返回的消息:Message Received close......
3.再看看服務端的響應結果
ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567] 得到客戶端地址:/127.0.0.1 Client Socket Message:howdy
成功了！
總結
以上就是本文關于Java多線程編程實現(xiàn)socket通信示例代碼，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站：Java網絡編程基礎篇之單向通信、Java使用代理進行網絡連接方法示例等，有什么問題可以隨時留言，小編會及時回復大家的。感謝朋友們對本站的支持。
