這篇文章主要介紹了JAVA之Socket編程方法怎么用的相關(guān)知識,內(nèi)容詳細易懂,操作簡單快捷,具有一定借鑒價值,相信大家閱讀完這篇JAVA之Socket編程方法怎么用文章都會有所收獲,下面我們一起來看看吧。
成都創(chuàng)新互聯(lián)公司-云計算及IDC服務(wù)提供商,涵蓋公有云、IDC機房租用、香港機房服務(wù)器托管、等保安全、私有云建設(shè)等企業(yè)級互聯(lián)網(wǎng)基礎(chǔ)服務(wù),聯(lián)系熱線:18980820575
(1)Java最初是作為網(wǎng)絡(luò)編程語言出現(xiàn)的,它對網(wǎng)絡(luò)的高度支持,使得客戶端和服務(wù)器端流暢的溝通成為現(xiàn)實。
(2)在網(wǎng)絡(luò)編程中,使用最多的就是Socket,每一個實用的網(wǎng)絡(luò)程序都少不了它的參與。
(3)在計算機網(wǎng)絡(luò)編程技術(shù)中,兩個進程或者說兩臺計算機可以通過一個網(wǎng)絡(luò)通信連接實現(xiàn)數(shù)據(jù)的交換,這種通信鏈路的端點就被稱為“套接字”(英文名稱也就是Socket)。
(4)Socket是網(wǎng)絡(luò)驅(qū)動層提供給應(yīng)用程序的一個接口或者說一種機制。
(5)使用物流送快遞的例子來說明Socket:
-->發(fā)件人將有收貨人地址信息的貨物送到快遞站,發(fā)件人不用關(guān)心物流是如何進行的,貨物被送到收貨人所在地區(qū)的快遞站點,進行配送,收貨人等待收貨就可以了。
-->這個過程很形象地說明了信息在網(wǎng)絡(luò)中傳遞的過程。其中,貨物就是數(shù)據(jù)信息,2個快遞站點就是2個端點Socket。

