REPORT-19945 设计器启动信息收集

designer-realize/src/main/java/com/fr/design/mainframe/InformationCollector.java

@@ -1,9 +1,7 @@
-/**
- *
- */
 package com.fr.design.mainframe;
 
 import com.fr.base.FRContext;
+import com.fr.concurrent.NamedThreadFactory;
 import com.fr.config.MarketConfig;
 import com.fr.design.DesignerEnvManager;
 import com.fr.design.mainframe.errorinfo.ErrorInfoUploader;
@@ -30,6 +28,7 @@ import com.fr.stable.xml.XMLTools;
 import com.fr.stable.xml.XMLWriter;
 import com.fr.stable.xml.XMLableReader;
 import com.fr.third.javax.xml.stream.XMLStreamException;
+import com.sun.management.OperatingSystemMXBean;
 
 import java.io.BufferedWriter;
 import java.io.ByteArrayInputStream;
@@ -43,6 +42,8 @@ import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.OutputStreamWriter;
 import java.io.UnsupportedEncodingException;
+import java.lang.management.ManagementFactory;
+import java.nio.charset.StandardCharsets;
 import java.text.DateFormat;
 import java.util.ArrayList;
 import java.util.Date;
@@ -53,15 +54,19 @@ import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
 /**
- * @author neil
+ * 设计器信息收集
  *
+ * @author neil
  * @date: 2015-4-8-下午5:11:46
  */
 public class InformationCollector implements XMLReadable, XMLWriter {
 
-	// 24小时上传一次
+	/**
+	 * 24小时上传一次
+	 */
 	private static final long DELTA = 24 * 3600 * 1000L;
 	private static final long SEND_DELAY = 300 * 1000L;
+	private static final int BYTE_TO_MB = 1024 * 1024;
 	private static final String FILE_NAME = "fr.info";
 	private static final String XML_START_STOP_LIST = "StartStopList";
 	private static final String XML_START_STOP = "StartStop";
@@ -74,26 +79,33 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 	private static final String XML_UUID = "UUID";
 	private static final String XML_KEY = "ActiveKey";
 	private static final String XML_OS = "OS";
+	private static final String XML_ARCH = "arch";
+	private static final String XML_AVAILABLE_PROCESSORS = "cpu";
+	private static final String XML_PHYSICAL_MEMORY = "systemMemory";
 
 	private static InformationCollector collector;
 
-	//启动时间与关闭时间列表
+	/**
-	private List<StartStopTime> startStop = new ArrayList<StartStopTime>();
+	 * 启动时间与关闭时间列表
-	//上一次的发送时间
+	 */
+	private List<StartStopTime> startStop = new ArrayList<>();
+	/**
+	 * 上一次的发送时间
+	 */
 	private String lastTime;
 	private StartStopTime current = new StartStopTime();
 
-	public static InformationCollector getInstance(){
+	public static InformationCollector getInstance() {
 		if (collector == null) {
 			collector = new InformationCollector();
 
-            readEncodeXMLFile(collector, collector.getInfoFile());
+			readEncodeXMLFile(collector, collector.getInfoFile());
 		}
 
 		return collector;
 	}
 
-	private static void readEncodeXMLFile(XMLReadable xmlReadable, File xmlFile){
+	private static void readEncodeXMLFile(XMLReadable xmlReadable, File xmlFile) {
 		if (xmlFile == null || !xmlFile.exists()) {
 			return;
 		}
@@ -119,13 +131,13 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 
 	}
 
-	private static String getDecodeFileContent(File xmlFile) throws FileNotFoundException, UnsupportedEncodingException{
+	private static String getDecodeFileContent(File xmlFile) throws FileNotFoundException, UnsupportedEncodingException {
 		InputStream encodeInputStream = new FileInputStream(xmlFile);
 		String encodeContent = IOUtils.inputStream2String(encodeInputStream);
 		return DesUtils.getDecString(encodeContent);
 	}
 
-	private long getLastTimeMillis(){
+	private long getLastTimeMillis() {
 		if (StringUtils.isEmpty(this.lastTime)) {
 			return 0;
 		}
@@ -142,23 +154,36 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 		JSONObject content = new JSONObject();
 
 		JSONArray startStopArray = new JSONArray();
-		for (int i = 0; i < startStop.size(); i++) {
+		for (StartStopTime startStopTime : startStop) {
 			JSONObject jo = new JSONObject();
-			jo.put(ATTR_START, startStop.get(i).getStartDate());
+			jo.put(ATTR_START, startStopTime.getStartDate());
-			jo.put(ATTR_STOP, startStop.get(i).getStopDate());
+			jo.put(ATTR_STOP, startStopTime.getStopDate());
 			startStopArray.put(jo);
-			DesignerEnvManager envManager = DesignerEnvManager.getEnvManager();
-			content.put(XML_START_STOP, startStopArray);
-			content.put(XML_UUID, envManager.getUUID());
-			content.put(XML_JAR, GeneralUtils.readBuildNO());
-			content.put(XML_VERSION, ProductConstants.RELEASE_VERSION);
-			content.put(XML_USERNAME, MarketConfig.getInstance().getBbsUsername());
-			content.put(XML_KEY, envManager.getActivationKey());
-			content.put(XML_OS, System.getProperty("os.name"));
 		}
+		DesignerEnvManager envManager = DesignerEnvManager.getEnvManager();
+		content.put(XML_START_STOP, startStopArray);
+		content.put(XML_UUID, envManager.getUUID());
+		content.put(XML_JAR, GeneralUtils.readBuildNO());
+		content.put(XML_VERSION, ProductConstants.RELEASE_VERSION);
+            content.put(XML_USERNAME, MarketConfig.getInstance().getBbsUsername());
+		content.put(XML_KEY, envManager.getActivationKey());
+		content.put(XML_OS, System.getProperty("os.name"));
+		content.put(XML_ARCH, System.getProperty("os.arch"));
+		content.put(XML_AVAILABLE_PROCESSORS, Runtime.getRuntime().availableProcessors());
+		content.put(XML_PHYSICAL_MEMORY, getTotalPhysicalMemorySize());
 		return content;
 	}
 
+	/**
+	 * 获取物理内存，单位GB
+	 *
+	 * @return 物理内存
+	 */
+	private static long getTotalPhysicalMemorySize() {
+		OperatingSystemMXBean bean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
+		return bean.getTotalPhysicalMemorySize() / BYTE_TO_MB;
+	}
+
 	private void sendUserInfo(){
 		long currentTime = new Date().getTime();
 		long lastTime = getLastTimeMillis();
@@ -186,18 +211,18 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 	/**
 	 * 收集开始使用时间，发送信息
 	 */
-	public void collectStartTime(){
+	public void collectStartTime() {
 		this.current.setStartDate(dateToString());
 
 		sendUserInfoInOtherThread();
 	}
 
-	private void sendUserInfoInOtherThread(){
+	private void sendUserInfoInOtherThread() {
 		if (!DesignerEnvManager.getEnvManager().isJoinProductImprove() || !FRContext.isChineseEnv()) {
 			return;
 		}
 
-		ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
+		ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("InformationCollector"));
 		service.schedule(new Runnable() {
 			@Override
 			public void run() {
@@ -210,67 +235,66 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 		}, SEND_DELAY, TimeUnit.MILLISECONDS);
 	}
 
-    /**
+	/**
-     * 收集结束使用时间
+	 * 收集结束使用时间
-     */
+	 */
-	public void collectStopTime(){
+	public void collectStopTime() {
 		this.current.setStopDate(dateToString());
 	}
 
-	private String dateToString(){
+	private String dateToString() {
 		DateFormat df = FRContext.getDefaultValues().getDateTimeFormat();
 		return df.format(new Date());
 	}
 
-	private void reset(){
+	private void reset() {
 		this.startStop.clear();
 		this.lastTime = dateToString();
 	}
 
-    private File getInfoFile() {
+	private File getInfoFile() {
-    	return new File(StableUtils.pathJoin(ProductConstants.getEnvHome(), FILE_NAME));
+		return new File(StableUtils.pathJoin(ProductConstants.getEnvHome(), FILE_NAME));
-    }
+	}
-
+
-    /**
+	/**
-     * 保存xml文件
+	 * 保存xml文件
-     */
+	 */
-    public void saveXMLFile() {
+	public void saveXMLFile() {
-    	File xmlFile = this.getInfoFile();
+		File xmlFile = this.getInfoFile();
-    	try{
+		try {
-    		ByteArrayOutputStream out = new ByteArrayOutputStream();
+			ByteArrayOutputStream out = new ByteArrayOutputStream();
 			XMLTools.writeOutputStreamXML(this, out);
 			out.flush();
 			out.close();
-			String fileContent = new String(out.toByteArray(), EncodeConstants.ENCODING_UTF_8);
+			String fileContent = new String(out.toByteArray(), StandardCharsets.UTF_8);
 			String encodeCotent = DesUtils.getEncString(fileContent);
 			writeEncodeContentToFile(encodeCotent, xmlFile);
-    	}catch (Exception e) {
+		} catch (Exception e) {
-            FineLoggerFactory.getLogger().error(e.getMessage(), e);
+			FineLoggerFactory.getLogger().error(e.getMessage(), e);
 		}
-    }
+	}
 
 
 	/**
 	 * 将文件内容写到输出流中
 	 */
-	private static void writeEncodeContentToFile(String fileContent, File file){
+	private static void writeEncodeContentToFile(String fileContent, File file) {
 		BufferedWriter bw = null;
 		try {
 			FileOutputStream fos = new FileOutputStream(file);
-			OutputStreamWriter osw = new OutputStreamWriter(fos, EncodeConstants.ENCODING_UTF_8);
+			OutputStreamWriter osw = new OutputStreamWriter(fos, StandardCharsets.UTF_8);
 			bw = new BufferedWriter(osw);
 			bw.write(fileContent);
 		} catch (Exception e) {
-            FineLoggerFactory.getLogger().error(e.getMessage(), e);
+			FineLoggerFactory.getLogger().error(e.getMessage(), e);
 		} finally {
-			if(bw != null){
+			if (bw != null) {
 				try {
 					bw.close();
-				} catch (IOException e) {
+				} catch (IOException ignore) {
 				}
 			}
 		}
-
 	}
 
 	@Override
@@ -285,56 +309,57 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 		writer.end();
 	}
 
-	private void writeStartStopList(XMLPrintWriter writer){
+	private void writeStartStopList(XMLPrintWriter writer) {
 		//启停
-    	writer.startTAG(XML_START_STOP_LIST);
+		writer.startTAG(XML_START_STOP_LIST);
-    	for (int i = 0; i < startStop.size(); i++) {
+		for (StartStopTime startStopTime : startStop) {
-    		startStop.get(i).writeXML(writer);
+			startStopTime.writeXML(writer);
 		}
-    	writer.end();
+		writer.end();
 	}
 
-	private void writeTag(String tag, String content, XMLPrintWriter writer){
+	private void writeTag(String tag, String content, XMLPrintWriter writer) {
 		if (StringUtils.isEmpty(content)) {
 			return;
 		}
 
-    	writer.startTAG(tag);
+		writer.startTAG(tag);
-    	writer.textNode(content);
+		writer.textNode(content);
-    	writer.end();
+		writer.end();
 	}
 
 	@Override
 	public void readXML(XMLableReader reader) {
-        if (reader.isChildNode()) {
+		if (reader.isChildNode()) {
-        	String name = reader.getTagName();
+			String name = reader.getTagName();
-            if (XML_START_STOP_LIST.equals(name)) {
+			if (XML_START_STOP_LIST.equals(name)) {
-            	readStartStopList(reader);
+				readStartStopList(reader);
-            } else if(XML_LAST_TIME.equals(name)){
+			} else if (XML_LAST_TIME.equals(name)) {
-            	readLastTime(reader);
+				readLastTime(reader);
 			}
-        }
+		}
 	}
 
-	private void readLastTime(XMLableReader reader){
+	private void readLastTime(XMLableReader reader) {
 		String tmpVal;
 		if (StringUtils.isNotBlank(tmpVal = reader.getElementValue())) {
 			this.lastTime = tmpVal;
 		}
 	}
 
-	private void readStartStopList(XMLableReader reader){
+	private void readStartStopList(XMLableReader reader) {
-    	startStop.clear();
+		startStop.clear();
 
 		reader.readXMLObject(new XMLReadable() {
-            public void readXML(XMLableReader reader) {
+			@Override
-                if (XML_START_STOP.equals(reader.getTagName())) {
+			public void readXML(XMLableReader reader) {
-                    StartStopTime startStopTime = new StartStopTime();
+				if (XML_START_STOP.equals(reader.getTagName())) {
-                    reader.readXMLObject(startStopTime);
+					StartStopTime startStopTime = new StartStopTime();
-                    startStop.add(startStopTime);
+					reader.readXMLObject(startStopTime);
-                }
+					startStop.add(startStopTime);
-            }
+				}
-        });
+			}
+		});
 	}
 
 	private class StartStopTime implements XMLReadable, XMLWriter {
@@ -358,17 +383,19 @@ public class InformationCollector implements XMLReadable, XMLWriter {
 			this.stopDate = endDate;
 		}
 
+		@Override
 		public void writeXML(XMLPrintWriter writer) {
-        	writer.startTAG(XML_START_STOP);
+			writer.startTAG(XML_START_STOP);
-        	if (StringUtils.isNotEmpty(startDate)) {
+			if (StringUtils.isNotEmpty(startDate)) {
-        		writer.attr(ATTR_START, this.startDate);
+				writer.attr(ATTR_START, this.startDate);
 			}
-        	if (StringUtils.isNotEmpty(stopDate)) {
+			if (StringUtils.isNotEmpty(stopDate)) {
-        		writer.attr(ATTR_STOP, this.stopDate);
+				writer.attr(ATTR_STOP, this.stopDate);
 			}
-        	writer.end();
+			writer.end();
 		}
 
+		@Override
 		public void readXML(XMLableReader reader) {
 			this.startDate = reader.getAttrAsString(ATTR_START, StringUtils.EMPTY);
 			this.stopDate = reader.getAttrAsString(ATTR_STOP, StringUtils.EMPTY);

designer-realize/src/main/java/com/fr/design/mainframe/messagecollect/StartupMessageCollector.java

@@ -0,0 +1,89 @@
+package com.fr.design.mainframe.messagecollect;
+
+import com.fr.concurrent.NamedThreadFactory;
+import com.fr.design.mainframe.SiteCenterToken;
+import com.fr.event.Event;
+import com.fr.event.EventDispatcher;
+import com.fr.event.Listener;
+import com.fr.general.CloudCenter;
+import com.fr.general.ComparatorUtils;
+import com.fr.general.http.HttpToolbox;
+import com.fr.json.JSONObject;
+import com.fr.log.FineLoggerFactory;
+import com.fr.module.ModuleContext;
+import com.fr.module.engine.FineModule;
+import com.fr.runtime.FineRuntime;
+import com.fr.stable.StringUtils;
+
+import java.util.HashMap;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * 启动信息收集
+ *
+ * @author vito
+ * @version 10.0
+ * Created by vito on 2019/9/4
+ */
+public class StartupMessageCollector {
+
+    private static final String XML_STARTUP_TIME = "t";
+    private static final String XML_STARTUP_LOG = "startupLog";
+    private static final String XML_STARTUP_Memory = "designerMemory";
+    private static final String XML_STARTUP_COST = "cost";
+    private static final String STARTUP_URL_KEY = "user.info.v10.startup";
+    private static final String LOG_TYPE = "single";
+    private static final int BYTE_TO_MB = 1024 * 1024;
+
+    public static final StartupMessageCollector INSTANCE = new StartupMessageCollector();
+
+    private StartupMessageCollector() {
+    }
+
+    public static StartupMessageCollector getInstance() {
+        return INSTANCE;
+    }
+
+    public void recordStartupLog() {
+        EventDispatcher.listen(FineRuntime.ApplicationEvent.AFTER_START, new Listener<Long>() {
+
+            @Override
+            public void on(Event event, Long param) {
+                final String url = CloudCenter.getInstance().acquireUrlByKind(STARTUP_URL_KEY);
+                if (StringUtils.isEmpty(url)) {
+                    return;
+                }
+                ExecutorService es = Executors.newSingleThreadExecutor(new NamedThreadFactory("StartupMessageCollector"));
+                es.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        FineModule root = (FineModule) ModuleContext.getRoot().getRoot();
+                        JSONObject profile = root.profile();
+                        JSONObject json = JSONObject.create()
+                                .put(XML_STARTUP_TIME, FineRuntime.getAppStartTime() + FineRuntime.getStartingTime())
+                                .put(XML_STARTUP_COST, FineRuntime.getStartingTime())
+                                .put(XML_STARTUP_LOG, profile)
+                                .put(XML_STARTUP_Memory, Runtime.getRuntime().totalMemory() / BYTE_TO_MB);
+                        sendInfo(json, url + LOG_TYPE);
+                    }
+                });
+                es.shutdown();
+            }
+        });
+    }
+
+    private boolean sendInfo(JSONObject content, String url) {
+        boolean success = false;
+        try {
+            HashMap<String, Object> para = new HashMap<>();
+            para.put("token", SiteCenterToken.generateToken());
+            para.put("content", content);
+            String res = HttpToolbox.post(url, para);
+            success = ComparatorUtils.equals(new JSONObject(res).get("status"), "success");
+        } catch (Exception e) {
+            FineLoggerFactory.getLogger().error(e.getMessage(), e);
+        }
+        return success;
+    }
+}

designer-realize/src/main/java/com/fr/start/module/DesignerStartup.java

@@ -1,14 +1,15 @@
 package com.fr.start.module;
 
 
+import com.fr.concurrent.NamedThreadFactory;
 import com.fr.design.file.HistoryTemplateListCache;
 import com.fr.design.mainframe.DesignerContext;
+import com.fr.design.mainframe.messagecollect.StartupMessageCollector;
 import com.fr.event.Event;
 import com.fr.event.Listener;
 import com.fr.module.Activator;
 import com.fr.record.analyzer.EnableMetrics;
 import com.fr.record.analyzer.Metrics;
-import com.fr.runtime.FineRuntime;
 import com.fr.start.Designer;
 import com.fr.start.ServerStarter;
 import com.fr.start.SplashContext;
@@ -42,7 +43,7 @@ public class DesignerStartup extends Activator {
         startSub(EnvBasedModule.class);
         //designer模块启动好后，查看demo
         browserDemo();
-        ExecutorService service = Executors.newFixedThreadPool(2);
+        ExecutorService service = Executors.newSingleThreadExecutor(new NamedThreadFactory("FineEmbedServerStart"));
         service.submit(new Runnable() {
             @Override
             public void run() {
@@ -67,7 +68,7 @@ public class DesignerStartup extends Activator {
 
         DesignerContext.getDesignerFrame().getProgressDialog().setVisible(true);
         startSub(StartFinishActivator.class);
-        FineRuntime.startFinish();
+        StartupMessageCollector.getInstance().recordStartupLog();
     }
 
     private void browserDemo() {
@@ -87,7 +88,7 @@ public class DesignerStartup extends Activator {
 
             @Override
             public void on(Event event, Workspace current) {
-                getSub(EnvBasedModule.class).stop();
+                stopSub(EnvBasedModule.class);
             }
         });
         /*切换环境后，重新启动所有相关模块，最先执行*/
@@ -95,7 +96,7 @@ public class DesignerStartup extends Activator {
 
             @Override
             public void on(Event event, Workspace current) {
-                getSub(EnvBasedModule.class).start();
+                startSub(EnvBasedModule.class);
                 // 切换后的环境是本地环境才启动内置服务器
                 if (current.isLocal()) {
                     ExecutorService service = Executors.newSingleThreadExecutor();