udp java_Java实现Udp网络编程
在看到本文之前,如果读者没看过笔者的上一个系列 Java实现Socket网络编程,建议先翻阅。
笔者将在上期Demo的基础上,进一步修改和扩展,达到本次Demo的运行效果。
首先展示Demo的演示效果:
初始状态:1个服务器,2个客户端
Paste_Image.png
检测通信正常:
Paste_Image.png
断开服务器,再次检测通信正常:
Paste_Image.png
服务器重新启动,自动刷新:
Paste_Image.png
添加客户端:
Paste_Image.png
关于 C(客户端)和 S(服务器)之间的TCP通信,以及 C 检测 S 状态,自动重连等机制,笔者在上期Demo的实现过程中已详细阐述,此处就不再赘述。
我们来看看本次案例的实现需求:
1、服务器支持多客户端访问
2、C和S之间使用TCP连接
3、C和C之间使用UDP直接通信
由于案例需求的步骤1、2已实现,我们对步骤3作如下设计思路:
1、客户端创建监听线程,建立UDP监听端口,并发消息告诉服务器,指定自己的服务端口。
2、服务器得知客户端的服务端口后,广播通知其他客户端,现已登录的客户端服务端口列表。
3、客户端之间直接通过UDP,向指定服务端口发送消息。
值得注意的是,C与C之间要求直接通信,所以必须满足“在服务器关闭的情况下,C与C之间仍能通信”的情况,而不是借助服务器完成间接通信
首先,我们创建客户端监听线程,并发消息告诉服务器public void run() { try {
DatagramSocket server = new DatagramSocket(0);// 随机分配一个端口号
// 向服务器发送接收客户端的DatagramSocket的端口号
String message = Common.SPECIAL; String t = "" + server.getLocalPort();
ClientMain.frame.setTitle("client " + t); String c = "" + t.length(); if (c.length()
c = "000" + c;
} else if (c.length()
c = "00" + c;
} else if (c.length()
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null; // 将信息发送给服务器
try {
outstream = new OutputStreamWriter(mSocket.getOutputStream(), "GBK");
outstream.write(message);
outstream.flush();
} catch (IOException e1) {
ClientMain.jlConnect.setText("Out Of Connect.");
ClientMain.isConnected = false; if (outstream != null) try {
outstream.close();
} catch (IOException e) {
e.printStackTrace();
}
e1.printStackTrace();
} while (true) {
byte[] recvBuf = new byte[1024];// 定义接收消息的缓冲区
DatagramPacket recvPacket = new DatagramPacket(recvBuf,
recvBuf.length);// 数据包
server.receive(recvPacket); // 接收到的消息
String recvStr = new String(recvPacket.getData(), 0,
recvPacket.getLength());
ClientMain.jtaReceivedMessage.append(recvStr + "\n"); // 滚动到底端
ClientMain.jtaReceivedMessage
.setCaretPosition(ClientMain.jtaReceivedMessage
.getText().length());
}
} catch (Exception e) {
e.printStackTrace();
}
}
服务器得知客户端的服务端口后,广播通知其他客户端else if (s.startsWith(Common.SPECIAL) && s.length() > 10
&& count == Integer.parseInt((s.substring(6, 10)))) { // 存储客户端监听端口
/**
* 一定要注意使用前初始化,否则在IDE在这里检测不到空指针错误
*/
HashMap map = new HashMap(); map.put(mSocket, s.substring(10));
ServerMain.clientMonitorPortList.add(map); // 发送更新列表信息给客户端
sendUpdateToClient();
count = -10;
s = "";
}
sendUpdateToClient方法如下:// 发送更新列表信息给所有客户端
private void sendUpdateToClient() { String message = Common.SEND_TO_CLIENT; String t = ""; for (int i = 0; i
HashMap map = ServerMain.clientMonitorPortList
.get(i);
Iterator iter1 = map.entrySet().iterator(); Map.Entry entry = (Map.Entry) iter1.next();
Socket key = (Socket) entry.getKey();
int localPort = key.getPort(); String port = (String) entry.getValue(); if (i != ServerMain.clientMonitorPortList.size() - 1)
t += localPort + " " + port + " "; else
t += localPort + " " + port;
} String c = "" + t.length(); if (c.length()
c = "000" + c;
} else if (c.length()
c = "00" + c;
} else if (c.length()
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null; // 将信息发送给每个客户端
for (int i = 0; i
HashMap map = ListenThread.clientSockets
.get(i); // 用迭代器获取HashMap的Key,即所选中的Socket
Iterator iter = map.entrySet().iterator(); Map.Entry entry = (Entry) iter
.next();
Socket key = (Socket) entry.getKey();
outstream = new OutputStreamWriter(key.getOutputStream(), "GBK");
outstream.write(message);
outstream.flush();
} catch (IOException e1) { if (outstream != null) try {
outstream.close();
} catch (IOException e) {
e.printStackTrace();
}
e1.printStackTrace();
}
}
}
最后,客户端通过UDP向指定服务端口发送消息
当选中JList的项时,向选中的项发送消息,如果没有选中项,则向服务器发送消息// 设置监听
jbSendMessage.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) { if (jtaSendMessage.getText().equals("")) {
JOptionPane.showMessageDialog(null, "发送内容不能为空!"); return;
} // 取得要发送的消息
String message = Common.SIMPLE; String t = "client " + Common.IP + ":" + mSocket.getLocalPort()
+ " " + jtaSendMessage.getText(); String c = "" + t.length(); if (c.length()
c = "000" + c;
} else if (c.length()
c = "00" + c;
} else if (c.length()
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null; // 如果没有选中,则向服务器发送消息
if (selecteds == null || selecteds.length == 0) { try {
outstream = new OutputStreamWriter(mSocket
.getOutputStream(), "GBK");
outstream.write(message);
outstream.flush();
} catch (IOException e1) { if (outstream != null) try {
outstream.close();
} catch (IOException e2) {
e2.printStackTrace();
}
e1.printStackTrace();
}
} else { String sendPort = ""; // 检测现在进行发送行为的是哪个客户端
for (int i = 0; i
HashMap map = (HashMap) clientPortList
.get(i);
Iterator iter1 = map.entrySet().iterator(); Map.Entry entry = (Map.Entry) iter1.next(); String sendSocketPort = (String) entry.getKey(); // mSocket.getLocalPort()是int类型,要注意加""
if (sendSocketPort.equals(mSocket.getLocalPort() + "")) {
sendPort = (String) entry.getValue();
}
} // 向选中的客户端发送消息
for (int i = 0; i
HashMap map = (HashMap) clientPortList
.get(selecteds[i]);
Iterator iter1 = map.entrySet().iterator(); Map.Entry entry = (Map.Entry) iter1.next(); String port = (String) entry.getValue(); try { // 生成一个临时发送端口
DatagramSocket client = new DatagramSocket(0); // 要发送的数据
String sendMessage = "client " + Common.IP + ":"
+ sendPort + " " + jtaSendMessage.getText();
byte[] buf = sendMessage.getBytes(); // 定义发送信息的目的地
InetAddress destination = InetAddress
.getByName(Common.IP); // 生成数据包
DatagramPacket dp = new DatagramPacket(buf,
buf.length, destination, Integer
.valueOf(port));
client.send(dp);
} catch (Exception e1) {
e1.printStackTrace();
}
}
} // 清空文本
jtaSendMessage.setText(null);
}
});
本次实验步骤看似简单,但也有几个不得不注意的地方:
1、在读写数据的循环里,是检测不到空指针错误的,只会检测到读写错误后不断尝试重连。读者在开发过程中一定要注意把相应的控件初始化,而发现不断重连,重复读写时,应首先考虑是否在读写循环里引用了未初始化的控件。
2、mSocket.getLocalPort()方法返回的是int类型,使用equals比较时要注意加双引号"",以转换成String类型,否则IDE不会编译报错,但结果并未如意。
3、使用UDP端口容易混乱:读者在开发过程中应尽量避免更新UI时整体删除再添加剩余项,而改用“只删除关闭项,只增加新增项”,前种方法在开发过程中容易造成端口混乱。同时,笔者建议读者在涉及JList操作时,多用ArrayList替代HashMap存储,因为ArrayList是插入有序的,能减少混乱的发生。
4、注意在视图model中删除了项,也要同时在列表List中删除对应项,以做到真正的删除,而不是假删除。
5、删除List中的所有项:
for(int i=0;i
注意!这里不能添加i++,因为每次remove后,list.size()会自动减小,如果添加了i++,则不能完全删除List中的元素,从而导致二次混乱
最后,笔者在github上给出了两次实验的Demo源码,供读者学习和思考,感谢关注!
作者:陆嘉杰
链接:https://www.jianshu.com/p/700e95a45206
udp java_Java实现Udp网络编程相关推荐
- Java网络编程之UDP与TCP的网络编程
⭐️前面的话⭐️ 本文将介绍java中的网络编程,常见的网络编程方式有两种,一种是UDP,另外一种是TCP,其中UDP的服务器与客户端之间不需要建立连接就能进行通信,而TCP需要先建立服务器与客户端之 ...
- tcp udp区别优缺点_Linux网络编程面试题--tcp和udp的区别
(1)TCP是基于连接的,UDP是基于无连接的. (2)TCP的数据是可靠的,UDP的数据是不可靠的. (3)TCP的数据是有序的,UDP的数据是无序的. (4)TCP不保存用户边界,UDP保存用户边 ...
- python实现udp聊天室_python网络编程基础--socket的简介,以及使用socket来搭建一个简单的udp小程序...
socket介绍: socket(简称套接字),是进程间通讯的一个工具,他能实现把数据从一方传输到另一方,完成不同电脑上进程之间的通讯,它好比数据的搬运工. socket应用: 不夸张来说,只要跟网络 ...
- python udp 传输文件_python网络编程:UDP方式传输数据
UDP --- 用户数据报协议(User Datagram Protocol),是一个无连接的简单的面向数据报的运输层协议. UDP不提供可靠性,它只是把应用程序传给IP层的数据报发送出去,但是并不能 ...
- nio的应用 java_Java NIO 在网络编程中的应用
事实上Java nio引入了异步机制,异步I/O 在Linux上有 select poll epoll,支持多路复用.在Java里就是通过nio的一整套类来实现的,主要有: ByteBuffer So ...
- C++ 网络编程下的socket编程(TCP\UDP),连接下位机
正常情况下我们需要对下位机进行通信需要使用Socket进行连接操作,而在网络编程中又分为面向连接(TCP)和面向无连接(UDP)这两种,针对这两种方式,我们不做具体的原理解释,只说各自的特点和各自的应 ...
- 你所需要的java网络编程大总结
好好学java java知识分享/学习教程免费分享 关注 精彩内容 你所需要的java全套视频教程 你所需要的java电子图书 你所需要的大数据视频教程 你所需要的java练习项目 如 / 梦 上个月 ...
- Linux网络编程一步一步学+基础
转自:http://blogold.chinaunix.net/u1/48325/showart_413841.html ·Linux网络编程基础(一) ·Linux网络编程基础(二) ·Linux网 ...
- 网络编程-网络分层的意义
网络 我们生活在一个网络无处不在的一个虚拟世界中,网络中的每一个设备都是一个节点.大多是我们的计算机,但是他还可以连接其他设备,例如打印机,路由器,网关,你的手机,智能家居等.我们可以使用java与计 ...
最新文章
- 【Android 高性能音频】OboeTester 音频性能测试应用 ( Oboe 输出测试参数 | API 选择 | 音频输出设备选择 | 采样率 | 通道 | 采样格式 | 播放偏好 )
- redis操作帮助类
- VTK:vtkCompositePolyDataMapper2用法实战
- vs2008生成自定义dll,VS2008发布、生成网站时设置固定的dll文件名
- php常驻对象,php对象
- VMware8 8.0.1 安装Lion正式版 原版镜像 直接DMG安装 非整合版 免引导 完美解决iCloud...
- 学python可以从事什么工作-学Python可以找什么工作或者做什么兼职?
- 《Python核心编程》第二版第308页第十一章练习 续一 -Python核心编程答案-自己做的-...
- android 常用依赖库
- Wilcoxon符号秩+秩和检验学习[转载]
- gis可达性分析步骤_干货来了!ArcGIS空间分析—空间聚类模式分析
- Redis源码解读(二十五)——集群模式—failover
- 流浪是对另一种生活的执着
- HTML学习总结 基础篇 图像标签imag的使用及其属性
- FPGA实现信号n倍插值(内插0)
- python 卡方分布值_python数据分析探索变量之间的关系
- nlp-with-transformers系列-02-从头构建文本分类器
- linux系统u盘安装教程
- NASBench101-安装及简单样例使用指南
- “应试教育的死穴,恰在于堵住了孩子“犯错”空间”——有感
热门文章
- java desktop和synth_java synth实例
- x86架构和arm架构_RISC-V架构1000核CPU登场 x86架构腹背受敌
- MySQL常用SQL语句(CURD,建表,加字段,查改参数)
- 微信小程序将页面按钮悬浮固定在底部
- 7nfs客户端没权限_Ant design pro v4-服务器菜单和路由权限控制
- 扬州大学广陵学院计算机网络试卷,扬州大学广陵学院控制工程考试样卷B.doc
- php写poc,xray写POC踩坑
- 电路中滤波电容和退耦电容_电子电路中电容的作用,滤波消抖,充放电,耦合,退耦...
- android自定义dialog不显示,Android 自定义的dialog显示不正常呢,怎么回事???
- java分割面板_Split 面板分割