//UDP協議簡單實現-----Server
package UDP;import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; import java.nio.ByteBuffer;public class UdpServer implements Runnable {private int port;public UdpServer(int port) {this.port = port;}public void run() {try {// listening at port for udp requestDatagramSocket server = new DatagramSocket(new InetSocketAddress(port));byte[] bs = new byte[4];ByteBuffer bbuf = null;DatagramPacket data = new DatagramPacket(bs, bs.length);server.setSoTimeout(1000 * 10); // set timeoutwhile (true) { // 一直監聽 server.receive(data);bbuf = ByteBuffer.wrap(bs, 0, 4);String s = "receive " + data.getData().length + " byte data,value: " + bbuf.getInt();System.out.println(s);}} catch (Exception e) {e.printStackTrace();}}public static void main(String[] args) {new Thread(new UdpServer(11111)).start();} }

?

//客戶端實現;

package UDP;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetSocketAddress;public class UdpClient implements Runnable {private int port;public UdpClient(int port) {this.port = port;}public void run() {try {DatagramSocket client = new DatagramSocket();byte[] bs = new byte[4];InetSocketAddress isa = new InetSocketAddress("localhost", port);DatagramPacket data = new DatagramPacket(bs, bs.length);data.setSocketAddress(isa);for (int i = 0; i < 10; i++) {data.setData(int2bytes(i));client.send(data);}} catch (Exception e) {e.printStackTrace();}}static byte[] int2bytes(int num) {byte[] b = new byte[4];for (int i = 0; i < 4; i++) {b[i] = (byte) (num >>> (24 - i * 8));}return b;}}

?

?

//測試代碼;

package UDP;public class Test {public static void main(String[] args) throws InterruptedException {int port = 11111;try{new Thread(new UdpServer(port)).start();new Thread(new UdpClient(port)).start();}catch(Exception e){//e.printStackTrace(); }} }

?

轉載于:https://www.cnblogs.com/qianyukun/p/4308785.html

總結

以上是生活随笔為你收集整理的java,UDP协议简单实现的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。