Java多線程編程實(shí)現(xiàn)socket通信示例代碼
流傳于網(wǎng)絡(luò)上有關(guān)Java多線程通信的編程實(shí)例有很多，這一篇還算比較不錯(cuò)，代碼可用。下面看看具體內(nèi)容。
TCP是Tranfer Control Protocol的 簡(jiǎn)稱，是一種面向連接的保證可靠傳輸?shù)膮f(xié)議。通過TCP協(xié)議傳輸，得到的是一個(gè)順序的無差錯(cuò)的數(shù)據(jù)流。發(fā)送方和接收方的成對(duì)的兩個(gè)socket之間必須建 立連接，以便在TCP協(xié)議的基礎(chǔ)上進(jìn)行通信，當(dāng)一個(gè)socket（通常都是server socket）等待建立連接時(shí)，另一個(gè)socket可以要求進(jìn)行連接，一旦這兩個(gè)socket連接起來，它們就可以進(jìn)行雙向數(shù)據(jù)傳輸，雙方都可以進(jìn)行發(fā)送 或接收操作。
UDP是User Datagram Protocol的簡(jiǎn)稱，是一種無連接的協(xié)議，每個(gè)數(shù)據(jù)報(bào)都是一個(gè)獨(dú)立的信息，包括完整的源地址或目的地址，它在網(wǎng)絡(luò)上以任何可能的路徑傳往目的地，因此能否到達(dá)目的地，到達(dá)目的地的時(shí)間以及內(nèi)容的正確性都是不能被保證的。
比較：
UDP：1，每個(gè)數(shù)據(jù)報(bào)中都給出了完整的地址信息，因此無需要建立發(fā)送方和接收方的連接。
2，UDP傳輸數(shù)據(jù)時(shí)是有大小限制的，每個(gè)被傳輸?shù)臄?shù)據(jù)報(bào)必須限定在64KB之內(nèi)。
3，UDP是一個(gè)不可靠的協(xié)議，發(fā)送方所發(fā)送的數(shù)據(jù)報(bào)并不一定以相同的次序到達(dá)接收方
TCP：1，面向連接的協(xié)議，在socket之間進(jìn)行數(shù)據(jù)傳輸之前必然要建立連接，所以在TCP中需要連接
時(shí)間。
2，TCP傳輸數(shù)據(jù)大小限制，一旦連接建立起來，雙方的socket就可以按統(tǒng)一的格式傳輸大的
數(shù)據(jù)。
3，TCP是一個(gè)可靠的協(xié)議，它確保接收方完全正確地獲取發(fā)送方所發(fā)送的全部數(shù)據(jù)。
應(yīng)用：
1，TCP在網(wǎng)絡(luò)通信上有極強(qiáng)的生命力，例如遠(yuǎn)程連接（Telnet）和文件傳輸（FTP）都需要不定長(zhǎng)度的數(shù)據(jù)被可靠地傳輸。但是可靠的傳輸是要付出代價(jià)的，對(duì)數(shù)據(jù)內(nèi)容正確性的檢驗(yàn)必然占用計(jì)算機(jī)的處理時(shí)間和網(wǎng)絡(luò)的帶寬，因此TCP傳輸?shù)男什蝗鏤DP高。
2，UDP操作簡(jiǎn)單，而且僅需要較少的監(jiān)護(hù)，因此通常用于局域網(wǎng)高可靠性的分散系統(tǒng)中client/server應(yīng)用程序。例如視頻會(huì)議系統(tǒng)，并不要求音頻視頻數(shù)據(jù)絕對(duì)的正確，只要保證連貫性就可以了，這種情況下顯然使用UDP會(huì)更合理一些。
二.基于Socket的java網(wǎng)絡(luò)編程
1.什么是Socket
網(wǎng)絡(luò)上的兩個(gè)程序通過一個(gè)雙向的通訊連接實(shí)現(xiàn)數(shù)據(jù)的交換，這個(gè)雙向鏈路的一端稱為一個(gè)Socket。Socket通常用來實(shí)現(xiàn)客戶方和服務(wù)方的連接。Socket是TCP/IP協(xié)議的一個(gè)十分流行的編程界面，一個(gè)Socket由一個(gè)IP地址和一個(gè)端口號(hào)唯一確定。
但是，Socket所支持的協(xié)議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯(lián)系的。在Java環(huán)境下，Socket編程主要是指基于TCP/IP協(xié)議的網(wǎng)絡(luò)編程。
2.Socket通訊的過程
Server端Listen(監(jiān)聽)某個(gè)端口是否有連接請(qǐng)求，Client端向Server 端發(fā)出Connect(連接)請(qǐng)求，Server端向Client端發(fā)回Accept（接受）消息。一個(gè)連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對(duì)方通信。
對(duì)于一個(gè)功能齊全的Socket，都要包含以下基本結(jié)構(gòu)，其工作過程包含以下四個(gè)基本的步驟：
?。?） 創(chuàng)建Socket；
?。?） 打開連接到Socket的輸入/出流；
（3） 按照一定的協(xié)議對(duì)Socket進(jìn)行讀/寫操作；
（4） 關(guān)閉Socket.
3.創(chuàng)建Socket
java在包java.net中提供了兩個(gè)類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務(wù)端。這是兩個(gè)封裝得非常好的類，使用很方便。其構(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ī)名和端 口號(hào)，stream指明socket是流socket還是數(shù)據(jù)報(bào)socket，localPort表示本地主機(jī)的端口號(hào)，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);
注意，在選擇端口時(shí)，必須小心。每一個(gè)端口提供一種特定的服務(wù)，只有給出正確的端口，才 能獲得相應(yīng)的服務(wù)。
0~1023的端口號(hào)為系統(tǒng)所保留，例如http服務(wù)的端口號(hào)為80,telnet服務(wù)的端口號(hào)為21,ftp服務(wù)的端口號(hào)為23, 所以我們?cè)谶x擇端口號(hào)時(shí)，最好選擇一個(gè)大于1023的數(shù)以防止發(fā)生沖突。
在創(chuàng)建socket時(shí)如果發(fā)生錯(cuò)誤，將產(chǎn)生IOException，在程序中必須對(duì)之作出處理。所以在創(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);
//等待請(qǐng)求,此方法會(huì)一直阻塞,直到獲得請(qǐng)求才往下走
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)請(qǐ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ù),接收客戶端請(qǐng)求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對(duì)象
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.客戶端請(qǐng)求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í)需要將數(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();
}
}
}
}
四.測(cè)試
1,首先啟動(dòng)服務(wù)端MultiSocketServer ,等待請(qǐng)求
ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]
2.啟動(dòng)客戶端MultiClientSocket ,向服務(wù)端發(fā)送請(qǐng)求,已經(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通信示例代碼，希望對(duì)大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站：Java網(wǎng)絡(luò)編程基礎(chǔ)篇之單向通信、Java使用代理進(jìn)行網(wǎng)絡(luò)連接方法示例等，有什么問題可以隨時(shí)留言，小編會(huì)及時(shí)回復(fù)大家的。感謝朋友們對(duì)本站的支持。
相關(guān)文章
這篇文章主要介紹了Java線程中的ThreadLocal詳細(xì)分析,ThreadLocal?提供線程的局部變量,每個(gè)線程都可以通過?get()和?set()對(duì)局部變量進(jìn)行操作而不會(huì)對(duì)其他線程的局部變量產(chǎn)生影響,實(shí)現(xiàn)了線程之間的數(shù)據(jù)隔離,需要的朋友可以參考下2023-09-09
詳細(xì)總結(jié)Java創(chuàng)建文件夾的方法及優(yōu)缺點(diǎn)
很多小伙伴都不知道如何用Java創(chuàng)建文件夾,今天給大家整理了這篇文章,文中有非常詳細(xì)的方法介紹及方法的優(yōu)缺點(diǎn),對(duì)正在學(xué)習(xí)java的小伙伴們有很好地幫助,需要的朋友可以參考下2021-05-05
第三方網(wǎng)站微信登錄java代碼實(shí)現(xiàn)
這篇文章主要為大家詳細(xì)介紹了第三方網(wǎng)站微信登錄的java代碼實(shí)現(xiàn)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-04-04
Eclipse可視化插件WindowBuilder的安裝方法
這篇文章主要介紹了Eclipse可視化插件WindowBuilder的安裝方法，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
劍指Offer之Java算法習(xí)題精講二叉樹與斐波那契函數(shù)
跟著思路走，之后從簡(jiǎn)單題入手，反復(fù)去看，做過之后可能會(huì)忘記，之后再做一次，記不住就反復(fù)做，反復(fù)尋求思路和規(guī)律，慢慢積累就會(huì)發(fā)現(xiàn)質(zhì)的變化2022-03-03
Spring事務(wù)失效的一種原因關(guān)于this調(diào)用的問題
這篇文章主要介紹了Spring事務(wù)失效的一種原因關(guān)于this調(diào)用的問題,本文給大家分享問題原因及解決辦法，通過實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下2021-10-10
基于SpringBoot上傳任意文件功能的實(shí)現(xiàn)
下面小編就為大家?guī)硪黄赟pringBoot上傳任意文件功能的實(shí)現(xiàn)。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-08-08
java實(shí)現(xiàn)短信驗(yàn)證碼5分鐘有效時(shí)間
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)短信驗(yàn)證碼5分鐘有效時(shí)間，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-07-07
詳解Spring Boot的GenericApplicationContext使用教程
這篇教程展示了如何在Spring應(yīng)用程序中使用GenericApplicationContext 。小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-11-11
Spring注解配置AOP導(dǎo)致通知執(zhí)行順序紊亂解決方案
這篇文章主要介紹了Spring注解配置AOP導(dǎo)致通知執(zhí)行順序紊亂解決方案,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-10-10