java UDP 操作

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

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

      两者使用的socket都是一样的，区别仅仅在于服务器端的端口是已知端口，而客户端的端口是系统分配的。
     TCP端口和UDP端口之间没有关联，所以两者可以共同绑定在同一个端口上，而不会有相互影响。

1.2 DatagramSocket 类的构造函数

      DatagramSocket创建一个在指定端口监听的入站数据报的 socket ，使用此构造函数可以编写出在指导的端口监听的服务器。
      如果服务器在匿名端口监听，客户端就无法与之联系。

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

   1.3 一个简单的UDP 客户端

         客户端接收用户在控制台上的输入，然后调用 DatagramSocket 中的send方法，将数据传递出去。

package cn.bupt.udptest;

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 {

public final static int DEFAULT_PORT = 9 ;

/**

* @param args

public static void main(String[] args) {

String hostname = null;

int port = DEFAULT_PORT ;

if(args.length > 0)

{

hostname = args[0] ;

port = Integer.parseInt(args[1]) ;

}

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();

}

1.4 UDP服务器

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

package cn.bupt.udptest;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.SocketException;

public class UDPDiscardServer {

public final static int DEFAULT_PORT = 9 ;

public final static int MAX_PACKET_SIZE = 65507 ;

/**

* @param args

public static void main(String[] args) {

// TODO Auto-generated method stub

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();

}

2 感想

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


       在服务器端UDP需要调用含有端口参数的DatagramSocket 构造函数，在客户端设置DatagramSocket时，调用匿名端口构造函数。
       然后在构造DatagramPacket 构造函数的时候，发送端需要制定发送主机的主机名和端口。

posted on 2010-07-20 21:19 buptduming 阅读(2363) 评论(1) 编辑收藏

Comments

# re: java UDP 操作
o
Posted @ 2016-02-27 14:07
<font size=4>写的不错!</font> 回复更多评论

新用户注册刷新评论列表


只有注册用户登录后才能发表评论。




网站导航: 博客园 IT新闻知识库 C++博客博问管理

导航

常用链接

留言簿

随笔档案

搜索

最新评论

阅读排行榜

评论排行榜