Google Git
Sign in
third-party-mirror / backupdr / 93282939cf091afb539a751899f207531ebf1e1c / . / quickserver / src / main / org / quickserver / net / qsadmin / CommandHandler.java
blob: 8d9366d51fdea658d33832c4d1fdc38385373e5c [file] [log] [blame]
/*
* This file is part of the QuickServer library
* Copyright (C) QuickServer.org
*
* Use, modification, copying and distribution of this software is subject to
* the terms and conditions of the GNU Lesser General Public License.
* You should have received a copy of the GNU LGP License along with this
* library; if not, you can download a copy from <http://www.quickserver.org/>.
*
* For questions, suggestions, bug-reports, enhancement-requests etc.
* visit http://www.quickserver.org
*
*/
package org.quickserver.net.qsadmin;
import java.net.*;
import java.io.*;
import java.text.Format;
import java.text.SimpleDateFormat;
import java.util.StringTokenizer;
import org.quickserver.net.server.ClientCommandHandler;
import org.quickserver.net.server.ClientEventHandler;
import org.quickserver.net.server.ClientHandler;
import org.quickserver.net.server.QuickServer;
import org.quickserver.net.AppException;
import java.util.logging.*;
import org.quickserver.util.*;
import org.quickserver.util.pool.thread.*;
import java.util.*;
import org.quickserver.util.pool.*;
import org.apache.commons.pool.ObjectPool;
import org.quickserver.net.server.ClientIdentifier;
/**
* ClientCommandHandler for QSAdminServer.
* <p>
* = Protocol =<br>
* Each response starts with a status.
* <ul>
* <li>+OK = Success
* <li>-ERR = Failed
* </ul>
* If response if one lined then it follows the status.
* Else You will get "info follows" as the first line
* followed by with many lines of response ending by a
* dot in a line by itself. i.e., &lt;CR&gt;&lt;LF&gt;.&lt;CR&gt;&lt;LF&gt;<br>
* Command supported are give below .. [ Note: &lt;&lt;target&gt;&gt; = server|self ]
* <br>&nbsp;<br>
* <table align="center" border=1>
* <tr><th>Command</th><th>Param</th><th>Effect</th></tr>
* <tr><td>start</td><td>&lt;&lt;target&gt;&gt;</td><td>Starts target.</td></tr>
* <tr><td>stop</td><td>&lt;&lt;target&gt;&gt;</td><td>Stops target.</td></tr>
* <tr><td>restart</td><td>&lt;&lt;target&gt;&gt;</td><td>=stop+start command</td></tr>
* <tr><td>shutdown</td><td>&nbsp;</td><td>Stops server and self. </td></tr>
* <tr><td>kill or exit</td><td>&nbsp;</td><td>Stops server and self and kill all threads. </td></tr>
* <tr><td>info</td><td>&lt;&lt;target&gt;&gt;</td><td>Information about target.</td></tr>
* <tr><td>noclient</td><td>&lt;&lt;target&gt;&gt;</td><td>No Client connected to the target.</td></tr>
* <tr><td>running</td><td>&lt;&lt;target&gt;&gt;</td><td>Checks if target is running.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; maxClient</td><td>Gets max no of client for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; port</td><td>Gets port for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; maxAuthTryMsg</td><td>Gets maxAuthTryMsg for the target. </td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientCommandHandler</td><td>Gets ClientCommandHandler class for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientAuthenticationHandler</td><td>Gets ClientAuthenticationHandler class for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientData</td><td>Gets ClientData class for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; timeout</td><td>Gets timeout set for clients for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; maxClient &lt;&lt;value&gt;&gt;</td><td>Sets max no of client for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; port &lt;&lt;value&gt;&gt;</td><td>Sets port for the target.*</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; maxAuthTryMsg &lt;&lt;value&gt;&gt;</td><td>Sets maxAuthTryMsg for the target. *</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientCommandHandler &lt;&lt;value&gt;&gt;</td><td>Sets ClientCommandHandler class for the target. *</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientAuthenticationHandler &lt;&lt;value&gt;&gt;</td><td>Sets ClientAuthenticationHandler class for the target. *</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientData &lt;&lt;value&gt;&gt;</td><td>Sets ClientData class for the target. *</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; timeout &lt;&lt;value&gt;&gt;</td><td>Sets timeout set for clients for the target. *</td></tr>
* <tr><td>version</td><td>&nbsp;</td><td>Gets the version of the QuickServer library used.</td></tr>
* <tr><td>quit</td><td>&nbsp;</td><td>Close session.</td></tr>
* <tr><td colspan=3>New Command in v1.2 </td></tr>
* <tr><td>get</td><td>self plugin</td><td>Gets pluggable command handler for QsAdminServer. *</td></tr>
* <tr><td>set</td><td>self plugin &lt;&lt;full class name&gt;&gt;</td><td>Sets Pluggable command handler for QsAdminServer. *</td></tr>
* <tr><td colspan=3>New Command in v1.3 </td></tr>
* <tr><td>suspendService</td><td>&lt;&lt;target&gt;&gt;</td><td>Suspends target.</td></tr>
* <tr><td>resumeService</td><td>&lt;&lt;target&gt;&gt;</td><td>Resume target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; maxAuthTry</td><td>Gets maxAuthTry for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; maxAuthTry</td><td>Sets maxAuthTry for the target.*</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientObjectHandler</td><td>Gets ClientObjectHandler class for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientObjectHandler</td><td>Sets ClientObjectHandler class for the target.*</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; timeoutMsg</td><td>Gets timeout Message for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; timeoutMsg</td><td>Sets timeout Message for the target.*</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; serviceState</td><td>Gets Service State for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; consoleLoggingFormatter</td><td>Sets consoleLoggingFormatter for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; consoleLoggingFormatter</td><td>Sets consoleLoggingFormatter for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; consoleLoggingLevel</td><td>Sets consoleLoggingLevel for the target. <br>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; consoleLoggingLevel</td><td>Sets consoleLoggingLevel for the target. <br>
* [<code>SEVERE|WARNING|INFO|CONFIG|FINE|FINER|FINEST<code>]</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; maxClientMsg</td><td>Sets maxClientMsg for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; maxClientMsg</td><td>Gets maxClientMsg for the target.</td></tr>
* <tr><td colspan=3>New Command in v1.3.1 </td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; loggingLevel</td><td>Sets LoggingLevel for the target. <br>
* [<code>SEVERE|WARNING|INFO|CONFIG|FINE|FINER|FINEST<code>]</td></tr>
* <tr><td colspan=3>New Command in v1.3.2 </td></tr>
* <tr><td>memoryInfo</td><td>&nbsp;</td><td>Memory Information {Total:Used:Max}</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; communicationLogging</td><td>Sets communication logging flag for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; communicationLogging</td><td>Gets communication logging flag for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-maxActive</td><td>Sets maxActive of objectPoolConfig for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-maxActive</td><td>Gets maxActive of objectPoolConfig for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-maxIdle</td><td>Sets maxIdle of objectPoolConfig for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-maxIdle</td><td>Gets maxIdle of objectPoolConfig for the target.</td></tr>
*
* <tr><td colspan=3>New Command in v1.4.5 </td></tr>
* <tr><td>all-pool-info</td><td>&lt;&lt;target&gt;&gt;</td><td>Gives stats of all pools for the target.</td></tr>
* <tr><td>client-thread-pool-dump</td><td>&lt;&lt;target&gt;&gt;</td><td>Gives dump of all threads in pool for the target.</td></tr>
* <tr><td>start</td><td>&lt;&lt;console&gt;&gt;</td><td>Starts console shell.</td></tr>
* <tr><td>stop</td><td>&lt;&lt;console&gt;&gt;</td><td>Stops console shell.</td></tr>
*
* <tr><td colspan=3>New Command in v1.4.6 </td></tr>
* <tr><td>client-handler-pool-dump</td><td>&lt;&lt;target&gt;&gt;</td><td>Gives dump of all ClientHandler in pool for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientEventHandler</td><td>Gets ClientEventHandler class for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientEventHandler &lt;&lt;value&gt;&gt;</td><td>Sets ClientEventHandler class for the target. *</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientWriteHandler</td><td>Gets ClientWriteHandler class for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientWriteHandler &lt;&lt;value&gt;&gt;</td><td>Sets ClientWriteHandler class for the target. *</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; clientExtendedEventHandler</td><td>Gets ClientExtendedEventHandler class for the target.</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; clientExtendedEventHandler &lt;&lt;value&gt;&gt;</td><td>Sets ClientExtendedEventHandler class for the target. *</td></tr>
* <tr><td>set</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-initSize</td><td>Sets initSize of objectPoolConfig for the target.</td></tr>
* <tr><td>get</td><td>&lt;&lt;target&gt;&gt; objectPoolConfig-initSize</td><td>Gets initSize of objectPoolConfig for the target.</td></tr>
* <tr><td colspan=3>New Command in v2.0.0 </td></tr>
* <tr><td>kill-clients-all</td><td>&lt;&lt;target&gt;&gt;</td><td>Kill all ClientHandler/Client in pool for the target.</td></tr>
* <tr><td>kill-client-with</td><td>&lt;&lt;target&gt;&gt; &lt;&lt;search term&gt;&gt;</td><td>Kill all ClientHandler/Client in pool for the target which has the search term n toString (check client-handler-pool-dump command for the format).</td></tr>
*
* <tr><td>jvm</td><td>dumpJmapHisto file</td><td>Dump JMAP to file</td></tr>
* <tr><td>jvm</td><td>dumpJmapHisto log</td><td>Dump JMAP to jdk log</td></tr>
* <tr><td>jvm</td><td>dumpJStack file</td><td>Dump JStack to file</td></tr>
* <tr><td>jvm</td><td>dumpJStack log</td><td>Dump JStack to jdk log</td></tr>
* <tr><td>jvm</td><td>threadDump file</td><td>Take thread dump to file</td></tr>
* <tr><td>jvm</td><td>threadDump log</td><td>Take thread dump to jdk log</td></tr>
* <tr><td>jvm</td><td>dumpHeap</td><td>Dump Heap to file</td></tr>
*
* <tr><td colspan=3>* = Take effect after a restart command.<br>
* value if set null then key will be set to <code>null</code>
* </td></tr>
* </table>
* <br>Note:
* <ul>
* <li>Stopping the QuickServer will not disconnect any client connect to it, since
* client connections are handled by different thread.
* <li><code>restart</code> and <code>start</code> response just indicate only
* if command was sent. Do check the state of the target using
* <code>running</code> command to see if server was started successful.
* <li>Demo code examples\EchoServer shows the use of QsAdminServer to control itself.
* </ul>
* Eg: <br>
* <BLOCKQUOTE>
* noClient server<br>
* noClient self<br>
* get server maxClient<br>
* set server maxClient 10
* </BLOCKQUOTE>
* </p>
* @since 1.1
*/
public class CommandHandler implements ClientCommandHandler, ClientEventHandler {
private static Logger logger = Logger.getLogger(CommandHandler.class.getName());
private static Format formatter = new SimpleDateFormat("yyyyMMdd_HHmmss");
private static File getFile(String name, String ext) {
StringBuilder sb = new StringBuilder("./");
File logDir = new File("./log/");
if(logDir.exists()==false) {
logDir.mkdirs();
}
if(logDir.canWrite()) {
sb.append("log/");
}
sb.append(name);
sb.append("_");
sb.append(formatter.format(new Date()));
sb.append(ext);
return new File(sb.toString());
}
private CommandPlugin plugin;
private Runtime runtime;
StringBuilder temp = new StringBuilder();
//-- ClientEventHandler
public void gotConnected(ClientHandler handler)
throws SocketTimeoutException, IOException {
logger.log(Level.FINE, "Connection opened : {0}", handler.getHostAddress());
handler.sendClientMsg("+OK +++++++++++++++++++++++++++++++++");
handler.sendClientMsg("+OK Welcome to QsAdminServer v 1.0 ");
handler.sendClientMsg("+OK +++++++++++++++++++++++++++++++++");
//v.2
if(plugin==null || runtime==null) {
plugin = (CommandPlugin)
handler.getServer().getStoreObjects()[1];
//v1.3.2
runtime = Runtime.getRuntime();
}
}
public void lostConnection(ClientHandler handler)
throws IOException {
logger.log(Level.FINE, "Connection lost : {0}", handler.getHostAddress());
}
public void closingConnection(ClientHandler handler)
throws IOException {
logger.log(Level.FINE, "Connection closing : {0}", handler.getHostAddress());
}
//-- ClientEventHandler
public void handleCommand(ClientHandler handler, String command)
throws SocketTimeoutException, IOException {
if(command==null || command.trim().equals("")) {
handler.sendClientMsg("-ERR No command");
return;
}
//v1.2 - plugin
if( plugin != null && plugin.handleCommand(handler,command) ) {
logger.fine("Handled by plugin.");
return;
}
QSAdminServer adminServer = (QSAdminServer)
handler.getServer().getStoreObjects()[2];
StringTokenizer st = new StringTokenizer(command," ");
String cmd = null;
cmd = st.nextToken().toLowerCase();
String param[] = new String[st.countTokens()];
QuickServer target = null;
for (int i=0;st.hasMoreTokens();i++) {
param[i] = st.nextToken();
}
if(command.equals("start console")) { /*v1.4.5*/
QSAdminShell.getInstance(
(QuickServer) handler.getServer().getStoreObjects()[0], null);
handler.sendClientMsg("+OK QSAdminShell is started.");
return;
} else if(command.equals("stop console")) { /*v1.4.5*/
QSAdminShell shell = QSAdminShell.getInstance(null, null);
if(shell!=null) {
try {
shell.stopShell();
} catch(Exception err) {
handler.sendClientMsg("-ERR Error stopping QSAdminShell: "+err);
}
handler.sendClientMsg("+OK QSAdminShell is stopped.");
} else {
handler.sendClientMsg("-ERR QSAdminShell is not running.");
}
return;
} else if(cmd.equals("jvm")) {/*2.0.0*/
/*
jvm dumpHeap
jvm dumpJmapHisto file
jvm dumpJmapHisto log
jvm threadDump file
jvm threadDump log
jvm dumpJStack file
jvm dumpJStack log
*/
if(param.length==0) {
handler.sendClientMsg("-ERR "+"Use jvm help");
return;
}
if(param[0].equals("dumpHeap")) {
File file = getFile("dumpHeap", ".bin");
JvmUtil.dumpHeap(file.getAbsolutePath(), true);
handler.sendClientMsg("+OK File "+file.getAbsolutePath());
} else if(param[0].equals("dumpJmapHisto")) {
if(param.length < 2)/*dumpJmapHisto file*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
if(param[1].equals("file")) {
File file = getFile("dumpJmapHisto", ".txt");
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.dumpJmapHisto(file.getAbsolutePath());
handler.sendClientMsg("Done - File "+file.getAbsolutePath());
handler.sendClientMsg(".");
} else if(param[1].equals("log")) {
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.dumpJmapHistoToLog();
handler.sendClientMsg("Done - Dumped to jdk log file");
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR "+"bad param");
return;
}
} else if(param[0].equals("threadDump")) {
if(param.length < 2)/*threadDump file*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
if(param[1].equals("file")) {
File file = getFile("threadDump", ".txt");
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.threadDump(file.getAbsolutePath());
handler.sendClientMsg("Done - File "+file.getAbsolutePath());
handler.sendClientMsg(".");
} else if(param[1].equals("log")) {
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.threadDumpToLog();
handler.sendClientMsg("Done - Dumped to jdk log file");
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR "+"bad param");
return;
}
} else if(param[0].equals("dumpJStack")) {
if(param.length < 2)/*dumpJStack file*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
if(param[1].equals("file")) {
File file = getFile("dumpJStack", ".txt");
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.dumpJStack(file.getAbsolutePath());
handler.sendClientMsg("Done - File "+file.getAbsolutePath());
handler.sendClientMsg(".");
} else if(param[1].equals("log")) {
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("Starting.. ");
JvmUtil.dumpJStackToLog();
handler.sendClientMsg("Done - Dumped to jdk log file");
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR "+"bad param");
return;
}
} else if(param[0].equals("help")) {
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg("jvm dumpJmapHisto file");
handler.sendClientMsg("jvm dumpJStack file");
handler.sendClientMsg(" ");
handler.sendClientMsg("jvm threadDump file");
handler.sendClientMsg("jvm dumpHeap");
handler.sendClientMsg(" ");
handler.sendClientMsg("jvm threadDump log");
handler.sendClientMsg("jvm dumpJmapHisto log");
handler.sendClientMsg("jvm dumpJStack log");
handler.sendClientMsg(".");
return;
} else {
handler.sendClientMsg("-ERR "+"bad param use jvm help");
}
return;
}
if(param.length > 0) {
if( param[0].equals("server") )
target = (QuickServer) handler.getServer().getStoreObjects()[0];
else if( param[0].equals("self") )
target = handler.getServer();
else {
handler.sendClientMsg("-ERR Bad <<target>> : "+param[0]);
return;
}
}
if(cmd.equals("help")) {
handler.sendClientMsg("+OK info follows"+"\r\n"+
"Refer Api Docs for org.quickserver.net.qsadmin.CommandHandler");
handler.sendClientMsg(".");
return;
} else if(cmd.equals("quit")) {
handler.sendClientMsg("+OK Bye ;-)");
handler.closeConnection();
return;
} else if(cmd.equals("shutdown")) {
try {
QuickServer controlServer =
(QuickServer) handler.getServer().getStoreObjects()[0];
if(controlServer!=null && controlServer.isClosed()==false) {
controlServer.stopServer();
}
if(handler.getServer()!=null && handler.getServer().isClosed()==false) {
handler.getServer().stopServer();
}
QSAdminShell shell = QSAdminShell.getInstance(null, null);
if(shell!=null) {
try {
shell.stopShell();
} catch(Exception err) {
logger.warning("Error stoping shell: "+err);
}
}
handler.sendClientMsg("+OK Done");
} catch (AppException e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("version")) {
handler.sendClientMsg("+OK "+QuickServer.getVersion());
return;
} else if(cmd.equals("kill") || cmd.equals("exit")) /*v1.3,v1.3.2*/{
StringBuilder errBuf = new StringBuilder();
QuickServer controlServer =
(QuickServer) handler.getServer().getStoreObjects()[0];
int exitCode = 0;
if(param.length!=0) {
try {
exitCode = Integer.parseInt(param[0]);
} catch(Exception nfe) {/*ignore*/}
}
try {
if(controlServer!=null && controlServer.isClosed()==false) {
try {
controlServer.stopServer();
} catch(AppException ae) {
errBuf.append(ae.toString());
}
}
if(handler.getServer()!=null && handler.getServer().isClosed()==false) {
try {
handler.getServer().stopServer();
} catch(AppException ae) {
errBuf.append(ae.toString());
}
}
QSAdminShell shell = QSAdminShell.getInstance(null, null);
if(shell!=null) {
try {
shell.stopShell();
} catch(Exception err) {
errBuf.append(err.toString());
}
}
if(errBuf.length()==0)
handler.sendClientMsg("+OK Done");
else
handler.sendClientMsg("+OK Done, Errors: "+errBuf.toString());
} catch (Exception e) {
handler.sendClientMsg("-ERR Exception : "+e+"\r\n"+errBuf.toString());
if(exitCode==0) exitCode = 1;
} finally {
try {
if(controlServer!=null)
controlServer.closeAllPools();
if(handler.getServer()!=null)
handler.getServer().closeAllPools();
} catch(Exception er) {
logger.warning("Error closing pools: "+er);
}
System.exit(exitCode);
}
return;
} else if(cmd.equals("memoryinfo")) { /*v1.3.2*/
//Padding : Total:Used:Max
float totalMemory = (float) runtime.totalMemory();
float usedMemory = totalMemory - (float) runtime.freeMemory();
float maxMemory = (float) runtime.maxMemory();
handler.sendClientMsg("+OK "+totalMemory+":"+usedMemory+":"+maxMemory);
return;
} else if(cmd.equals("systeminfo")) { /*v1.4.5*/
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg(MyString.getSystemInfo(target.getVersion()));
handler.sendClientMsg(".");
return;
} else if(param.length==0) {
handler.sendClientMsg("-ERR Bad Command or No Param : ->"+cmd+"<-");
return;
}
if(cmd.equals("start")) {
try {
target.startServer();
handler.sendClientMsg("+OK Server Started");
} catch (AppException e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("stop")) {
try {
target.stopServer();
handler.sendClientMsg("+OK Server Stopped");
} catch (AppException e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("restart")) {
try {
target.stopServer();
target.startServer();
handler.sendClientMsg("+OK Server Restarted");
} catch (AppException e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("info")) {
handler.sendClientMsg("+OK info follows");
handler.sendClientMsg(""+target);
handler.sendClientMsg("Running : "+!target.isClosed());
handler.sendClientMsg("PID : "+QuickServer.getPID());
handler.sendClientMsg("Max Client Allowed : "+target.getMaxConnection() );
handler.sendClientMsg("No Client Connected : "+target.getClientCount() );
if(target.isRunningSecure()==true) {
handler.sendClientMsg("Running in secure mode : "+
target.getSecure().getProtocol() );
} else {
handler.sendClientMsg("Running in non-secure mode");
}
handler.sendClientMsg("Server Mode : "+target.getBasicConfig().getServerMode());
handler.sendClientMsg("QuickServer v : "+QuickServer.getVersion());
handler.sendClientMsg("Uptime : "+target.getUptime());
handler.sendClientMsg(".");
return;
} else if(cmd.equals("noclient")) {
handler.sendClientMsg("+OK "+target.getClientCount() );
return;
} else if(cmd.equals("running")) {
handler.sendClientMsg("+OK "+!target.isClosed() );
return;
} else if(cmd.equals("suspendservice")) {
handler.sendClientMsg("+OK "+target.suspendService() );
return;
} else if(cmd.equals("resumeservice")) {
handler.sendClientMsg("+OK "+target.resumeService() );
return;
} else if(cmd.equals("client-thread-pool-info")) /*v1.3.2*/{
temp.setLength(0);//used:idle
if(PoolHelper.isPoolOpen(target.getClientPool().getObjectPool())==true) {
temp.append(target.getClientPool().getNumActive());
temp.append(':');
temp.append(target.getClientPool().getNumIdle());
} else {
temp.append("0:0");
}
handler.sendClientMsg("+OK "+temp.toString() );
return;
} else if(cmd.equals("client-thread-pool-dump")) /*v1.4.5*/{
if(PoolHelper.isPoolOpen(target.getClientPool().getObjectPool())==true) {
handler.sendClientMsg("+OK info follows");
ClientThread ct = null;
synchronized(target.getClientPool().getObjectToSynchronize()) {
Iterator iterator = target.getClientPool().getAllClientThread();
while(iterator.hasNext()) {
ct = (ClientThread)iterator.next();
handler.sendClientMsg(ct.toString());
}
}
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR Pool Closed");
}
return;
} else if(cmd.equals("client-handler-pool-dump")) /*v1.4.6*/{
ObjectPool objectPool = target.getClientHandlerPool();
if(PoolHelper.isPoolOpen(objectPool)==true) {
if(QSObjectPool.class.isInstance(objectPool)==false) {
handler.sendClientMsg("-ERR System Error!");
}
ClientIdentifier clientIdentifier = target.getClientIdentifier();
ClientHandler foundClientHandler = null;
synchronized(clientIdentifier.getObjectToSynchronize()) {
Iterator iterator = clientIdentifier.findAllClient();
handler.sendClientMsg("+OK info follows");
while(iterator.hasNext()) {
foundClientHandler = (ClientHandler) iterator.next();
handler.sendClientMsg(foundClientHandler.info());
}
}
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR Pool Closed");
}
return;
} else if(cmd.equals("client-data-pool-info")) /*v1.3.2*/{
temp.setLength(0);//used:idle
if(target.getClientDataPool()!=null) {
if(PoolHelper.isPoolOpen(target.getClientDataPool())==true) {
temp.append(target.getClientDataPool().getNumActive());
temp.append(':');
temp.append(target.getClientDataPool().getNumIdle());
handler.sendClientMsg("+OK "+temp.toString() );
} else {
handler.sendClientMsg("-ERR Client Data Pool Closed");
}
} else {
handler.sendClientMsg("-ERR No Client Data Pool");
}
return;
} else if(cmd.equals("byte-buffer-pool-info")) /*v1.4.6*/{
temp.setLength(0);//used:idle
if(target.getByteBufferPool()!=null) {
if(PoolHelper.isPoolOpen(target.getByteBufferPool())==true) {
temp.append(target.getByteBufferPool().getNumActive());
temp.append(':');
temp.append(target.getByteBufferPool().getNumIdle());
handler.sendClientMsg("+OK "+temp.toString() );
} else {
handler.sendClientMsg("-ERR ByteBuffer Pool Closed");
}
} else {
handler.sendClientMsg("-ERR No ByteBuffer Pool");
}
return;
} else if(cmd.equals("all-pool-info")) /*v1.4.5*/{
handler.sendClientMsg("+OK info follows");
temp.setLength(0);//used:idle
if(PoolHelper.isPoolOpen(target.getClientPool().getObjectPool())==true) {
temp.append("Client Thread Pool - ");
temp.append("Num Active: ");
temp.append(target.getClientPool().getNumActive());
temp.append(", Num Idle: ");
temp.append(target.getClientPool().getNumIdle());
temp.append(", Max Idle: ");
temp.append(target.getClientPool().getPoolConfig().getMaxIdle());
temp.append(", Max Active: ");
temp.append(target.getClientPool().getPoolConfig().getMaxActive());
} else {
temp.append("Byte Buffer Pool - Closed");
}
handler.sendClientMsg(temp.toString());
temp.setLength(0);
if(PoolHelper.isPoolOpen(target.getClientHandlerPool())==true) {
temp.append("Client Handler Pool - ");
temp.append("Num Active: ");
temp.append(target.getClientHandlerPool().getNumActive());
temp.append(", Num Idle: ");
temp.append(target.getClientHandlerPool().getNumIdle());
temp.append(", Max Idle: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getClientHandlerObjectPoolConfig().getMaxIdle());
temp.append(", Max Active: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getClientHandlerObjectPoolConfig().getMaxActive());
} else {
temp.append("Client Handler Pool - Closed");
}
handler.sendClientMsg(temp.toString());
temp.setLength(0);
if(target.getByteBufferPool()!=null) {
if(PoolHelper.isPoolOpen(target.getByteBufferPool())==true) {
temp.append("ByteBuffer Pool - ");
temp.append("Num Active: ");
temp.append(target.getByteBufferPool().getNumActive());
temp.append(", Num Idle: ");
temp.append(target.getByteBufferPool().getNumIdle());
temp.append(", Max Idle: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getByteBufferObjectPoolConfig().getMaxIdle());
temp.append(", Max Active: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getByteBufferObjectPoolConfig().getMaxActive());
} else {
temp.append("Byte Buffer Pool - Closed");
}
} else {
temp.append("Byte Buffer Pool - Not Used");
}
handler.sendClientMsg(temp.toString());
temp.setLength(0);
if(target.getClientDataPool()!=null) {
if(PoolHelper.isPoolOpen(target.getClientDataPool())==true) {
temp.append("Client Data Pool - ");
temp.append("Num Active: ");
temp.append(target.getClientDataPool().getNumActive());
temp.append(", Num Idle: ");
temp.append(target.getClientDataPool().getNumIdle());
temp.append(", Max Idle: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getClientDataObjectPoolConfig().getMaxIdle());
temp.append(", Max Active: ");
temp.append(target.getBasicConfig().getObjectPoolConfig().getClientDataObjectPoolConfig().getMaxActive());
} else {
temp.append("Client Data Pool - Closed");
}
} else {
temp.append("Client Data Pool - Not Used");
}
handler.sendClientMsg(temp.toString());
temp.setLength(0);
handler.sendClientMsg(".");
return;
} else if(cmd.equals("set")) {
if(param.length < 3)/*target,key,value*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
if(param[2].equals("null"))
param[2]=null;
try {
if(param[1].equals("maxClient")) {
long no = Long.parseLong(param[2]);
target.setMaxConnection(no);
} else if(param[1].equals("maxClientMsg")) {
target.setMaxConnectionMsg(param[2]);
} else if(param[1].equals("port")) {
long no = Long.parseLong(param[2]);
target.setPort((int)no);
} else if(param[1].equals("port")) {
long no = Long.parseLong(param[2]);
target.setPort((int)no);
} else if(param[1].equals("maxAuthTry")) {
int no = Integer.parseInt(param[2]);
target.setMaxAuthTry(no);
} else if(param[1].equals("maxAuthTryMsg")) {
target.setMaxAuthTryMsg(param[2]);
} else if(param[1].equals("clientEventHandler")) { /*v1.4.6*/
target.setClientEventHandler(param[2]);
} else if(param[1].equals("clientCommandHandler")) {
target.setClientCommandHandler(param[2]);
} else if(param[1].equals("clientWriteHandler")) { /*v1.4.6*/
target.setClientWriteHandler(param[2]);
} else if(param[1].equals("clientObjectHandler")) {
target.setClientObjectHandler(param[2]); /*v1.3*/
} else if(param[1].equals("clientAuthenticationHandler")) {
target.setClientAuthenticationHandler(param[2]);
} else if(param[1].equals("clientData")) {
target.setClientData(param[2]);
} else if(param[1].equals("clientExtendedEventHandler")) { /*v1.4.6*/
target.setClientExtendedEventHandler(param[2]);
} else if(param[1].equals("timeout")) {
long no = Long.parseLong(param[2]);
target.setTimeout((int)no);
} else if(param[1].equals("timeoutMsg")) {
target.setTimeoutMsg(param[2]); /* v1.3 */
} else if(param[1].equals("plugin")) /* v1.2*/{
if(param[0].equals("self")) {
try {
adminServer.setCommandPlugin(param[2]);
} catch(Exception e) {
handler.sendClientMsg("-ERR not set : "+e);
return;
}
} else {
handler.sendClientMsg("-ERR Bad target : "+param[0]+" self is only allowed.");
return;
}
} else if(param[1].equals("consoleLoggingFormatter")) {
target.setConsoleLoggingFormatter(param[2]); /* v1.3 */
} else if(param[1].equals("consoleLoggingLevel")) { /* v1.3 */
if(param[2].endsWith("SEVERE"))
target.setConsoleLoggingLevel(Level.SEVERE);
else if(param[2].endsWith("WARNING"))
target.setConsoleLoggingLevel(Level.WARNING);
else if(param[2].endsWith("INFO"))
target.setConsoleLoggingLevel(Level.INFO);
else if(param[2].endsWith("CONFIG"))
target.setConsoleLoggingLevel(Level.CONFIG);
else if(param[2].endsWith("FINE"))
target.setConsoleLoggingLevel(Level.FINE);
else if(param[2].endsWith("FINER"))
target.setConsoleLoggingLevel(Level.FINER);
else if(param[2].endsWith("FINEST"))
target.setConsoleLoggingLevel(Level.FINEST);
else if(param[2].endsWith("ALL"))
target.setConsoleLoggingLevel(Level.ALL);
else if(param[2].endsWith("OFF"))
target.setConsoleLoggingLevel(Level.OFF);
else {
handler.sendClientMsg("-ERR Bad Level "+param[2]);
return;
}
} else if(param[1].equals("loggingLevel")) { /* v1.3.1 */
if(param[2].endsWith("SEVERE"))
target.setLoggingLevel(Level.SEVERE);
else if(param[2].endsWith("WARNING"))
target.setLoggingLevel(Level.WARNING);
else if(param[2].endsWith("INFO"))
target.setLoggingLevel(Level.INFO);
else if(param[2].endsWith("CONFIG"))
target.setLoggingLevel(Level.CONFIG);
else if(param[2].endsWith("FINE"))
target.setLoggingLevel(Level.FINE);
else if(param[2].endsWith("FINER"))
target.setLoggingLevel(Level.FINER);
else if(param[2].endsWith("FINEST"))
target.setLoggingLevel(Level.FINEST);
else if(param[2].endsWith("ALL"))
target.setLoggingLevel(Level.ALL);
else if(param[2].endsWith("OFF"))
target.setLoggingLevel(Level.OFF);
else {
handler.sendClientMsg("-ERR Bad Level "+param[2]);
return;
}
} else if(param[1].equals("communicationLogging")) {
if(param[2].equals("true"))/* v1.3.2 */
target.setCommunicationLogging(true);
else
target.setCommunicationLogging(false);
} else if(param[1].equals("objectPoolConfig-maxActive")) {
int no = Integer.parseInt(param[2]);
target.getConfig().getObjectPoolConfig().setMaxActive(no);
} else if(param[1].equals("objectPoolConfig-maxIdle")) {
int no = Integer.parseInt(param[2]);
target.getConfig().getObjectPoolConfig().setMaxIdle(no);
} else if(param[1].equals("objectPoolConfig-initSize")) {
int no = Integer.parseInt(param[2]);
target.getConfig().getObjectPoolConfig().setInitSize(no);
} else {
handler.sendClientMsg("-ERR Bad Set Key : "+param[1]);
return;
}
handler.sendClientMsg("+OK Set");
} catch(Exception e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("get")) {
if(param.length < 2)/*target,key*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
try {
if(param[1].equals("maxClient")) {
long no = target.getMaxConnection();
handler.sendClientMsg("+OK "+no);
} else if(param[1].equals("maxClientMsg")) {
String msg = target.getMaxConnectionMsg();
msg = MyString.replaceAll(msg, "\n", "\\n");
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("port")) {
long no = target.getPort();
handler.sendClientMsg("+OK "+no);
} else if(param[1].equals("maxAuthTry")) {
int no = target.getMaxAuthTry();
handler.sendClientMsg("+OK "+no);
} else if(param[1].equals("maxAuthTryMsg")) {
String msg=target.getMaxAuthTryMsg();
msg = MyString.replaceAll(msg, "\n", "\\n");
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientEventHandler")) { /*v1.4.6*/
String msg=target.getClientEventHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientCommandHandler")) {
String msg=target.getClientCommandHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientWriteHandler")) { /*v1.4.6*/
String msg=target.getClientWriteHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientObjectHandler")) {
String msg=target.getClientObjectHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientAuthenticationHandler")) {
String msg=target.getClientAuthenticationHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientData")) {
String msg=target.getClientData();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("clientExtendedEventHandler")) { /*v1.4.6*/
String msg=target.getClientExtendedEventHandler();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("timeout")) {
String msg=""+target.getTimeout();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("timeoutMsg")) {
String msg=""+target.getTimeoutMsg();
msg = MyString.replaceAll(msg, "\n", "\\n");
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("plugin")) /* v1.2*/{
if(param[0].equals("self")) {
String msg = adminServer.getCommandPlugin();
handler.sendClientMsg("+OK "+msg);
} else {
handler.sendClientMsg("-ERR Bad target : "+param[0]+" self is only allowed.");
}
} else if(param[1].equals("consoleLoggingFormatter")) {
String msg=""+target.getConsoleLoggingFormatter(); /* v1.3 */
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("consoleLoggingLevel")) { /* v1.3 */
String msg=""+target.getConsoleLoggingLevel();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("serviceState")) {
int state=target.getServiceState(); /*v1.3*/
if(state==org.quickserver.net.Service.INIT)
handler.sendClientMsg("+OK INIT");
else if(state==org.quickserver.net.Service.RUNNING)
handler.sendClientMsg("+OK RUNNING");
else if(state==org.quickserver.net.Service.STOPPED)
handler.sendClientMsg("+OK STOPPED");
else if(state==org.quickserver.net.Service.SUSPENDED)
handler.sendClientMsg("+OK SUSPENDED");
else
handler.sendClientMsg("+OK UNKNOWN");
} else if(param[1].equals("communicationLogging")) {
String msg=""+target.getCommunicationLogging();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("objectPoolConfig-maxActive")) {
String msg=""+target.getConfig().getObjectPoolConfig().getMaxActive();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("objectPoolConfig-maxIdle")) {
String msg=""+target.getConfig().getObjectPoolConfig().getMaxIdle();
handler.sendClientMsg("+OK "+msg);
} else if(param[1].equals("objectPoolConfig-initSize")) {
String msg=""+target.getConfig().getObjectPoolConfig().getInitSize();
handler.sendClientMsg("+OK "+msg);
} else {
handler.sendClientMsg("-ERR Bad Get Key : "+param[1]);
}
} catch(Exception e) {
handler.sendClientMsg("-ERR "+e);
}
return;
} else if(cmd.equals("kill-clients-all")) /*v2.0.0*/{
ObjectPool objectPool = target.getClientHandlerPool();
if(PoolHelper.isPoolOpen(objectPool)==true) {
if(QSObjectPool.class.isInstance(objectPool)==false) {
handler.sendClientMsg("-ERR System Error!");
}
ClientIdentifier clientIdentifier = target.getClientIdentifier();
ClientHandler foundClientHandler = null;
synchronized(clientIdentifier.getObjectToSynchronize()) {
Iterator iterator = clientIdentifier.findAllClient();
handler.sendClientMsg("+OK closing");
int count = 0;
int found = 0;
while(iterator.hasNext()) {
foundClientHandler = (ClientHandler) iterator.next();
found++;
if(foundClientHandler.isClosed()==false) {
foundClientHandler.closeConnection();
count ++;
}
}
handler.sendClientMsg("Count Found: "+found);
handler.sendClientMsg("Count Closed: "+count);
}
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR Closing");
}
return;
} else if(cmd.equals("kill-client-with")) /*v2.0.0*/{
if(param.length < 2)/*target,search*/ {
handler.sendClientMsg("-ERR "+"insufficient param");
return;
}
String search = param[1];
ObjectPool objectPool = target.getClientHandlerPool();
if(PoolHelper.isPoolOpen(objectPool)==true) {
if(QSObjectPool.class.isInstance(objectPool)==false) {
handler.sendClientMsg("-ERR System Error!");
}
ClientIdentifier clientIdentifier = target.getClientIdentifier();
ClientHandler foundClientHandler = null;
synchronized(clientIdentifier.getObjectToSynchronize()) {
Iterator iterator = clientIdentifier.findAllClient();
handler.sendClientMsg("+OK closing");
int count = 0;
int found = 0;
while(iterator.hasNext()) {
foundClientHandler = (ClientHandler) iterator.next();
if(foundClientHandler.toString().indexOf(search)!=-1) {
found++;
if(foundClientHandler.isClosed()==false) {
foundClientHandler.closeConnection();
count ++;
}
}
}
handler.sendClientMsg("Count Found: "+found);
handler.sendClientMsg("Count Closed: "+count);
}
handler.sendClientMsg(".");
} else {
handler.sendClientMsg("-ERR Closing");
}
return;
} else {
handler.sendClientMsg("-ERR Bad Command : "+cmd);
}
return;
}
}