数据报（datagram）使网络层数据单元在介质上传输信息的一种逻辑分组格式，它是一种在网络中传播的、独立的、自身包含地址信息的消息，它能否到达目的地，到达的时间，到达时内容是否会变化不能准确知道的。它的通讯双方是不需要建立连接的，对于一些不需要很高质量的应用程序来说，数据报通讯是一个非常好的选择。在java的java.net包中有两个类datagramsocket和datagrampacket，为应用程序中采用数据报通讯方式进行网络通讯。

　　下面，我想详细解释在java中实现客户端与服务器之间数据报通讯的方法，请看：

　　一、客户端应用程序的工作流程

　　1） 首先要建立数据报通讯的socket，我们可以通过创建一个datagramsocket对象来实现它，在java中datagramsocket类有如下两种构造方法：

　　a)public datagramsocket() 构造一个数据报socket，并使其与本地主机任一可用的端口连接。若打不开socket则抛出socketexception异常。

　　b) public datagramsocket(int port) 构造一个数据报socket，并使其与本地主机指定的端口连接。若打不开socket或socket无法与指定的端口连接则抛出socketexception异常。

　　2） 创建一个数据报文包，用来实现无连接的包传送服务。每个数据报文包是用datagrampacket类来创建，datagrampacket对象封装了数据报包数据，包长度，目标地址，目标端口。作为客户端要发送数据报文包，要调用datagrampacket类以如下形式的构造函数创建datagrampacket对象，将要发送的数据和包文目的地址信息放入对象之中。

　　datagrampacket（byte bufferedarray[],int length,inetaddress address,int port）即构造一个包长度为length的包传送到指定主机指定端口号上的数据报文包，参数length必须小于等于bufferedarry.length

　　datagrampacket类提供了四个类来获取信息

　　a) public byte[] getdata() 返回一个字节数组，包含收到或要发送的数据报中的数据

　　b) public int getlength() 返回发送或接收到的数据的长度

　　c) public inetaddress getaddress() 返回一个发送或接收此数据报包文的机器的ip地址

　　d) public int getport() 返回发送或接收数据报的远程主机的端口号。

　　3）创建完datagramsocket和datagrampacket对象，就可以发送数据报文包了。发送是通过调用datagramsocket对象的send方法实现，它需要以datagrampacket对象为参数，将刚才封装进datagrampacket对象中的数据组成数据报发出。

　　4）当然，我们也可以接收数据报文包，为了接收从服务器返回的结果数据报文包，我们需要创建一个新的datagrampacket对象，这就需要用到datagrampacket的另一种构造方式datagrampacket（byte bufferedarray[],int length），即只需指明存放接收的数据报的缓冲区和长度。调用datagramsocket对象的receive()方法来完成接收数据报的工作，此时需要将上面创建的datagrampacket对象作为参数，该方法会一直阻塞知道收到一个数据报文包，此时datagrampacket的缓冲区中包含的就是接收到的数据，数据报文包中也包含发送者的ip地址，发送者机器上的端口号等信息。

　　5）处理接收缓冲区内的数据，获取服务结果。

　　6）当通讯完成后，可以使用datagramsocket对象的close()方法来关闭数据报通讯socket。当然，java自己会自动关闭socket，释放datagramsocket和datagrampacket所占用的资源。但是作为一种良好的编程习惯，还是要显示的予以关闭。 　　
　　下面我给出一个简单的利用数据报通讯的客户端程序，它能够完成与服务器简单的通讯。为了直观，我把它写成了applet程序，由于本文不是介绍applet，所以我只写了简要的注释，对applet感兴趣的朋友亲参阅有关书籍。

　　import java.applet.*;
　　import java.awt.*;
　　import java.net.*;
　　import java.io.*;

