我已经使用java(多线程)实现了客户界面。在客户端,客户端在服务器已经运行时登录。多个客户端可以登录为每个客户端创建一个线程。我想实现的是当多个客户端登录时我想在服务器控制台(eclipse)中输入一个命令,该命令列出了在控制台上输入内容后登录的所有客户端。如何在客户端服务器程序中从服务器控制台获取输入
客户方的代码:代码
btnLogin.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
// TODO Auto-generated method stub
Connection conn = null;
try // try block
{
// declare variables
String username = "";
String pwd = "";
// get values using getText() method
username = loginEmail.getText().trim();
pwd = new String(loginPassword.getPassword());
// check condition it field equals to blank throw error
// message
if (username.equals("") || pwd.equals("")) {
JOptionPane.showMessageDialog(null, " name or password or Role is wrong", "Error",
JOptionPane.ERROR_MESSAGE);
} else // else insert query is run properly
{
String IQuery = "select accountnumber, customername, address from `customeraccount` where emailaddress=? and password=?";
String accnum = null;
System.out.println("Connecting to a selected database...");
// STEP 3: Open a connection
conn = DriverManager.getConnection(DB_URL, user_name, password);
System.out.println("Connected database successfully...");
PreparedStatement stmt = conn.prepareStatement(IQuery);
stmt.setString(1, username);
stmt.setString(2, pwd);
ResultSet rs = stmt.executeQuery();
while (rs.next()) {
detailName.setText(rs.getString("customername"));
detailAddress.setText(rs.getString("address"));
accnum = rs.getString("accountnumber");
}
out.println(accnum);
out.println(detailName.getText());
rs.close();
((java.sql.Connection) conn).close();
}
} catch (SQLException se) {
// handle errors for JDBC
se.printStackTrace();
} catch (Exception a) // catch block
{
a.printStackTrace();
}
}
});
服务器端:
public class StoreServer {
static ArrayList<String[]> list2 = new ArrayList<String[]>();
public static void main(String[] args) throws IOException {
System.out.println("The server is running.");
int clientNumber = 0;
ServerSocket listener = new ServerSocket(3355);
try {
while (true) {
new Thread(new Customer(listener.accept(), clientNumber++)).start();
}
} finally {
listener.close();
}
}
private static class Customer implements Runnable {
private Socket socket;
private int clientNumber;
public Customer(Socket socket, int clientNumber) {
this.socket = socket;
this.clientNumber = clientNumber;
// log("New connection with client# " + clientNumber + " at " +
// socket);
}
/**
* Services this thread's client by first sending the client a welcome
* message then repeatedly reading strings and sending back the
* capitalized version of the string.
*/
public void run() {
try {
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
while (true) {
System.out.println("Account Number: " + acnum + " Name: " + name);
if (acnum == null || acnum.equals(".")) {
break;
}
// out.println(input.toUpperCase());
}
} catch (IOException e) {
log("Error handling client# " + clientNumber + ": " + e);
} finally {
try {
socket.close();
} catch (IOException e) {
log("Couldn't close a socket, what's going on?");
}
// log("Connection with client# " + clientNumber + " closed");
}
}}}
我认为它是最合适的答案。谢谢Sumit。 –
@human此代码段是否帮助您? –