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网络编程的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： python 字典取值加引号创建一个对象
- 下一篇： java quartz timer_Ja