黑马程序员技术交流社区

标题: 客户端第二次输入用户名会报异常，第一次不会，求解！ [打印本页]
作者: Adualtbird    时间: 2015-9-10 22:59
标题: 客户端第二次输入用户名会报异常，第一次不会，求解！
/*
需求：
在客户端，输入用户名，如果该用户名在系统数据库存在，则提示欢迎登陆，如果不存在，则提示用户不存在，每个IP限制登陆三次
*/
import java.io.*;
import java.net.*;
class LoginClient
{
        public static void main(String[] args)throws Exception
        {
                Socket s=new Socket("192.168.100.100",10001);
                String line=null;
                String info=null;
                        //创建客户端源为控制台的读入流
                BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
                        //创建打印流，将控制台读入的数据打印到网络输出流
                PrintWriter pw=new PrintWriter(s.getOutputStream(),true);
                        //创建带缓冲器的网络输入流，用来读取服务端反馈的数据
                BufferedReader bufin=new BufferedReader(new InputStreamReader(s.getInputStream()));
                while(true){
                        line=br.readLine();
               
                        if(line==null)
                                break;
                        if("over".equals(line))
                                break;
                        pw.println(line);
                        //将服务器端反馈的信息输出在控制台上
                        info=bufin.readLine();
                        System.out.println(info);
                        if(info.contains("欢迎"))
                                break;
                        
                        
                        //br.close();

                }
                s.close();
        
        }
}
class LoginServer
{
        public static void main(String[] args)throws Exception
        {
                //创建服务器端Socket服务
                ServerSocket ss=new ServerSocket(10001);
                while(true){
                        //当服务器端接收到一个客户端对象时，则开启一个子线程，处理客户端请求
                        Socket s=ss.accept();
                        new Thread(new LoginUser(s)).start();
                }
        }
}
class LoginUser implements Runnable
{
        private Socket s;
        LoginUser(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 brIn=new BufferedReader(new InputStreamReader(s.getInputStream()));

                                
                                //创建服务器端读取流缓冲器，关联文件读取流，来读取指定文件数据
                                BufferedReader br=new BufferedReader(new FileReader("D:\\Mysql.txt"));
                                //创建打印流，关联客户端网络输出流，来将反馈信息打印到网络输出流传递给客户端
                                PrintWriter pw=new PrintWriter(s.getOutputStream(),true);
                                String name=brIn.readLine();

                                String line=null;
                                //添加标记
                                boolean flag=false;
                                //判断客户端输入的用户名称，在服务器端数据库是否存在
                                while((line=br.readLine())!=null){
                                        if(name.equals(line)){
                                                flag=true;
                                                break;
                                        }
                                }
                                if(flag==true){
                                        System.out.println(name+"已登陆");
                                        pw.println(name+":欢迎登陆");
                                        break;
                                }
                                else{
                                        System.out.println(name+"：尝试登陆");
                                        pw.println(name+"用户不存在");
                                        break;
                                }
                        
                        }
                        s.close();
                }
                catch(Exception e){
                        throw new RuntimeException("用户校验失败");
                }
        }
}
服务器端主线程进来后就一直处于等待状态了，而客户端，我把while循环放在开始读控制台输入的地方，依然是不行，按理说如果客户端输入的用户名不符，客户端应该是可以再次输入的，因为客户端线程还没有断开，会去重复等待读控制台输入的内容，直到达到3次，才会被服务器端关闭socket，可是我运行第二次就抛异常了，很不解！
作者: Doug    时间: 2015-9-10 22:59
给你改了，自己看吧。
ps：我真无聊。。。
  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import java.io.PrintWriter;
  4. import java.net.Socket;

  6. class LoginClient {
  7.         public static void main(String[] args) throws Exception {
  8.                 Socket s = new Socket("127.0.0.1", 10001);

  10.                 String line = null;
  11.                 String info = null;

  13.                 // 创建客户端源为控制台的读入流
  14.                 BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

  16.                 // 创建打印流，将控制台读入的数据打印到网络输出流
  17.                 PrintWriter pw = new PrintWriter(s.getOutputStream(), true);

  19.                 // 创建带缓冲器的网络输入流，用来读取服务端反馈的数据
  20.                 BufferedReader bufin = new BufferedReader(new InputStreamReader(s.getInputStream()));

  22.                 while (true) {
  23.                         line = br.readLine();

  25.                         // if (line == null)
  26.                         // break;
  27.                         if ("over".equals(line)) {
  28.                                 s.shutdownOutput();
  29.                                 break;
  30.                         }

  32.                         pw.println(line);

  34.                         // 将服务器端反馈的信息输出在控制台上
  35.                         info = bufin.readLine();
  36.                         System.out.println(info);

  38.                         if (info.contains("欢迎"))
  39.                                 break;

  41.                         // br.close();
  42.                 }

  44.                 // br.close();
  45.                 // pw.close();
  46.                 // bufin.close();
  47.                 s.close();
  48.         }
  49. }


  52. import java.io.BufferedReader;
  53. import java.io.FileReader;
  54. import java.io.InputStreamReader;
  55. import java.io.PrintWriter;
  56. import java.net.Socket;

  58. public class LoginUser implements Runnable {
  59.         private static Socket s;
  60.         private static int count = 0;

  62.         public LoginUser(Socket s) {
  63.                 this.s = s;
  64.         }

  66.         public void run() {
  67.                 func();
  68.         }

  70.         synchronized public static void func() {
  71.                 String ip = s.getInetAddress().getHostAddress();
  72.                 System.out.println(ip + ":connected");
  73.                 try {
  74.                         // 创建服务端读取流缓冲器，关联网络输入流，来读取客户端输入的数据
  75.                         BufferedReader brIn = new BufferedReader(new InputStreamReader(s.getInputStream()));

  77.                         // 创建服务器端读取流缓冲器，关联文件读取流，来读取指定文件数据
  78.                         BufferedReader br = new BufferedReader(new FileReader("D:\\Mysql.txt"));

  80.                         // 创建打印流，关联客户端网络输出流，来将反馈信息打印到网络输出流传递给客户端
  81.                         PrintWriter pw = new PrintWriter(s.getOutputStream(), true);
  82.                         String name = brIn.readLine();

  84.                         String line = "";

  86.                         boolean flag = false;
  87.                         // 判断客户端输入的用户名称，在服务器端数据库是否存在
  88.                         while (true) {
  89.                                 while ((line = br.readLine()) != null) {
  90.                                         if (name.equals(line)) {
  91.                                                 flag = true;
  92.                                                 break;
  93.                                         }
  94.                                 }
  95.                                 if (flag == true) {
  96.                                         System.out.println(name + "已登陆");
  97.                                         pw.println(name + ":欢迎登陆");
  98.                                         break;
  99.                                 } else {
  100.                                         count++;
  101.                                         if (count < 3) {
  102.                                                 System.out.println(name + "：尝试登陆");
  103.                                                 pw.println(name + "用户不存在!");
  104.                                         } else {
  105.                                                 System.out.println(name + "：尝试登陆");
  106.                                                 System.out.println("该IP已出错三次，结束本次登录!");
  107.                                                 pw.println(name + "用户不存在!该IP已出错三次，结束本次登录!"); // 注意，无法发送两条信息，因为客户端设置的是先发再收，一次一条。

  109.                                                 s.shutdownOutput();
  110.                                                 break;
  111.                                         }
  112.                                 }
  113.                                 name = brIn.readLine();
  114.                         }

  116.                         s.close();
  117.                         count = 0;
  118.                 } catch (Exception e) {
  119.                         throw new RuntimeException("用户校验失败");
  120.                 }
  121.         }
  122. }
  123. import java.net.ServerSocket;
  124. import java.net.Socket;

  126. public class LoginServer {
  127.         public static void main(String[] args) throws Exception {
  128.                 // 创建服务器端Socket服务
  129.                 ServerSocket ss = new ServerSocket(10001);
  130.                 while (true) {
  131.                         // 当服务器端接收到一个客户端对象时，则开启一个子线程，处理客户端请求
  132.                         Socket s = ss.accept();
  133.                         new Thread(new LoginUser(s)).start();
  134.                 }
  135.         }
  136. }
