Java基于socket服务实现UDP协议的方法

更新时间：2015年05月29日 14:55:32 作者：wo_soul

这篇文章主要介绍了Java基于socket服务实现UDP协议的方法,通过两个简单实例分析了java通过socket实现UDP发送与接收的技巧,需要的朋友可以参考下

本文实例讲述了Java基于socket服务实现UDP协议的方法。分享给大家供大家参考。具体如下：

示例1：

接收类：

package com.socket.demo; 
import java.io.IOException; 
import java.net.DatagramPacket; 
import java.net.DatagramSocket; 
public class UDPReceiveDemo { 
 public static void main(String[] args) throws IOException{ 
  System.out.println("接收端启动…………"); 
 /* 
  2、建立UDP的socket的服务,必须明确一个端口号 
  3、创建数据包，用于储存接收到的数据，方便用数据包对象的方法解析这些数据 
  4、使用DatagramSocket的receive方法将接收到的数据存储到数据包中 
  5、通过数据包的方法解析数据包中的数据 
  5、关闭socket服务 
  */ 
  //udpsocket服务，使用DatagramSocket对象 
  DatagramSocket ds=new DatagramSocket(10002); 
  //使用DatagramPacket将数据封装到该对象中 
  byte[] buf=new byte[1024]; 
  DatagramPacket dp=new DatagramPacket(buf, buf.length); 
  //通过udp的socket服务将数据包发送出去，通过send方法 
  ds.receive(dp); 
  //通过数据包的方法解析数据包中的数据,比如，地址、端口、数据内容等 
  String ip=dp.getAddress().getHostAddress(); 
  //String name=dp.getAddress().getHostName(); 
  int port=dp.getPort(); 
  String text=new String(dp.getData(),0,dp.getLength()); 
  //System.out.println("-----"+ip+"-----"+name+"-----"+port+"-----"+text); 
  System.out.println("-----"+ip+"----------"+port+"-----"+text); 
  //关闭资源 
  ds.close(); 
 } 
}

发送类：

package com.socket.demo; 
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 UDPSendDemo { 
 public static void main(String[] args) throws IOException{ 
  System.out.println("发送端启动…………"); 
 /* 
  * 1、创建udp传输的发送端 
  2、建立UDP的socket的服务 
  3、将要发送的数据封装到数据包中 
  4、通过udp的socket服务将数据包发送出去 
  5、关闭socket服务 
  */ 
  //udpsocket服务，使用DatagramSocket对象 
  DatagramSocket ds=new DatagramSocket(8888);//监听端口 
  //将要发送的数据封装到数据包中 
  String str="udp传输演示，go"; 
  //使用DatagramPacket将数据封装到该对象中 
  byte[] buf=str.getBytes(); 
  DatagramPacket dp= 
    new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.100"),10002); 
  //通过udp的socket服务将数据包发送出去，通过send方法 
  ds.send(dp); 
  //关闭资源 
  ds.close(); 
 } 
}

示例2：

接收类：

package com.socket.demo; 
import java.io.IOException; 
import java.net.DatagramPacket; 
import java.net.DatagramSocket; 
public class UDPReceiveDemo2 { 
 public static void main(String[] args) throws IOException{ 
  System.out.println("接收端启动…………"); 
 /* 
  2、建立UDP的socket的服务,必须明确一个端口号 
  3、创建数据包，用于储存接收到的数据，方便用数据包对象的方法解析这些数据 
  4、使用DatagramSocket的receive方法将接收到的数据存储到数据包中 
  5、通过数据包的方法解析数据包中的数据 
  5、关闭socket服务 
  */ 
  //udpsocket服务，使用DatagramSocket对象 
  DatagramSocket ds=new DatagramSocket(10003); 
  while(true){ 
   //使用DatagramPacket将数据封装到该对象中 
   byte[] buf=new byte[1024]; 
   DatagramPacket dp=new DatagramPacket(buf, buf.length); 
   //通过udp的socket服务将数据包发送出去，通过send方法 
   ds.receive(dp);//阻塞式的。 
   //通过数据包的方法解析数据包中的数据,比如，地址、端口、数据内容等 
   String ip=dp.getAddress().getHostAddress(); 
   //String name=dp.getAddress().getHostName(); 
   int port=dp.getPort(); 
   String text=new String(dp.getData(),0,dp.getLength()); 
   //System.out.println("-----"+ip+"-----"+name+"-----"+port+"-----"+text); 
   System.out.println("-----"+ip+"----------"+port+"-----"+text); 
  } 
  //关闭资源 
  //ds.close(); 
 } 
}

