黑马程序员技术交流社区

标题: 一个Socket问题 [打印本页]
作者: 于启会    时间: 2012-9-16 05:39
标题: 一个Socket问题
本帖最后由 于启会 于 2012-9-16 08:46 编辑
  1. <p>package com.users;</p><p>import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.io.PrintWriter;
  5. import java.net.Socket;
  6. import java.net.UnknownHostException;</p><p>public class UsersLogin {
  7. public static void main(String[] args) {
  8.   try {
  9.    Socket s=new Socket("127.0.0.1",9527);
  10.    BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
  11.    PrintWriter pw=new PrintWriter(s.getOutputStream(),true);
  12.    BufferedReader reader=new BufferedReader(new InputStreamReader(s.getInputStream()));
  13.    for(int i=0;i<3;i++){
  14.     String line=br.readLine();
  15.     if(line==null){
  16.      break;
  17.     }
  18.     pw.println(line);
  19.    
  20.     String read=reader.readLine();
  21.     if(read.contains("欢迎")){
  22.      System.out.println(read);
  23.      break;
  24.     }else{
  25.      System.out.println(read);
  26.     }
  27.    }
  28.    br.close();
  29.    s.close();
  30.   } catch (UnknownHostException e) {
  31.    e.printStackTrace();
  32.   } catch (IOException e) {
  33.    e.printStackTrace();
  34.   }
  35. }
  36. }

  38. package com.users;</p><p>import java.io.IOException;
  39. import java.net.ServerSocket;
  40. import java.net.Socket;</p><p>public class UserService {
  41. public static void main(String[] args) {
  42.   try {
  43.    ServerSocket ss=new ServerSocket(9527);
  44.    while(true){
  45.     Socket s= ss.accept();
  46.     new Thread(new User(s)).start();
  47.    }
  48.   } catch (IOException e) {
  49.    e.printStackTrace();
  50.   }
  51. }
  52. }

  54. package com.users;</p><p>import java.io.BufferedReader;
  55. import java.io.File;
  56. import java.io.FileReader;
  57. import java.io.IOException;
  58. import java.io.InputStreamReader;
  59. import java.io.PrintWriter;
  60. import java.net.Socket;</p><p>public class User implements Runnable{
  61. private Socket s;
  62. public User(Socket s){
  63.   this.s=s;
  64. }
  65. public void run(){
  66.   String ip=s.getInetAddress().getHostAddress();
  67.   try {
  68.    for(int i=0;i<3;i++){
  69.     BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
  70.     PrintWriter pw=new PrintWriter(s.getOutputStream(),true);
  71.     BufferedReader read=new BufferedReader(new FileReader(new File("E:\\学习记录<a href="file://\\User.txt">\\User.txt</a>")));
  72.     boolean bl=false;
  73.     String r_read=null;
  74.     while((r_read=read.readLine())!=null){
  75.      if(br.readLine().equals(r_read)){
  76.       bl=true;
  77.       break;
  78.      }
  79.     }
  80.     if(bl){
  81.      System.out.println(ip+":"+r_read+":登陆成功");
  82.      pw.println(r_read+"欢迎登陆");
  83.      break;
  84.     }else{
  85.      System.out.println(ip+":"+r_read+":尝试登陆");
  86.      pw.println(r_read+"登陆失败");
  87.     }
  88.     read.close();
  89.    }
  90.    s.close();
  91.   } catch (IOException e) {
  92.    e.printStackTrace();
  93.   }
  94.   
  95. }
  96. }
  97. </p>
复制代码
运行在输入的时候回车了  还是继续输入。没找到什么原因，求解
作者: 朱烈葵    时间: 2012-9-16 08:24
代码错了，你服务端在那？
作者: 朱烈葵    时间: 2012-9-16 08:28
看错了，正在找原因
作者: 张 涛    时间: 2012-9-16 08:31
错误一：
  1. String r_read=null;
  2.     //不能每次循环都读一次br.readLine
  3.     String str = br.readLine();
  4.     while((r_read=read.readLine())!=null){

  6.      if(str.equals(r_read)){//这里改了

  8.       bl=true;

  10.       break;

  12.      }
复制代码
错误二：

  2.      pw.println(r_read+"欢迎登陆");
  3.      pw.flush();//这种输出流操作，一定要记得flush。这里没写的不止一处，自己找找改改吧
复制代码
作者: 于启会    时间: 2012-9-16 08:46
张 涛 发表于 2012-9-16 08:31
错误一：错误二：

额    明白了  readLine()在循环中读了多次。。
作者: 朱烈葵    时间: 2012-9-16 09:10
张 涛 发表于 2012-9-16 08:31
错误一：错误二：


错误二不存在，那个流不需要手动刷新



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