如何从客户端服务器程序中的服务器控制台获取输入 [英] How to get input from server console in a client server program
问题描述
我已经使用Java(多线程)实现了客户界面.在客户端,客户在服务器已经运行时登录.多个客户端可以登录,为每个客户端创建一个线程.我想要实现的是当多个客户端登录时,我想在服务器控制台(eclipse)中输入一个命令,该命令列出在控制台上输入某些内容后登录的所有客户端.
I have implemented a customer interface using java (multithreaded). On the client side customer logs in when the server is already running. Multiple clients can login creating a thread for each client. What I want to achieve is when multiple clients are logged in I want to enter a command in server console(eclipse) that lists all the clients logged in after i input something on console.
代码的客户端:
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");
}
}}}
推荐答案
以下是您想要的摘录:
private static class CommandListener implements Runnable {
@Override
public void run() {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
while(true) {
try {
String command = br.readLine();
if(command.equals("listClients")) {
// Assuming you will have static list of customer. In which you will
// add a customer/client when a new client get connected and remove
// when a client get disconnected
System.out.println("Total Connected customer :" + customers.size());
System.out.println("Details :");
for(Customer cust : customers) {
System.out.println(cust.getName());
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
在您的StoreServer
类中,创建一个CommandListener
类的对象,并在侦听服务器端口之前将其传递给线程.像这样:
In your StoreServer
class create an object of CommandListener
class and pass it to a thread just before listening on server port. Something like this:
public class StoreServer {
static ArrayList<String[]> list2 = new ArrayList<String[]>();
static List<Customer> customers = new LinkedList<Customer>();
public static void main(String[] args) throws IOException {
System.out.println("The server is running.");
int clientNumber = 0;
ServerSocket listener = new ServerSocket(3355);
Thread commandListenerThread = new Thread(new CommandListener());
commandListenerThread.start();
try {
while (true) {
Socket socket = listener.accept();
Customer cust = new Customer(socket, clientNumber++);
customers.add(cust);
new Thread(cust).start();
}
} finally {
listener.close();
}
.....
请注意,这只是一个片段,而不是正确且经过优化的代码.除此之外,您可以在发布的代码中进行很多改进,例如在线程创建逻辑上设置阈值等.但是我跳过了这一点,因为您的问题仅与从
Please note that this is just a snippet and not a proper and optimized code. Apart from this, there are lot of improvements which could be done in the code you posted, like keeping a threshold on thread creation logic etc. But I am skipping that, as your question is related only to getting input from console in the Server
program.
这篇关于如何从客户端服务器程序中的服务器控制台获取输入的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!