关于socket编程 - 黑马程序员技术交流社区

class client
{
public static void main(String[] args) throws IOException {
Socket s = new Socket("192.168.1.102",10012);
//键盘录入
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//服务器端反馈接收
BufferedReader bin = new BufferedReader(new InputStreamReader(s.getInputStream()));
for(int i = 0 ; i<3 ; i++)
{
String str = br.readLine();
out.print(str);
String strReturn = bin.readLine();
System.out.println(strReturn);
}
br.close();
s.close();
}
}
class user implements Runnable
{
private Socket s ;
user(Socket s)
{
this.s = s;
}
@Override
public void run() {
try {
for(int i=0;i<3;i++)
{
BufferedReader b = new BufferedReader(new InputStreamReader(s.getInputStream()));
String name = b.readLine();
PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
BufferedReader br = new BufferedReader(new FileReader("user.txt"));
String userStr = null;
boolean flag = false;
while((userStr = br.readLine())!=null)
{
if(userStr.contains(name))
{
flag = true;
break;
}
}
if(flag)
{
System.out.println("login success");
pw.print("loginsuccess");
}else
{
}
}
s.close();
} catch (Exception e) {
}
}
}
public class server
{
public static void main(String[] args) throws IOException
{
ServerSocket ss = new ServerSocket(10012);
while(true)
{
Socket s = ss.accept();
new Thread(new user(s));
}
}
}

复制代码