UDP协议的聊天程序，使用两个线程分别发生和接收,却出错... - 黑马程序员技术交流社区

package day23;
import java.io.*;
import java.net.*;
//1发送线程类
class Send implements Runnable {
private DatagramSocket ds;
private InetAddress ip;
private int port;
public Send(DatagramSocket ds,InetAddress ip,int port) {
this.ds = ds;
this.ip=ip;
this.port=port;
}
@Override
public void run() {
SendAndRece sr = new SendAndRece();
sr.send(ds,ip,port);
}
}
// 2接收线程类
class Rece implements Runnable {
private DatagramSocket ds;
public Rece(DatagramSocket ds) {
this.ds = ds;
}
@Override
public void run() {
SendAndRece sr = new SendAndRece();
sr.rece(ds);
}
}
// 4主调程序
public class ChatDemo {
/**
* @param args
*/
public static void main(String[] args) {
// ①发送的DatagramSocket,加上端口
try {
//目的地址和端口号
InetAddress ip = InetAddress.getByName("127.0.0.1");
int port=10001;
DatagramSocket dss = new DatagramSocket();
new Thread(new Send(dss,ip,port)).start();
// ②接收端DatagramSocket,加上端口
DatagramSocket dsr=new DatagramSocket(10001);
new Thread(new Rece(dsr)).start();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
// 3业务类:定义一个类，两方法：发送和接收
class SendAndRece {
// ①发送业务：发送udpsocket+目的地ip+目的端口
public void send(DatagramSocket ds, InetAddress ip,int port) {
try {
// 从键盘录入数据
BufferedReader bufr = new BufferedReader(new InputStreamReader(
System.in));
// 循环往bufr里面如
String line = null;
while ((line = bufr.readLine()) != null) {
if (line.equals("886")) {
break;
}
// 将数据封装到DatagramPacket
byte[] buf = line.getBytes();
DatagramPacket dp = new DatagramPacket(buf, buf.length, ip,
port);
ds.send(dp);
//发完一个，休息1秒
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.out.println("发送到失败");
e.printStackTrace();
}
}
ds.close();
} catch (Exception e) {
System.out.println(e);
}
}
// ②接收业务：接收udpSocket
public void rece(DatagramSocket ds) {
try {
while (true) {
// ①定义一个数据包
byte[] buf = new byte[1024 * 64];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
// ②将接收的数据包存放如dp中
ds.receive(dp);
// ③处理接收的数据
String ip = dp.getAddress().getHostAddress();
String data = new String(buf, 0, buf.length);
//System.out.println(data);
System.out.println(ip + ":" + data);
//收完一个，休息1秒
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.out.println("发送到失败");
e.printStackTrace();
}
}
} catch (Exception e) {
System.out.println(e);
}
}
}

复制代码