黑马程序员技术交流社区

标题: 关于TCP客户端并发登陆的疑问 [打印本页]
作者: 高丽华    时间: 2014-1-14 13:24
标题: 关于TCP客户端并发登陆的疑问
  1. <p>import java.net.*;
  2. import java.io.*;
  3. class SocketLogin
  4. {
  5.         public static void main(String[] args) throws Exception
  6.         {
  7.                 Socket s=new Socket("127.0.0.1",10009);

  9.                 BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));

  11.                 PrintWriter out=new PrintWriter(s.getOutputStream());
  12.                
  13.                 BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));

  15.                 for (int x=0;x<3;x++)
  16.                 {
  17.                         String line=bufr.readLine();

  19.                         if(line==null)
  20.                                 break;
  21.                         out.println(line);

  23.                         String info=bufrin.readLine();
  24.                         System.out.println("info:"+info);
  25.                         if(info.contains("欢迎"))
  26.                                 break;
  27.                        
  28.                 }
  29.                 bufr.close();
  30.                 s.close();
  31.         }
  32. }
  33. class ServerSocketLogin
  34. {
  35.         public static void main(String[] args)throws Exception
  36.         {
  37.                 ServerSocket ss=new ServerSocket(10009);
  38.                 while(true)
  39.                 {
  40.                         Socket s=ss.accept();
  41.                         new Thread(new LoginThread(s)).start();
  42.                 }
  43.         }
  44. }
  45. class LoginThread implements Runnable
  46. {
  47.         private Socket s;
  48.         LoginThread(Socket s)
  49.         {
  50.                 this.s=s;
  51.         }
  52.         public void run()
  53.         {
  54.                 String ip=s.getInetAddress().getHostAddress();
  55.                 System.out.println(ip+"......connected");
  56.                
  57.                 try
  58.                 {
  59.                         for (int x=0;x<3 ;x++ )
  60.                         {
  61.                                 BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));
  62.                                 String name=bufrin.readLine();
  63.                                 BufferedReader bufr=new BufferedReader(new FileReader("user.txt"));
  64.                                 PrintWriter out=new PrintWriter(s.getOutputStream(),true);
  65.                                 String line=null;
  66.                                 boolean flag=false;
  67.                                 while ((line=bufr.readLine())!=null)
  68.                                 {
  69.                                         if(line.equals(name))
  70.                                         {
  71.                                                 flag=true;
  72.                                                 break;
  73.                                         }
  74.                                 }
  75.                                 if (false)
  76.                                 {
  77.                                         System.out.println(name+",已登陆");
  78.                                         out.println(name+",欢迎光临");</p><p> }
  79.                                 else
  80.                                 {
  81.                                         System.out.println(name+",尝试登录");
  82.                                         out.println(name+"，用户名不存在");
  83. }
  84. }
  85.                         s.close();
  86.                 }
  87.                 catch (Exception e)
  88.                 {
  89.                         throw new RuntimeException(ip+"校验失败");
  90.                 }
  91.         }
  92. }</p><p>为什么运行不了，纠结呀！！</p>
复制代码

作者: 几番意难相付    时间: 2014-1-14 13:55
研究了一下你的代码，两个问题。
第一个 读取完客户端输入的信息后，并没有刷新流，导致服务端没有收到数据。
解决办法 在第22行后加上out.flush();
第二个 第75行 if(false)是什么意思？我猜你是想判断定义的flag标记是否为真吧？
解决办法 把if(false)改成 if(flag)


