Java Socket实现UDP编程浅析

 更新时间:2022年11月05日 16:53:29   作者:OlaiolaiO  
类 DatagramSocket 何 DatagramPacket(数据包/数据报) 实现了基于 UDP协议网络程序;UDP数据报通过数据报套接字 DatagramSocket 发送和接收,系统不保证 UDP数据报一定能够安全送达目的地,也不确定什么时候可以抵达

一、概述

在 Java 中使用 UDP 编程,仍然需要使用 Socket ,因为应用程序在使用 UDP 时必须指定网络接口 ( IP地址 )和端口号。注意: UDP 端口和 TCP 端口虽然都使用 0 ~ 65535 ,但他们是两套独立的 端口,即一个应用程序用TCP占用了端口 1234 ,不影响另一个应用程序用UDP占用端口 1234 。

二、服务器端

在服务器端,使用 UDP 也需要监听指定的端口。Java提供了 DatagramSocket 来实现这个功能

package com.ljl.udp.demo2;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;
public class ChatB {
	public static void main(String[] args) {
		Scanner input = new Scanner(System.in);
		//客户端B监听7788端口
		try (DatagramSocket socket = new DatagramSocket(7788)) {
			//提前创建两个Packet数据包分别用于发送和接收
			DatagramPacket sendPacked = new DatagramPacket(new byte[1024],1024,//数据
					new InetSocketAddress("192.168.254.163",8899));//目的地
			DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);
			DatagramPacket sendPackedx = new DatagramPacket(new byte[1024],1024,//数据
					new InetSocketAddress("192.168.254.163",6677));//目的地
			while(true) {
				//发送
				System.out.println("你说:");
				String sendContent = input.nextLine();
				sendPacked.setData(sendContent.getBytes());
				socket.send(sendPacked);
				sendPackedx.setData(sendContent.getBytes());
				socket.send(sendPackedx);
				if(sendContent.equals("退下")) {
					System.out.println("你退出了聊天...");
					break;
				}
				//接收
				socket.receive(receivePacket);
				String receiveContent = new String(receivePacket.getData(),receivePacket.getOffset(),receivePacket.getLength());
				if(sendContent.equals("退下")) {
					System.out.println("对方退出了聊天...");
					break;
				}
				System.out.println("他说:"+receiveContent);
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

三、客户端

和服务器端相比,客户端使用 UDP 时,只需要直接向服务器端发送 UDP 包,然后接收返回的 UDP 包:

package com.ljl.udp.demo2;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;
public class ChatA {
	public static void main(String[] args) {
		Scanner input = new Scanner(System.in);
		//客户端A监听8899端口
		try (
		 DatagramSocket socket = new DatagramSocket(8899)) {
			DatagramPacket sendPacked = new DatagramPacket(new byte[1024], 1024);
			DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024,new InetSocketAddress("192.168.254.163",7788));
			while(true) {
				//接收
				socket.receive(receivePacket);
				String receiveContent = new String(receivePacket.getData(),receivePacket.getOffset(),receivePacket.getLength());
				if(receiveContent.equals("退下")) {
					System.out.println("对方退出了聊天...");
					break;
				}
				System.out.println("他说:"+receiveContent);
				//发送
				System.out.println("你说:");
				String sendContent = input.nextLine();
				sendPacked.setData(sendContent.getBytes());
				socket.send(sendPacked);
				if(sendContent.equals("退下")) {
					System.out.println("你退出了聊天...");
					break;
				}
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

四、总结

  • 使用 UDP 协议通信时,服务器和客户端双方无需建立连接;
  • 服务器端用 DatagramSocket(port) 监听端口;
  • 客户端使用 DatagramSocket.connect() 指定远程地址和端口;
  • 双方通过 receive() 和 send() 读写数据;
  • DatagramSocket 没有 IO 流接口,数据被直接写入 byte[] 缓冲区。

到此这篇关于Java Socket实现UDP编程浅析的文章就介绍到这了,更多相关Java UDP编程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Mybatis动态调用表名和字段名的解决方法

    Mybatis动态调用表名和字段名的解决方法

    今天在项目开发中有个业务是需要限制各个用户对某些表里的字段查询以及某些字段是否显示,这种情况下,就需要构建sql来动态传入表名、字段名了,下面给大家介绍mybatis动态调用表名和字段名的解决方法,一起看看吧
    2016-10-10
  • netty服务端处理请求联合pipeline分析

    netty服务端处理请求联合pipeline分析

    这篇文章主要为大家介绍了netty服务端处理请求联合pipeline示例分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-04-04
  • Java面试题冲刺第十二天--数据库(2)

    Java面试题冲刺第十二天--数据库(2)

    这篇文章主要为大家分享了最有价值的三道数据库面试题,涵盖内容全面,包括数据结构和算法相关的题目、经典面试编程题等,感兴趣的小伙伴们可以参考一下
    2021-07-07
  • Spring多数据源导致配置失效的解决

    Spring多数据源导致配置失效的解决

    这篇文章主要介绍了Spring多数据源导致配置失效的解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-01-01
  • 轻松掌握Java观察者模式

    轻松掌握Java观察者模式

    这篇文章主要帮助大家轻松掌握Java观察者模式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-09-09
  • Java中如何模拟HTTP请求并验证功能

    Java中如何模拟HTTP请求并验证功能

    要模拟HTTP请求并验证功能,你可以使用Spring Boot提供的MockMvc工具,它允许我们在没有实际启动HTTP服务器的情况下测试Spring MVC控制器,下面给大家分享如何模拟HTTP请求并验证功能,感兴趣的朋友一起看看吧
    2024-05-05
  • 史上最全图文讲解Java泛型

    史上最全图文讲解Java泛型

    泛型在java中有很重要的地位,在面向对象编程及各种设计模式中有非常广泛的应用,下面这篇文章主要给大家介绍了Java泛型的相关资料,需要的朋友可以参考下
    2022-02-02
  • 程序包org.springframework.boot不存在的问题解决

    程序包org.springframework.boot不存在的问题解决

    本文主要介绍了程序包org.springframework.boot不存在的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-09-09
  • Java实现接口限流方案

    Java实现接口限流方案

    这篇文章主要为大家详细介绍了Java实现接口限流方案,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-11-11
  • RocketMq 消息重试机制及死信队列详解

    RocketMq 消息重试机制及死信队列详解

    这篇文章主要为大家介绍了RocketMq 消息重试机制及死信队列详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-10-10

最新评论