A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 张淼 中级黑马   /  2012-9-27 12:20  /  1112 人查看  /  1 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class UploadClient {
public static void main(String[] args) {
  Socket s = null;
  BufferedReader br = null;
  try {
   s = new Socket("192.168.1.100", 10001);
   br = new BufferedReader(new FileReader("a.txt"));
   PrintWriter pw = new PrintWriter(s.getOutputStream(), true);
   String line = null;
   while ((line = br.readLine()) != null) {
    pw.println(line);
   }
   BufferedReader brServer = new BufferedReader(new InputStreamReader(
     s.getInputStream()));
   String text = brServer.readLine();
   System.out.println("Server:" + text);
  } catch (UnknownHostException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   if (br != null) {
    try {
     br.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
   if (s != null) {
    try {
     s.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
  }
}
}
--------------------------上面是客户端,下面是服务端-------------------------------------------
import java.io.BufferedReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class UploadServer {
public static void main(String[] args) {
  ServerSocket ss = null;
  PrintWriter pw = null;
  try {
   ss = new ServerSocket(10001);
   Socket s = ss.accept();
   BufferedReader br = new BufferedReader(new InputStreamReader(
     s.getInputStream()));
   pw = new PrintWriter(new FileWriter("b.txt"), true);
   String line = null;
   while ((line = br.readLine()) != null) {
    pw.println(line);
   }
   PrintWriter pw2 = new PrintWriter(s.getOutputStream(), true);
   pw2.println("上传文件成功");
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   if (ss != null) {
    try {
     ss.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
  }
}
}

我的问题是:当先开启服务端,后开启客户端的情况下,没有任何反应。
上课的时候老师讲了,说是readLine()是阻塞式的,但是我还是没理解,具体两个程序是阻塞在了哪条语句呢,以及阻塞式是什么意思?应该怎么理解呢?

1 个回复

倒序浏览
    /*
    通常的,对一个文件描述符指定的文件或设备, 有两种工作方式: 阻塞 与非阻塞 。
    所谓阻塞方式的意思是指, 当试图对该文件描述符进行读写时, 如果当时没有东西可读,或者暂时不可写, 程序就进入等待 状态, 直到有东西可读或者可写为止。
    而对于非阻塞状态, 如果没有东西可读, 或者不可写, 读写函数马上返回, 而不会等待 。
    */
readLine()方法是阻塞式的方法,通过下列字符之一即可认为某行已终止:换行 ('\n')、回车 ('\r') 或回车后直接跟着换行。
但是你只是PrintWriter pw = new PrintWriter(s.getOutputStream(), true); 没有写换回或回车。
这个时候服务器短实际上是接受到客户端了,也就是服务器端运行到这里了String str = br.readLine(); 但是客户端这个时候已经运行完毕,并且关闭了连接。
所以就会出现异常。你PrintWriter pw = new PrintWriter(s.getOutputStream()+"\n",true)这样写试试。

回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马