在線咨詢：兩個人都可以是發送方，也可以是接收方，實現網上在線咨詢正常通信。

聊天發送線程

package chat;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetSocketAddress;import java.net.SocketException;/** * 聊天發送線程： * 重寫 run 方法通過 implements 關鍵字實現 Runnable 接口 * 重寫方法快捷鍵：Ctrl + O */public class TalkSend implements Runnable { DatagramSocket socket = null; BufferedReader reader = null; private int fromPort; //從哪個端口 private String toIP; //到哪個地址 private int toPort; //到哪個端口 //構造：Alt + Insert public TalkSend(int fromPort, String toIP, int toPort) { this.fromPort = fromPort; this.toIP = toIP; this.toPort = toPort; //快捷鍵：Ctrl + Alt + T try { //構造一個數據報套接字并將其綁定到本地主機上的指定端口 socket = new DatagramSocket(fromPort); //準備數據：控制臺讀?。篠ystem.in reader = new BufferedReader(new InputStreamReader(System.in)); } catch (SocketException e) { e.printStackTrace(); } } @Override public void run() { while (true){ try { String data = reader.readLine(); byte[] dataBytes = data.getBytes(); DatagramPacket packet = new DatagramPacket(dataBytes, 0 , dataBytes.length, new InetSocketAddress(this.toIP, this.toPort)); //發送數據包 socket.send(packet); //當發送一句 bye 的時候表示結束發送 if (data.equals('bye')){ break; } } catch (IOException e) { e.printStackTrace(); } } //關閉 socket.close(); }}

聊天接收線程

package chat;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.SocketException;/** * 聊天接收線程： * 重寫 run 方法通過 implements 關鍵字實現 Runnable 接口 * 重寫方法快捷鍵：Ctrl + O */public class TalkReceive implements Runnable { DatagramSocket socket = null; private int port; private String msgFrom; //構造 public TalkReceive(int port, String msgFrom) { this.port = port; this.msgFrom = msgFrom; try { socket = new DatagramSocket(port); } catch (SocketException e) { e.printStackTrace(); } } @Override public void run() { while (true){ try { //準備接收數據包 byte[] container = new byte[1024]; DatagramPacket packet = new DatagramPacket(container, 0, container.length); //接收數據包 socket.receive(packet); //阻塞式接收包裹 //讀取數據 byte[] data = packet.getData(); String receiveData = new String(data, 0, data.length); //接收到的數據 System.out.println(msgFrom + '：' + receiveData); //當我們說一聲 bye 的時候就表示斷開連接 if (receiveData.equals('bye')){ break; } } catch (IOException e) { e.printStackTrace(); } } //關閉 socket.close(); }}

學生端

package chat;/** * 學生端 */public class TalkStudent { public static void main(String[] args) { /** * 學生端 * 從 7777 端口發送消息 * 發送消息到 9999 端口 * 從 8888 端口接收消息 * * 開啟兩個線程： * new TalkSend：從 77777 端口發送,發送到 localhost,發送給 9999 端口 * @param fromPort * @param toIP * @param toPort * * new TalkReceive：從 8888 端口接收,接收來自 “老師” 的消息 * @param port * @param msgFrom * * 使用了一種模式：靜態代理模式 */ new Thread(new TalkSend(7777, 'localhost', 9999)).start(); new Thread(new TalkReceive(8888, '老師')).start(); }}

老師端

package chat;/** * 老師端 */public class TalkTeacher { public static void main(String[] args) { /** * 老師端 * 從 5555 端口發送消息 * 發送消息到 8888 端口 * 從 9999 端口接收消息 * * 開啟兩個線程： * new TalkSend：從 5555 端口發送,發送到 localhost,發送給 8888 端口 * @param fromPort * @param toIP * @param toPort * * new TalkReceive：從 9999 端口接收,接收來自 “學生” 的消息 * @param port * @param msgFrom * * 使用了一種模式：靜態代理模式 */ new Thread(new TalkSend(5555, 'localhost', 8888)).start(); new Thread(new TalkReceive(9999, '學生')).start(); }}

效果一覽

以上就是java實現的多線程實現在線咨詢(udp)的詳細內容，更多關于java 在線咨詢的資料請關注好吧啦網其它相關文章！