复制代码
作者: 水果牛牛    时间: 2015-9-11 11:11
这么大串代码看着头晕啊
作者: Adualtbird    时间: 2015-9-11 20:55
Doug 发表于 2015-9-11 16:41
给你改了，自己看吧。
ps：我真无聊。。。

非常感谢，我知道问题出在哪里了！我只要把run()方法里面的break，去掉，然后再在else里面再添加一个条件判断，如果x=2,那么就关掉客户端的输出流，并返回给客户端，次数达到限制，否则，就返回客户端用户名不正确，然后让线程继续，而不知直接退出来关掉客户端连接！
有两处疑惑，自己刚发现的：
1、我的那个run()方法里面的第一个while循环，是一个阻塞式循环，如果接受到的用户名不存在，应该一直在while里面死等啊，怎么跳出来的，是不是我刚学一个月，把之前的哪里忘掉了？
2、看到你在run()方法里面调用了一个独立的func()方法，并对其多线程同步，我想了一下，服务器确实是支持多线程操作，但是各个线程之间不存在共享数据，应该不需要加这个同步吧？
作者: Adualtbird    时间: 2015-9-11 21:34
Doug 发表于 2015-9-11 16:41
给你改了，自己看吧。
ps：我真无聊。。。

追加一个问题。真实开发的情况下，遇到这种请款是怎么处理的？应该不会关掉对方的socket吧，是不是在服务器端做一个数据统计，比如限定5次，就抛给他一个改密码的链接，超过6次就把账号冻结？
作者: Doug    时间: 2015-9-12 10:37
Adualtbird 发表于 2015-9-11 20:55
非常感谢，我知道问题出在哪里了！我只要把run()方法里面的break，去掉，然后再在else里面再添加一个条件 ...

1、第一个while循环，是读取文本文件，读完了也就结束了。
2、我不习惯在run()中写大段代码，所以单独弄个方法；加同步只是个习惯。
作者: Doug    时间: 2015-9-12 10:39
Adualtbird 发表于 2015-9-11 21:34
追加一个问题。真实开发的情况下，遇到这种请款是怎么处理的？应该不会关掉对方的socket吧，是不是在服务 ...

参照银行登录，密码出错超过三次就冻结该账号的登录。
作者: Adualtbird    时间: 2015-9-12 10:41
Doug 发表于 2015-9-12 10:39
参照银行登录，密码出错超过三次就冻结该账号的登录。

好的，明白了，非常感谢！
作者: 0814java1    时间: 2015-9-12 23:36
好厉害 看的我都头疼了



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