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 构造函数的时候，发送端需要制定发送主机的主机名 和 端口 。