现在的位置: 首页 > 综合 > 正文

java UDP 操作

2013年09月08日 ⁄ 综合 ⁄ 共 2770字 ⁄ 字号 评论关闭

 1    DatagramSocket 类
       要收发DatagramPacket必须打开一个数据报socket ,当服务器构造DatagramSocket时。
  
1.1 服务器和客户端的服务器 

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

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

     DatagramSocket 中的receive 方法,是阻塞方法,只有当接收到数据的时候,才会进行下面的代码,否则只会阻塞当前的进程。
    
   1.3 一个简单的UDP 客户端 

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

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的值会变成已经接收到的最小的值。

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

抱歉!评论已关闭.