一：引言

實現(xiàn)一方 到另一方可以發(fā)送信息，而另一方也能回復(fù)信息。這里用到了多線程，開辟兩條不同的執(zhí)行路徑，一個執(zhí)行接收信息，一個執(zhí)行發(fā)送信息，但其端口號 要對應(yīng) ，即一個發(fā)送端口，對應(yīng)一個接收端口。

二：上碼：

1：發(fā)送端類的實現(xiàn)

package com.wyj.three;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;/*** 發(fā)送端* * @author 86155**/ public class Demo12_talk發(fā)送02 implements Runnable{private DatagramSocket client;private BufferedReader reader;private int port;private int toport;private String toIP;public Demo12_talk發(fā)送02(int port,int toport,String toIP) {this.port = port;this.toport = toport;this.toIP = toIP;try {client = new DatagramSocket(port);reader = new BufferedReader(new InputStreamReader(System.in));} catch (SocketException e) {// TODO Auto-generated catch blocke.printStackTrace();}}@Overridepublic void run() {// TODO Auto-generated method stubwhile( true ) {String msg ;try {msg = reader.readLine();byte[] dates = msg.getBytes();// 3.封裝成 DatagramPacket 包裹 指定目的地 即Ip地址和端口DatagramPacket packet = new DatagramPacket(dates, 0,dates.length, new InetSocketAddress(this.toIP,this.toport));// 4.發(fā)送包裹 send(DatagramPacket p)client.send(packet);if(msg.equals("bye")) {break;}}catch( IOException e ) {e.printStackTrace();}}client.close();}}

2：接受端類的實現(xiàn)

package com.wyj.three;import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.SocketException;/*** 接收端* * * @author 86155**/ public class Demo11_talk接收端02 implements Runnable{DatagramSocket server;public Demo11_talk接收端02(int port) {try {server = new DatagramSocket(port);} catch (SocketException e) {// TODO Auto-generated catch blocke.printStackTrace();}}@Overridepublic void run() {// TODO Auto-generated method stubwhile(true) {byte [] container = new byte[1024*60];DatagramPacket packet = new DatagramPacket(container,container.length); // 3.阻塞式接受包裹 receive?(DatagramPacket p)try {server.receive(packet);//會有延遲byte[] dates = packet.getData();int len = packet.getLength();//得用packet的實際大小 String date = new String(dates,0,len);System.out.println(date);if( date.equals("bye")) {break;}} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}//釋放資源server.close();}}

3：具體的實現(xiàn)（老師與學(xué)生的交流）

package com.wyj.three; /*** 實現(xiàn)相互交流吧* * * @author 86155**/ public class Demo1_student {public static void main(String[] args) { new Thread(new Demo11_talk接收端02(9998)).start();//接受new Thread(new Demo12_talk發(fā)送02(5555, 9997, "localhost")).start();//發(fā)送} }

4：具體的實現(xiàn)（老師與學(xué)生的交流）

package com.wyj.three; /*** * 實現(xiàn)相互交流* * @author 86155**/ public class Demo2_teacher {public static void main(String[] args) {new Thread(new Demo12_talk發(fā)送02(8888, 9998, "localhost")).start();//發(fā)送new Thread(new Demo11_talk接收端02(9997)).start();//接受} }

不同的顏色代表接受端和發(fā)送端不相同(黑色代表接收端）

總結(jié)

以上是生活随笔為你收集整理的java当中用UDP实现相互交流的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。