java基于UDP的socket通信

一.socket通信有2种，一种是基于tcp的可靠连接，一种是基于UDP的无连接包投递服务连接，UDP通信中常用到的类有：DatagramSocket类和DatagramPacket类。

二.DatagramSocket类
表示用来发送和接收数据报包的套接字。

数据报套接字是包投递服务的发送或接收点。每个在数据报套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。

在DatagramSocket上总是启用UDP广播发送。为了接收广播包，应该将DatagramSocket绑定到通配符地址。在某些实现中，将DatagramSocket绑定到一个更加具体的地址时广播包也可以被接收。

主要构造方法：

DatagramSocket


()

构造数据报套接字并将其绑定到本地主机上任何可用的端口。

DatagramSocket


(intport)

创建数据报套接字并将其绑定到本地主机上的指定端口。

主要方法有

void	receive ( DatagramPacket p) 从此套接字接收数据报包。
void	send ( DatagramPacket p) 从此套接字发送数据报包。

void	close () 关闭此数据报套接字。

三.DatagramPacket类提供数据包的服务。


数据报包用来实现无连接包投递服务。每条报文仅根据该包中包含的信息从一台机器路由到另一台机器。从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。不对包投递做出保证。

主要构造方法：

DatagramPacket

(byte[]buf,intlength)

构造

DatagramPacket

，用来接收
长度为

length

的数据包。

DatagramPacket

(byte[]buf,intlength,
InetAddress

address,intport)

构造数据报包，用来将长度为

length

的包发送到指定主机上的指定端口号。

主要方法：

int	getPort () 返回某台远程主机的端口号，此数据报将要发往该主机或者是从该主机接收到的。

int	getLength () 返回将要发送或接收到的数据的长度。

InetAddress

getAddress () 返回某台机器的IP地址，此数据报将要发往该机器或者是从该机器接收到的。

四.实验代码：

MyReceive.java

-----------------------------------------

packageudp;

importjava.net.*;

publicclassMyReceive{

/**

*@paramargs

*/

publicstaticvoidmain(String[]args){

//TODOAuto-generatedmethodstub

MyReceive.receive();

}

publicstaticvoidreceive()

{

try{

DatagramSocketds=newDatagramSocket(9528);//在端口9528接收数据报包的套接字

byte[]buf=newbyte[100];

DatagramPacketdp=newDatagramPacket(buf,100);//创建长度为100的数据接收包

ds.receive(dp);//套接字接受数据包

System.out.println(newString(buf,0,dp.getLength()));

//这里接收完成，我们给发送者一条消息，告诉他发送成功了

Stringstr="messagesendsuccess!";

DatagramPacketsenddp=newDatagramPacket(str.getBytes(),str.length(),

dp.getAddress(),dp.getPort());

//创建发送包

ds.send(senddp);//执行发送

ds.close();//关闭UDP套接字

}catch(Exceptione)

{e.printStackTrace();}

}

}

MySend.java

---------------------------------------------------------------

packageudp;

importjava.io.BufferedInputStream;

importjava.io.DataInputStream;

importjava.net.*;

publicclassMySend{

publicstaticvoidmain(String[]args){

Stringstr="";

try{

while(str.length()<1){

System.out.println("请输入您的名字");

str=newDataInputStream(newBufferedInputStream(System.in))

.readLine();

}

}catch(Exceptione){

e.printStackTrace();

}

MySend.send(str);

}

publicstaticvoidsend(Stringstr)

{

try{

DatagramSocketds=newDatagramSocket();

DatagramPacketdp=newDatagramPacket(str.getBytes(),str.length(),

InetAddress.getByName("127.0.0.1"),

9528);

ds.send(dp);

byte[]buf=newbyte[100];

DatagramPacketrecedp=newDatagramPacket(buf,100);

ds.receive(recedp);

System.out.println(newString(buf,0,recedp.getLength()));

ds.close();

}catch(Exceptione)

{e.printStackTrace();}

}

}