数据报（Datagram）使网络层数据单元在介质上传输信息的一种逻辑分组格式它是一种在网络中传播的独立的自身包含地址信息的消息它能否到达目的地到达的时间到达时内容是否会变化不能准确知道的它的通讯双方是不需要建立连接的对于一些不需要很高质量的应用程序来说数据报通讯是一个非常好的选择在Java的包中有两个类DatagramSocket和DatagramPacket为应用程序中采用数据报通讯方式进行网络通讯
下面我想详细解释在Java中实现客户端与服务器之间数据报通讯的方法请看
一客户端应用程序的工作流程
） 首先要建立数据报通讯的Socket我们可以通过创建一个DatagramSocket对象来实现它在Java中DatagramSocket类有如下两种构造方法
a)public DatagramSocket() 构造一个数据报socket并使其与本地主机任一可用的端口连接若打不开socket则抛出SocketException异常
b) public DatagramSocket(int port) 构造一个数据报socket并使其与本地主机指定的端口连接若打不开socket或socket无法与指定的端口连接则抛出SocketException异常
） 创建一个数据报文包用来实现无连接的包传送服务每个数据报文包是用DatagramPacket类来创建DatagramPacket对象封装了数据报包数据包长度目标地址目标端口作为客户端要发送数据报文包要调用DatagramPacket类以如下形式的构造函数创建DatagramPacket对象将要发送的数据和包文目的地址信息放入对象之中
DatagramPacket（byte bufferedarray[]int lengthInetAddress addressint port）即构造一个包长度为length的包传送到指定主机指定端口号上的数据报文包参数length必须小于等于bufferedarrylength
DatagramPacket类提供了四个类来获取信息
a) public byte[] getData() 返回一个字节数组包含收到或要发送的数据报中的数据
b) public int getLength() 返回发送或接收到的数据的长度
c) public InetAddress getAddress() 返回一个发送或接收此数据报包文的机器的IP地址
d) public int getPort() 返回发送或接收数据报的远程主机的端口号
）创建完DatagramSocket和DatagramPacket对象就可以发送数据报文包了发送是通过调用DatagramSocket对象的send方法实现它需要以DatagramPacket对象为参数将刚才封装进DatagramPacket对象中的数据组成数据报发出
）当然我们也可以接收数据报文包为了接收从服务器返回的结果数据报文包我们需要创建一个新的DatagramPacket对象这就需要用到DatagramPacket的另一种构造方式DatagramPacket（byte bufferedarray[]int length）即只需指明存放接收的数据报的缓沖区和长度调用DatagramSocket对象的receive()方法来完成接收数据报的工作此时需要将上面创建的DatagramPacket对象作为参数该方法会一直阻塞知道收到一个数据报文包此时DatagramPacket的缓沖区中包含的就是接收到的数据数据报文包中也包含发送者的IP地址发送者机器上的端口号等信息
）处理接收缓沖区内的数据获取服务结果
）当通讯完成后可以使用DatagramSocket对象的close()方法来关闭数据报通讯Socket当然Java自己会自动关闭Socket释放DatagramSocket和DatagramPacket所占用的资源但是作为一种良好的编程习惯还是要显示的予以关闭
下面我给出一个简单的利用数据报通讯的客户端程序它能够完成与服务器简单的通讯为了直观我把它写成了Applet程序由于本文不是介绍Applet所以我只写了简要的注释对Applet感兴趣的朋友亲参阅有关书籍
import javaapplet*;
import javaawt*;
import *;
import javaio*;
public final class javaCommunicationClient extends Applet
{
private Label labellabel ;
private Panel panelpanel;
private TextField textfield;
private TextArea textarea;
private DatagramSocket sendSocketreceiveSocket;//声明发送数据报Socket和接收数据报Socket
private DatagramPacket sendPacketreceivePacket;//声明发送数据报文包和接收数据报文包
public void init()
{
setBackground(Colorgray);
setLayout(new BorderLayout());//设置一个布局管理器
panel=new Panel();
panelsetLayout(new BorderLayout());//在容器中放置布局管理器
label=new Label(通话纪录);
textarea=new TextArea();//文本显示区域
textareasetText(欢迎您！);
paneladd(Northlabel);//将标签添加到布局管理器中
paneladd(Centertextarea);
add(Northpanel);
label=new Label(发言);//创建另一个容器
paneladd(Centerlabel);
textfield=new TextField();
textfieldsetText();
paneladd(Southtextfield);
add(Centerpanel);
show();
}
public void start()
{
waitForPackets();
}
public void waitForPackets()
/*方法waitForPacket用来监听来自于服务器的数据报当获得数据报后在文本显示区域显示出来
*/
{
try
{
sendSocket=new DatagramSocket();//实例化一个发送数据报Socket对象
receiveSocket= new DatagramSocket();//实例化一个接收数据报Socket对象以为端口
} catch (SocketException e)//捕获异常
{
textareaappendText(不能打开数据报Socket或数据报Socket无法与指定端口连接!);
}
while (true)
{
try
{
byte buf[]=new byte[];
receivePacket=new DatagramPacket(bufbuflength);//实例化一个接收数据报文包对象
receiveSocketreceive(receivePacket);//以receivePacket为参数接受文包
textareaappendText(\n服务器\t);
byte[] data=receivePacketgetData();
String receivedString=new String(data);
textareaappendText(receivedString);//将接收到的数据报文报中的数据显示出来
} catch(IOException e)
{
textareaappendText(网络通讯出现错误问题在+etoString());
}
}
}
public boolean action(Event eObject o)
{
try
{textareaappendText(\n客户端);
String string=otoString();
textareaappendText(string);
byte[] databyte=new byte[];
stringgetBytes(stringlength()databyte);
sendPacket=new DatagramPacket(databytestringlength()InetAddressgetByName());//发送数据报其中你可以用你自己的主机IP替换器中的IP地址
sendSocketsend(sendPacket);
}catch(IOException ioe)
{
textareaappendText(网络通讯出现错误问题在+ioetoString());
}
return true;
}
}
二服务器端应用程序的工作流程
不同于基于数据流通讯方式在数据报通讯中通讯双方之间并不要建立连接所以服务器应用程序通讯过程与客户端应用程序的通讯过程使非常相似的也要建立数据报通讯DatagramSocket构建数据报文包DatagramPacket接收数据报和发送数据报处理接收缓沖区内的数据通讯完毕后关闭数据报通讯Socket不同的是服务器应用程序要面向网络中的所有计算机所以服务器应用程序收到一个包文后要分析它得到数据报的源地址信息这样才能创建正确的返回结果报文给客户机
下面我给出了一个数据报通讯的服务器段程序由于服务器端的相应应用程序和客户端程序比较相似所以我不想详细的注释仅列出程序供大家参考
javaCommunicationServerjava
import *;
import javaio*;
import javaawt*;
import javaappletApplet;
public final class javaCommunicationServer extends Frame
{
private Label labellabel ;
private Panel panelpanel;
private TextField textfield;
private String namename;
private TextArea textarea;
private DatagramSocket sendSocketreceiveSocket;
private DatagramPacket sendPacketreceivePacket;
