添加monitor监控程序

config/applicationContext.xml

@@ -22,6 +22,7 @@
 				<ref bean="applicationSetting5" />
 				<ref bean="applicationSetting6" />
 				<ref bean="applicationSetting7" />
+				<ref bean="applicationSetting8" />
 			</list>
 		</property>
 	</bean>
@@ -35,21 +36,29 @@
 		<property name="name" value="报表服务程序"></property>
 		<property name="startBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\start.bat"></property>
 		<property name="stopBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\stop.bat"></property>
+		<property name="monitorUrl" value="http://127.0.0.1:81/monitor"></property>
+		<property name="token" value="123456"></property>
 	</bean>
 	<bean id="applicationSetting3" class="com.leanwo.management.model.ApplicationSetting">
 		<property name="name" value="工作流服务程序"></property>
 		<property name="startBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\start.bat"></property>
 		<property name="stopBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\stop.bat"></property>
+		<property name="monitorUrl" value="http://127.0.0.1:82/activiti/explorer/monitor"></property>
+		<property name="token" value="123456"></property>
 	</bean>
 	<bean id="applicationSetting4" class="com.leanwo.management.model.ApplicationSetting">
 		<property name="name" value="钉钉服务程序"></property>
 		<property name="startBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\start.bat"></property>
 		<property name="stopBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\stop.bat"></property>
+		<property name="monitorUrl" value="http://127.0.0.1:83/monitor"></property>
+		<property name="token" value="123456"></property>
 	</bean>
 	<bean id="applicationSetting5" class="com.leanwo.management.model.ApplicationSetting">
 		<property name="name" value="微信服务程序"></property>
 		<property name="startBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\start.bat"></property>
 		<property name="stopBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\stop.bat"></property>
+		<property name="monitorUrl" value="http://127.0.0.1:80/monitor"></property>
+		<property name="token" value="123456"></property>
 	</bean>
 	<bean id="applicationSetting6" class="com.leanwo.management.model.ApplicationSetting">
 		<property name="name" value="中间件程序"></property>
@@ -61,6 +70,13 @@
 		<property name="startBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\start.bat"></property>
 		<property name="stopBatFile" value="C:\Users\YangZhiJie\Desktop\Servers\DingTalk_Server_20171212\stop.bat"></property>
 	</bean>
+	<bean id="applicationSetting8" class="com.leanwo.management.model.ApplicationSetting">
+		<property name="name" value="文件服务程序"></property>
+		<property name="startBatFile" value=""></property>
+		<property name="stopBatFile" value=""></property>
+		<property name="monitorUrl" value="http://127.0.0.1:85/api/monitor"></property>
+		<property name="token" value="123456"></property>
+	</bean>
 	
 	<bean id="springUtil" class="org.leanwo.management.util.SpringUtil" />
 </beans>

pom.xml

@@ -22,7 +22,6 @@
 			<scope>test</scope>
 		</dependency>
 
-
 		<dependency>
 			<groupId>org.slf4j</groupId>
 			<artifactId>slf4j-api</artifactId>
@@ -50,11 +49,36 @@
 			<artifactId>spring-beans</artifactId>
 			<version>5.0.1.RELEASE</version>
 		</dependency>
+		
+		<!-- https://mvnrepository.com/artifact/org.springframework/spring-webmvc -->
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-webmvc</artifactId>
+			<version>4.3.12.RELEASE</version>
+		</dependency>
+		
 		<dependency>
 		    <groupId>org.apache.commons</groupId>
 		    <artifactId>commons-exec</artifactId>
 		    <version>1.3</version>
 		</dependency>
+		
+		<!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core -->
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-core</artifactId>
+			<version>2.9.2</version>
+		</dependency>
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-databind</artifactId>
+			<version>2.9.2</version>
+		</dependency>
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-annotations</artifactId>
+			<version>2.9.2</version>
+		</dependency>
 	</dependencies>
 	
 	