(6)信息如何在網(wǎng)絡(luò)中尋址傳遞,應(yīng)用程序并不用關(guān)心,只負責(zé)準(zhǔn)備發(fā)送數(shù)據(jù)和接收數(shù)據(jù)即可。
(1)對于編程人員來說,無須了解Socket底層機制是如何傳送數(shù)據(jù)的,而是直接將數(shù)據(jù)提交給Socket,Socket會根據(jù)應(yīng)用程序提供的相關(guān)信息,通過一系列計算,綁定IP及信息數(shù)據(jù),將數(shù)據(jù)交給驅(qū)動程序向網(wǎng)絡(luò)上發(fā)送。
(2)Socket的底層機制非常復(fù)雜,Java平臺提供了一些簡單但是強大的類,可以簡單有效地使用Socket開發(fā)通信程序而無須了解底層機制。
(1)java.net包提供了若干支持基于套接字的客戶端/服務(wù)器通信的類。
(2)java.net包中常用的類有Socket、ServerSocket、DatagramPacket、DatagramSocket、InetAddress、URL、URLConnection和URLEncoder等。
(3)為了監(jiān)聽客戶端的連接請求,可以使用ServerSocket類。
(4)Socket類實現(xiàn)用于網(wǎng)絡(luò)上進程間通信的套接字。
(5)DatagramSocket類使用UDP協(xié)議實現(xiàn)客戶端和服務(wù)器套接字。
(6)DatagramPacket類使用DatagramSocket類的對象封裝設(shè)置和收到的數(shù)據(jù)報。
(7)InetAddress類表示Internet地址。
(8)在創(chuàng)建數(shù)據(jù)報報文和Socket對象時,可以使用InetAddress類
(1)java.net包的兩個類Socket和ServerSocket,分別用來實現(xiàn)雙向安全連接的客戶端和服務(wù)器端,它們是基于TCP協(xié)議進行工作的,工作過程如同打電話的過程,只有雙方都接通了,才能開始通話。
(2)進行網(wǎng)絡(luò)通信時,Socket需要借助數(shù)據(jù)流來完成數(shù)據(jù)的傳遞工作。
(3)一個應(yīng)用程序要通過網(wǎng)絡(luò)向另一個應(yīng)用程序發(fā)送數(shù)據(jù),只要簡單地創(chuàng)建Socket,然后將數(shù)據(jù)寫入到與該Socket關(guān)聯(lián)的輸出流即可。對應(yīng)的,接收方的應(yīng)用程序創(chuàng)建Socket,從相關(guān)聯(lián)的輸入流讀取數(shù)據(jù)即可。
(4)注意:2個端點在基于TCP協(xié)議的Socket編程中,經(jīng)常一個作為客戶端,一個作為服務(wù)器端,也就是遵循client-server模型。
● Socket類
Socket對象在客戶端和服務(wù)器之間建立連接。可用Socket類的構(gòu)造方法創(chuàng)建套接字,并將此套接字連接至指定的主機和端口。
(1)構(gòu)造方法
-->第一種構(gòu)造方法以主機名和端口號作為參數(shù)來創(chuàng)建一個Socket對象。創(chuàng)建對象時可能拋出UnknownHostException或IOException異常,必須捕獲它們。
Socket s = new Socket(hostName,port);
-->第二種構(gòu)造方法以InetAddress對象和端口號作為參數(shù)來創(chuàng)建一個Socket對象。構(gòu)造方法可能拋出IOException或UnknownHostException異常,必須捕獲并處理它們。
Socket s = new Socket(address,port);
(2)常用方法 
● ServerSocket類
ServerSocket對象等待客戶端建立連接,連接建立以后進行通信。
(1)構(gòu)造方法
-->第一種構(gòu)造方法接受端口號作為參數(shù)創(chuàng)建ServerSocket對象,創(chuàng)建此對象時可能拋出IOException異常,必須捕獲和處理它。
ServerSocket ss = new ServerSocket(port);
-->第二種構(gòu)造方法接受端口號和最大隊列長度作為參數(shù),隊列長度表示系統(tǒng)在拒絕連接前可以擁有的最大客戶端連接數(shù)。
ServerSocket ss = new ServerSocket(port,maxqu);
(2)常用方法
-->Socket類中列出的方法也適用于ServerSocket類。
-->ServerSocket類具有accept()方法,此方法用于等待客戶端發(fā)起通信,這樣Socket對象就可用于進一步的數(shù)據(jù)傳輸。

