本文實例為大家分享了java使用UDP模式編寫聊天程序的具體代碼，供大家參考，具體內容如下
Java代碼：
/* 使用UDP模式,編寫一個聊天程序有發送和接收數據2部分, 一個線程接收,一個線程發送由於發送和接收動作是不一致的,所以要使用2個run方法而且這兩個方法要封裝到不同的類中本程序忽略了部分異常的處理,也未加入UI組件這樣比較簡潔發送端口9998 接受端口9999 用的是局域網廣播地址,所以自己發的消息自己也收到了[示例]:簡易控制台聊天程序*/ import java.net.*; import java.io.*; class Demo { public static void main(String[] args) throws Exception { DatagramSocket sendSocket = new DatagramSocket(9998); //發送端DatagramSocket receSocket = new DatagramSocket(9999); //接收端new Thread(new MsgSend(sendSocket)).start(); //發送線程new Thread(new MsgRece(receSocket)).start(); //接受線程} } class MsgSend implements Runnable //發送{ private DatagramSocket dsock; public MsgSend(DatagramSocket dsock) { this.dsock= dsock; } public void run() { BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in)); String lineStr = null; try { while(true) { lineStr = bufr.readLine(); if(lineStr!=null) { if(lineStr.equals("over886")) { break; } else { byte[] dataBuf = lineStr.getBytes(); DatagramPacket dataPack = //數據打包new DatagramPacket( dataBuf, dataBuf.length, InetAddress.getByName("192.168.1.255"), //廣播9999 //目標端口); dsock.send(dataPack); } } } bufr.close(); dsock.close(); } catch(Exception e) { throw new RuntimeException("發送失敗!"); } } } class MsgRece implements Runnable //接收{ private DatagramSocket dsock; public MsgRece(DatagramSocket dsock) { this.dsock= dsock; } public void run() { try { while(true) { byte[] dataBuf = new byte[1024]; DatagramPacket dataPack = new DatagramPacket(dataBuf,dataBuf.length); dsock.receive(dataPack); //將獲取的數據保存到指定的數據包String ip = dataPack.getAddress().getHostAddress(); String data = new String(dataPack.getData(),0,dataPack.getLength()); int port = dataPack.getPort(); System.out.println(); System.out.println("來自ip為"+ip+" <對方端口>: "+port+" 的消息"); System.out.println(data); } } catch(Exception e) { throw new RuntimeException("接受失敗!"); } finally { dsock.close(); } } }以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。