本文共 3891 字，大约阅读时间需要 12 分钟。
package com.cug.net03;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;public class ReceiveDemo { public static void main(String[] args) throws IOException { //接收端Socket DatagramSocket ds = new DatagramSocket(12306); byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf,buf.length); ds.receive(dp); System.out.println(dp.getAddress().getHostAddress()+ ","+new String(dp.getData(),0,dp.getLength())); ds.close(); }} package com.cug.net03;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;public class SendDemo { public static void main(String[] args) throws IOException { DatagramSocket ds = new DatagramSocket(); byte[] buf = "I Love you,Java!!!".getBytes(); DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("bluze"),12306); ds.send(dp); ds.close(); }} package com.cug.net04;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;public class ReceiveDemo { public static void main(String[] args) throws IOException { //接收端Socket DatagramSocket ds = new DatagramSocket(12306); while(true){ byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf,buf.length); ds.receive(dp); System.out.println(dp.getAddress().getHostAddress()+ ","+new String(dp.getData(),0,dp.getLength())); } // ds.close(); }} package com.cug.net04;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;public class SendDemo { public static void main(String[] args) throws IOException { DatagramSocket ds = new DatagramSocket(); while(true){ BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = br.readLine(); if(line.equals("886")){ break; } byte[] buf = line.getBytes(); DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("bluze"),12306); ds.send(dp); } ds.close(); }} package com.cug.net05;import java.net.DatagramSocket;import java.net.SocketException;public class ChatRoom { public static void main(String[] args) throws SocketException { DatagramSocket dsReceive = new DatagramSocket(12306); DatagramSocket dsSend = new DatagramSocket(); ReceiveThread rt = new ReceiveThread(dsReceive); SendThread st = new SendThread(dsSend); Thread t1 = new Thread(rt); Thread t2 = new Thread(st); t1.start(); t2.start(); }} package com.cug.net05;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;public class ReceiveThread implements Runnable { DatagramSocket ds; public ReceiveThread(DatagramSocket ds){ this.ds = ds; } @Override public void run() { try{ while(true){ byte[] buf = new byte[1024]; DatagramPacket dp = new DatagramPacket(buf,buf.length); ds.receive(dp); System.out.println(dp.getAddress().getHostAddress()+ ","+new String(dp.getData(),0,dp.getLength())); } }catch(IOException e){ e.printStackTrace(); } }} package com.cug.net05;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;public class SendThread implements Runnable { DatagramSocket ds; public SendThread(DatagramSocket ds){ this.ds = ds; } @Override public void run() { try{ while(true){ BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = br.readLine(); if(line.equals("886")){ break; } byte[] buf = line.getBytes(); DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("bluze"),12306); ds.send(dp); } ds.close(); }catch(IOException e){ e.printStackTrace(); } }} 转载地址：http://nmhkb.baihongyu.com/