　　public final class javacommunicationclient extends applet
　　{
　　　private label label1,label2 ;
　　　private panel panel1,panel2;
　　　private textfield textfield;
　　　private textarea textarea;
　　　private datagramsocket sendsocket,receivesocket;//声明发送数据报socket和接收数据报socket
　　　private datagrampacket sendpacket,receivepacket;//声明发送数据报文包和接收数据报文包

　　public void init()
　　　{
　　　　setbackground(color.gray);
　　　　setlayout(new borderlayout());//设置一个布局管理器
　　　　panel1=new panel();
　　　　panel1.setlayout(new borderlayout());//在容器中放置布局管理器
　　　　label1=new label("通话纪录");
　　　　textarea=new textarea(10,20);//文本显示区域
　　　　textarea.settext("欢迎您！");
　　　　panel1.add("north",label1);//将标签添加到布局管理器中
　　　　panel1.add("center",textarea);
　　　　add("north",panel1);
　　　　label2=new label("发言：");//创建另一个容器
　　　　panel2.add("center",label2);
　　　　textfield=new textfield(20);
　　　　textfield.settext("");
　　　　panel2.add("south",textfield);
　　　　add("center",panel2);
　　　　show();
　　　}

　　public void start()
　　　{
　　　　waitforpackets();
　　　}

　　public void waitforpackets()

　　/*方法waitforpacket用来监听来自于服务器的数据报，当获得数据报后，在文本显示区域显示出来

　　*/
　　{
　　　try
　　　{
　　　　sendsocket=new datagramsocket();//实例化一个发送数据报socket对象
　　　　receivesocket= new datagramsocket(5001);//实例化一个接收数据报socket对象，以5001为端口

　　　　} catch (socketexception e)//捕获异常
　　　{
　　　　textarea.appendtext("不能打开数据报socket，或数据报socket无法与指定端口连接!");
　　　}
　　　while (true)
　　　　{
　　　　　try
　　　　　{
　　　　　　byte buf[]=new byte[100];
　　　　　　receivepacket=new datagrampacket(buf,buf.length);//实例化一个接收数据报文包对象

　　　　　　receivesocket.receive(receivepacket);//以receivepacket为参数，接受文包
　　　　　　textarea.appendtext("/n服务器：/t");
　　　　　　byte[] data=receivepacket.getdata();
　　　　　　string receivedstring=new string(data);
　　　　　　textarea.appendtext(receivedstring);//将接收到的数据报文报中的数据显示出来
　　　　　} catch(ioexception e)
　　　　{
　　　　　textarea.appendtext("网络通讯出现错误，问题在"+e.tostring());
　　　　}
　　　}
　　}

　　public boolean action(event e,object o)
　　　{
　　　　try
　　　　　{textarea.appendtext("/n客户端：");
　　　　　string string=o.tostring();
　　　　　textarea.appendtext(string);
　　　　　byte[] databyte=new byte[100];
　　　　　string.getbytes(0,string.length(),databyte,0);
　　　　　sendpacket=new datagrampacket(databyte,string.length(),inetaddress.getbyname("202.38.64.4"),5000);//发送数据报，其中你可以用你自己的主机ip替换器中的ip地址
　　　　　sendsocket.send(sendpacket);
　　　　}catch(ioexception ioe)
　　　　{
　　　　　textarea.appendtext("网络通讯出现错误，问题在"+ioe.tostring());
　　　　}
　　　return true;
　　}

　　} 　　
　　二、服务器端应用程序的工作流程

　　不同于基于数据流通讯方式，在数据报通讯中，通讯双方之间并不要建立连接，所以，服务器应用程序通讯过程与客户端应用程序的通讯过程使非常相似的，也要建立数据报通讯datagramsocket，构建数据报文包datagrampacket，接收数据报和发送数据报，处理接收缓冲区内的数据，通讯完毕后，关闭数据报通讯socket。不同的是，服务器应用程序要面向网络中的所有计算机，所以服务器应用程序收到一个包文后要分析它，得到数据报的源地址信息，这样才能创建正确的返回结果报文给客户机。

　　下面我给出了一个数据报通讯的服务器段程序，由于服务器端的相应应用程序和客户端程序比较相似，所以我不想详细的注释，仅列出程序供大家参考：

