32、UDP传输

一、UDP传输

 

1. DatagramSocket与DatagramPacket
2. 建立发送端，接收端
3. 建立数据包
4. 调用Socket的发送接收方法
5. 关闭Socket
6. 发送端与接收端是两个独立的运行程序

二、DatagramSocket

 

1. 此类表示用来发送和接收 数据报 包的套接字
2. 数据报套接字是包投递服务的发送或接收点。
3. 每个在数据报套接字上发送或接收的包都是单独编址和路由的。
4. 从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。 
5. 在 DatagramSocket 上总是启用 UDP 广播发送。
6. 为了接收广播包，应该将 DatagramSocket 绑定到通配符地址。
7. 在某些实现中，将 DatagramSocket 绑定到一个更加具体的地址时广播包也可以被接收。

public class DatagramSocket
{
	//构造方法*****************************

	//构造数据报套接字并将其绑定到本地主机上任何可用的端口。套接字将被绑定到通配符地址，IP 地址由内核来选择。
	public DatagramSocket()
               throws SocketException{}

	//创建数据报套接字并将其绑定到本地主机上的指定端口。套接字将被绑定到通配符地址，IP 地址由内核来选择。
	public DatagramSocket(int port)
               throws SocketException{}

	//创建数据报套接字，将其绑定到指定的本地地址。本地端口必须在 0 到 65535 之间（包括两者）。
	//如果 IP 地址为 0.0.0.0，套接字将被绑定到通配符地址，IP 地址由内核选择。
	public DatagramSocket(int port,
                      InetAddress laddr)
               throws SocketException{}

	//创建数据报套接字，将其绑定到指定的本地套接字地址。
	public DatagramSocket(SocketAddress bindaddr)
               throws SocketException{}


	//常用方法*******************************

	//关闭此数据报套接字
	public void close(){}

	/**
	 *从此套接字接收数据报包。
	 *当此方法返回时，DatagramPacket 的缓冲区填充了接收的数据。
	 *数据报包也包含发送方的 IP 地址和发送方机器上的端口号。 
	 *此方法在接收到数据报前一直阻塞。
	 *数据报包对象的 length 字段包含所接收信息的长度。如果信息比包的长度长，该信息将被截短。
	 */
	public void receive(DatagramPacket p)
             throws IOException{}

	//从此套接字发送数据报包。DatagramPacket 包含的信息指示：将要发送的数据、其长度、远程主机的 IP 地址和远程主机的端口号。
	public void send(DatagramPacket p)
          throws IOException{}
}

 

三、DatagramPacket

 

1. 此类表示数据报包。 
2. 数据报包用来实现无连接包投递服务。
3. 每条报文仅根据该包中包含的信息从一台机器路由到另一台机器。
4. 从一台机器发送到另一台机器的多个包可能选择不同的路由，也可能按不同的顺序到达。不对包投递做出保证。

public final class DatagramPacket
{
	//构造方法*******************************

	//构造 DatagramPacket，用来接收长度为 length 的数据包。 length 参数必须小于等于 buf.length。
	public DatagramPacket(byte[] buf,
                      int length){}

	//构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。length 参数必须小于等于 buf.length
	public DatagramPacket(byte[] buf,
                      int length,
                      InetAddress address,
                      int port){}

	//构造 DatagramPacket，用来接收长度为 length 的包，在缓冲区中指定了偏移量
	public DatagramPacket(byte[] buf,
                      int offset,
                      int length){}

	//构造数据报包，用来将长度为 length 偏移量为 offset 的包发送到指定主机上的指定端口号。
	public DatagramPacket(byte[] buf,
                      int offset,
                      int length,
                      InetAddress address,
                      int port){}

	public DatagramPacket(byte[] buf,
                      int offset,
                      int length,
                      SocketAddress address)
               throws SocketException{}

	public DatagramPacket(byte[] buf,
                      int length,
                      SocketAddress address)
               throws SocketException{}

	//常用方法**********************************

	//返回某台机器的 IP 地址，此数据报将要发往该机器或者是从该机器接收到的
	public InetAddress getAddress(){}

	//返回数据缓冲区。接收到的或将要发送的数据从缓冲区中的偏移量 offset 处开始，持续 length 长度
	public byte[] getData(){}

	//返回将要发送或接收到的数据的长度
	public int getLength(){}

	//返回将要发送或接收到的数据的偏移量
	public int getOffset(){}

	//返回某台远程主机的端口号，此数据报将要发往该主机或者是从该主机接收到的
	public int getPort(){}

	//获取要将此包发送到的或发出此数据报的远程主机的 SocketAddress（通常为 IP 地址 + 端口号）。 
	public SocketAddress getSocketAddress(){}
}

 

四、示例

 

import java.net.*;
import java.io.*;

/**
 * 需求：编写一个聊天程序
 * 分析：
 * １，需要一个发送端和一个接收端
 * ２，两部分需要同时执行，要用到多线程技术
 * ３，一个线程用于发送，一个线程用于接收
 */
public class UDPTest
{
	public static void main(String[] args) throws Exception{
		DatagramSocket ds = new DatagramSocket();
		DatagramSocket ds1 = new DatagramSocket(10000);
		new Thread(new Send(ds)).start();
		new Thread(new Receive(ds1)).start();
	}
}
//发送
class Send implements Runnable
{
	DatagramSocket ds;
	Send(DatagramSocket ds)
	{
		this.ds = ds;
	}
	public void run()
	{
		try
		{
			BufferedReader br = 
				new BufferedReader(new InputStreamReader(System.in));
			String msg = null;
			DatagramPacket dp;
			while((msg=br.readLine())!=null)
			{
				byte[] buf = msg.getBytes();
				dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("localhost"),10000);
				ds.send(dp);
			}
		}
		catch (Exception e)
		{
			throw new RuntimeException("运行错误");
		}
	}
}
//接收
class Receive implements Runnable
{
	DatagramSocket ds;
	Receive(DatagramSocket ds)
	{
		this.ds = ds;
	}
	public void run()
	{
		try
		{
			byte[] buf = new byte[1024];
			String msg = null;
			DatagramPacket dp = new DatagramPacket(buf,buf.length);
			while(true)
			{
				ds.receive(dp);
				String ip = dp.getAddress().getHostAddress();
				msg = new String(buf,0,dp.getLength());
				System.out.pritnln(ip);
				System.out.println(msg);
			}		
		}
		catch (Exception e)
		{
			throw new RuntimeException("运行错误");
		}
	}
}