java使用UDP实现点对点通信
更新时间:2022年06月15日 12:11:53 作者:Orange#
这篇文章主要为大家详细介绍了java使用UDP实现点对点通信,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
(福利推荐:【腾讯云】服务器最新限时优惠活动,云服务器1核2G仅99元/年、2核4G仅768元/3年,立即抢购>>>:9i0i.cn/qcloud)
(福利推荐:你还在原价购买阿里云服务器?现在阿里云0.8折限时抢购活动来啦!4核8G企业云服务器仅2998元/3年,立即抢购>>>:9i0i.cn/aliyun)
本文实例为大家分享了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(); ?? ??? ?} ? ?? ?} ? }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持程序员之家。
相关文章
java集合中HashSet LinkedHashSet TreeSet三者异同面试精讲
这篇文章主要为大家介绍了java集合中HashSet LinkedHashSet TreeSet三者异同面试精讲,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-10-10详解Intellij IDEA中.properties文件中文显示乱码问题的解决
这篇文章主要介绍了详解Intellij IDEA中.properties文件中文显示乱码问题的解决,具有一定的参考价值,感兴趣的小伙伴们可以参考一下2017-11-11Idea安装Eslint插件提示:Plugin NativeScript was not installed的问题
这篇文章主要介绍了Idea安装Eslint插件提示:Plugin NativeScript was not installed的问题,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-10-10
最新评论