zoukankan      html  css  js  c++  java
  • java udp 简单例子

    java udp 接收数据

    package udp;

    import java.io.IOException;

    import java.net.DatagramPacket;

    import java.net.DatagramSocket;

    import java.net.SocketException;

    public class UDPReceive {

    public static void main(String[] args){   

      Integer port = 2345;   

      byte[] buffer = new byte[2048];   

      try {    

        DatagramSocket datagramSocket = new DatagramSocket(port);    

        DatagramPacket datagramPacket = new DatagramPacket(buffer,    buffer.length);    

        try {     

          for (int i=0;i<3;i++) {     

          System.out.println("begin receive data....");     

          datagramSocket.receive(datagramPacket);     

          System.out.println(datagramPacket.getAddress().getAddress().toString()+"======="+new String(datagramPacket.getData()));     

          datagramPacket.setLength(datagramPacket.getData().toString().length());   

         }    

        } catch (IOException e) {     

          e.printStackTrace();    

        }   

      } catch (SocketException e) {   

         e.printStackTrace();   

      }  

      }

    }

    java udp 发送数据

    package udp;

    import java.io.IOException;

    import java.net.DatagramPacket;

    import java.net.DatagramSocket;

    import java.net.InetAddress;

    import java.net.SocketException;

    import java.net.UnknownHostException;

    public class UDPSend {

    public static void main(String[] args) {  

      String str = "abcdefghigklmn......";  

       try {    

        for (int i =0 ;i<1;i++) {     

          DatagramSocket sendSocket = new DatagramSocket();     

          DatagramPacket dataPack = new DatagramPacket(     

          str.getBytes(),str.length(), InetAddress.getByName("127.0.0.1"), new Integer(2345));    

          try {      

            sendSocket.send(dataPack);      

            sendSocket.close();     

          } catch (IOException e) {     

             e.printStackTrace();     

          }    

        }   

      } catch (SocketException e) {   

         e.printStackTrace();   

      } catch (UnknownHostException e) {    

        e.printStackTrace();   

      }  

      }

    }

  • 相关阅读:
    Spark&Hadoop:scala编写spark任务jar包,运行无法识别main函数,怎么办?
    Linux:krb5
    SqlServer数据库端口默认是1433吗?
    Linux下使用shell实现上传linux下某个目录下所有文件到ftp
    Spark+Hadoop+Hive集群上数据操作记录
    hadoop之 Hadoop2.2.0中HDFS的高可用性实现原理
    虚拟路由冗余协议VRRP
    hadoop 之Hadoop生态系统
    Oracle NoLogging Append 方式减少批量insert的redo_size
    Oracle常用的性能诊断语句
  • 原文地址:https://www.cnblogs.com/bailuobo/p/2823284.html
Copyright © 2011-2022 走看看