package j2se.core.net.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;
/**
* 通过 UDP 发送数据的简单范例
*/
public class Sender {
public static void main(String[] args) throws IOException {
// 使用指定的端口，创建 数据报嵌套字(用于发送数据)
DatagramSocket socket = new DatagramSocket();
// 创建数据报发送目的地的地址对象
InetSocketAddress address = new InetSocketAddress("127.0.0.1", 1234);
// 接收用户输入
Scanner scanner = new Scanner(System.in);
while (true) {
String content = scanner.nextLine();
if (content.length() == 0)
break;
byte[] message = content.getBytes();
DatagramPacket packet = new DatagramPacket(message, message.length, address);
socket.send(packet);
}
socket.close();
}
}
package j2se.core.net.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;
/**
* 通过 UDP 发送数据的简单范例
*/
public class Sender {
public static void main(String[] args) throws IOException {
// 使用指定的端口，创建 数据报嵌套字(用于发送数据)
DatagramSocket socket = new DatagramSocket();
// 创建数据报发送目的地的地址对象
InetSocketAddress address = new InetSocketAddress("127.0.0.1", 1234);
// 接收用户输入
Scanner scanner = new Scanner(System.in);
while (true) {
String content = scanner.nextLine();
if (content.length() == 0)
break;
byte[] message = content.getBytes();
DatagramPacket packet = new DatagramPacket(message, message.length, address);
socket.send(packet);
}
socket.close();
}
}
package j2se.core.net.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
/**
* 通过 UDP 接收数据的简单范例
*/
public class Receiver {
public static void main(String[] args) throws IOException {
// 使用指定的端口，创建 数据报嵌套字(用于接收数据)
DatagramSocket socket = new DatagramSocket(1234);
// 创建长度为 1024 个字节的数据报对象
DatagramPacket packet = new DatagramPacket(new byte[1024], 1024);
while (true) {
socket.receive(packet);
byte[] data = packet.getData();
String s = new String(data, 0, packet.getLength());
System.out.println("接收到的内容:" + s);
if (s.equals("quit"))
break;
}
socket.close();
}
}