У меня есть этот код для «Сервер» в приложении программирования сокетов, и у меня есть это Исключение java.net.SocketException в строке 26 следующего кода в этой строке кода:
while((line=bReader.readLine())!=null){
В чем проблема, вызывающая это исключение?
Сервер:
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server implements Runnable{
final public int PORT=1212;
private Socket client;
private ServerSocket server;
private BufferedReader bReader;
private PrintWriter pWriter;
public void run(){
try {
System.out.println("Start server ...");
server=new ServerSocket(PORT);
while(true){
System.out.println("Start listening on PORT "+PORT+" ...");
client=server.accept();
System.out.println("Connection with client["+client.getInetAddress().getHostName()+"]");
bReader=new BufferedReader(new InputStreamReader(client.getInputStream()));
pWriter=new PrintWriter(new BufferedWriter(new OutputStreamWriter(client.getOutputStream())),true);
String line="";
while((line=bReader.readLine())!=null){
RecoginzeMessage(line);
}
}
} catch (IOException e) {
e.printStackTrace();
}finally{
try {
client.close();
// server.close();
bReader.close();
pWriter.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public void RecoginzeMessage(String msg){
String msg_params[]=msg.split(":");
switch(Integer.parseInt(msg_params[0])){
case 0:// Authetication process
System.out.println("Authentication new client");
AuthenticateUser(msg_params[1],msg_params[2]);
break;
}
}
public void AuthenticateUser(String username, String password){
if(username.equals("adham")&&password.equals("adham")){
pWriter.println("1");
pWriter.flush();
}
else{
pWriter.println("0");
pWriter.flush();
}
}
}
и этот код для "клиента" ..
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class Client implements Runnable {
public final String SERVER_IP="127.0.0.1";
public final int PORT=1212;
private Socket client;
private BufferedReader bReader;
private PrintWriter pWriter;
Scanner sc=new Scanner(System.in);
public Client(){
if(client==null)
try {
client=new Socket(SERVER_IP,PORT);
bReader=new BufferedReader(new InputStreamReader(client.getInputStream()));
pWriter=new PrintWriter(new BufferedWriter(new OutputStreamWriter(client.getOutputStream())),true);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void run(){
System.out.print("Enter username: ");
String username=sc.nextLine();
System.out.print("Enter password: ");
String password=sc.nextLine();
if(login(username,password)){
System.out.print(">logged in successfuly");
}else{
System.out.print(">Inavlied username or password");
}
}
private boolean login(String username, String password){
try{
pWriter.println("0:"+username+":"+password);
pWriter.flush();
while(true){
String line="";
while((line=bReader.readLine())!=null){
if(line.equals("1"))
return true;
else
return false;
}
}
}catch(Exception ex){
return false;
}
}
}
Редактировать: класс для запуска клиентского потока
public class RunClient {
public static void main(String args[]){
Client cThread=new Client();
cThread.run();
}
}
Редактировать: класс для запуска потока сервера
public class RunServer {
public static void main(String args[]){
Server sThread=new Server();
sThread.run();
}
}