首页 > 代码库 > UDP数据交互
UDP数据交互
服务器端:
public static void main(String[] args) { // 1、创建一个服务器 套接字 DatagramSocket server = null; try { server = new DatagramSocket(18899); // 2、定一个字节 数组来接收数据 byte[] data = http://www.mamicode.com/new byte[1024]; // 3、定义一个数据包对象 DatagramPacket recePacket = new DatagramPacket(data, data.length); // 4、阻塞式的接收 server.receive(recePacket); System.out.println("*************客户端来消息了***********"); // 5、打印消息 String msg = new String(recePacket.getData(), 0, recePacket.getLength()); // 6、向发过来的那个客户端回复点消息 InetAddress addr = recePacket.getAddress(); // 客户端的IP int port = recePacket.getPort(); // 客户端的端口号 System.out.println(addr.toString()+"-"+port+":客户端发过来的消息是:" + msg); // 7、回复 :收到了 String str = "收到了"; byte[] buf = str.getBytes(); // 8、创建一个发送的报文 DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, addr, port); server.send(sendPacket); } catch (SocketException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { if (server != null) { server.close(); } } }
客户端:
public static void main(String[] args) { //创建一个客户端 DatagramSocket client=null; try { client=new DatagramSocket(); //向服务器发送消息 String str="客户端测试消息!"; byte[] buf=str.getBytes(); //3、定义服务器的IP InetAddress addr=InetAddress.getByName("192.168.16.171"); //4、创建一个数据报对象 DatagramPacket sendPacket=new DatagramPacket(buf, buf.length, addr, 18899); //5、发送消息 client.send(sendPacket); //6、客户端等待服务器发送过来的消息 byte[] data=http://www.mamicode.com/new byte[1024]; DatagramPacket recePacket=new DatagramPacket(data, data.length); //7、客户阻止式的接收消息 client.receive(recePacket); //8、把消息转换成字符串 String msg=new String(recePacket.getData(),0,recePacket.getLength() ); System.out.println("服务器回复的消息是:"+msg); } catch (SocketException e) { e.printStackTrace(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); }finally{ if(client!=null){ client.close(); } } }
UDP数据交互
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。