Server類(服務(wù)器端)
package cn.tkrnet.server;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) throws IOException {
System.out.println("--服務(wù)器端已開啟--");
//創(chuàng)建ServerSocket對象,這里的端口號必須與客戶端的端口號相同
ServerSocket server = new ServerSocket(9000);
//調(diào)用方法accept(),用來監(jiān)聽客戶端發(fā)來的請求
Socket socket = server.accept();
//獲取輸入流對象
InputStream is = socket.getInputStream();
//讀取輸入流中的數(shù)據(jù)
int b = 0;
while ((b =is.read()) != -1){
System.out.print((char)b);
}
//關(guān)閉流
is.close();
socket.close();
server.close();
}
}
提示:在運行程序時,一定要先運行服務(wù)器端的程序代碼,再運行客戶端的程序代碼。因為客戶端要向服務(wù)器發(fā)送請求,前提是服務(wù)器端要處于開啟狀態(tài)。
Server類(服務(wù)器端)運行結(jié)果:
--服務(wù)器端已開啟--
Client類(客戶端)運行結(jié)果:
信息已發(fā)送
Client類(客戶端)運行后,Server類(服務(wù)器端)收到信息,運行結(jié)果:
--服務(wù)器端已開啟--
Java is my friend !
實例分析:
服務(wù)器端啟動后,服務(wù)器端的accept()方法一直處于監(jiān)聽狀態(tài),直到客戶端連接了服務(wù)器,服務(wù)器端再從流中讀取客戶端發(fā)來的數(shù)據(jù)。
恕我直言,這是一個超級無敵簡單的單向通信實例。
六、UDP編程
UDP使用數(shù)據(jù)報進(jìn)行數(shù)據(jù)傳輸,沒有客戶端與服務(wù)器端之分,只有發(fā)送方與接收方,兩者哪個先啟動都不會報錯,但是會出現(xiàn)數(shù)據(jù)丟包現(xiàn)象。發(fā)送的內(nèi)容有字?jǐn)?shù)限制,大小必須限制在64k以內(nèi)。
發(fā)送方與接收方實現(xiàn)步驟:
前提:創(chuàng)建一個項目,在項目中創(chuàng)建兩個模塊(model),一個模塊用來放發(fā)送方相關(guān)代碼,一個模塊用來放接收方相關(guān)代碼。
目錄結(jié)構(gòu)如下圖
發(fā)送方 :
1、創(chuàng)建DatagramSocket對象,可以指定應(yīng)用程序的端口號,也可以不指定。
2、準(zhǔn)備需要發(fā)送的數(shù)據(jù)
3、創(chuàng)建DatagramPacket對象,用來對發(fā)送的數(shù)據(jù)進(jìn)行打包,需要指定發(fā)送內(nèi)容、發(fā)送多少、發(fā)送到哪里和接收方的端口號四個參數(shù)。
4、調(diào)用DatagramSocket對象的send()方法發(fā)送數(shù)據(jù)。
5、記得關(guān)閉流。
接收方 :
1、創(chuàng)建DatagramSocket對象,指定接收方的端口號,這個必須指定。
2、創(chuàng)建一個byte類型數(shù)組,用來接收發(fā)送方發(fā)送過來的數(shù)據(jù)。
3、創(chuàng)建DatagramPacket對象,準(zhǔn)備接收數(shù)據(jù)。
4、調(diào)用DatagramSocket對象的receive()方法用于接收數(shù)據(jù)。
5、使用String類的構(gòu)造方法將byte類型的數(shù)組中的數(shù)據(jù)轉(zhuǎn)化成String類型并顯示。
6、記得關(guān)閉流。
實例 :
發(fā)送方發(fā)送信息,接收方接收信息,并顯示。
Sender類(發(fā)送方)
package cn.tkrnet.Sender;
import java.io.IOException;
import java.net.*;
public class Sender {
public static void main(String[] args) throws IOException {
//創(chuàng)建接受或發(fā)送的數(shù)據(jù)報套接字,并指定發(fā)送方的端口號為7770
DatagramSocket ds = new DatagramSocket(7770); //端口號也可以不指定
System.out.println("---發(fā)送方---");
//創(chuàng)建數(shù)據(jù)報對象,用來發(fā)送數(shù)據(jù)
byte[] b = "Java is my friend !".getBytes();
//8800為接收方的端口號,netAddress.getByName("localhost")是獲取主機(jī)的IP地址
DatagramPacket dp = new DatagramPacket(b,b.length, InetAddress.getByName("localhost"),7788);
ds.send(dp); //發(fā)送數(shù)據(jù)報
System.out.println("數(shù)據(jù)已發(fā)送");
//關(guān)閉流
ds.close();
}
}
Receiver類(接收方)
package cn.tkrnet.receiver;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Receiver {
public static void main(String[] args) throws IOException {
System.out.println("---接收方---");
//創(chuàng)建數(shù)據(jù)報套接字對象,指定的端口號要和發(fā)送方發(fā)送數(shù)據(jù)的端口號相同
// (不是發(fā)送方的端口號7770,是發(fā)送方發(fā)送數(shù)據(jù)的端口號7788)
DatagramSocket ds = new DatagramSocket(7788);
//創(chuàng)建接收數(shù)據(jù)報的對象
byte[] b = new byte[1024];
DatagramPacket dp = new DatagramPacket(b,b.length);
//接收數(shù)據(jù)
ds.receive(dp);
System.out.println(new String(b,0,dp.getLength()));
//關(guān)閉流
ds.close();
}
}
提示:在運行程序時,先運行發(fā)送方程序,還是先運行接收方程序都不會報錯,但是有可能會出現(xiàn)數(shù)據(jù)丟包,一般我們都先運行接收方的程序代碼,再運行發(fā)送方的程序代碼。
Receiver類(接收方)運行結(jié)果:
---接收方---
Sender類(發(fā)送方)運行結(jié)果:
---發(fā)送方---
數(shù)據(jù)已發(fā)送
Sender類(發(fā)送方)運行后,Receiver類(接收方)接收到信息,運行結(jié)果:
---接收方---
Java is my friend !
實例分析:
只有接收方先啟動運行,才會存在端口號為7788的程序,發(fā)送方才能發(fā)送數(shù)據(jù)到指定端口號7788,接收方才能接收數(shù)據(jù)。
不瞞你說,這也是個超級無敵簡單的單向通信實例。
-
通信協(xié)議
+關(guān)注
關(guān)注
28文章
840瀏覽量
40215 -
TCP
+關(guān)注
關(guān)注
8文章
1347瀏覽量
78933 -
UDP
+關(guān)注
關(guān)注
0文章
322瀏覽量
33849 -
端口
+關(guān)注
關(guān)注
4文章
948瀏覽量
31984 -
網(wǎng)絡(luò)編程
+關(guān)注
關(guān)注
0文章
68瀏覽量
10055
發(fā)布評論請先 登錄
相關(guān)推薦
評論