import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
?
public class Stu {
?
?? ?public static void main(String[] args) throws IOException {
?? ??? ?new Thread(new StuSendThread("127.0.0.1", 8888)).start();
?? ??? ?new Thread(new StuReceiverThread(8889)).start();
?? ?}
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
?
?
public class StuReceiverThread implements Runnable{
?
?? ?private int port;
?
?? ?public StuReceiverThread(int port) {
?? ??? ?this.port = port;
?? ?}
?? ?
?? ?@Override
?? ?public void run() {
?? ??? ?// 創(chuàng)建接收方
?? ??? ?DatagramSocket socket;
?? ??? ?try {
?? ??? ??? ?socket = new DatagramSocket(port);
?? ??? ??? ?while(true) {
?? ??? ??? ??? ?// 準(zhǔn)備容器
?? ??? ??? ??? ?byte[] buf = new byte[1024];
?? ??? ??? ??? ?DatagramPacket dPacket = new DatagramPacket(buf, buf.length);
?? ??? ??? ??? ?// 阻塞式接受數(shù)據(jù)
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?socket.receive(dPacket);
?? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ??? ?// 分析數(shù)據(jù)
?? ??? ??? ??? ?System.out.println(new String(buf));
?? ??? ??? ??? ?if (new String(buf).equals("exit")) {
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ?}
?? ??? ??? ?// 釋放資源
?? ??? ??? ?socket.close();
?? ??? ?} catch (SocketException e1) {
?? ??? ??? ?e1.printStackTrace();
?? ??? ?}?? ??? ?
?? ?}?? ?
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
?
public class StuSendThread implements Runnable{
?
?? ?private DatagramSocket socket;
?? ?private BufferedReader br;
?? ?String IP;
?? ?int port;
?? ?
?? ?public StuSendThread(String IP, int port) throws SocketException {
?? ??? ?socket = new DatagramSocket();
?? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ?this.IP = IP;
?? ??? ?this.port = port;
?? ?}
?? ?
?? ?@Override
?? ?public void run() {?? ??? ?
?? ??? ?while(true) {
?? ??? ??? ?// 準(zhǔn)備數(shù)據(jù)
?? ??? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ? ? ?String msg;
?? ??? ??? ?try {
?? ??? ??? ??? ?msg = br.readLine();
?? ??? ??? ??? ?byte[] data = msg.getBytes();
?? ??? ??? ??? ?// 封裝數(shù)據(jù)
?? ??? ??? ??? ?DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
?? ??? ??? ??? ?// 發(fā)送數(shù)據(jù)
?? ??? ??? ??? ?socket.send(dPacket);
?? ??? ??? ??? ?if(msg.equals("exit")) {
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?? ??? ??? ?
?? ??? ?}
?? ??? ?
?? ??? ?// 關(guān)閉資源
?? ??? ?try {
?? ??? ??? ?br.close();
?? ??? ??? ?socket.close();
?? ??? ?} catch (IOException e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?? ??? ?
?? ?}
?
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
?
public class TeaSendThread implements Runnable{
?? ?private DatagramSocket socket;
?? ?private BufferedReader br;
?? ?String IP;
?? ?int port;
?
?? ?public TeaSendThread(String IP, int port) throws SocketException {
?? ??? ?socket = new DatagramSocket();
?? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ?this.IP = IP;
?? ??? ?this.port = port;
?? ?}
?
?? ?@Override
?? ?public void run() {
?? ??? ?while (true) {
?? ??? ??? ?// 準(zhǔn)備數(shù)據(jù)
?? ??? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ??? ?String msg;
?? ??? ??? ?try {
?? ??? ??? ??? ?msg = br.readLine();
?? ??? ??? ??? ?byte[] data = msg.getBytes();
?? ??? ??? ??? ?// 封裝數(shù)據(jù)
?? ??? ??? ??? ?DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
?? ??? ??? ??? ?// 發(fā)送數(shù)據(jù)
?? ??? ??? ??? ?socket.send(dPacket);
?? ??? ??? ??? ?if (msg.equals("exit")) {
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?
?? ??? ?}
?
?? ??? ?// 關(guān)閉資源
?? ??? ?try {
?? ??? ??? ?br.close();
?? ??? ??? ?socket.close();
?? ??? ?} catch (IOException e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?
?? ?}
?
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
?
public class TeaReceiverTread implements Runnable{
?? ?private int port;
?
?? ?public TeaReceiverTread(int port) {
?? ??? ?this.port = port;
?? ?}
?? ?
?? ?@Override
?? ?public void run() {
?? ??? ?// 創(chuàng)建接收方
?? ??? ?DatagramSocket socket;
?? ??? ?try {
?? ??? ??? ?socket = new DatagramSocket(port);
?? ??? ??? ?while(true) {
?? ??? ??? ??? ?// 準(zhǔn)備容器
?? ??? ??? ??? ?byte[] buf = new byte[1024];
?? ??? ??? ??? ?DatagramPacket dPacket = new DatagramPacket(buf, buf.length);
?? ??? ??? ??? ?// 阻塞式接受數(shù)據(jù)
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?socket.receive(dPacket);
?? ??? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ??? ?// 分析數(shù)據(jù)
?? ??? ??? ??? ?System.out.println(new String(buf));
?? ??? ??? ??? ?if (new String(buf).equals("exit")) {
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ?}
?? ??? ??? ?// 釋放資源
?? ??? ??? ?socket.close();
?? ??? ?} catch (SocketException e1) {
?? ??? ??? ?e1.printStackTrace();
?? ??? ?}?? ??? ?
?? ?}?? ?
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
?
public class TeaSendThread implements Runnable{
?? ?private DatagramSocket socket;
?? ?private BufferedReader br;
?? ?String IP;
?? ?int port;
?
?? ?public TeaSendThread(String IP, int port) throws SocketException {
?? ??? ?socket = new DatagramSocket();
?? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ?this.IP = IP;
?? ??? ?this.port = port;
?? ?}
?
?? ?@Override
?? ?public void run() {
?? ??? ?while (true) {
?? ??? ??? ?// 準(zhǔn)備數(shù)據(jù)
?? ??? ??? ?br = new BufferedReader(new InputStreamReader(System.in));
?? ??? ??? ?String msg;
?? ??? ??? ?try {
?? ??? ??? ??? ?msg = br.readLine();
?? ??? ??? ??? ?byte[] data = msg.getBytes();
?? ??? ??? ??? ?// 封裝數(shù)據(jù)
?? ??? ??? ??? ?DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
?? ??? ??? ??? ?// 發(fā)送數(shù)據(jù)
?? ??? ??? ??? ?socket.send(dPacket);
?? ??? ??? ??? ?if (msg.equals("exit")) {
?? ??? ??? ??? ??? ?break;
?? ??? ??? ??? ?}
?? ??? ??? ?} catch (IOException e) {
?? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ?}
?
?? ??? ?}
?
?? ??? ?// 關(guān)閉資源
?? ??? ?try {
?? ??? ??? ?br.close();
?? ??? ??? ?socket.close();
?? ??? ?} catch (IOException e) {
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?
?? ?}
?
}