java UDP操作实例源码介绍



java UDP操作实例源码介绍，

DatagramSocket 类 
要收发DatagramPacket必须打开一个数据报socket ，当服务器构造DatagramSocket时。

1.1      服务器和客户端的服务器

      两者使用的socket都是一样的，区别仅仅在于 服务器端的端口是已知端口，而客户端的端口是系统分配的。

     TCP端口和UDP端口之间没有关联，所以两者可以共同绑定在同一个端口上，而不会有相互影响。

1.2 DatagramSocket 类的构造函数

      DatagramSocket创建一个在指定端口监听的入站数据报的 socket  ，使用此构造函数可以编写出在指导的端口监听的服务器。

      如果服务器在匿名端口监听，客户端就无法与之联系。

     DatagramSocket 中的receive 方法，是阻塞方法，只有当接收到数据的时候，才会进行下面的代码，否则只会阻塞当前的进程。

 

一个简单的UDP 客户端

 

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

public class UDPDiscardClient extends Thread {

    public final static int DEFAULT_PORT = 3000;

    public UDPDiscardClient() {

       start();

    }

    public void run() {

       String hostname = “localhost”;

       int port = DEFAULT_PORT;

       try {

           InetAddress server = InetAddress.getByName(hostname);

           BufferedReader userInput = new BufferedReader(

                  new InputStreamReader(System.in));

           DatagramSocket theSocket = new DatagramSocket();

           while (true) {

              String theLine =  userInput.readLine();

              if (theLine.equals(“.”))

                  break;

              byte[] data = theLine.getBytes(“UTF-8″);

              DatagramPacket theOutput = new  DatagramPacket(data,

                     data.length, server, port);

              theSocket.send(theOutput);

           }

       } catch (UnknownHostException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       } catch (SocketException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       } catch (IOException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       }

    }

    public static void main(String[] args) {


       new UDPDiscardClient();

    }

}

 1.4 UDP服务器

      每当接收到一个数据报的时候，packet需要设置成最大的可能的值，否则当接收多个数据报以后，packet的值会变成已经接收到的最小的值。

 

 

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.SocketException;

public class UDPDiscardServer extends Thread {

    public final static int DEFAULT_PORT = 3000;

    public final static int MAX_PACKET_SIZE = 65507;

    public UDPDiscardServer() {

       start();

    }

    public void run() {

       serverWork();

    }

    public void serverWork() {

       int port = DEFAULT_PORT;

       byte[] buffer = new byte[MAX_PACKET_SIZE];

       // port = Integer.parseInt(args[0]);

       try {

           DatagramSocket server = new  DatagramSocket(port);

           DatagramPacket packet = new  DatagramPacket(buffer, buffer.length);

           while (true) {

              server.receive(packet);

              String s = new  String(packet.getData(), 0, packet.getLength(),

                     “UTF-8″);

              System.out.println(“我是服务器：” + packet.getAddress()  + “at port “

                     + packet.getPort() + “says” + s);

              /**//* 必须重新设置 */

              packet.setLength(buffer.length);

           }

       } catch (SocketException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       } catch (IOException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       }

    }

    public static void main(String[] args) {

       new UDPDiscardServer();

    }

}

  2  感想

利用UDP协议来收发数据，都是将数据放在DatagramPacket 中，而TCP协议都是放在流中，通过getInputStream 和 getOutputStream 函数来获得流。

在服务器端UDP需要调用含有端口参数的DatagramSocket 构造函数 ， 在客户端设置DatagramSocket时，调用匿名端口构造函数。

然后在构造DatagramPacket 构造函数的时候，发送端需要制定发送主机的 主机名 和 端口 。