Java操作另一个Java程序使其重启的简单实现
大概思路：
写两个程序，一个负责重启的程序，一个是待重启的程序，在这里为了区分我们假设负责重启的那个程序叫A,待重启的程序叫B，他们都是线程，还要搭配数据库，他是两个程序的桥梁，通过设置信号量进行判断程序状态（不妨设置信号量为Flag），我是这么设置的，0：表示程序正在运行中，1：表示程序需要重启，正准备做关闭自己的操作（只针对待重启的程序B），2：表示B程序已经把自己给关闭了，需要A程序把B程序启动。
实现步骤：
A程序：写一个线程进行读信号量Flag,当Flag为2的时候就把B程序启动
B程序：写一个线程进行读信号量Flag，当Flag为1的时候就把自己给关闭（javaSystem.exit(0);）
数据库：需要一个表存Flag的值，创建表restart，并新建一个字段Flag,int(4）noNull
实现细节：
A程序：
packagecom.app;
importjava.io.IOException;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importdatabasetool.DBtool;
publicclassReStartimplementsRunnable{
intstatus=0;
publicvoidrun(){
DBtoolcon=newDBtool();
ResultSetrs=null;
Stringselect="select*fromrestart";
Stringrestar="updaterestartsetstatus='0'";//准备启动程序，设置Status为0，表示已启动
try{
intresult=con.executeUpdate(restar);
System.out.println("初始化，并将status状态设置为0，表示程序正常被启动了！");
}catch(SQLExceptione){
e.printStackTrace();
}
while(true){
while(true){
if(status==2){//2：表示关闭的程序等待重启
System.out.println("status状态为2，表示需要重新启动数采程序！");
try{
intresult=con.executeUpdate(restar);
System.out.println("程序马上就被启动，并将status状态设置为0，表示程序正常运行！");
}catch(SQLExceptione){
e.printStackTrace();
}
Stringcmd="cmd/cstartE:\\Bats\\MainThread.bat";//pass
try{
Processps=Runtime.getRuntime().exec(cmd);
ps.waitFor();
}catch(IOExceptionioe){
ioe.printStackTrace();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
try{
rs=con.executeQuery(select);
while(rs.next()){
status=rs.getInt("status");
System.out.println("检测当前状态status:"+status);
}
}catch(SQLExceptione){
e.printStackTrace();
}
try{
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
}
}
publicstaticvoidmain(String[]args){
ReStartres=newReStart();
res.run();
}
}
B程序：
packagedatacollect;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importdatabasetool.DBtool;
publicclassExitMainimplementsRunnable{
@Override
publicvoidrun(){
DBtooldbtool=newDBtool();
intstatus=0;//0：表示不需要重启
ResultSetrs=null;
Stringselect="select*fromrestart";
Stringrestar="updaterestartsetstatus='2'";//关闭了程序，等待重启
//写日志相关内容
while(true){
try{
rs=dbtool.executeQuery(select);
while(rs.next()){
status=rs.getInt("status");
}
}catch(SQLExceptione){
e.printStackTrace();
}
if(status==1){//1：表示等待关闭程序
System.out.println("status状态为1，表示需要关闭当前程序！");
try{
intresult=dbtool.executeUpdate(restar);
System.out.println("程序马上就被关闭，并将status状态设置为2，表示程序关闭了，需要重启！");
}catch(SQLExceptione){
e.printStackTrace();
}
System.exit(0);
}
try{
Thread.sleep(5000);
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}
publicstaticvoidmain(String[]args){
ExitMainextm=newExitMain();
extm.run();
}
}
数据库读取工具类：
packagedatabasetool;
importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.sql.Statement;
publicclassDBtool{
privateConnectionconnection=null;
publicStatementstatement=null;
privateResultSetresult=null;
publicDBtool(){
try{
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
Stringurl="jdbc:sqlserver://localhost:1433;databaseName=tianjincollect;user=sa;password=123456";
connection=DriverManager.getConnection(url);
statement=connection.createStatement();
}catch(SQLExceptionex){
System.out.println(ex.getMessage());
}catch(ClassNotFoundExceptionex){
System.out.println(ex.getMessage());
}
}
publicResultSetexecuteQuery(Stringsql)throwsSQLException{
try{
result=statement.executeQuery(sql);
}catch(SQLExceptionse){
System.out.println("ERROR:"+se.getMessage());
}
returnresult;
}
publicintexecuteUpdate(Stringsql)throwsSQLException{
intupdatenum=0;
try{
updatenum=statement.executeUpdate(sql);
returnupdatenum;
}catch(SQLExceptionse){
System.out.println("ERROR:"+se.getMessage());
}
returnupdatenum;
}
publicvoidfree()throwsSQLException{
try{
if(result!=null)
result.close();
if(statement!=null)
statement.close();
if(connection!=null)
connection.close();
}catch(SQLExceptionse){
System.out.println("ERROR:"+se.getMessage());
}
}
publicstaticvoidmain(String[]args){
DBtoolcon=newDBtool();
ResultSetrs=null;
Stringsql="select*fromrestart";
try{
rs=con.executeQuery(sql);
while(rs.next()){
intstatus=rs.getInt("status");
System.out.println(status);
}
}catch(SQLExceptione){
e.printStackTrace();
}
sql="updaterestartsetstatus='1'";
try{
intresult=con.executeUpdate(sql);
}catch(SQLExceptione){
e.printStackTrace();
}
}
}
以上这篇Java操作另一个Java程序使其重启的简单实现就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。