UDP通信（二）下

    @Test
    public void send4Test() throws Exception{
        //1. 定义客户端
        System.out.println("------------发送方开始发送图片文件数据--------------");
        DatagramSocket datagramSocket=new DatagramSocket(6666);
        //2. 准备数据
        //3. 将数据转换成字节数据
        String path="E:"+ File.separator+"ideaWork"+File.separator+"Java2"+File.separator+"fileSrc"
                +File.separator+"129.png";
        byte[] bytes= IOUtils.fileToByteArray(path);
        //   System.out.println("发送数据为:"+new String(bytes));
        //4. 封装进包
        InetSocketAddress inetSocketAddress=new InetSocketAddress("localhost",9999);
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length,inetSocketAddress);
        datagramSocket.send(datagramPacket);
        //关闭流
        datagramSocket.close();
    }

@Test
    public void send4Test() throws Exception{
        //1. 定义服务器
        System.out.println("---------------服务器启动成功,接收图片文件数据----------------");
        DatagramSocket datagramSocket=new DatagramSocket(9999);
        //2. 设置数据
        byte[] bytes=new byte[1024*20];
        //能接收的大小，并不是实际接收的大小
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length);
        //3. 阻塞式接收传递过来的数据
        datagramSocket.receive(datagramPacket);
        //4. 获取接收的数据
        byte[] content=datagramPacket.getData();
        int len=datagramPacket.getLength();
       String path="E:"+ File.separator+"ideaWork"+File.separator+"Java2"+File.separator+"fileSrc"
               +File.separator+"129Udp.png";
        IOUtils.byteArrayToFile(content,path);
        //5 关闭流
        datagramSocket.close();
    }

 public static void main(String[] args) {
        try {
           send5Test();
            //send6Test();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static void send5Test() throws Exception{
        //1. 定义客户端
        System.out.println("------------发送方开始发送控制台打印数据--------------");
        DatagramSocket datagramSocket=new DatagramSocket(6666);
        //2. 准备数据
        BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(System.in));
        String content=bufferedReader.readLine();
        byte[] bytes=content.getBytes("UTF-8");
        //   System.out.println("发送数据为:"+new String(bytes));
        //4. 封装进包
        InetSocketAddress inetSocketAddress=new InetSocketAddress("localhost",9999);
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length,inetSocketAddress);
        datagramSocket.send(datagramPacket);
        //关闭流
        datagramSocket.close();
    }

@Test
    public void send5Test() throws Exception{
        //1. 定义服务器
        System.out.println("---------------服务器启动成功,接收控制台数据----------------");
        DatagramSocket datagramSocket=new DatagramSocket(9999);
        //2. 设置数据
        byte[] bytes=new byte[1024];
        //能接收的大小，并不是实际接收的大小
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length);
        //3. 阻塞式接收传递过来的数据
        datagramSocket.receive(datagramPacket);
        //4. 获取接收的数据
        byte[] content=datagramPacket.getData();
        int len=datagramPacket.getLength();
        System.out.println("接收的内容是:"+new String(content,0,len));
        datagramSocket.close();
    }

public static void send6Test() throws Exception{
        //1. 定义客户端
        System.out.println("------------发送方开始发送控制台多条数据--------------");
        DatagramSocket datagramSocket=new DatagramSocket(6666);
        //2. 准备数据
        BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(System.in));
        while(true){
            String content=bufferedReader.readLine();
            byte[] bytes=content.getBytes("UTF-8");
            //   System.out.println("发送数据为:"+new String(bytes));
            //4. 封装进包
            InetSocketAddress inetSocketAddress=new InetSocketAddress("localhost",9999);
            DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length,inetSocketAddress);
            datagramSocket.send(datagramPacket);
            if("bye".equalsIgnoreCase(content)||"quit".equalsIgnoreCase(content)){
                System.out.println("退出程序");
                break;
            }
        }
        //关闭流
        datagramSocket.close();
    }

 @Test
    public void send6Test() throws Exception{
        //1. 定义服务器
        System.out.println("---------------服务器启动成功,接收控制台多条数据----------------");
        DatagramSocket datagramSocket=new DatagramSocket(9999);
        //2. 设置数据
        byte[] bytes=new byte[1024];
        while(true){
            //能接收的大小，并不是实际接收的大小
            DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length);
            //3. 阻塞式接收传递过来的数据
            datagramSocket.receive(datagramPacket);
            //4. 获取接收的数据
            byte[] content=datagramPacket.getData();
            int len=datagramPacket.getLength();
            String temp=new String(content,0,len);
            if("bye".equalsIgnoreCase(temp)||"quit".equalsIgnoreCase(temp)){
                break;
            }
            System.out.println("echo:"+temp);
        }
        datagramSocket.close();
    }