src/main/java/com/leanwo/management/ServerManagmentJFrame.java

@@ -9,6 +9,7 @@ import java.awt.event.ActionEvent;
 import java.awt.event.ActionListener;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -28,6 +29,14 @@ import org.apache.commons.exec.PumpStreamHandler;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.leanwo.management.util.SpringUtil;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
+import org.springframework.web.client.RestTemplate;
 
 import com.leanwo.management.model.ApplicationSetting;
 import com.leanwo.management.model.ApplicationSettingCache;
@@ -242,7 +251,35 @@ public class ServerManagmentJFrame extends JFrame implements ActionListener {
 						statusLabel.setText("运行中");
 					}
 				}
+				
+				// 监控各个服务程序是否正在运行
+				String url = setting.getMonitorUrl();
+				String token = setting.getToken();
+				if(url == null || "".equals(url) || token == null || "".equals(token)){
+					continue;
+				}
+				RestTemplate restTemplate = new RestTemplate();		
+				restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
+				HttpHeaders headers = new HttpHeaders();
+				headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
+				headers.add("account", "2");
+				headers.add("token", token);
+				HttpEntity entity = new HttpEntity(headers);
+				try{			
+					ResponseEntity<Long> response = restTemplate.exchange(url, HttpMethod.GET, entity, Long.class);
+					((SimpleClientHttpRequestFactory)restTemplate.getRequestFactory()).setReadTimeout(1000*30);
+					((SimpleClientHttpRequestFactory)restTemplate.getRequestFactory()).setConnectTimeout(1000*30);
+					Long result = response.getBody();
+					long mills = new Date().getTime() - result;
+					if(statusLabel != null){
+						statusLabel.setText("运行中(" + mills + "ms)");
+					}
+				}catch(Exception ex){
+					if(statusLabel != null){
+						statusLabel.setText("已停止");
+					}
+				}
 			}
 		}
-	}
+	}	
 }

src/main/java/com/leanwo/management/model/ApplicationSetting.java

@@ -29,10 +29,52 @@ public class ApplicationSetting {
 	 */
 	private String stopBatFile;
 	
+	/** The execute watchdog. */
+	private ExecuteWatchdog executeWatchdog;
+
+	/** 监控地址. */
+	private String monitorUrl;
+	
+	/** token. */
+	private String token;
+	
+	
+	
 	/**
-	 * 
+	 * Gets the token.
+	 *
+	 * @return the token
 	 */
-	private ExecuteWatchdog executeWatchdog;
+	public String getToken() {
+		return token;
+	}
+
+	/**
+	 * Sets the token.
+	 *
+	 * @param token the new token
+	 */
+	public void setToken(String token) {
+		this.token = token;
+	}
+
+	/**
+	 * Gets the 监控地址.
+	 *
+	 * @return the 监控地址
+	 */
+	public String getMonitorUrl() {
+		return monitorUrl;
+	}
+
+	/**
+	 * Sets the 监控地址.
+	 *
+	 * @param monitorUrl the new 监控地址
+	 */
+	public void setMonitorUrl(String monitorUrl) {
+		this.monitorUrl = monitorUrl;
+	}
 
 	/**
 	 * Gets the 应用程序名称.
@@ -107,18 +149,18 @@ public class ApplicationSetting {
 	}
 
 	/**
-	 * 
+	 * Gets the execute watchdog.
 	 *
-	 * @return 
+	 * @return the execute watchdog
 	 */
 	public ExecuteWatchdog getExecuteWatchdog() {
 		return executeWatchdog;
 	}
 
 	/**
-	 * 
+	 * Sets the execute watchdog.
 	 *
-	 * @param executeWatchdog 
+	 * @param executeWatchdog the new execute watchdog
 	 */
 	public void setExecuteWatchdog(ExecuteWatchdog executeWatchdog) {
 		this.executeWatchdog = executeWatchdog;