io.jpom.common.commander

Class AbstractProjectCommander

java.lang.Object

io.jpom.common.commander.AbstractProjectCommander

Direct Known Subclasses:

BaseUnixProjectCommander, WindowsProjectCommander

public abstract class AbstractProjectCommander
extends Object

项目命令执行基类

Author:

Administrator

Field Summary

Fields

Modifier and Type	Field and Description
static ConcurrentHashMap<Integer,String>	PID_JPOM_NAME 进程id 对应Jpom 名称
static cn.hutool.cache.impl.LRUCache<Integer,String>	PID_PORT 进程Id 获取端口号
static String	RUNNING_TAG
static String	STOP_TAG

Constructor Summary

Constructors

Constructor and Description
AbstractProjectCommander()

Method Summary

Modifier and Type	Method and Description
String	backLog(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 清空日志信息
abstract String	buildJavaCommand(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 生成可以执行的命令
static AbstractProjectCommander	getInstance() 实例化Commander
String	getJpomNameByPid(int pid) 根据指定进程id获取Jpom 名称
String	getMainPort(int pid) 获取进程占用的主要端口
int	getPid(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 获取进程id
int	getPid(String tag) 获取进程id
protected String	getRunJavaPath(NodeProjectInfoModel nodeProjectInfoModel, boolean w)
boolean	isRun(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 是否正在运行
abstract List<NetstatModel>	listNetstat(int pid, boolean listening) 查询出指定端口信息
protected boolean	loopCheckRun(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem, boolean status) 阻塞检查程序状态
protected boolean	loopCheckRun(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem, int stopWaitTime, boolean status) 阻塞检查程序状态
cn.hutool.core.lang.Tuple	restart(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 重启
String	start(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 启动
String	status(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 查询项目状态
protected String	status(String tag) 查看状态
String	stop(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem) 停止
abstract String	stopJava(NodeProjectInfoModel nodeProjectInfoModel, NodeProjectInfoModel.JavaCopyItem javaCopyItem, int pid) 停止

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RUNNING_TAG

public static final String RUNNING_TAG

See Also:

Constant Field Values

STOP_TAG

public static final String STOP_TAG

See Also:

Constant Field Values

PID_JPOM_NAME

public static final ConcurrentHashMap<Integer,String> PID_JPOM_NAME

进程id 对应Jpom 名称

PID_PORT

public static final cn.hutool.cache.impl.LRUCache<Integer,String> PID_PORT

进程Id 获取端口号

Constructor Detail

AbstractProjectCommander

public AbstractProjectCommander()

Method Detail

getInstance

public static AbstractProjectCommander getInstance()

实例化Commander

Returns:

命令执行对象

buildJavaCommand

public abstract String buildJavaCommand(NodeProjectInfoModel nodeProjectInfoModel,
                                        NodeProjectInfoModel.JavaCopyItem javaCopyItem)

生成可以执行的命令

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本信息

Returns:

null 是条件不足

getRunJavaPath

protected String getRunJavaPath(NodeProjectInfoModel nodeProjectInfoModel,
                                boolean w)

start

public String start(NodeProjectInfoModel nodeProjectInfoModel,
                    NodeProjectInfoModel.JavaCopyItem javaCopyItem)
             throws Exception

启动

Parameters:

nodeProjectInfoModel - 项目

Returns:

结果

Throws:

Exception - 异常

listNetstat

public abstract List<NetstatModel> listNetstat(int pid,
                                               boolean listening)

查询出指定端口信息

Parameters:

pid - 进程id

listening - 是否只获取检查状态的

Returns:

数组

stop

public String stop(NodeProjectInfoModel nodeProjectInfoModel,
                   NodeProjectInfoModel.JavaCopyItem javaCopyItem)
            throws Exception

停止

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本信息

Returns:

结果

Throws:

Exception - 异常

stopJava

public abstract String stopJava(NodeProjectInfoModel nodeProjectInfoModel,
                                NodeProjectInfoModel.JavaCopyItem javaCopyItem,
                                int pid)
                         throws Exception

停止

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本信息

pid - 进程ID

Returns:

结果

Throws:

Exception - 异常

restart

public cn.hutool.core.lang.Tuple restart(NodeProjectInfoModel nodeProjectInfoModel,
                                         NodeProjectInfoModel.JavaCopyItem javaCopyItem)
                                  throws Exception

重启

Parameters:

nodeProjectInfoModel - 项目

Returns:

结果

Throws:

Exception - 异常

backLog

public String backLog(NodeProjectInfoModel nodeProjectInfoModel,
                      NodeProjectInfoModel.JavaCopyItem javaCopyItem)

清空日志信息

Parameters:

nodeProjectInfoModel - 项目

Returns:

结果

status

public String status(NodeProjectInfoModel nodeProjectInfoModel,
                     NodeProjectInfoModel.JavaCopyItem javaCopyItem)

查询项目状态

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本

Returns:

状态

status

protected String status(String tag)

查看状态

Parameters:

tag - 运行标识

Returns:

查询结果

getMainPort

public String getMainPort(int pid)

获取进程占用的主要端口

Parameters:

pid - 进程id

Returns:

端口

getJpomNameByPid

public String getJpomNameByPid(int pid)
                        throws IOException

根据指定进程id获取Jpom 名称

Parameters:

pid - 进程id

Returns:

false 不是来自Jpom

Throws:

IOException - 异常

getPid

public int getPid(NodeProjectInfoModel nodeProjectInfoModel,
                  NodeProjectInfoModel.JavaCopyItem javaCopyItem)
           throws Exception

获取进程id

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本

Returns:

未运行 返回 0

Throws:

Exception - 异常

getPid

public int getPid(String tag)
           throws Exception

获取进程id

Parameters:

tag - 项目Id

Returns:

未运行 返回 0

Throws:

Exception - 异常

isRun

public boolean isRun(NodeProjectInfoModel nodeProjectInfoModel,
                     NodeProjectInfoModel.JavaCopyItem javaCopyItem)

是否正在运行

Parameters:

nodeProjectInfoModel - 项目

Returns:

true 正在运行

loopCheckRun

protected boolean loopCheckRun(NodeProjectInfoModel nodeProjectInfoModel,
                               NodeProjectInfoModel.JavaCopyItem javaCopyItem,
                               boolean status)

阻塞检查程序状态

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本

status - 要检查的状态

Returns:

和参数status相反

loopCheckRun

protected boolean loopCheckRun(NodeProjectInfoModel nodeProjectInfoModel,
                               NodeProjectInfoModel.JavaCopyItem javaCopyItem,
                               int stopWaitTime,
                               boolean status)

阻塞检查程序状态

Parameters:

nodeProjectInfoModel - 项目

javaCopyItem - 副本

status - 要检查的状态

stopWaitTime - 检查等待时间

Returns:

和参数status相反