package com.ray.net;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

/*
 * 键盘录入
 * 
 * 需求：通过UDP传输方式，将一段文字数据发送出去。
 * 定义一个udp发送端。
 * 思路：
 *      1.建立udpsocket服务。
 *      2.提供数据，并将数据封装到数据包中。
 *      3.通过socket服务的发送功能，将数据包发送出去。
 *      4.关闭资源。
 */
public class UDP_Send2 {

    public static void main(String[] args) throws Exception{
        // TODO Auto-generated method stub
        
        DatagramSocket ds=new DatagramSocket();
        
        //键盘录入
        BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));
        
        String line=null;
        
        while((line=bufr.readLine())!=null){
            if("886".equals(line))  break;
            
            byte[] buf=line.getBytes();
            DatagramPacket dp=
                new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.31.190"), 10001); 

            ds.send(dp);
        }
 
        ds.close();
    }

}

package com.ray.net;

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

/*
 * 需求： 定义一个应用程序，用于接收udp协议传输的数据并处理的。
 * 
 * 思路： 
 *       1.定义udpSocket服务。通常会监听一个端口。其实就是给这个就收网络应用程序定义数字标识。
 *       2.定义数据包，用于存储接收的数据。
 *       3.通过socket服务的receive方法，将接收到的数据存入数据包中。
 *       4.通过数据包的方法获取其中的数据。
 *       5.关闭资源
 * 
 */
public class UDP_Receive {

    public static void main(String[] args) throws Exception{
        
        //1.创建udp socket, 建立端点,设置监听端口。
        DatagramSocket ds=new DatagramSocket(10001);
        
        while(true){   //由于ds.receive(dp)方法是阻塞式。
        //2.定义数据包，用于存储数据。
        byte[] buf=new byte[1024];
        DatagramPacket dp=new DatagramPacket(buf,buf.length);
        
        //3.通过服务的receive方法，将接收到的数据存入数据包中。
        //ds.receive(dp)方法是阻塞式方法，线程运行到此处，便停止。没数据就等，有数据接收数据。
        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();
        
        
        
        
        
        
    }
}