完整代码给你重发一下
  1. import java.net.*;
  2. import java.io.*;
  3. class SocketLogin
  4. {
  5.         public static void main(String[] args) throws Exception
  6.         {
  7.                 Socket s=new Socket("127.0.0.1",10009);

  9.                 BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));

  11.                 PrintWriter out=new PrintWriter(s.getOutputStream());
  12.                
  13.                 BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));

  15.                 for (int x=0;x<3;x++)
  16.                 {
  17.                         String line=bufr.readLine();

  19.                         if(line==null)
  20.                                 break;
  21.                         out.println(line);
  22.                                                 out.flush();
  23.                         String info=bufrin.readLine();
  24.                         System.out.println("info:"+info);
  25.                         if(info.contains("欢迎"))
  26.                                 break;
  27.                         
  28.                 }
  29.                 bufr.close();
  30.                 s.close();
  31.         }
  32. }








  41. class ServerSocketLogin
  42. {
  43.         public static void main(String[] args)throws Exception
  44.         {
  45.                 ServerSocket ss=new ServerSocket(10009);
  46.                 while(true)
  47.                 {
  48.                         Socket s=ss.accept();
  49.                         new Thread(new LoginThread(s)).start();
  50.                 }
  51.         }
  52. }



  56. class LoginThread implements Runnable
  57. {
  58.         private Socket s;
  59.         LoginThread(Socket s)
  60.         {
  61.                 this.s=s;
  62.         }
  63.         public void run()
  64.         {
  65.                 String ip=s.getInetAddress().getHostAddress();
  66.                 System.out.println(ip+"......connected");
  67.                 try
  68.                 {
  69.                         for (int x=0;x<3 ;x++ )
  70.                         {
  71.                                 BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));
  72.                                 String name=bufrin.readLine();
  73.                                 BufferedReader bufr=new BufferedReader(new FileReader("user.txt"));
  74.                                 PrintWriter out=new PrintWriter(s.getOutputStream(),true);
  75.                                 String line=null;
  76.                                 boolean flag=false;
  77.                                 while ((line=bufr.readLine())!=null)
  78.                                 {
  79.                                                                         System.out.println("line="+line);
  80.                                         if(line.equals(name))
  81.                                         {
  82.                                                 flag=true;
  83.                                                 break;
  84.                                         }
  85.                                 }
  86.                                 if (flag)
  87.                                 {
  88.                                         System.out.println(name+",已登陆");
  89.                                         out.println(name+",欢迎光临");
  90.                                                                                 return;
  91.                                                                                 }
  92.                                 else
  93.                                 {
  94.                                         System.out.println(name+",尝试登录");
  95.                                         out.println(name+"，用户名不存在");
  96. }
  97. }
  98.                         s.close();
  99.                 }
  100.                 catch (Exception e)
  101.                 {
  102.                         throw new RuntimeException(ip+"校验失败");
  103.                 }
  104.         }
  105. }
复制代码

作者: 范二青年    时间: 2014-1-14 13:58
能成功就怪了，你这写了个if(false)怎么可能进得去判断？ 用if(flag)啊！！！！！
  1.   if (false)
  2.                                 {
  3.                                         System.out.println(name+",已登陆");
  4.                                         out.println(name+",欢迎光临"); }
  5.                                 else
  6.                                 {
  7.                                         System.out.println(name+",尝试登录");
  8.                                         out.println(name+"，用户名不存在");
  9.                                 }
复制代码
作者: 汪伟楠    时间: 2014-1-14 16:31
class SocketLogin
{
        public static void main(String[] args) throws Exception
        {
                Socket s=new Socket("127.0.0.1",10009);

                BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));

                PrintWriter out=new PrintWriter(s.getOutputStream());
               
                BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));

                for (int x=0;x<3;x++)
                {
                        String line=bufr.readLine();

                        if(line==null)
                                break;
                        out.println(line);

                        String info=bufrin.readLine();
                        System.out.println("info:"+info);
                        if(info.contains("欢迎"))
                                break;
                       
                }
                bufr.close();
                s.close();
        }
}
class ServerSocketLogin
{
        public static void main(String[] args)throws Exception
        {
                ServerSocket ss=new ServerSocket(10009);
                while(true)
                {
                        Socket s=ss.accept();
                        new Thread(new LoginThread(s)).start();
                }
        }
}
class LoginThread implements Runnable
{
        private Socket s;
        LoginThread(Socket s)
        {
                this.s=s;
        }
        public void run()
        {
                String ip=s.getInetAddress().getHostAddress();
                System.out.println(ip+"......connected");
               
                try
                {
                        for (int x=0;x<3 ;x++ )
                        {
                                BufferedReader bufrin=new BufferedReader(new InputStreamReader(s.getInputStream()));
                                String name=bufrin.readLine();
                                BufferedReader bufr=new BufferedReader(new FileReader("user.txt"));
                                PrintWriter out=new PrintWriter(s.getOutputStream(),true);
                                String line=null;
                                boolean flag=false;
                                while ((line=bufr.readLine())!=null)
                                {
                                        if(line.equals(name))
                                        {
                                                flag=true;
                                                break;
                                        }
                                }
                                if (false)
                                {
                                        System.out.println(name+",已登陆");
                                        out.println(name+",欢迎光临");
                                                break;
                                }
                                else
                                {
                                        System.out.println(name+",尝试登录");
                                        out.println(name+"，用户名不存在");
                                        break;
                                }
                               
                        }
                        s.close();
                }
                catch (Exception e)
                {
                        throw new RuntimeException(ip+"校验失败");
                }
        }
}
是不是这两处少了break，我这个程序，你运行试试



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