扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
大概思路：
创新互联一直秉承“诚信做人，踏实做事”的原则，不欺瞒客户，是我们最起码的底线！ 以服务为基础，以质量求生存，以技术求发展，成交一个客户多一个朋友！为您提供成都网站制作、网站建设、外贸网站建设、成都网页设计、重庆小程序开发公司、成都网站开发、成都网站制作、成都软件开发、手机APP定制开发是成都本地专业的网站建设和网站设计公司，等你一起来见证！
写两个程序，一个负责重启的程序，一个是待重启的程序，在这里为了区分我们假设负责重启的那个程序叫A,待重启的程序叫B，他们都是线程，还要搭配数据库，他是两个程序的桥梁，通过设置信号量进行判断程序状态（不妨设置信号量为Flag），我是这么设置的，0：表示程序正在运行中，1：表示程序需要重启，正准备做关闭自己的操作（只针对待重启的程序B），2：表示B程序已经把自己给关闭了，需要A程序把B程序启动。
实现步骤：
A程序：写一个线程进行读信号量Flag,当Flag为2的时候就把B程序启动
B程序：写一个线程进行读信号量Flag，当Flag为1的时候就把自己给关闭（java System.exit(0);）
数据库：需要一个表存Flag的值，创建表restart，并新建一个字段Flag,int(4）noNull
实现细节：
A 程序：
package com.app;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import databasetool.DBtool;
public class ReStart implements Runnable {
int status = 0;
public void run() {
DBtool con = new DBtool();
ResultSet rs = null;
String select = "select * from restart";
String restar = "update restart set status = '0'";// 准备启动程序，设置Status为0，表示已启动
try {
int result = con.executeUpdate(restar);
System.out.println("初始化，并将status状态设置为0，表示程序正常被启动了！");
} catch (SQLException e) {
e.printStackTrace();
}
while (true) {
while (true) {
if (status == 2) {// 2：表示关闭的程序等待重启
System.out.println("status状态为2，表示需要重新启动数采程序！");
try {
int result = con.executeUpdate(restar);
System.out.println("程序马上就被启动，并将status状态设置为0，表示程序正常运行！");
} catch (SQLException e) {
e.printStackTrace();
}
String cmd = "cmd /c start E:\\Bats\\MainThread.bat";// pass
try {
Process ps = Runtime.getRuntime().exec(cmd);
ps.waitFor();
} catch (IOException ioe) {
ioe.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
try {
rs = con.executeQuery(select);
while (rs.next()) {
status = rs.getInt("status");
System.out.println("检测当前状态status:"+status);
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
ReStart res = new ReStart();
res.run();
}
}B程序：
package datacollect;
import java.sql.ResultSet;
import java.sql.SQLException;
import databasetool.DBtool;
public class ExitMain implements Runnable {
@Override
public void run() {
DBtool dbtool = new DBtool();
int status = 0;// 0：表示不需要重启
ResultSet rs = null;
String select = "select * from restart";
String restar = "update restart set status = '2'";// 关闭了程序，等待重启
// 写日志相关内容
while (true) {
try {
rs = dbtool.executeQuery(select);
while (rs.next()) {
status = rs.getInt("status");
}
} catch (SQLException e) {
e.printStackTrace();
}
if (status == 1) {// 1：表示等待关闭程序
System.out.println("status状态为1，表示需要关闭当前程序！");
try {
int result = dbtool.executeUpdate(restar);
System.out.println("程序马上就被关闭，并将status状态设置为2，表示程序关闭了，需要重启！");
} catch (SQLException e) {
e.printStackTrace();
}
System.exit(0);
}
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public static void main(String[] args) {
ExitMain extm = new ExitMain();
extm.run();
}
}数据库读取工具类：
package databasetool;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DBtool {
private Connection connection = null;
public Statement statement = null;
private ResultSet result = null;
public DBtool() {
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
String url = "jdbc:sqlserver://localhost:1433;databaseName=tianjincollect;user=sa;password=123456";
connection = DriverManager.getConnection(url);
statement = connection.createStatement();
} catch (SQLException ex) {
System.out.println(ex.getMessage());
} catch (ClassNotFoundException ex) {
System.out.println(ex.getMessage());
}
}
public ResultSet executeQuery(String sql) throws SQLException {
try {
result = statement.executeQuery(sql);
} catch (SQLException se) {
System.out.println("ERROR:" + se.getMessage());
}
return result;
}
public int executeUpdate(String sql) throws SQLException {
int updatenum = 0;
try {
updatenum = statement.executeUpdate(sql);
return updatenum;
} catch (SQLException se) {
System.out.println("ERROR:" + se.getMessage());
}
return updatenum;
}
public void free() throws SQLException {
try {
if (result != null)
result.close();
if (statement != null)
statement.close();
if (connection != null)
connection.close();
} catch (SQLException se) {
System.out.println("ERROR:" + se.getMessage());
}
}
public static void main(String[] args) {
DBtool con = new DBtool();
ResultSet rs = null;
String sql = "select * from restart";
try {
rs = con.executeQuery(sql);
while(rs.next()){
int status = rs.getInt("status");
System.out.println(status);
}
} catch (SQLException e) {
e.printStackTrace();
}
sql = "update restart set status = '1'";
try {
int result = con.executeUpdate(sql);
} catch (SQLException e) {
e.printStackTrace();
}
}
}以上这篇Java操作另一个Java程序使其重启的简单实现就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持创新互联。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
微信二维码
移动版官网