DatagramSocket数据报加强版，实现聊天功能

创建一个线程类（用来执行接收数据的操作）

public class SoketRead extends Thread{

//声明一个数据报
private DatagramSocket socket;
//声明一个数据包
private DatagramPacket packet;
private byte[] b;
//读取数据包
@Override
public void run() {
//通过循环读数据包
while(true){
try {
//读数据包
socket.receive(packet);
//获取数据包里面的内容
b=Arrays.copyOfRange(packet.getData(), 0, packet.getLength());
//如果内容>0就转成字符串打印到控制台
if(b.length>0){
System.out.println(new String(b));
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

//通过构造函数实例化数据包和数据报和字节数组
public SoketRead(DatagramPacket packet,DatagramSocket socket,byte[] b){
this.packet=packet;
this.socket=socket;
this.b=b;
}

}

再创建两个线程类来执行发送数据（因为发送地址不一样，所以必须创建两个）
public class ServerWrite extends Thread{

//声明一个数据报
private DatagramSocket socket;
//声明一个数据包
private DatagramPacket packet;
private byte[] b;

//读取数据包
@Override
public void run() {
//声明一个流对象用来获取打印台的数据
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
while(true){
try {
//获取打印台的数据
System.out.println("服务端：请输入：");
String str=bf.readLine();
//把数据转成字节
b=str.getBytes();
//把数据放到包里面，设置好包的发送地址和端口
packet=new DatagramPacket(b,b.length,InetAddress.getLocalHost(),7777);
//通过数据报发送包
socket.send(packet);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

//通过构造函数实例化数据包和数据报和字节数组
public ServerWrite(DatagramPacket packet,DatagramSocket socket,byte[] b){
this.packet=packet;
this.socket=socket;
this.b=b;
}

}

public class SoketWrite extends Thread{

//声明一个数据报
private DatagramSocket socket;
//声明一个数据包
private DatagramPacket packet;
private byte[] b;

//读取数据包
@Override
public void run() {
//声明一个流对象用来获取打印台的数据
BufferedReader bf=new BufferedReader(new InputStreamReader(System.in));
while(true){
try {
//获取打印台的数据
System.out.println("服务端:请输入：");
String str=bf.readLine();
//把数据转成字节
b=str.getBytes();
//把数据放到包里面，设置好包的发送地址和端口
packet=new DatagramPacket(b,b.length,InetAddress.getLocalHost(),6666);
//通过数据报发送包
socket.send(packet);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

//通过构造函数实例化数据包和数据报和字节数组
public SoketWrite(DatagramPacket packet,DatagramSocket socket,byte[] b){
this.packet=packet;
this.socket=socket;
this.b=b;
}

}

客户端数据报
public class Client {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub

//创建一个字节数组
byte[] b=new byte[10];
//创建一个字节数组
byte[] b2=new byte[1024];
try {
//声明并实例化数据报（发送数据包到指定服务器）
DatagramSocket socket=new DatagramSocket(
4000
);
//声明并实例化数据报(监听端口，获取数据)
DatagramSocket socket2=new DatagramSocket(7777);

//声明并实例化数据包（用来发送数据）
DatagramPacket packet=null;
//声明并实例化数据包（用来接收数据）
DatagramPacket packet2=new DatagramPacket(b,b.length);

//把数据包和数据报放到SoketWrite对象里面进行把数据包发送到服务器的操作
SoketWrite write=new SoketWrite(packet, socket, b);
//开启线程
write.start();

//把数据包和数据报放到SoketRead对象里面进行监听端口获取数据的操作
SoketRead read=new SoketRead(packet2, socket2, b2);
//开启线程
read.start();

} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

服务端数据报
public class Service {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
byte[] b=new byte[10];
byte[] b2=new byte[1024];
try {
//声明并实例化数据报（用来发送数据包到指定服务器）
DatagramSocket socket=new DatagramSocket();
//声明并实例化数据报(用来监听端口，获取数据)
DatagramSocket socket2=new DatagramSocket(6666);

//声明并实例化数据包（用来发送数据）
DatagramPacket packet=null;
//声明并实例化数据包（用来接收数据）
DatagramPacket packet2=new DatagramPacket(b,b.length);;

//把数据包和数据报放到SoketWrite对象里面进行把数据包发送到服务器的操作
ServerWrite write=new ServerWrite(packet, socket, b);
//开启线程
write.start();

//把数据包和数据报放到SoketRead对象里面进行监听端口获取数据的操作
SoketRead read=new SoketRead(packet2, socket2, b2);
//开启线程
read.start();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}