黑马程序员技术交流社区

标题: 关于并发访问的一个问题 [打印本页]
作者: 徐帅    时间: 2012-10-16 16:04
标题: 关于并发访问的一个问题

我先启动了服务端，然后服务端刚启动，还未等键盘录入，就执行完毕，抛出throw new RuntimeException(ip+"检验失败");

readLine( ) 应该是阻塞，服务端要等到客户端键盘录入数据并传入到服务端，才能继续向下执行，为什么这里直接结束了呢？找了半天，不知道哪里
出了问题，请大侠帮忙看看，谢谢了
  1. package cn.it.xushuai.netProgram;

  3. import java.io.BufferedReader;
  4. import java.io.FileReader;
  5. import java.io.IOException;
  6. import java.io.InputStreamReader;
  7. import java.io.PrintWriter;
  8. import java.net.ServerSocket;
  9. import java.net.Socket;
  10. import java.net.UnknownHostException;


  13. class LoginClient{
  14.        
  15.         public static void main(String[] args) throws UnknownHostException, IOException{
  16.                
  17.                 System.out.println("Client...........run");
  18.                
  19.                 Socket s  = new Socket("127.0.0.1",10012);
  20.                
  21.                 //需要明确3个流：键盘录入，读取服务端，写入服务端
  22.                 BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
  23.                
  24.                 PrintWriter out = new PrintWriter(s.getOutputStream(),true);        //向服务端传送数据
  25.                
  26.                 BufferedReader bufrIn = new BufferedReader(new InputStreamReader(s.getInputStream()));//获取服务端反馈的信息
  27.                
  28.                 for(int i=0;i<3;i++){        //向服务端提交数据，最多3次机会
  29.                        
  30.                         String line = bufr.readLine();        //从键盘读取数据
  31.                         if(line==null)
  32.                                 break;
  33.                        
  34.                         out.println(line);        //向服务端传送键盘录入的数据
  35.                        
  36.                         String info = bufrIn.readLine();                //读取服务端返回的信息，并做判断               
  37.                         System.out.println("info"+info);       
  38.                         if(info.contains("欢迎"))        //如果 登陆成功， 跳出循环
  39.                                 break;
  40.                 }
  41.                 bufr.close();
  42.                 s.close();
  43.                
  44.         }
  45. }

  47. class UserThread implements Runnable{

  49.         private Socket s ;
  50.         UserThread(Socket s ){
  51.                
  52.                 this.s = s ;
  53.         }
  54.        
  55.         @Override
  56.         public void run() {
  57.                 // TODO Auto-generated method stub
  58.                
  59.                         //明确3个流：接收客户端、输出、 以及读取数据库
  60.                        
  61.                         String ip = s.getInetAddress().getHostAddress();
  62.                
  63.                         System.out.println("userThread........run");
  64.                         System.out.println(ip+"........connected");
  65.                
  66.                 try {

  68.                         for(int i=0;i<3;i++){
  69.                                
  70.                                 BufferedReader bufrIn =
  71.                                                 new BufferedReader(new InputStreamReader(s.getInputStream()));
  72.                                
  73.                                 BufferedReader bufr = new BufferedReader(new FileReader("user.txt"));
  74.                                 PrintWriter out = new PrintWriter(s.getOutputStream(),true);
  75.                                
  76.                                 String userName = bufrIn.readLine();        //读取客户端发送的数据

  78.                                         String line = null;
  79.                                        
  80.                                         boolean flag = false;
  81.                                         while((line = bufr.readLine())!=null){
  82.                                                
  83.                                                 if(line.equals(userName)){               
  84.                                                         flag = true;
  85.                                                         break;
  86.                                                         }
  87.                                                
  88.                                                 }
  89.                                        
  90.                                         if(flag){
  91.                                                 System.out.println(userName+",已登陆");
  92.                                                 out.println(userName+"登陆成功，欢迎您！");                        //向客户端反馈数据
  93.                                                 break;
  94.                                         }
  95.                                         else{
  96.                                                
  97.                                                 System.out.println(userName+",尝试登陆");
  98.                                                 out.println(userName+",用户名不存在");
  99.                                         }                               
  100.                                 }
  101.                                 s.close();               
  102.                                 } catch (IOException e) {
  103.                                         throw new RuntimeException(ip+"检验失败");
  104.                                 }
  105.                        
  106.         }}

  108. class  LoginServer
  109. {
  110.         public static void main(String[] args) throws Exception
  111.         {
  112.                 System.out.println("server run..........");
  113.                 ServerSocket ss = new ServerSocket(10012);

  115.                 while(true)
  116.                 {
  117.                         Socket s = ss.accept();

  119.                         new Thread(new UserThread(s)).start();
  120.                 }
  121.         }
  122. }
复制代码
user.txt :
zhangsan
lisi
wangwu





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