題目：假設(shè)Tom和Jerry利用Java UDP進(jìn)行聊天，請(qǐng)為他們編寫程序。具體如下：（1）、Tom和Jerry聊天的雙方都應(yīng)該具有發(fā)送端和接收端；（2）、利用DatagramSocket與DatagramPacket；（3）、實(shí)現(xiàn) java.lang.Runnable類，重寫 run()方法。

學(xué)過計(jì)網(wǎng)的都知道，利用三元組（ip地址，協(xié)議，端口）就可以標(biāo)識(shí)網(wǎng)絡(luò)的進(jìn)程了。而進(jìn)行通信我們直接運(yùn)用socket就可以了，首先需要知道是socket是什么，這部分可以參考這個(gè)大佬寫的博客。https://www.jb51.net/article/121601.htm實(shí)現(xiàn)一個(gè)客戶端，那么需要Tom和Jerry都可以實(shí)現(xiàn)接收和發(fā)送功能，分別用兩個(gè)線程啟動(dòng)。

接收線程Receive_Thread.java

package Chat_UDP;import java.io.IOException;import java.util.Date;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.text.SimpleDateFormat;public class Receive_Thread extends Thread { private static final int MAX_RECEIVE_BUFFER = 1024; private DatagramSocket server; private DatagramPacket packet; byte[] buffer = new byte[MAX_RECEIVE_BUFFER]; public Receive_Thread(DatagramSocket server) { this.server = server; packet = new DatagramPacket(buffer, buffer.length); } @Override public void run() { try { while(true) { //接收數(shù)據(jù)包 server.receive(packet); String s = new String(packet.getData(),packet.getOffset(),packet.getLength(),'UTF-8'); Date day=new Date(); SimpleDateFormat df = new SimpleDateFormat('yyyy-MM-dd HH:mm:ss'); if(packet.getPort() == 10001) System.out.println('Tom'+packet.getAddress()+' 說:'+s+'t'+df.format(day)); else{ System.out.println('Jerry'+packet.getAddress()+' 說 :'+s+'t'+df.format(day)); } packet.setLength(buffer.length); } } catch(IOException e) { System.out.println('IOException'); } }}

發(fā)送線程Send_Thread.java

package Chat_UDP;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;import java.net.InetSocketAddress;import java.util.Scanner;public class Send_Thread extends Thread{ //發(fā)送的socket端 private DatagramSocket sender = null; //待發(fā)送的目標(biāo)地址 private InetSocketAddress address = null; //從鍵盤輸入 Scanner scan = new Scanner(System.in); public Send_Thread(DatagramSocket sender,InetSocketAddress address) { this.sender = sender; this.address = address; } @Override public void run() { // TODO Auto-generated method stub try { while(true) { //輸入待發(fā)送的內(nèi)容 String input = scan.nextLine(); if(input.equals('exit')) break; byte[] data = null; data = input.getBytes('UTF-8'); //創(chuàng)建UDP數(shù)據(jù)報(bào) DatagramPacket pack = new DatagramPacket(data, data.length,address); sender.send(pack); } System.out.println('Exit!'); }catch(IOException e) { System.out.println('IOException'); } }}

聊天服務(wù)器Chat_Server.java

package Chat_UDP;//楊麗冰 201831064402import java.net.DatagramSocket;import java.net.InetSocketAddress;public class Chat_Server { private static final int DEST_PORT = 8888; private static final int SEND_PORT = 10001; private static final int RECE_PORT = 9000; private static final String IP = '127.0.0.1'; public static void main(String[] args) { try{ Send_Thread send_thread = null; Receive_Thread rece_thread = null; InetSocketAddress address = null; //創(chuàng)建待接受數(shù)據(jù)包的目的機(jī)的端口號(hào)和IP地址 address = new InetSocketAddress(IP, DEST_PORT); //創(chuàng)建發(fā)送的Socket端 DatagramSocket sendsocket = new DatagramSocket(SEND_PORT); //創(chuàng)建接受的Socket端 DatagramSocket recesocket = new DatagramSocket(RECE_PORT); //發(fā)送線程建立 send_thread = new Send_Thread(sendsocket, address); //接受線程的建立 rece_thread = new Receive_Thread(recesocket); send_thread.start(); rece_thread.start(); }catch(Exception e) { System.out.println('Exception!'); } }}

聊天客戶端 Chat_Client.java

package Chat_UDP;//楊麗冰 201831064402import java.net.DatagramSocket;import java.net.InetSocketAddress;public class Chat_Client {//聲明端口號(hào) private static final int DEST_PORT = 9000; private static final int SEND_PORT = 10000; private static final int RECE_PORT = 8888; private static final String IP = '127.0.0.1'; public static void main(String[] args) { try{ Send_Thread send_thread = null; Receive_Thread rece_thread = null; InetSocketAddress address = null; //創(chuàng)建待接受數(shù)據(jù)包的目的機(jī)的端口號(hào)和IP地址 address = new InetSocketAddress(IP, DEST_PORT); //創(chuàng)建發(fā)送的Socket端 DatagramSocket sendsocket = new DatagramSocket(SEND_PORT); //創(chuàng)建接受的Socket端 DatagramSocket recesocket = new DatagramSocket(RECE_PORT); //發(fā)送線程建立 send_thread = new Send_Thread(sendsocket, address); //接受線程的建立 rece_thread = new Receive_Thread(recesocket); send_thread.start(); rece_thread.start(); }catch(Exception e) { System.out.println('Exception!'); } }}

需要注意的時(shí)候運(yùn)行的時(shí)候需要同時(shí)運(yùn)行聊天服務(wù)器和客戶端，才能夠正常運(yùn)行。最終效果如下：

到此這篇關(guān)于java UDP實(shí)現(xiàn)一個(gè)聊天工具的文章就介紹到這了,更多相關(guān)java UDP聊天工具內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！