溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
流傳于網絡上有關Java多線程通信的編程實例有很多，這一篇還算比較不錯，代碼可用。下面看看具體內容。
TCP是Tranfer Control Protocol的 簡稱，是一種面向連接的保證可靠傳輸的協議。通過TCP協議傳輸，得到的是一個順序的無差錯的數據流。發送方和接收方的成對的兩個socket之間必須建 立連接，以便在TCP協議的基礎上進行通信，當一個socket（通常都是server socket）等待建立連接時，另一個socket可以要求進行連接，一旦這兩個socket連接起來，它們就可以進行雙向數據傳輸，雙方都可以進行發送 或接收操作。
UDP是User Datagram Protocol的簡稱，是一種無連接的協議，每個數據報都是一個獨立的信息，包括完整的源地址或目的地址，它在網絡上以任何可能的路徑傳往目的地，因此能否到達目的地，到達目的地的時間以及內容的正確性都是不能被保證的。
比較：
UDP：1，每個數據報中都給出了完整的地址信息，因此無需要建立發送方和接收方的連接。
2，UDP傳輸數據時是有大小限制的，每個被傳輸的數據報必須限定在64KB之內。
3，UDP是一個不可靠的協議，發送方所發送的數據報并不一定以相同的次序到達接收方
TCP：1，面向連接的協議，在socket之間進行數據傳輸之前必然要建立連接，所以在TCP中需要連接
時間。
2，TCP傳輸數據大小限制，一旦連接建立起來，雙方的socket就可以按統一的格式傳輸大的
數據。
3，TCP是一個可靠的協議，它確保接收方完全正確地獲取發送方所發送的全部數據。
應用：
1，TCP在網絡通信上有極強的生命力，例如遠程連接（Telnet）和文件傳輸（FTP）都需要不定長度的數據被可靠地傳輸。但是可靠的傳輸是要付出代價的，對數據內容正確性的檢驗必然占用計算機的處理時間和網絡的帶寬，因此TCP傳輸的效率不如UDP高。
2，UDP操作簡單，而且僅需要較少的監護，因此通常用于局域網高可靠性的分散系統中client/server應用程序。例如視頻會議系統，并不要求音頻視頻數據絕對的正確，只要保證連貫性就可以了，這種情況下顯然使用UDP會更合理一些。
二.基于Socket的java網絡編程
1.什么是Socket
網絡上的兩個程序通過一個雙向的通訊連接實現數據的交換，這個雙向鏈路的一端稱為一個Socket。Socket通常用來實現客戶方和服務方的連接。Socket是TCP/IP協議的一個十分流行的編程界面，一個Socket由一個IP地址和一個端口號唯一確定。
但是，Socket所支持的協議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯系的。在Java環境下，Socket編程主要是指基于TCP/IP協議的網絡編程。
2.Socket通訊的過程
Server端Listen(監聽)某個端口是否有連接請求，Client端向Server 端發出Connect(連接)請求，Server端向Client端發回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。
對于一個功能齊全的Socket，都要包含以下基本結構，其工作過程包含以下四個基本的步驟：
（1） 創建Socket；
（2） 打開連接到Socket的輸入/出流；
（3） 按照一定的協議對Socket進行讀/寫操作；
（4） 關閉Socket.
3.創建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還是數據報socket，localPort表示本地主機的端口號，localAddr和 bindAddr是本地機器的地址（ServerSocket的主機地址），impl是socket的父類，既可以用來創建serverSocket又可 以用來創建Socket。count則表示服務端所能支持的最大連接數。
Socket client = new Socket("127.0.01.", 80);
ServerSocket server = new ServerSocket(80);
注意，在選擇端口時，必須小心。每一個端口提供一種特定的服務，只有給出正確的端口，才 能獲得相應的服務。
0~1023的端口號為系統所保留，例如http服務的端口號為80,telnet服務的端口號為21,ftp服務的端口號為23, 所以我們在選擇端口號時，最好選擇一個大于1023的數以防止發生沖突。
在創建socket時如果發生錯誤，將產生IOException，在程序中必須對之作出處理。所以在創建Socket或ServerSocket是必須捕獲或拋出例外。
三.服務端與客戶端代碼
1.首先實現服務類(代碼中有詳細的注釋,不再一一贅述)
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;
//聲明構造函數,接收客戶端請求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);
//用于發送給server端的信息
pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
//用于接收Server端發來的信息
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
// for (int i = 0; i < 10; i++) {
//注意首先向服務端發送消息,再接收服務端返回的休息,不要寫反了
pw.println("howdy ");
pw.flush();
//flush()一般用于處理中時需要將數據立即寫出。將緩沖區的內容輸出
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 ,向服務端發送請求,已經拿到服務端返回的信息
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多線程編程實現socket通信示例代碼，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站：Java網絡編程基礎篇之單向通信、Java使用代理進行網絡連接方法示例等，有什么問題可以隨時留言，小編會及時回復大家的。感謝朋友們對本站的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