发送类：

package com.socket.demo; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.net.DatagramPacket; 
import java.net.DatagramSocket; 
import java.net.InetAddress; 
public class UDPSendDemo2 { 
 public static void main(String[] args) throws IOException{ 
  System.out.println("发送端启动…………"); 
 /* 
  * 1、创建udp传输的发送端 
  2、建立UDP的socket的服务 
  3、将要发送的数据封装到数据包中 
  4、通过udp的socket服务将数据包发送出去 
  5、关闭socket服务 
  */ 
  //udpsocket服务，使用DatagramSocket对象 
  DatagramSocket ds=new DatagramSocket(9999);//监听端口 
  //将要发送的数据封装到数据包中 
  //String str="udp传输演示，go"; 
  BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));//键盘输入 
  String line=null; 
  //使用DatagramPacket将数据封装到该对象中 
  while((line=bufr.readLine())!=null){ 
   byte[] buf=line.getBytes();// 
   DatagramPacket dp= 
     new DatagramPacket(buf, buf.length,InetAddress.getByName("192.168.1.100"),10003); 
   //通过udp的socket服务将数据包发送出去，通过send方法 
   ds.send(dp); 
   if("886".equals(line)){ 
    break; 
   } 
  } 
  //关闭资源 
  ds.close(); 
 } 
}

运行效果图如下：

接收：

发送：

希望本文所述对大家的java程序设计有所帮助。

您可能感兴趣的文章:

Spark SQL配置及使用教程
SparkSQL是spark的一个模块，主入口是SparkSession，将SQL查询与Spark程序无缝混合，这篇文章主要介绍了Spark SQL配置及使用,需要的朋友可以参考下
2021-12-12
SpringBoot整合Elasticsearch7.2.0的实现方法
这篇文章主要介绍了SpringBoot整合Elasticsearch7.2.0的实现方法,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-08-08
Java实现视频初步压缩和解压的代码示例
从摄像头读取每一帧的图片,用一些简单的方法将多张图片信息压缩到一份文件中（自定义的视频文件）,自定义解码器读取视频文件,并将每帧图片展示成视频,本文主要介绍了Java实现视频初步压缩和解压,需要的朋友可以参考下
2023-10-10
使用eclipse导入javaWeb项目的图文教程
这篇文章主要介绍了如何使用eclipse导入别人的javaWeb项目,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-07-07
Java+Selenium调用JavaScript的方法详解
这篇文章主要为大家讲解了java在利用Selenium操作浏览器网站时候，有时会需要用的JavaScript的地方，代码该如何实现呢？快跟随小编一起学习一下吧
2023-01-01
Linux服务器Java进程消失问题解决
这篇文章主要介绍了Linux服务器Java进程消失问题解决,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
浅谈Java中Collections.sort对List排序的两种方法
本文介绍了Java中Collections.sort对List排序的两种方法以及Comparable 与Comparator区别，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-12-12
全面了解java byte数组与文件读写
下面小编就为大家带来一篇全面了解java byte数组与文件读写。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-08-08
JpaRepository如何实现增删改查并进行单元测试
这篇文章主要介绍了JpaRepository如何实现增删改查并进行单元测试，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-11-11
Java中SSM框架实现增删改查功能代码详解
这篇文章主要介绍了Java中SSM框架实现增删改查功能代码详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-07-07