快捷導(dǎo)航

Java Socket實(shí)現(xiàn)UDP編程淺析

更新時(shí)間：2022年11月05日 16:53:29 作者：OlaiolaiO

類 DatagramSocket 何 DatagramPacket（數(shù)據(jù)包/數(shù)據(jù)報(bào)）實(shí)現(xiàn)了基于 UDP協(xié)議網(wǎng)絡(luò)程序；UDP數(shù)據(jù)報(bào)通過(guò)數(shù)據(jù)報(bào)套接字 DatagramSocket 發(fā)送和接收，系統(tǒng)不保證 UDP數(shù)據(jù)報(bào)一定能夠安全送達(dá)目的地，也不確定什么時(shí)候可以抵達(dá)

一、概述

在 Java 中使用 UDP 編程，仍然需要使用 Socket ，因?yàn)閼?yīng)用程序在使用 UDP 時(shí)必須指定網(wǎng)絡(luò)接口（ IP地址）和端口號(hào)。注意： UDP 端口和 TCP 端口雖然都使用 0 ~ 65535 ，但他們是兩套獨(dú)立的端口，即一個(gè)應(yīng)用程序用TCP占用了端口 1234 ，不影響另一個(gè)應(yīng)用程序用UDP占用端口 1234 。

二、服務(wù)器端

在服務(wù)器端，使用 UDP 也需要監(jiān)聽指定的端口。Java提供了 DatagramSocket 來(lái)實(shí)現(xiàn)這個(gè)功能

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監(jiān)聽7788端口
		try (DatagramSocket socket = new DatagramSocket(7788)) {
			//提前創(chuàng)建兩個(gè)Packet數(shù)據(jù)包分別用于發(fā)送和接收
			DatagramPacket sendPacked = new DatagramPacket(new byte[1024],1024,//數(shù)據(jù)
					new InetSocketAddress("192.168.254.163",8899));//目的地
			DatagramPacket receivePacket = new DatagramPacket(new byte[1024], 1024);
			DatagramPacket sendPackedx = new DatagramPacket(new byte[1024],1024,//數(shù)據(jù)
					new InetSocketAddress("192.168.254.163",6677));//目的地
			while(true) {
				//發(fā)送
				System.out.println("你說(shuō)：");
				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("對(duì)方退出了聊天...");
					break;
				}
				System.out.println("他說(shuō)："+receiveContent);
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

三、客戶端

和服務(wù)器端相比，客戶端使用 UDP 時(shí)，只需要直接向服務(wù)器端發(fā)送 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監(jiān)聽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("對(duì)方退出了聊天...");
					break;
				}
				System.out.println("他說(shuō)："+receiveContent);
				//發(fā)送
				System.out.println("你說(shuō)：");
				String sendContent = input.nextLine();
				sendPacked.setData(sendContent.getBytes());
				socket.send(sendPacked);
				if(sendContent.equals("退下")) {
					System.out.println("你退出了聊天...");
					break;
				}
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}