在并发上传图片的程序中遇到的关于死循环的问题 - 黑马程序员技术交流社区

/*
需求:
通过TCP的Socket和ServerSocket,向服务端上传图片;
*/
import java.io.*;
import java.net.*;
class SocketClient
{
public static void main(String[] args)
{
File file=new File("yuanye.jpg");
if (!file.exists())
{
throw new RuntimeException("你所关联的图片不存在");
}
BufferedInputStream bufi=null;
try
{
bufi=new BufferedInputStream(new FileInputStream(file));
}
catch (FileNotFoundException fe)
{
throw new RuntimeException("您所关联的文件不存在");
}
Socket s=null;
try
{
s=new Socket("192.168.0.4",10000);
}
catch (UnknownHostException ue)
{
throw new RuntimeException("你说要连接的服务器地址有误");
}
catch (IOException ie)
{
throw new RuntimeException("套接字建立失败");
}
BufferedOutputStream bufo=null;
try
{
bufo=new BufferedOutputStream(s.getOutputStream());
byte[] buf=new byte[1024];
int len=0;
while ((len=bufi.read(buf))!=-1)
{
bufo.write(buf,0,len);
bufo.flush();
} //为什么这会变成死循环啊???
System.out.println("到这里..............");
s.shutdownOutput();
byte[] b=new byte[1024];
int num=s.getInputStream().read(b);
System.out.println(new String(b,0,num));
}
catch (IOException ie)
{
throw new RuntimeException("文件上传失败");
}
}
}
class ClientThread implements Runnable
{
private Socket s;
public ClientThread(Socket s)
{
this.s=s;
}
public void run()
{
File file=new File("yuanye复件.jpg");
InputStream is=null;
try
{
is=s.getInputStream();
}
catch (IOException ie)
{
throw new RuntimeException("获取用户端读取流失败");
}
BufferedOutputStream bufo=null;
try
{
bufo=new BufferedOutputStream(new FileOutputStream(file));
byte[] buf=new byte[1024];
int len=0;
while ((len=is.read(buf))!=-1)
{
bufo.write(buf,0,len);
bufo.flush();
}
OutputStream os=s.getOutputStream();
os.write("上传成功".getBytes());
}
catch (IOException ie)
{
throw new RuntimeException("文件上传失败");
}
finally
{
try
{
if (bufo!=null)
{
bufo.close();
}
}
catch (IOException i)
{
throw new RuntimeException("输出流关闭失败");
}
try
{
s.close();
}
catch (IOException i)
{
throw new RuntimeException("关闭客户端失败");
}
}
}
}
class SocketServer
{
public static void main(String[] args) throws Exception
{
ServerSocket ss=new ServerSocket(10000);
while (true)
{
Socket s=ss.accept();
new Thread(new ClientThread(s));
}
}
}

复制代码