java 监听udp_Java实现Udp网络编程
在看到本文之前，如果讀者沒看過筆者的上一個系列 Java實現(xiàn)Socket網(wǎng)絡編程，建議先翻閱。
筆者將在上期Demo的基礎上，進一步修改和擴展，達到本次Demo的運行效果。
首先展示Demo的演示效果：
初始狀態(tài)：1個服務器，2個客戶端
Paste_Image.png
檢測通信正常：
Paste_Image.png
斷開服務器，再次檢測通信正常：
Paste_Image.png
服務器重新啟動，自動刷新：
Paste_Image.png
添加客戶端：
Paste_Image.png
關于 C(客戶端)和 S(服務器)之間的TCP通信，以及 C 檢測 S 狀態(tài)，自動重連等機制，筆者在上期Demo的實現(xiàn)過程中已詳細闡述，此處就不再贅述。
我們來看看本次案例的實現(xiàn)需求：
1、服務器支持多客戶端訪問
2、C和S之間使用TCP連接
3、C和C之間使用UDP直接通信
由于案例需求的步驟1、2已實現(xiàn)，我們對步驟3作如下設計思路：
1、客戶端創(chuàng)建監(jiān)聽線程，建立UDP監(jiān)聽端口，并發(fā)消息告訴服務器，指定自己的服務端口。
2、服務器得知客戶端的服務端口后，廣播通知其他客戶端，現(xiàn)已登錄的客戶端服務端口列表。
3、客戶端之間直接通過UDP，向指定服務端口發(fā)送消息。
值得注意的是，C與C之間要求直接通信，所以必須滿足“在服務器關閉的情況下，C與C之間仍能通信”的情況，而不是借助服務器完成間接通信
首先，我們創(chuàng)建客戶端監(jiān)聽線程，并發(fā)消息告訴服務器
public void run() {
try {
DatagramSocket server = new DatagramSocket(0);// 隨機分配一個端口號
// 向服務器發(fā)送接收客戶端的DatagramSocket的端口號
String message = Common.SPECIAL;
String t = "" + server.getLocalPort();
ClientMain.frame.setTitle("client " + t);
String c = "" + t.length();
if (c.length() < 2) {
c = "000" + c;
} else if (c.length() < 3) {
c = "00" + c;
} else if (c.length() < 4) {
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null;
// 將信息發(fā)送給服務器
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];// 定義接收消息的緩沖區(qū)
DatagramPacket recvPacket = new DatagramPacket(recvBuf,
recvBuf.length);// 數(shù)據(jù)包
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)))) {
// 存儲客戶端監(jiān)聽端口
/**
* 一定要注意使用前初始化，否則在IDE在這里檢測不到空指針錯誤
*/
HashMap map = new HashMap();
map.put(mSocket, s.substring(10));
ServerMain.clientMonitorPortList.add(map);
// 發(fā)送更新列表信息給客戶端
sendUpdateToClient();
count = -10;
s = "";
}
sendUpdateToClient方法如下：
// 發(fā)送更新列表信息給所有客戶端
private void sendUpdateToClient() {
String message = Common.SEND_TO_CLIENT;
String t = "";
for (int i = 0; i < ServerMain.clientMonitorPortList.size(); 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() < 2) {
c = "000" + c;
} else if (c.length() < 3) {
c = "00" + c;
} else if (c.length() < 4) {
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null;
// 將信息發(fā)送給每個客戶端
for (int i = 0; i < ListenThread.clientSockets.size(); i++) {
try {
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向指定服務端口發(fā)送消息
當選中JList的項時，向選中的項發(fā)送消息，如果沒有選中項，則向服務器發(fā)送消息
// 設置監(jiān)聽
jbSendMessage.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
if (jtaSendMessage.getText().equals("")) {
JOptionPane.showMessageDialog(null, "發(fā)送內(nèi)容不能為空!");
return;
}
// 取得要發(fā)送的消息
String message = Common.SIMPLE;
String t = "client " + Common.IP + ":" + mSocket.getLocalPort()
+ " " + jtaSendMessage.getText();
String c = "" + t.length();
if (c.length() < 2) {
c = "000" + c;
} else if (c.length() < 3) {
c = "00" + c;
} else if (c.length() < 4) {
c = "0" + c;
}
message += c + t;
OutputStreamWriter outstream = null;
// 如果沒有選中，則向服務器發(fā)送消息
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 = "";
// 檢測現(xiàn)在進行發(fā)送行為的是哪個客戶端
for (int i = 0; i < clientPortList.size(); 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();
}
}
// 向選中的客戶端發(fā)送消息
for (int i = 0; i < selecteds.length; 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 {
// 生成一個臨時發(fā)送端口
DatagramSocket client = new DatagramSocket(0);
// 要發(fā)送的數(shù)據(jù)
String sendMessage = "client " + Common.IP + ":"
+ sendPort + " " + jtaSendMessage.getText();
byte[] buf = sendMessage.getBytes();
// 定義發(fā)送信息的目的地
InetAddress destination = InetAddress
.getByName(Common.IP);
// 生成數(shù)據(jù)包
DatagramPacket dp = new DatagramPacket(buf,
buf.length, destination, Integer
.valueOf(port));
client.send(dp);
} catch (Exception e1) {
e1.printStackTrace();
}
}
}
// 清空文本
jtaSendMessage.setText(null);
}
});
本次實驗步驟看似簡單，但也有幾個不得不注意的地方：
1、在讀寫數(shù)據(jù)的循環(huán)里，是檢測不到空指針錯誤的，只會檢測到讀寫錯誤后不斷嘗試重連。讀者在開發(fā)過程中一定要注意把相應的控件初始化，而發(fā)現(xiàn)不斷重連，重復讀寫時，應首先考慮是否在讀寫循環(huán)里引用了未初始化的控件。
2、mSocket.getLocalPort()方法返回的是int類型，使用equals比較時要注意加雙引號""，以轉換成String類型，否則IDE不會編譯報錯，但結果并未如意。
3、使用UDP端口容易混亂：讀者在開發(fā)過程中應盡量避免更新UI時整體刪除再添加剩余項，而改用“只刪除關閉項，只增加新增項”，前種方法在開發(fā)過程中容易造成端口混亂。同時，筆者建議讀者在涉及JList操作時，多用ArrayList替代HashMap存儲，因為ArrayList是插入有序的，能減少混亂的發(fā)生。
4、注意在視圖model中刪除了項，也要同時在列表List中刪除對應項，以做到真正的刪除，而不是假刪除。
5、刪除List中的所有項：
for(int i=0;i
注意！這里不能添加i++，因為每次remove后，list.size()會自動減小，如果添加了i++，則不能完全刪除List中的元素，從而導致二次混亂
最后，筆者在github上給出了兩次實驗的Demo源碼，供讀者學習和思考，感謝關注！
總結
以上是生活随笔為你收集整理的java 监听udp_Java实现Udp网络编程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 前端学习（2879）：实现v-if和v-
- 下一篇： java美元兑换,（Java实现） 美元