　　1、javacommunicationserver.java

　　import java.net.*;
　　import java.io.*;
　　import java.awt.*;
　　import java.applet.applet;

　　public final class javacommunicationserver extends frame
　　　{
　　　　private label label1,label2 ;
　　　　private panel panel1,panel2;
　　　　private textfield textfield;
　　　　private string name,name1;
　　　　private textarea textarea;
　　　　private datagramsocket sendsocket,receivesocket;
　　　　private datagrampacket sendpacket,receivepacket;

　　public javachatserver()
　　　{
　　　　super("通讯控制台:");//使用超类构造方法，构造一个frame
　　　　panel1=new panel();
　　　　panel1.setlayout(new borderlayout());
　　　　label1=new label("通话纪录");
　　　　textarea=new textarea(10,20);
　　　　textarea.settext("欢迎您！");

　　　　panel1.add("north",label1);
　　　　panel1.add("center",textarea);
　　　　add("north",panel1);
　　　　panel2=new panel();
　　　　panel2.setlayout(new borderlayout());
　　　　label2=new label("发言：");
　　　　panel2.add("center",label2);
　　　　textfield=new textfield(20);
　　　　panel2.add("south",textfield);
　　　　add("center",panel2);
　　　　show();

　　　try
　　　{
　　　　sendsocket=new datagramsocket();
　　　　receivesocket= new datagramsocket(5000);
　　　}
　　　catch (socketexception e)
　　　　{
　　　　　e.printstacktrace();
　　　　　system.exit(1);
　　　　}
　　　}

　　public void waitforpacket()
　　　{
　　　　while (true)
　　　{
　　　try
　　　　{
　　　　　byte buf[]=new byte[100];
　　　　　receivepacket=new datagrampacket(buf,buf.length);
　　　　　receivesocket.receive(receivepacket);
　　　　　name=receivepacket.getaddress().tostring()；
　　　　　if(name1!=name)
　　　　　　{
　　　　　　　textarea.appendtext("/n来自主机："+name+"/n端口："+receivepacket.getport());
　　　　　　}
　　　　　textarea.appendtext("/n客户：/t");
　　　　　byte[] data=receivepacket.getdata();
　　　　　string receivedstring=new string(data,0);
　　　　　textarea.appendtext(receivedstring);
　　　　　name1=name;
　　　　}

　　　catch(ioexception e)
　　　　{
　　　　　textarea.appendtext("网络通讯出现错误，问题在"+e.tostring());
　　　　　}
　　　　}
　　　}

　　public boolean handleevent(event e)
　　　　{
　　　　　if(e.id==event.windows_destroy)
　　　　　{
　　　　　　hide();
　　　　　　dispose();
　　　　　　system.exit(0);
　　　　　}
　　　　return super.handleevent(e);
　　　　}

　　public boolean action(event e,object o)
　　　{
　　　　try
　　　　　{textarea.appendtext("/n服务器：");
　　　　　　string string=o.tostring();
　　　　　　textarea.appendtext(string);
　　　　　　byte[] databyte=new byte[100];
　　　　　　string.getbytes(0,string.length(),databyte,0);
　　　　　　sendpacket=new datagrampacket(databyte,string.length(),inetaddress.getbyname(name),5001);
　　　　　　sendsocket.send(sendpacket);
　　　　　}catch(ioexception ioe)
　　　　　{
　　　　　　textarea.appendtext("网络通讯出现错误，问题在"+ioe.tostring());
　　　　　}
　　　　　return true;
　　　　}

　　　}


　　2、communicationserverrun.java,建立javacommunicationserver的实例，然后运行。

　　　import javacommunicationserver
　　　class communicationserverrun extends javacommunicationserver
　　　　{
　　　　　public static void main(string args[])
　　　　　{
　　　　　　javacommunicationserver cs=new javacommunicationserver();
　　　　　　cs.waitforpacket();
　　　　　　}
　　　　}