Java Socket实现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编程内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞！