java基础23天，模拟UDP聊天，在本人机子上为什么不能运行？ - 黑马程序员技术交流社区

import java.io.*;
import java.net.*;
class Send implements Runnable
{
private DatagramSocket ds;
Send(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while ((line=br.readLine())!=null)
{
if(!line.equals("886"))
break;
byte[] buff = line.getBytes();
DatagramPacket dp = new DatagramPacket(buff,buff.length,InetAddress.getLocalHost(),54321);
ds.send(dp);
}
ds.close();
}
catch (Exception e)
{
throw new RuntimeException("传输失败");
}
}
}
class Receive implements Runnable
{
private DatagramSocket ds;
Receive(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
while (true)
{
byte[] buff = new byte[1024];
DatagramPacket dp = new DatagramPacket(buff,buff.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());
System.out.println(ip+"::"+data);
}
}
catch (Exception e)
{
throw new RuntimeException();
}
}
}
class ChatDemo
{
public static void main(String[] args) throws Exception
{
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receiveSocket = new DatagramSocket(54321);
new Thread(new Send(sendSocket)).start();
new Thread(new Receive(receiveSocket)).start();
}
}

复制代码