Java实现UDP多线程在线咨询
作者:微滑低 时间:2022-08-30 13:15:08
本文实例为大家分享了Java实现UDP多线程在线咨询,供大家参考,具体内容如下
1.发送的线程
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;
//发送线程
public class TalkSend implements Runnable {
DatagramSocket socket = null;
BufferedReader reader = null;
private int formPort; //自身端口
private String toIP; //发送到的IP
private int toPort; //发送到的端口
public TalkSend(int formPort, String toIP, int toPort) {
this.formPort = formPort;
this.toIP = toIP;
this.toPort = toPort;
try {
socket = new DatagramSocket(formPort);
reader = new BufferedReader(new InputStreamReader(System.in)); //获取控制台输入
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while(true) {
try {
String data = reader.readLine(); //获取到的数据
byte[] datas = data.getBytes(); //转换为需要的字节数组
//将数据打包成包
DatagramPacket packet = new DatagramPacket(datas,0, datas.length,new InetSocketAddress(this.toIP,this.toPort));
socket.send(packet); //发送包
//退出指令
if(packet.equals("bye")){
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
socket.close();
}
}
2.接收的线程
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
//接收线程
public class TalkReceive implements Runnable {
DatagramSocket socket = null; //与发送端的socket为同一个,实现通信
private int port;
private String msgFrom; //标志信息来源
public TalkReceive(int port, String msgFrom) {
this.port = port;
this.msgFrom= msgFrom;
try {
socket = new DatagramSocket(port);
} catch (SocketException e) {
e.printStackTrace();
}
}
@Override
public void run() {
while (true){
try {
byte[] container = new byte[1024];
DatagramPacket packet = new DatagramPacket(container, 0, container.length);
socket.receive(packet);//接收数据
byte[] data = packet.getData();
String receiveData = new String(data, 0, data.length);
System.out.println(msgFrom+":"+receiveData);
if(receiveData.equals("bye")){
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
socket.close();
}
}
3.模拟学生端
//模拟学生
public class TalkStudent {
public static void main(String[] args) {
new Thread(new TalkSend(7777, "localhost", 9999)).start();
new Thread(new TalkReceive(8888, "老师")).start();
}
}
4.模拟老师端
//模拟老师
public class TalkTeacher {
public static void main(String[] args) {
new Thread(new TalkSend(5555, "localhost", 8888)).start();
new Thread(new TalkReceive(9999, "学生")).start();
}
}
5.截图
学生端:
老师端:
6.总结
首先创建一个发送线程,里面定义要发送到的IP地址和端口,再创建一个DatagramSocket来进行通信,创建一个BufferReader(new InputStreamReader(System.in))来获取控制台的输入的数据,将获取到的数据打包进行发送。之后创建一个接收线程,里面定义自身的端口即可,再创建一个和发送端一样的DatagramSocket来进行通信,接收数据进行打印输出即可。最后模拟学生端和老师端,创建这两个线程来进行通信。学生发送线程到的端口是老师的接收端口,老师发送的端口是学生的接收端口,这样才能互相通信。
来源:https://blog.csdn.net/weixin_49092628/article/details/115837912
标签:java,多线程,在线咨询
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
Springboot多种情况yml配置代码实例
2022-05-14 23:26:00
C# wpf 通过HwndHost渲染视频的实现方法
2023-08-30 03:33:35
![](https://img.aspxhome.com/file/2023/1/74821_0s.jpg)
Android实现登录界面的注册功能
2021-10-22 01:17:55
![](https://img.aspxhome.com/file/2023/3/106873_0s.jpg)
Java字节流和字符流总结IO流!
2023-10-21 13:06:02
![](https://img.aspxhome.com/file/2023/1/74971_0s.png)
Spring SpringMVC在启动完成后执行方法源码解析
2023-01-01 12:46:57
java开发实现订阅到货通知帮我们买到想买的东西
2022-05-01 18:55:11
![](https://img.aspxhome.com/file/2023/6/77366_0s.png)
C#使用读写锁解决多线程并发问题
2022-02-28 20:36:09
![](https://img.aspxhome.com/file/2023/0/119460_0s.png)
使用mybatis-plus的insert方法遇到的问题及解决方法(添加时id值不存在异常)
2023-11-12 19:25:55
![](https://img.aspxhome.com/file/2023/6/59606_0s.png)
Activiti开发环境的配置
2021-07-31 21:57:51
![](https://img.aspxhome.com/file/2023/9/83499_0s.jpg)
unity实现虚拟摇杆控制Virtual Joystick
2022-09-26 11:56:28
![](https://img.aspxhome.com/file/2023/3/77263_0s.jpg)
java微信公众号开发(搭建本地测试环境)
2021-07-07 05:32:40
![](https://img.aspxhome.com/file/2023/6/63076_0s.png)
C# 输出参数out问题
2023-02-27 00:19:32
java之static关键字用法实例解析
2023-11-21 14:42:49
![](https://img.aspxhome.com/file/2023/8/78388_0s.png)
C#实现观察者模式(Observer Pattern)的两种方式
2023-06-20 21:05:18
![](https://img.aspxhome.com/file/2023/0/66130_0s.png)
一文带你搞懂Java8的LocalDateTime
2023-11-10 02:02:22
![](https://img.aspxhome.com/file/2023/4/59234_0s.png)
SpringBoot中的Aop用法示例详解
2023-03-31 14:12:00
![](https://img.aspxhome.com/file/2023/6/62986_0s.png)
Java算法设计与分析分治算法
2022-04-02 08:07:15
![](https://img.aspxhome.com/file/2023/9/92549_0s.png)
深入探讨C#中的const、readonly关键字
2023-01-20 23:42:25
![](https://img.aspxhome.com/file/2023/5/80105_0s.png)
Spring Cache和EhCache实现缓存管理方式
2023-01-17 01:44:40
![](https://img.aspxhome.com/file/2023/7/64927_0s.png)
java对象转换String类型的三种方法
2023-11-09 15:50:59