（网络编程）Socket编程之UDP

UDP 高效，但不保证数据一定被接收成功

 

/*
通过UDP传输方式，将一段文字发送出去
思路：
1，建立udpsocket服务
2，提供数据，将数据封装到数据包中
3，通过socekt服务的发送功能将数据包发送出去
4，关闭资源
*/
import java.net.*;
import java.io.*;

//定义一个udp发送端
class UdpSendData 
{
	public static void main(String[] args) throws IOException
	{
		//1,创建dup服务，通过DatagramSocekt对象
		DatagramSocket ds = new DatagramSocket(8888);//发送端可以使用默认端口

		//2,确定数据，并封装成数据包
		byte[] data = "udp data send".getBytes();
		DatagramPacket dp = 
			new DatagramPacket(data,data.length,InetAddress.getByName("127.0.0.1"),9999);//必须指定接收端端口
		//3,通过socket服务，将已有的数据包发送出去，通过send发送
		ds.send(dp);
		//4,关闭资源
		ds.close();
	}
}

/*
需求：
定义一个应用程序，用于接收udp协议传输的数据并处理

思路：
1，定义udpsocket服务。
   设置一个监听端口，给接收网络应用程序定义数字标识
   明确哪些数据该此应用程序处理
2，定义一个数据包，存储接收到的字节数据
   (用数据包对象中的功能提取字节数据中的不同数据信息)
3，通过socket服务的receive方法将收到的数据存入已定义好的数据包中
4，通过数据包对象的特有功能，将不同的数据取出，打印到控制台上
5，关闭资源
*/


//定义一个udp接收端
class UdpReceiveData
{
	public static void main(String[] args)throws IOException
	{
		//1,创建udp服务，建立端点
		DatagramSocket ds = new DatagramSocket(9999);
		while(true)
		{
			//2,定义数据包，用于存储数据
			byte[] buf = new byte[1024];
			DatagramPacket dp = 
				new DatagramPacket(buf,buf.length);
			//3,通过服务的receive方法将收到的数据存入数据包中
			ds.receive(dp);//阻塞式方法
			//4,通过数据包的方法获取其中的数据
			String ip = dp.getAddress().getHostAddress();
			String data = new String(dp.getData(),0,dp.getLength());
			int port = dp.getPort();

			System.out.println(ip+data+"发送端端口号:"+port);
		}
		//5,关闭资源
		//ds.close();
	}
}

 

 

/*
UDP传输
发送端通过键盘录入数据，发送数据到接收端

局域网广播地址---应用：群聊

//192.168.1.0 代表一个网络段
//192.168.1.255 代表这个网段的广播地址 
	使用255这个地址，网段内的所有存活的主机都能收到

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


//DUP发送端
class  UdpSendData2
{
	public static void main(String[] args) throws IOException
	{
		DatagramSocket ds = new DatagramSocket();
		BufferedReader bufr = 
						new BufferedReader(new InputStreamReader(System.in));
		String line = null;
		while((line=bufr.readLine())!=null)
		{
			if(line.equals("886"))
				break;
			byte[] buf = line.getBytes();
			DatagramPacket dp = 
				new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),6666);
				//new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),6666);
				//设置为广播地址，向网段内所有主机发广播
			ds.send(dp);
		}
		ds.close();
	}
}

//DUP接收端
class  UdpReceiveData2
{
	public static void main(String[] args) throws IOException
	{
		DatagramSocket ds = new DatagramSocket(6666);
		while(true)
		{
			byte[] buf = new byte[1024];//最大64K，UDP一次最多能发的数据量
			DatagramPacket dp = 
				new DatagramPacket(buf,buf.length);
			ds.receive(dp);
			String ip = dp.getAddress().getHostAddress();
			String message = new String(dp.getData(),0,dp.getLength());
			int port = dp.getPort();
			System.out.println("ip:"+ip+"\tport:"+port);
			System.out.println("message:"+message);
		}
	}
}

 

/*
编写一个聊天程序
有收数据和发数据的部分
这两部分需要同时执行---多线程
一个线程负责发送，一个线程负责接收
在一个DOS窗口中完成聊天
既能发数据，又能接收数据！

多线程
IO
UDP
Socket
*/

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

class Send implements Runnable
{
	private DatagramSocket ds;
	public Send(DatagramSocket ds)
	{
		this.ds = ds;
	}
	public void run()
	{
		try
		{
			BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
			String line = null;
			while((line=bufr.readLine())!=null)
			{
				if(line.equals("886"))
					break;
				byte[] buf = line.getBytes();
				DatagramPacket dp =
					new DatagramPacket(buf,buf.length,InetAddress.getByName("127.0.0.1"),6688);
				ds.send(dp);
			}
		}
		catch (Exception e)
		{
			throw new RuntimeException("发送失败！");
		}
		finally
		{
			ds.close();
		}
	}
}

class Receive implements Runnable
{
	private DatagramSocket ds;
	public Receive(DatagramSocket ds)
	{
		this.ds = ds;
	}
	public void run()
	{
		try
		{
			while(true)
			{
				byte[] buf = new byte[1024];
				DatagramPacket dp = new DatagramPacket(buf,buf.length);
				ds.receive(dp);
				String ip = dp.getAddress().getHostAddress();
				int port = dp.getPort();
				String message = new String(dp.getData(),0,dp.getLength());
				System.out.println("ip:"+ip+"\tport:"+port);
				System.out.println("message:"+message);			
			}
		}
		catch (Exception e)
		{
			throw new RuntimeException("接收失败！");
		}
		finally
		{
			ds.close();
		}
	}
}

class ChatDemo
{
	public static void main(String[] args) throws Exception
	{
		DatagramSocket sendSocket = new DatagramSocket();
		DatagramSocket receiveSocket = new DatagramSocket(6688);

		new Thread(new Send(sendSocket)).start();
		new Thread(new Receive(receiveSocket)).start();

	}
}