黑马程序员技术交流社区

标题: 图片上传服务器端read方法阻塞 [打印本页]

---

作者: 李靖    时间: 2012-10-26 19:32
标题: 图片上传服务器端read方法阻塞
查看read如下：
public abstract int read(char[] cbuf,                         int off,                         int len)                  throws IOException将字符读入数组的某一部分。在某个输入可用、发生 I/O 错误或者到达流的末尾前，此方法一直阻塞。
下面上传图片的代码，张孝祥老师说服务器端无法识别结束标示，这个无法识别应该是某个输入可用。因为通过 sk.shutdownOutput () 就可以禁用此套接字的输出流,而客户端的输出流正好对应服务器端的输入流的。因为如果不用sk.shutdownOutput()的话，就表示客户端在使用着输出流，所以服务器端的read()方法一直处于阻塞。
import java.net.*;
import java.io.*;
class TCPClient{
public static void main(String[] args) throws Exception{
  Socket sk =new Socket();
  //通过connect方法连接
  sk.connect(new InetSocketAddress(InetAddress.getByName("192.168.1.100"),10009));
  //为了发送数据需要获得Socket流的输出流
  FileInputStream fis=new FileInputStream("1.gif");
  
  OutputStream ops=sk.getOutputStream();
  
  byte[] buf=new byte[1024];
  int len;
  while((len=fis.read(buf))!=-1){
   ops.write(buf, 0, len);
  }
  sk.shutdownOutput();
  InputStream ips=sk.getInputStream();
  byte[] bufr =new byte[1024];
  ips.read(bufr);
  String ref=new String(bufr,0,bufr.length);
  System.out.println(ref);
  fis.close();
  sk.close();
}}
/*
需求：定义端点接受数据并打印在控制台上
1.通过ServerSocket建立服务端Socket
2.获得客户端的对象。通过accept方法实现，这个方法是阻塞式的，没有连接就会等。
3，客户端如果发送过来数据，服务端需要用对于的客户端对象，用客户端对象会的输入流对象，并打印到控制台
4.关闭服务（可选操作）
*/
class TCPServe{
public static void main(String[] args) throws Exception{
  ServerSocket ss =new ServerSocket(10009);
  while(true){
  Socket sk =ss.accept();
  String ip =sk.getInetAddress().getHostAddress();
  FileOutputStream fos=new FileOutputStream("2.bmp");
  InputStream ips =sk.getInputStream();
  byte[] buf=new byte[1024];
  int len;
  while((len=ips.read(buf))!=-1){
   fos.write(buf, 0, len);
  }
  OutputStream out=sk.getOutputStream();
  out.write("上传成功".getBytes());
  sk.close();
  }

}}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2