● 實現(xiàn)單用戶登錄
-->Socket網(wǎng)絡(luò)編程一般分成如下4個步驟進行:
(1)建立連接。
(2)打開Socket關(guān)聯(lián)的輸入/輸出流。
(3)從數(shù)據(jù)流中寫入信息和讀取信息。
(4)關(guān)閉所有的數(shù)據(jù)流和Socket。
-->使用兩個類模擬實現(xiàn)用戶登錄的功能,實現(xiàn)客戶端向服務(wù)器端發(fā)送用戶登錄信息,服務(wù)器端顯示這些信息。
客戶端實現(xiàn)步驟:
1)建立連接,連接指向服務(wù)器及端口。
2)打開Socket關(guān)聯(lián)的輸入/輸出流。
3)向輸出流中寫入信息。
4)從輸入流中讀取響應(yīng)信息。
5)關(guān)閉所有的數(shù)據(jù)流和Socket。
服務(wù)器端實現(xiàn)步驟:
1)建立連接,監(jiān)聽端口。
2)使用accept()方法等待客戶端發(fā)起通信
3)打開Socket關(guān)聯(lián)的輸入/輸出流。
4)從輸入流中讀取請求信息。
5)向輸出流中寫入信息。
6)關(guān)閉所有的數(shù)據(jù)流和Socket。
-->客戶端和服務(wù)器端的交互,采用一問一答的模式,先啟動服務(wù)器進入監(jiān)聽狀態(tài),等待客戶端的連接請求,連接成功以后,客戶端先“發(fā)言”,服務(wù)器給予“回應(yīng)”。
示例01:實現(xiàn)傳遞對象信息。
? user類
package cn.bdqn.demo02; import java.io.Serializable; public class User implements Serializable { private static final long serialVersionUID = 1L; /** 用戶名 */ private String loginName; /** 用戶密碼 */ private String pwd; public User() { super(); } public User(String loginName, String pwd) { super(); this.loginName = loginName; this.pwd = pwd; } public String getLoginName() { return loginName; } public void setLoginName(String loginName) { this.loginName = loginName; } public String getPwd() { return pwd; } public void setPwd(String pwd) { this.pwd = pwd; } }? LoginServer類
package cn.bdqn.demo02; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class LoginServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; InputStream is = null; ObjectInputStream ois = null; OutputStream os = null; try { // 建立一個服務(wù)器Socket(ServerSocket),指定端口8800并開始監(jiān)聽 serverSocket = new ServerSocket(8800); // 使用accept()方法等待客戶端發(fā)起通信 socket = serverSocket.accept(); // 打開輸入流 is = socket.getInputStream(); // 反序列化 ois = new ObjectInputStream(is); // 獲取客戶端信息,即從輸入流讀取信息 User user = (User) ois.readObject(); if (user != null) { System.out.println("我是服務(wù)器,客戶登錄信息為:" + user.getLoginName() + "," + user.getPwd()); } // 給客戶端一個響應(yīng),即向輸出流中寫入信息 String reply = "歡迎你,登錄成功"; os = socket.getOutputStream(); os.write(reply.getBytes()); } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } finally { // 關(guān)閉資源 try { os.close(); ois.close(); is.close(); socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } }LoginClient類
package cn.bdqn.demo02; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class LoginClient { /* * 示例02:升級演示示例01,實現(xiàn)傳遞對象信息。 */ public static void main(String[] args) { Socket socket = null; OutputStream os = null; ObjectOutputStream oos = null; InputStream is = null; BufferedReader br = null; try { // 建立客戶端Socket連接,指定服務(wù)器的位置為本機以及端口為8800 socket = new Socket("localhost", 8800); // 打開輸出流 os = socket.getOutputStream(); // 對象序列化 oos = new ObjectOutputStream(os); // 發(fā)送客戶端信息,即向輸出流中寫入信息 User user = new User("Tom", "123456"); oos.writeObject(user); socket.shutdownOutput(); // 接收服務(wù)器端的響應(yīng),即從輸入流中讀取信息 is = socket.getInputStream(); br = new BufferedReader(new InputStreamReader(is)); String reply; while ((reply = br.readLine()) != null) { System.out.println("我是客戶端,服務(wù)器的響應(yīng)為:" + reply); } } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { br.close(); is.close(); oos.close(); os.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
示例02:升級演示示例01,實現(xiàn)傳遞多個對象信息。
user類
package cn.bdqn.demo03; import java.io.Serializable; public class User implements Serializable { private static final long serialVersionUID = 1L; /** 用戶名 */ private String loginName; /** 用戶密碼 */ private String pwd; public User() { super(); } public User(String loginName, String pwd) { super(); this.loginName = loginName; this.pwd = pwd; } public String getLoginName() { return loginName; } public void setLoginName(String loginName) { this.loginName = loginName; } public String getPwd() { return pwd; } public void setPwd(String pwd) { this.pwd = pwd; } }LoginServer類
package cn.bdqn.demo03; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class LoginServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; InputStream is = null; ObjectInputStream ois = null; OutputStream os = null; try { // 建立一個服務(wù)器Socket(ServerSocket),指定端口8800并開始監(jiān)聽 serverSocket = new ServerSocket(8800); // 使用accept()方法等待客戶端發(fā)起通信 socket = serverSocket.accept(); // 打開輸入流 is = socket.getInputStream(); // 反序列化 ois = new ObjectInputStream(is); // 獲取客戶端信息,即從輸入流讀取信息 User[] users = (User[]) ois.readObject(); for (int i = 0; i < users.length; i++) { System.out.println("我是服務(wù)器,客戶登錄信息為:" + users[i].getLoginName() + "," + users[i].getPwd()); } // 給客戶端一個響應(yīng),即向輸出流中寫入信息 String reply = "歡迎你,登錄成功"; os = socket.getOutputStream(); os.write(reply.getBytes()); } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } finally { // 關(guān)閉資源 try { os.close(); ois.close(); is.close(); socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } }LoginClient類
package cn.bdqn.demo03; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class LoginClient { /* * 示例02:升級演示示例01,實現(xiàn)傳遞對象信息。 */ public static void main(String[] args) { Socket socket = null; OutputStream os = null; ObjectOutputStream oos = null; InputStream is = null; BufferedReader br = null; try { // 建立客戶端Socket連接,指定服務(wù)器的位置為本機以及端口為8800 socket = new Socket("localhost", 8800); // 打開輸出流 os = socket.getOutputStream(); // 對象序列化 oos = new ObjectOutputStream(os); // 發(fā)送客戶端信息,即向輸出流中寫入信息 User user1 = new User("Tom", "123456"); User user2 = new User("bob", "123456"); User user3 = new User("lisa", "123456"); User[] users = {user1,user2,user3}; oos.writeObject(users); socket.shutdownOutput(); // 接收服務(wù)器端的響應(yīng),即從輸入流中讀取信息 is = socket.getInputStream(); br = new BufferedReader(new InputStreamReader(is)); String reply; while ((reply = br.readLine()) != null) { System.out.println("我是客戶端,服務(wù)器的響應(yīng)為:" + reply); } } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { br.close(); is.close(); oos.close(); os.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
● 實現(xiàn)多客戶端用戶登錄

-->一問一答的模式在現(xiàn)實中顯然不是人們想要的。一個服務(wù)器不可能只針對一個客戶端服務(wù),一般是面向很多的客戶端同時提供服務(wù)的,但是單線程實現(xiàn)必然是這樣的結(jié)果。
-->解決這個問題的辦法是采用多線程的方式,可以在服務(wù)器端創(chuàng)建一個專門負責(zé)監(jiān)聽的應(yīng)用主服務(wù)程序、一個專門負責(zé)響應(yīng)的線程程序。這樣可以利用多線程處理多個請求。
->客戶端實現(xiàn)步驟:
1)建立連接,連接指向服務(wù)器及端口。
2)打開Socket關(guān)聯(lián)的輸入/輸出流。
3)向輸出流中寫入信息。
4)從輸入流中讀取響應(yīng)信息。
5)關(guān)閉所有的數(shù)據(jù)流和Socket。
-->服務(wù)器端實現(xiàn)步驟:
1)創(chuàng)建服務(wù)器線程類,run()方法中實現(xiàn)對一個請求的響應(yīng)處理。
2)修改服務(wù)器端代碼,讓服務(wù)器端Socket一直處于監(jiān)聽狀態(tài)。
3)服務(wù)器端每監(jiān)聽到一個請求,創(chuàng)建一個線程對象并啟動。
示例03:升級演示示例02,實現(xiàn)多客戶端的響應(yīng)處理。
user類
package cn.bdqn.demo04; import java.io.Serializable; public class User implements Serializable { private static final long serialVersionUID = 1L; /** 用戶名 */ private String loginName; /** 用戶密碼 */ private String pwd; public User() { super(); } public User(String loginName, String pwd) { super(); this.loginName = loginName; this.pwd = pwd; } public String getLoginName() { return loginName; } public void setLoginName(String loginName) { this.loginName = loginName; } public String getPwd() { return pwd; } public void setPwd(String pwd) { this.pwd = pwd; } }LoginThread
package cn.bdqn.demo04; import java.io.IOException; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.OutputStream; import java.net.Socket; public class LoginThread extends Thread { /* * 示例03:升級示例02,實現(xiàn)多客戶端的響應(yīng)處理。 * * 分析如下: * (1)創(chuàng)建服務(wù)器端線程類,run()方法中實現(xiàn)對一個請求的響應(yīng)處理。 * (2)修改服務(wù)器端代碼,讓服務(wù)器端Socket一直處于監(jiān)聽狀態(tài)。 * (3)服務(wù)器端每監(jiān)聽到一個請求,創(chuàng)建一個線程對象并啟動 */ Socket socket = null; //每啟動一個線程,連接對應(yīng)的Socket public LoginThread(Socket socket) { this.socket = socket; } //啟動線程,即響應(yīng)客戶請求 public void run() { InputStream is = null; ObjectInputStream ois = null; OutputStream os = null; try { //打開輸入流 is = socket.getInputStream(); //反序列化 ois = new ObjectInputStream(is); //獲取客戶端信息,即從輸入流讀取信息 User user = (User)ois.readObject(); if(user!=null){ System.out.println("我是服務(wù)器,客戶登錄信息為:"+user.getLoginName()+","+user.getPwd()); } //給客戶端一個響應(yīng),即向輸出流中寫入信息 os = socket.getOutputStream(); String reply = "歡迎你,登錄成功"; os.write(reply.getBytes()); } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); }finally{ try { os.close(); ois.close(); is.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }LoginServer類
package cn.bdqn.demo04; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; public class LoginServer { public static void main(String[] args) { ServerSocket serverSocket = null; try { // 建立一個服務(wù)器Socket(ServerSocket)指定端口并開始監(jiān)聽 serverSocket = new ServerSocket(8800); // 監(jiān)聽一直進行中 while (true) { // 使用accept()方法等待客戶發(fā)起通信 Socket socket = serverSocket.accept(); LoginThread loginThread = new LoginThread(socket); loginThread.start(); } } catch (IOException e) { e.printStackTrace(); } } }? LoginClient1類
package cn.bdqn.demo04; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.ObjectOutputStream; import java.io.OutputStream; import java.net.Socket; import java.net.UnknownHostException; public class LoginClient01 { /* * 客戶端通過輸出流向服務(wù)器端發(fā)送請求信息 * 服務(wù)器偵聽客戶端的請求得到一個Socket對象,將這個Socket對象傳遞給線程類 * 線程類通過輸入流獲取客戶端的請求并通過輸出流向客戶端發(fā)送響應(yīng)信息 * 客戶端通過輸入流讀取服務(wù)器發(fā)送的響應(yīng)信息 * */ /* * 示例03:升級演示示例02,實現(xiàn)多客戶端的響應(yīng)處理 */ public static void main(String[] args) { Socket socket = null; OutputStream os = null; ObjectOutputStream oos = null; InputStream is = null; BufferedReader br = null; try { // 建立客戶端Socket連接,指定服務(wù)器的位置為本機以及端口為8800 socket = new Socket("localhost", 8800); // 打開輸出流 os = socket.getOutputStream(); // 對象序列化 oos = new ObjectOutputStream(os); // 發(fā)送客戶端信息,即向輸出流中寫入信息 User user = new User("Tom", "123456"); oos.writeObject(user); socket.shutdownOutput(); // 接收服務(wù)器端的響應(yīng),即從輸入流中讀取信息 is = socket.getInputStream(); br = new BufferedReader(new InputStreamReader(is)); String reply; while ((reply = br.readLine()) != null) { System.out.println("我是客戶端,服務(wù)器的響應(yīng)為:" + reply); } } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { br.close(); is.close(); oos.close(); os.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }? LoginClient2類和LoginClient3類
同LoginClient1類一樣,創(chuàng)建不同的User對象即可
-->java.net包中的InetAddress類用于封裝IP地址和DNS。要創(chuàng)建InetAddress類的實例,可以使用工廠方法,因為此類沒有構(gòu)造方法。
-->InetAddress類中的工廠方法
-->如果找不到主機,兩種方法都將拋出UnknownHostNameException異常。
| TCP | UDP | |
| 是否連接 | 面向連接 | 面向非連接 |
| 傳輸可靠性 | 可靠 | 不可靠 |
| 速度 | 慢 | 快 |
(1)基于TCP的網(wǎng)絡(luò)通信是安全的,是雙向的,如同打電話,需要先有服務(wù)端,建立雙向連接后,才開始數(shù)據(jù)通信。
(2)基于UDP的網(wǎng)絡(luò)通信只需要指明對方地址,然后將數(shù)據(jù)送出去,并不會事先連接。這樣的網(wǎng)絡(luò)通信是不安全的,所以只應(yīng)用在如聊天系統(tǒng)、咨詢系統(tǒng)等場合下。
(3)數(shù)據(jù)報是表示通信的一種報文類型,使用數(shù)據(jù)報進行通信時無須事先建立連接,它是基于UDP協(xié)議進行的。
(4)Java中有兩個可使用數(shù)據(jù)報實現(xiàn)通信的類,即DatagramPacket和DatagramSocket。
(5)DatagramPacket類起到容器的作用,DatagramSocket類用于發(fā)送或接收DatagramPacket。
(6)DatagramPacket類不提供發(fā)送或接收數(shù)據(jù)的方法,而DatagramSocket類提供send()方法和receive()方法,用于通過套接字發(fā)送和接收數(shù)據(jù)報。
● DatagramPacket類
(1)構(gòu)造方法
-->客戶端要向外發(fā)送數(shù)據(jù),必須首先創(chuàng)建一個DatagramPacket對象,再使用DatagramSocket對象發(fā)送。

(2)常用方法

● DatagramSocket類
(1)構(gòu)造方法
-->DatagramSocket類不維護連接狀態(tài),不產(chǎn)生輸入/輸出數(shù)據(jù)流,它的唯一作用就是接收和發(fā)送DatagramPacket對象封裝好的數(shù)據(jù)報。

(2)常用方法

-->利用UDP通信的兩個端點是平等的,也就是說通信的兩個程序關(guān)系是對等的,沒有主次之分,甚至它們的代碼都可以完全是一樣的,這一點要與基于TCP協(xié)議的Socket編程區(qū)分開來。
-->基于UDP協(xié)議的Socket網(wǎng)絡(luò)編程一般按照以下4個步驟進行:
(1)利用DatagramPacket對象封裝數(shù)據(jù)包。
(2)利用DatagramSocket對象發(fā)送數(shù)據(jù)包。
(3)利用DatagramSocket對象接收數(shù)據(jù)包。
(4)利用DatagramPacket對象處理數(shù)據(jù)包。

-->模擬客戶咨詢功能,實現(xiàn)發(fā)送方發(fā)送咨詢問題,接收方接收并顯示發(fā)送來的咨詢問題。
發(fā)送方實現(xiàn)步驟:
1)獲取本地主機的InetAddress對象。
2)創(chuàng)建DatagramPacket對象,封裝要發(fā)送的信息。
3)利用DatagramSocket對象將DatagramPacket對象數(shù)據(jù)發(fā)送出去。
接收方實現(xiàn)步驟:
1)創(chuàng)建DatagramPacket對象,準(zhǔn)備接收封裝的數(shù)據(jù)。
2)創(chuàng)建DatagramSocket對象,接收數(shù)據(jù)保存于DatagramPacket對象中。
3)利用DatagramPacket對象處理數(shù)據(jù)。
示例04:發(fā)送方發(fā)送咨詢問題,接收方回應(yīng)咨詢。
? Receive類
package cn.bdqn.demo05; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketAddress; import java.net.SocketException; public class Receive { public static void main(String[] args) { /* * 示例06:發(fā)送方發(fā)送咨詢問題,接收方回應(yīng)咨詢。 * * 接收方實現(xiàn)步驟如下: * (1)創(chuàng)建DatagramPacket對象,準(zhǔn)備接收封裝的數(shù)據(jù)。 * (2)創(chuàng)建DatagramSocket對象,接收數(shù)據(jù)保存于DatagramPacket對象中。 * (3)利用DatagramPacket對象處理數(shù)據(jù)。 */ DatagramSocket ds = null; DatagramPacket dp = null; DatagramPacket dpto = null; // 創(chuàng)建DatagramPacket對象,用來準(zhǔn)備接收數(shù)據(jù) byte[] buf = new byte[1024]; dp = new DatagramPacket(buf, 1024); try { // 創(chuàng)建DatagramSocket對象,接收數(shù)據(jù) ds = new DatagramSocket(8800); ds.receive(dp); // 顯示接收到的信息 String mess = new String(dp.getData(), 0, dp.getLength()); System.out.println(dp.getAddress().getHostAddress() + "說:" + mess); String reply = "你好,我在,請咨詢!"; // 顯示與本地對話框 System.out.println("我 說:" + reply); // 創(chuàng)建DatagramPacket對象,封裝數(shù)據(jù) SocketAddress sa = dp.getSocketAddress(); dpto = new DatagramPacket(reply.getBytes(), reply.getBytes().length, sa); ds.send(dpto); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { ds.close(); } } }? Send類
package cn.bdqn.demo05; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; import java.net.UnknownHostException; public class Send { /* * 示例06:升級示例05,發(fā)送方發(fā)送咨詢問題,接收方回應(yīng)咨詢。 * * 發(fā)送方實現(xiàn)步驟如下: * (1)獲取本地主機的InetAddress對象。 * (2)創(chuàng)建DatagramPacket對象,封裝要發(fā)送的信息。 * (3)利用DatagramSocket對象將DatagramPacket對象數(shù)據(jù)發(fā)送出去。 */ public static void main(String[] args) { DatagramSocket ds = null; InetAddress ia = null; String mess = "你好,我想咨詢一個問題。"; System.out.println("我說:" + mess); try { // 獲取本地主機地址 ia = InetAddress.getByName("localhost"); // 創(chuàng)建DatagramPacket對象,封裝數(shù)據(jù) DatagramPacket dp = new DatagramPacket(mess.getBytes(), mess.getBytes().length, ia, 8800); // 創(chuàng)建DatagramSocket對象,向服務(wù)器發(fā)送數(shù)據(jù) ds = new DatagramSocket(); ds.send(dp); byte[] buf = new byte[1024]; DatagramPacket dpre = new DatagramPacket(buf, buf.length); ds.receive(dpre); // 顯示接收到的信息 String reply = new String(dpre.getData(), 0, dpre.getLength()); System.out.println(dpre.getAddress().getHostAddress() + "說:" + reply); } catch (UnknownHostException e) { e.printStackTrace(); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { ds.close(); } } }
關(guān)于“JAVA之Socket編程方法怎么用”這篇文章的內(nèi)容就介紹到這里,感謝各位的閱讀!相信大家對“JAVA之Socket編程方法怎么用”知識都有一定的了解,大家如果還想學(xué)習(xí)更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)頁題目:JAVA之Socket編程方法怎么用
網(wǎng)站鏈接:http://www.chinadenli.net/article32/pgcgpc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供軟件開發(fā)、靜態(tài)網(wǎng)站、Google、建站公司、小程序開發(fā)、全網(wǎng)營銷推廣
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)