增加flushmethod命令,可以在需要的时候刷出tmethod.log

src/main/java/com/taobao/profile/Manager.java

@@ -49,6 +49,10 @@ public class Manager {
 	 * 获取状态命令
 	 */
 	public static final String STATUS = "status";
+	/**
+	 * 远程刷出方法数据
+	 */
+	public static final String FLUSHMETHOD = "flushmethod";
 	/**
 	 * 是否用纳秒采集
 	 */
@@ -97,7 +101,7 @@ public class Manager {
 	 * 将性能分析数据写出到磁盘
 	 */
 	private final DataDumpThread dumpThread;
-	
+
 	/**
 	 * 采样线程
 	 */
@@ -168,11 +172,11 @@ public void setSwitchProfile(boolean switchProfile) {
 	}
 
 	/**
-     * @return the switchProfile
-     */
-    public boolean getSwitchProfile() {
-    	return switchProfile.get();
-    }
+	 * @return the switchProfile
+	 */
+	public boolean getSwitchProfile() {
+		return switchProfile.get();
+	}
 
 	/**
 	 * @param canProfile

src/main/java/com/taobao/profile/client/TProfilerClient.java

@@ -54,6 +54,16 @@ public static String status(String server) {
 		return getStatus("status", server);
 	}
 
+	/**
+	 * 远程刷出方法数据
+	 * 
+	 * @param server
+	 *            ip
+	 */
+	public static void flushMethod(String server) {
+		doSend("flushmethod", server);
+	}
+
 	/**
 	 * 建立远程连接并发送命令
 	 * 
@@ -150,6 +160,8 @@ public static void main(String[] args) {
 			start(args[0]);
 		} else if (args[1].toLowerCase().equals("stop")) {
 			stop(args[0]);
+		} else if (args[1].toLowerCase().equals("flushmethod")) {
+			flushMethod(args[0]);
 		} else {
 			System.out.println(status(args[0]));
 		}

src/main/java/com/taobao/profile/runtime/MethodCache.java

@@ -10,6 +10,10 @@
 
 import java.util.Vector;
 
+import com.taobao.profile.Manager;
+import com.taobao.profile.Profiler;
+import com.taobao.profile.utils.DailyRollingFileWriter;
+
 /**
  * 方法名缓存,用ID代替方法名进行剖析,提升性能
  * 
@@ -70,14 +74,31 @@ public synchronized static void UpdateMethodName(int id, String className, Strin
 	}
 
 	/**
-	 * 取得方法名
-	 * 
-	 * @param id
-	 * @return
+	 * 写出方法信息
 	 */
-	public static String getClasssMethodInfo(int id) {
-		MethodInfo method = mCacheMethods.get(id);
-		return method.toString();
-	}
+	public synchronized static void flushMethodData() {
+		DailyRollingFileWriter fileWriter = new DailyRollingFileWriter(Manager.METHOD_LOG_PATH);
+
+		fileWriter.append("instrumentclass:");
+		fileWriter.append(String.valueOf(Profiler.instrumentClassCount));
+		fileWriter.append(" instrumentmethod:");
+		fileWriter.append(String.valueOf(Profiler.instrumentMethodCount));
+		fileWriter.append("\n");
 
+		Vector<MethodInfo> vector = MethodCache.mCacheMethods;
+		int size = vector.size();
+		StringBuilder sb = new StringBuilder();
+		for (int i = 0; i < size; i++) {
+			sb.append(i);
+			sb.append(' ');
+			sb.append(vector.get(i).toString());
+			sb.append('\n');
+			fileWriter.append(sb.toString());
+			sb.setLength(0);
+			if ((i % 50) == 0) {
+				fileWriter.flushAppend();
+			}
+		}
+		fileWriter.closeFile();
+	}
 }

src/main/java/com/taobao/profile/thread/InnerSocketThread.java

@@ -18,6 +18,7 @@
 import java.net.SocketException;
 
 import com.taobao.profile.Manager;
+import com.taobao.profile.runtime.MethodCache;
 
 /**
  * 对外提供Socket开关
@@ -50,6 +51,8 @@ public void run() {
 					Manager.instance().setSwitchProfile(true);
 				} else if (Manager.STATUS.equals(command)) {
 					write(child.getOutputStream());
+				} else if (Manager.FLUSHMETHOD.equals(command)) {
+					MethodCache.flushMethodData();
 				} else {
 					Manager.instance().setSwitchProfile(false);
 				}

src/main/java/com/taobao/profile/thread/TimeControlThread.java

@@ -12,7 +12,7 @@
 
 import com.taobao.profile.Manager;
 import com.taobao.profile.config.ProfConfig;
-import com.taobao.profile.utils.MethodDump;
+import com.taobao.profile.runtime.MethodCache;
 
 /**
  * 开始时间结束时间控制线程
@@ -115,7 +115,7 @@ public void run() {
 				} else {
 					Manager.instance().setCanProfile(false);
 					Manager.instance().setPauseProfile(true);
-					MethodDump.flushMethodData();
+					MethodCache.flushMethodData();
 					time = nextStartTime(startTime);
 					await(time);
 				}