`
wakin2003
  • 浏览: 67440 次
  • 性别: Icon_minigender_1
  • 来自: 长春
社区版块
存档分类
最新评论

UDP基础

阅读更多
无连接的操作使用UDP协议:
一个数据报文是一个独立的单元,其包含了所有的这次投递的信息,目的地址和要发送的内容,快速高效,但是可靠性不佳。
UDP协议下的Socket是一种无连接的Socket。
UDP通讯API
DatagramSocket类:
用于创建接受和发送UDP的Socket实例。
构造器:
DatagramSocket(),特殊用法,常用于客户端编程,没有特定监听的端口。
DatagramSocket(int port),创建实例,并固定监听port端口的报文
DatagramSocket(int port,InerAddress localAddr),当一台机器拥有多个ip地址时,创建只接受来自localAddr的报文。
4个主要方法
void receive(DatagramPacket d):接受数据报文到d中。产生阻塞。
void send(DatagramPacket d):发送报文d到目的地。
void setSoTimeout(int timeout):设置超时时间,单位为毫秒。
void close():关闭DatagramSocket。

DatagramPacket类:
用于处理报文,将字节数组,目标地址,目标端口等数据包装成报文或者将报文拆卸成字节数组。大多数平台能够支持8192字节大小的报文。
构造器:
发送方:
DatagramPacket(byte[] buf,int length,InetAddress addr,int port)
DatagramPacket(byte[] buf,int offset,int length,InetAddress addr,int port)
接收方:
DatagramPacket(byte[] buf,int length)
DatagramPacket(byte[] buf,int offset,int length)

简单的UDP通讯程序如下:
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;


public class UDPSend {
	/**
	 * UDP数据发送方,args[0]为目的host.args[1]为端口号,args[2]为数据
	 * @param args
	 */
	public static void main(String [] args){
		try {
			if(args.length<3)
				throw new IllegalArgumentException("Wrong number of args");
			String host = args[0];
			int port = Integer.parseInt(args[1]);
			String msg = args[2];
			byte [] message;
			message = msg.getBytes();
			InetAddress addr = InetAddress.getByName(host);//获得host的地址
			DatagramSocket dgs = new DatagramSocket();
			DatagramPacket dgp = new DatagramPacket(message,message.length,addr,port);
			dgs.send(dgp); //发送数据包
			dgs.close();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

}


import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class UDPReceive {
	public static void main(String [] args){
		try {
			if(args.length!=1)
				throw new IllegalArgumentException("Wrong number of args");
			byte [] buffer = new byte [1024<<1];
			DatagramPacket packet = new DatagramPacket(buffer,buffer.length);
			DatagramSocket socket = new DatagramSocket(Integer.parseInt(args[0]));
			for(;;) {
				socket.receive(packet);
				String msg = new String(packet.getData());
				System.out.println(packet.getAddress().getHostName()+" "+msg);
			}
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
}

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics