UDP实现点对点通信

整体的结构思路：

Stu和Tea是收发消息的两端；

Stu和Tea类都是通过启动两个线程完成通信的，这两个线程分别是发消息线程和收消息线程；

Stu类中启动的两个线程分别写在两个类里，Tea也是这样做。

Stu端及其收发消息代码：

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;}@Overridepublic void run() {// 创建接收方DatagramSocket socket;try {socket = new DatagramSocket(port);while(true) {// 准备容器byte[] buf = new byte[1024];DatagramPacket dPacket = new DatagramPacket(buf, buf.length);// 阻塞式接受数据try {socket.receive(dPacket);} catch (IOException e) {e.printStackTrace();}// 分析数据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;}@Overridepublic void run() {		while(true) {// 准备数据br = new BufferedReader(new InputStreamReader(System.in));String msg;try {msg = br.readLine();byte[] data = msg.getBytes();// 封装数据DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);// 发送数据socket.send(dPacket);if(msg.equals("exit")) {break;}} catch (IOException e) {e.printStackTrace();}}// 关闭资源try {br.close();socket.close();} catch (IOException e) {e.printStackTrace();}}}

Tea端及其收发消息代码：

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;}@Overridepublic void run() {while (true) {// 准备数据br = new BufferedReader(new InputStreamReader(System.in));String msg;try {msg = br.readLine();byte[] data = msg.getBytes();// 封装数据DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);// 发送数据socket.send(dPacket);if (msg.equals("exit")) {break;}} catch (IOException e) {e.printStackTrace();}}// 关闭资源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;}@Overridepublic void run() {// 创建接收方DatagramSocket socket;try {socket = new DatagramSocket(port);while(true) {// 准备容器byte[] buf = new byte[1024];DatagramPacket dPacket = new DatagramPacket(buf, buf.length);// 阻塞式接受数据try {socket.receive(dPacket);} catch (IOException e) {e.printStackTrace();}// 分析数据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;}@Overridepublic void run() {while (true) {// 准备数据br = new BufferedReader(new InputStreamReader(System.in));String msg;try {msg = br.readLine();byte[] data = msg.getBytes();// 封装数据DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);// 发送数据socket.send(dPacket);if (msg.equals("exit")) {break;}} catch (IOException e) {e.printStackTrace();}}// 关闭资源try {br.close();socket.close();} catch (IOException e) {e.printStackTrace();}}}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！