我的服务器代码
问题出在服务器代码中，当检查登录用户名和密码时，它每次都会输出“重试”消息
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.*;
import java.util.ArrayList;
//test
public class server {
public static void main(String[] args) {
// TODO Auto-generated method stub
ServerSocket listener;
int clientid=0;
try
{
listener = new ServerSocket(10000,10);
while(true)
{
System.out.println("Main thread listening for incoming new connections");
Socket newconnection = listener.accept();
System.out.println("New connection received and spanning a thread");
Connecthandler t = new Connecthandler(newconnection, clientid);
clientid++;
t.start();
}
}
catch (IOException e)
{
System.out.println("Socket not opened");
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class Connecthandler extends Thread
{
Socket individualconnection;
int socketid;
ObjectOutputStream out;
ObjectInputStream in;
String message;
public Connecthandler(Socket s, int i)
{
individualconnection = s;
socketid = i;
}
void sendMessage(String msg)
{
try{
out.writeObject(msg);
out.flush();
System.out.println("client>" + msg);
}
catch(IOException ioException){
ioException.printStackTrace();
}
}
public void run()
{
int clubId;
String clubName;
String clubEmail;
int fundsAvailTransfer;
String agentName;
int agentId;
String agentEmail;
String username;
int password;
ClubUser loggedInUser = null;
try
{
out = new ObjectOutputStream(individualconnection.getOutputStream());
out.flush();
in = new ObjectInputStream(individualconnection.getInputStream());
System.out.println("Connection"+ socketid+" from IP address "+individualconnection.getInetAddress());
//Commence
do
{
ArrayList<ClubUser> clubuser = new ArrayList<ClubUser>();
do
{
sendMessage("Please Enter 1 to Register or 2 to Login");
message = (String)in.readObject();
}while(!message.equals("1")&&!message.equals("2"));
if(message.equals("1"))
{
sendMessage("Enter 1 to Register Club or 2 to Register Player Agent");
message = (String)in.readObject();
// Club Registration
if(message.equals("1"))
{
sendMessage("Enter Club Name: ");
message = (String)in.readObject();
clubName = message;
sendMessage("Enter Club Id: ");
message = (String)in.readObject();
clubId = Integer.parseInt(message);
sendMessage("Enter Club Email: ");
message = (String)in.readObject();
clubEmail = message;
sendMessage("Enter Funds Available To Transfer: ");
message = (String)in.readObject();
fundsAvailTransfer = Integer.parseInt(message);
ClubUser cu = new ClubUser(clubId, clubName, clubEmail, fundsAvailTransfer);
clubuser.add(cu);
for (ClubUser u : clubuser)
{
System.out.println(u);
}// for
}// innerif
}// outerif
else if(message.equals("2"))
{
sendMessage("Please enter Club Name: ");
message = (String)in.readObject();
username = message;
sendMessage("Please enter Club Id: ");
message = (String)in.readObject();
password = Integer.parseInt(message);
for (ClubUser user : clubuser)
{
if (user.getClubId()==(password))
{
if (user.getClubName().equalsIgnoreCase(username))
{
loggedInUser = user;
// when a user is found, "break" stops iterating through the list
// break;
}
}
}// for
if(loggedInUser != null)
{
sendMessage("welcome!!!!!! " + loggedInUser.getClubName());
}
// problem here
else
{
sendMessage("try again ");
}
}// else if
sendMessage("Y to repeat or N to terminate");
message = (String)in.readObject();
}while(message.equalsIgnoreCase("Y"));
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
try
{
out.close();
in.close();
individualconnection.close();
}
catch (IOException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
我的客户代码
客户端代码似乎还可以。
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.*;
import java.util.Scanner;
//test
public class Client
{
private Socket connection;
private String message;
private Scanner console;
private String ipaddress;
private int portaddress;
private ObjectOutputStream out;
private ObjectInputStream in;
public Client()
{
console = new Scanner(System.in);
System.out.println("Enter the IP Address of the server");
ipaddress = console.nextLine();
System.out.println("Enter the TCP Port");
portaddress = console.nextInt();
}
void sendMessage(String msg)
{
try{
out.writeObject(msg);
out.flush();
System.out.println("client>" + msg);
}
catch(IOException ioException){
ioException.printStackTrace();
}
}
public static void main(String[] args)
{
Client temp = new Client();
temp.clientapp();
}
public void clientapp()
{
try
{
connection = new Socket(ipaddress,portaddress);
out = new ObjectOutputStream(connection.getOutputStream());
out.flush();
in = new ObjectInputStream(connection.getInputStream());
System.out.println("Client Side ready to communicate");
/// Client App.
do
{
do
{
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
}while(!message.equalsIgnoreCase("1")&&!message.equalsIgnoreCase("2"));
if(message.equals("1"))
{
// reg as club or agent
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
if(message.equals("1"))
{
// club name
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
// club id
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
// club email
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
// club funds
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
}// inner if
}// outer if
else if(message.equals("2"))
{
// club name
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
// club id
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
// welcome message
message = (String)in.readObject();
System.out.println(message);
}// outer else if
message = (String)in.readObject();
System.out.println(message);
message = console.next();
sendMessage(message);
}while(message.equalsIgnoreCase("Y"));
out.close();
in.close();
connection.close();
}
catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
my clubuser class with getters and setters
public class ClubUser extends server{
int clubId;
String clubName;
String clubEmail;
int fundsAvailTransfer;
public ClubUser(int clubId, String clubName, String clubEmail, int fundsAvailTransfer) {
super();
this.clubId = clubId;
this.clubName = clubName;
this.clubEmail = clubEmail;
this.fundsAvailTransfer = fundsAvailTransfer;
}
int getClubId() {
return clubId;
}
private void setClubId(int clubId) {
this.clubId = clubId;
}
String getClubName() {
return clubName;
}
private void setClubName(String clubName) {
this.clubName = clubName;
}
private String getClubEmail() {
return clubEmail;
}
private void setClubEmail(String clubEmail) {
this.clubEmail = clubEmail;
}
private int getFundsAvailTransfer() {
return fundsAvailTransfer;
}
private void setFundsAvailTransfer(int fundsAvailTransfer) {
this.fundsAvailTransfer = fundsAvailTransfer;
}
@Override
public String toString() {
return "ClubUser clubId=" + clubId + ", clubName=" + clubName + ", clubEmail=" + clubEmail
+ ", fundsAvailTransfer=" + fundsAvailTransfer;
}
}
我想要做的另一件事是将添加的用户详细信息保存在文件中，然后在程序开始时使用它们初始化数组。我该怎么办？
在Connecthandler :: run（）方法中，尝试将ArrayList“ clubUser”移动到最外面的do / while范围之外。这样，它不会在每次迭代时都重新初始化。
// Place the list initialization here; outside the scope of the outer-most do loop
ArrayList<ClubUser> clubuser = new ArrayList<ClubUser>();
do {
// remove from here.
// ArrayList<ClubUser> clubuser = new ArrayList<ClubUser>();
do {
sendMessage("Please Enter 1 to Register or 2 to Login");
message = (String) in.readObject();
} while (!message.equals("1") && !message.equals("2"));
...
}