网络编程问题 - 黑马程序员技术交流社区

package demo;
import java.net.*;
import java.io.*;
/*
* 客户端通过键盘录入用户名
* 服务端对这个用户名进行检验
*
* 如果该用户存在，在服务端显示xxx，已登陆
* 在服务端显示，xxx 欢迎光临
*
* 如果该用户不存在，在服务端显示xxx，尝试登陆
* 在客户端显示，xxx，该用户不存在
*
* 最多就登陆3次
*/
//客户端
public class UserLoginClient {
public static void main(String[] args) throws Exception{
//客户端的Socket端点，指定目的主机与端口
Socket socket = new Socket("192.168.1.104",10007);
//读取键盘录入
BufferedReader bufr =
new BufferedReader(new InputStreamReader(System.in));
//获取网络流（Socket流）
PrintWriter bufOut = new PrintWriter(socket.getOutputStream(),true);//自动刷新功能
BufferedReader bufIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
for(int x=0;x<3;x++){
//获取键盘录入数据
String line = bufr.readLine();
//没有输入任何数据(ctrl+c）
if(line==null)
break ;
//将这行数据发送的服务端，ln表示换行（结束标记）
bufOut.println(line);
//获取服务端反馈信息
String info = bufIn.readLine();
System.out.println("info:"+info);
if(info.contains("欢迎")){
break;
}
}
bufr.close();
socket.close();//当键盘录入ctrl+c是，for循环结束，读到该句代码，给服务端发一个 -1（socket流）
}
}

复制代码

package demo;
import java.io.*;
import java.net.*;
//多线程并发验证
class UserThread implements Runnable{
private Socket socket;
UserThread(Socket socket){
this.socket = socket;
}
//线程运行代码
public void run(){
//获取IP
String ip = socket.getInetAddress().getHostAddress();
System.out.println(ip+"...connect");
try{
//验证
for(int x=0;x<3;x++){
//获取网络流
BufferedReader bufIn =
new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter bufOut = new PrintWriter(socket.getOutputStream(),true);
//创建字符流与硬盘用户信息文件相关联
BufferedReader bufi = new BufferedReader(new FileReader("F:\\userInfo.txt"));
String name = bufIn.readLine();//客户端发的-1，readLine返回null,会打印null 尝试登陆
//所以加一个判断判断是否为null的标记
if(name==null){
break;
}
//定义标记用于验证用于信息
boolean flag = false;
//验证用户信息
String line = null;
while((line = bufi.readLine())!=null){
if(line.equals(name)){
//验证后存在，就更改标记
flag = true;
break;
}
}
//向客户端反馈信息
if(flag){
bufOut.println(name+",欢迎光临");
System.out.println(name+",登陆成功");
}else{
bufOut.println(name+",用户名不存在");//记得写ln啊
System.out.println(name+",尝试登陆");
}
}
socket.close();
}catch(IOException e){
throw new RuntimeException("登陆失败");
}
}
}
//服务端
public class UserLoginServer {
public static void main(String[] args) throws Exception{
//创建服务端的Socket对象，并监听指定端口
ServerSocket serverSocket = new ServerSocket(10007);
while(true){
Socket socket = serverSocket.accept();
//每获取到一个客户端对象就开启一个新线程，以达到并发验证的目的
new Thread(new UserThread(socket)).start();
}
}
}

复制代码