使用Java实现数据报通讯过程

发布时间:2024-02-28 17:21:38

使用Java实现数据报通信过程 Wayne

  数据报(Datagram)使网络层数据单元在介质上传输信息的逻辑分组格式,

它是一种在互联网上传播的、独立的、包含地址信息的信息,能否到达目的地,

到达时间,内容是否会发生变化不能准确知道。它的通信双方都不需要建立联系

对于一些不需要高质量的应用程序来说,数据报告和通信是一个很好的选择。

Javajava在Java.在net包中,DatagramSocket和DatagramPacket有两种类型,用于应用程序

网络通信是通过报告通信的方式进行的。

  下面,我想详细解释如何在Java中实现客户端和服务器之间的数据报告和通信。请看

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

  1) 首先,通过创建DatagramSocket对象,我们可以建立数据报告通信的Socket。

在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必须

小于等于bufferedary.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对象。

DatagramPackete(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(\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.getByName5000(202.38.64.4);//发

发送数据报告,您可以在自己的主机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,建立javacomunicationserver的实例,然后运行

   import javaCommunicationServer   class CommunicationServerRun extends javaCommunicationServer    {     public static void main(String args[])     {      javaCommunicationServer cs=new javaCommunicationServer();      cs.waitForPacket();      }    }

 

上一篇 Java动画编程基础第二部分
下一篇 实 现JAVA 的 动 态 类 载 入 机 制

文章素材均来源于网络,如有侵权,请联系管理员删除。

标签: Java教程Java基础Java编程技巧面试题Java面试题