Java Socket編程之UDP編程

ityouknow 發(fā)布于2019-08-16 17:08 / 2162人閱讀

摘要：更多資料請(qǐng)看編程之編程協(xié)議用戶數(shù)據(jù)報(bào)協(xié)議是無連接的不可靠的無序的速度快進(jìn)行數(shù)據(jù)傳輸時(shí)，首先將要傳輸?shù)臄?shù)據(jù)定義成數(shù)據(jù)報(bào)，大小限制在，在數(shù)據(jù)報(bào)中指明數(shù)據(jù)索要達(dá)到的主機(jī)地址和端口號(hào)，然后再將數(shù)據(jù)報(bào)發(fā)送出去類表示數(shù)據(jù)報(bào)包類進(jìn)行端到端通信的類服務(wù)器端

更多資料請(qǐng)看：https://www.yuque.com/shizhiy...

Java Socket編程之UDP編程

UDP協(xié)議（用戶數(shù)據(jù)報(bào)協(xié)議）是無連接的、不可靠的、無序的,速度快
? ? ? 進(jìn)行數(shù)據(jù)傳輸時(shí)，首先將要傳輸?shù)臄?shù)據(jù)定義成數(shù)據(jù)報(bào)（Datagram），大小限制在64k，在數(shù)據(jù)報(bào)中指明數(shù)據(jù)索要達(dá)到的Socket（主機(jī)地址和端口號(hào)），然后再將數(shù)據(jù)報(bào)發(fā)送出去;
**
? ? ? DatagramPacket類:表示數(shù)據(jù)報(bào)包
? ? ? DatagramSocket類：進(jìn)行端到端通信的類

服務(wù)器端實(shí)現(xiàn)步驟

創(chuàng)建DatagramSocket，指定端口號(hào)

創(chuàng)建DatagramPacket

接受客戶端發(fā)送的數(shù)據(jù)信息

讀取數(shù)據(jù)

//服務(wù)器端，實(shí)現(xiàn)基于UDP的用戶登錄
//1、創(chuàng)建服務(wù)器端DatagramSocket，指定端口
DatagramSocket socket =new datagramSocket(10010);
//2、創(chuàng)建數(shù)據(jù)報(bào)，用于接受客戶端發(fā)送的數(shù)據(jù)
byte[] data =newbyte[1024];//
DatagramPacket packet =newDatagramPacket(data,data.length);
//3、接受客戶端發(fā)送的數(shù)據(jù)
socket.receive(packet);//此方法在接受數(shù)據(jù)報(bào)之前會(huì)一致阻塞
//4、讀取數(shù)據(jù)
String info =newString(data,o,data.length);
System.out.println("我是服務(wù)器，客戶端告訴我"+info);


//=========================================================
//向客戶端響應(yīng)數(shù)據(jù)
//1、定義客戶端的地址、端口號(hào)、數(shù)據(jù)
InetAddress address = packet.getAddress();
int port = packet.getPort();
byte[] data2 = "歡迎您！".geyBytes();
//2、創(chuàng)建數(shù)據(jù)報(bào)，包含響應(yīng)的數(shù)據(jù)信息
DatagramPacket packet2 = new DatagramPacket(data2,data2.length,address,port);
//3、響應(yīng)客戶端
socket.send(packet2);
//4、關(guān)閉資源
socket.close();

客戶端實(shí)現(xiàn)步驟

定義發(fā)送信息

創(chuàng)建DatagramPacket，包含將要發(fā)送的信息

創(chuàng)建DatagramSocket

發(fā)送數(shù)據(jù)

//客戶端
//1、定義服務(wù)器的地址、端口號(hào)、數(shù)據(jù)
InetAddress address =InetAddress.getByName("localhost");
int port =10010;
byte[] data ="用戶名：admin;密碼：123".getBytes();
//2、創(chuàng)建數(shù)據(jù)報(bào)，包含發(fā)送的數(shù)據(jù)信息
DatagramPacket packet = newDatagramPacket(data,data,length,address,port);
//3、創(chuàng)建DatagramSocket對(duì)象
DatagramSocket socket =newDatagramSocket();
//4、向服務(wù)器發(fā)送數(shù)據(jù)
socket.send(packet);


//接受服務(wù)器端響應(yīng)數(shù)據(jù)
//======================================
//1、創(chuàng)建數(shù)據(jù)報(bào)，用于接受服務(wù)器端響應(yīng)數(shù)據(jù)
byte[] data2 = new byte[1024];
DatagramPacket packet2 = new DatagramPacket(data2,data2.length);
//2、接受服務(wù)器響應(yīng)的數(shù)據(jù)
socket.receive(packet2);
String raply = new String(data2,0,packet2.getLenth());
System.out.println("我是客戶端，服務(wù)器說："+reply);
//4、關(guān)閉資源
socket.close();