UDP问题求助! 高手指点下 , 谢谢! - 黑马程序员技术交流社区

class Fasong implements Runnable
{
public void run()
{
try
{
DatagramSocket ds=new DatagramSocket();
byte []b=new byte[1024];
InputStream is=new FileInputStream("D:\\截图.bmp");
int len;
while((len=is.read(b))!=-1)
{
DatagramPacket dp=new DatagramPacket(b,len,InetAddress.getByName("192.168.1.106"),50012);
ds.send(dp);
Thread.sleep(1);
}
b="over".getBytes();
DatagramPacket dp=new DatagramPacket(b,"over".length(),InetAddress.getByName("192.168.1.106"),50012);
ds.send(dp);
ds.close();
is.close();
System.out.println("传输完毕!");
} catch (Exception e) {
e.printStackTrace();
}
}
}
class Jieshou implements Runnable
{
public void run()
{
try
{
DatagramSocket ds=new DatagramSocket(50012);
byte []b=new byte [1024];
OutputStream os=new FileOutputStream("D:\\截图备份.bmp");
while(true)
{
DatagramPacket dp=new DatagramPacket(b,b.length);
ds.receive(dp);
if(new String(b).contains("over"))
{
break;
}
os.write(b);
}
System.out.println("接收完毕!");
ds.close();
os.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class Demo
{
public static void main(String[] args)throws Exception
{
new Thread(new Jieshou()).start();
Thread.sleep(100);
new Thread(new Fasong()).start();
}
}

复制代码

复制代码