java使用UDP实现点对点通信
更新时间：2022年06月15日 12:11:53 作者：Orange#
这篇文章主要为大家详细介绍了java使用UDP实现点对点通信，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
本文实例为大家分享了java使用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;
}
@Override
public 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;
}
@Override
public 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;
}
@Override
public 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;
}
@Override
public 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;
}
@Override
public 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();
}
}
}以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本篇文章主要介绍了浅谈Mybatis通用Mapper使用方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-10-10
懒人 IDEA 插件推荐: EasyCode 一键帮你生成所需代码(Easycode用法)
这篇文章主要介绍了懒人 IDEA 插件推荐: EasyCode 一键帮你生成所需代码,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-08-08
这篇文章主要为大家介绍了jOOQ串联字符串拒绝使用的原因实例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-08-08
这篇文章主要给大家介绍了关于Spring Boot接口限流的常用算法及特点的相关资料，文中通过图文介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-02-02
这篇文章主要介绍了java开源调度如何给xxljob加一个k8s执行器， xxljob 在设计上，抽象出了执行器的接口，所以实现一个语言的执行器并不复杂，这里主要探索下，如何利用k8s的pod 的能力，使用 xxljob 调度 pod 运行，实现一个通用的和语言无关的执行器2022-02-02
这篇文章主要介绍了java json与map互相转换的示例，帮助大家更好的理解和使用Java，感兴趣的朋友可以了解下2020-10-10
这篇文章主要为大家介绍了java实现用户签到BitMap功能实现demo,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-11-11
本篇文章小编就为大家简单说说JavaSE、JavaEE、JavaME三者之间的区别,需要的朋友可以过来参考下,感兴趣的小伙伴们可以参考一下2023-08-08
这篇文章主要为大家详细介绍了Java观察者设计模式，对观察者设计模式进行分析理解，感兴趣的小伙伴们可以参考一下2016-02-02
这篇文章主要为大家介绍了java注解处理器学习在编译期修改语法树教程，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-09-09
最新评论