MATRIX_VERSION=0.6.5 

dependencies { classpath ("com.tencent.matrix:matrix-gradle-plugin:${MATRIX_VERSION}") { changing = true } } 

 dependencies { implementation group: "com.tencent.matrix", name: "matrix-android-lib", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-android-commons", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-trace-canary", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-resource-canary-android", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-resource-canary-common", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-io-canary", version: MATRIX_VERSION, changing: true implementation group: "com.tencent.matrix", name: "matrix-sqlite-lint-android-sdk", version: MATRIX_VERSION, changing: true } apply plugin: 'com.tencent.matrix-plugin' matrix { trace { enable = true	//if you don't want to use trace canary, set false baseMethodMapFile = "${project.buildDir}/matrix_output/Debug.methodmap" blackListFile = "${project.projectDir}/matrixTrace/blackMethodList.txt" } } 

 public class TestPluginListener extends DefaultPluginListener { public static final String TAG = "Matrix.TestPluginListener"; public TestPluginListener(Context context) { super(context); } @Override public void onReportIssue(Issue issue) { super.onReportIssue(issue); MatrixLog.e(TAG, issue.toString()); //add your code to process data } } 

 public class DynamicConfigImplDemo implements IDynamicConfig { public DynamicConfigImplDemo() {} public boolean isFPSEnable() { return true;} public boolean isTraceEnable() { return true; } public boolean isMatrixEnable() { return true; } public boolean isDumpHprof() { return false;} @Override public String get(String key, String defStr) { //hook to change default values } @Override public int get(String key, int defInt) { //hook to change default values } @Override public long get(String key, long defLong) { //hook to change default values } @Override public boolean get(String key, boolean defBool) { //hook to change default values } @Override public float get(String key, float defFloat) { //hook to change default values } } 

 Matrix.Builder builder = new Matrix.Builder(application); // build matrix builder.patchListener(new TestPluginListener(this)); // add general pluginListener DynamicConfigImplDemo dynamicConfig = new DynamicConfigImplDemo(); // dynamic config // init plugin IOCanaryPlugin ioCanaryPlugin = new IOCanaryPlugin(new IOConfig.Builder() .dynamicConfig(dynamicConfig) .build()); //add to matrix builder.plugin(ioCanaryPlugin); //init matrix Matrix.init(builder.build()); // start plugin ioCanaryPlugin.start(); 

java -jar matrix-apk-canary-0.6.5.jar 

Usages: --config CONFIG-FILE-PATH or [--input INPUT-DIR-PATH] [--apk APK-FILE-PATH] [--unzip APK-UNZIP-PATH] [--mappingTxt MAPPING-FILE-PATH] [--resMappingTxt RESGUARD-MAPPING-FILE-PATH] [--output OUTPUT-PATH] [--format OUTPUT-FORMAT] [--formatJar OUTPUT-FORMAT-JAR] [--formatConfig OUTPUT-FORMAT-CONFIG (json-array format)] [Options] Options: -manifest Read package info from the AndroidManifest.xml. -fileSize [--min DOWN-LIMIT-SIZE (KB)] [--order ORDER-BY ('asc'|'desc')] [--suffix FILTER-SUFFIX-LIST (split by ',')] Show files whose size exceed limit size in order. -countMethod [--group GROUP-BY ('class'|'package')] Count methods in dex file, output results group by class name or package name. -checkResProguard Check if the resguard was applied. -findNonAlphaPng [--min DOWN-LIMIT-SIZE (KB)] Find out the non-alpha png-format files whose size exceed limit size in desc order. -checkMultiLibrary Check if there are more than one library dir in the 'lib'. -uncompressedFile [--suffix FILTER-SUFFIX-LIST (split by ',')] Show uncompressed file types. -countR Count the R class. -duplicatedFile Find out the duplicated resource files in desc order. -checkMultiSTL --toolnm TOOL-NM-PATH Check if there are more than one shared library statically linked the STL. -unusedResources --rTxt R-TXT-FILE-PATH [--ignoreResources IGNORE-RESOURCES-LIST (split by ',')] Find out the unused resources. -unusedAssets [--ignoreAssets IGNORE-ASSETS-LIST (split by ',')] Find out the unused assets file. -unstrippedSo --toolnm TOOL-NM-PATH Find out the unstripped shared library file. 

implementation 'org.nanohttpd:nanohttpd:2.3.1' 

 public class App extends NanoHTTPD { public App() throws IOException { super(8080); start(NanoHTTPD.SOCKET_READ_TIMEOUT, false); System.out.println("\nRunning! Point your browsers to http://localhost:8080/ \n"); } public static void main(String[] args) { try { new App(); } catch (IOException ioe) { System.err.println("Couldn't start server:\n" + ioe); } } @Override public Response serve(IHTTPSession session) { String msg = "<html><body><h1>Hello server</h1>\n"; Map<String, String> parms = session.getParms(); if (parms.get("username") == null) { msg += "<form action='?' method='get'>\n <p>Your name: <input type='text' name='username'></p>\n" + "</form>\n"; } else { msg += "<p>Hello, " + parms.get("username") + "!</p>"; } return newFixedLengthResponse(msg + "</body></html>\n"); } } 

public class AndroidHttpServer extends NanoHTTPD { private static final String TAG = "AndroidHttpServer"; //定义一个默认的端口号 private static final int DEFAULT_PORT = 8088; //Prometheus用于获取数据 private CollectorRegistry registry; //ByteArrayOutputStream private final LocalByteArray response = new LocalByteArray(); private static class LocalByteArray extends ThreadLocal<ByteArrayOutputStream> { protected ByteArrayOutputStream initialValue() { return new ByteArrayOutputStream(1 << 20); } } public AndroidHttpServer() { this(DEFAULT_PORT); } public AndroidHttpServer(int port) { super(port); registry = CollectorRegistry.defaultRegistry; } public AndroidHttpServer(String hostname, int port) { super(hostname, port); registry = CollectorRegistry.defaultRegistry; } @Override public Response serve(IHTTPSession session) { //获取浏览器输入的Uri String uri = session.getUri(); //获取session的Method Method method = session.getMethod(); Log.i(TAG, "method = " + method + " uri= " + uri); //这里需要判断下Uri是否符合要求，比如浏览器输入http://localhost:8088/metrics符合，其他都不合符。 if(uri.startsWith("/metrics")){ //本地输出流 ByteArrayOutputStream response = this.response.get(); if(response == null){ return newFixedLengthResponse("response is null "); } //每次使用前要reset response.reset(); //创建一个Writer OutputStreamWriter osw = new OutputStreamWriter(response); try { TextFormat.write004(osw, registry.filteredMetricFamilySamples(parseQuery(uri))); osw.flush(); osw.close(); response.flush(); response.close(); } catch (IOException e) { e.printStackTrace(); } return responseMetrics(session, response.toByteArray()); } return response404(uri); } /** * 是否压缩 * @param session IHTTPSession * @return boolean */ protected static boolean shouldUseCompression(IHTTPSession session) { String encodingHeaders = session.getHeaders().get("Accept-Encoding"); if (encodingHeaders == null) return false; String[] encodings = encodingHeaders.split(","); for (String encoding : encodings) { if (encoding.trim().toLowerCase().equals("gzip")) { return true; } } return false; } /** * 解析uri * @param query String * @return Set<String> * @throws IOException */ protected static Set<String> parseQuery(String query) throws IOException { Set<String> names = new HashSet<>(); if (query != null) { String[] pairs = query.split("&"); for (String pair : pairs) { int idx = pair.indexOf("="); if (idx != -1 && URLDecoder.decode(pair.substring(0, idx), "UTF-8").equals("name[]")) { names.add(URLDecoder.decode(pair.substring(idx + 1), "UTF-8")); } } } return names; } /** * 访问/metrics,返回对应的Response * @param session IHTTPSession * @param bytes byte[] * @return Response */ private Response responseMetrics(IHTTPSession session,byte[] bytes) { //调用newFixedLengthResponse,生成一个Response Response response = newFixedLengthResponse(Response.Status.OK, NanoHTTPD.MIME_PLAINTEXT,new ByteArrayInputStream(bytes), bytes.length); //Header添加Content-Type:"text/plain; version=0.0.4; charset=utf-8" response.addHeader("Content-Type", TextFormat.CONTENT_TYPE_004); if (shouldUseCompression(session)) { //Header添加Content-Encoding:"gzip" response.addHeader("Content-Encoding", "gzip"); try { ByteArrayOutputStream out = new ByteArrayOutputStream(); GZIPOutputStream gzip = new GZIPOutputStream(out); gzip.write(bytes); gzip.close(); response.setData(new ByteArrayInputStream(out.toByteArray())); out.close(); } catch (IOException e) { e.printStackTrace(); } }else{ response.addHeader("Content-Length", String.valueOf(bytes.length)); } return response; } /** * 访问无效页面，返回404 * @param url 没有定义的url * @return Response */ private Response response404(String url) { //构造一个简单的Html 404页面 StringBuilder builder = new StringBuilder(); builder.append("<!DOCTYPE html><html><body>"); builder.append("Sorry,Can't Found Uri:" ); builder.append(url ); builder.append(" !"); builder.append("</body></html>\n"); //调用newFixedLengthResponse返回一个固定长度的Response return newFixedLengthResponse(builder.toString()); } } 

public class AndroidHttpService extends Service { public AndroidHttpService() { } @Override public int onStartCommand(Intent intent, int flags, int startId) { try { //注册prometheus的采集器 new MemoryUsageCollector(getApplicationContext()).register(); //启动AndroidHttpServer new AndroidHttpServer().start(); } catch (IOException e) { e.printStackTrace(); } return super.onStartCommand(intent, flags, startId); } @Override public IBinder onBind(Intent intent) { // TODO: Return the communication channel to the service. throw new UnsupportedOperationException("Not yet implemented"); } }】 

# HELP MemoryUsage Android Performance Monitors # TYPE MemoryUsage gauge MemoryUsage{MemoryUsage="MemoryUsage",} 64.57366943359375 

 - job_name: 'pushgateway' honor_labels: true static_configs: - targets: ['填入IP:9091'] labels: instance: pushgateway 

 implementation 'io.prometheus:simpleclient_pushgateway:0.8.0' 

public interface IPushGateWay { String getInstanceKey(); String getInstanceValue(); String getJobName(); void push(); } 

public class PushGateWayImpl implements IPushGateWay{ private Context context; //根据需要改成可配置的 private static final String DEFAULT_PUSH_GATEWAY_SERVER_IP = "IP:9091";//pushgateway的ip private static String getIpAddressString() { try { for (Enumeration<NetworkInterface> enNetI = NetworkInterface .getNetworkInterfaces(); enNetI.hasMoreElements(); ) { NetworkInterface netI = enNetI.nextElement(); for (Enumeration<InetAddress> enumIpAddress = netI .getInetAddresses(); enumIpAddress.hasMoreElements(); ) { InetAddress inetAddress = enumIpAddress.nextElement(); if (inetAddress instanceof Inet4Address && !inetAddress.isLoopbackAddress()) { return inetAddress.getHostAddress(); } } } } catch (SocketException e) { e.printStackTrace(); } return "0.0.0.0"; } public PushGateWayImpl(Context context) { this.context = context; } @Override public String getInstanceKey() { return "instance"; } @Override public String getInstanceValue() { return getIpAddressString(); } @Override public String getJobName() { return "AndroidJob"; } @Override public void push() { try{ //CollectorRegistry CollectorRegistry registry = new CollectorRegistry(); //Gauge Of MemoryUsage Gauge gaugeMemoryUsage = Gauge.build("MemoryUsage", "Android Performance Monitors").create(); gaugeMemoryUsage.set(CollectorUtil.getMemoryUsed(context)); gaugeMemoryUsage.register(registry); //Push To Gateway PushGateway pg = new PushGateway(DEFAULT_PUSH_GATEWAY_SERVER_IP); Map<String, String> groupingKey = new HashMap<>(); groupingKey.put(getInstanceKey(), getInstanceValue()); pg.pushAdd(registry, getJobName(), groupingKey); } catch (Exception e){ e.printStackTrace(); } } } 

public class AndroidHttpService extends Service { private static final String TAG = "AndroidHttpService"; private ScheduledExecutorService mScheduledExecutorService = Executors.newScheduledThreadPool(1); public AndroidHttpService() { } @Override public int onStartCommand(Intent intent, int flags, int startId) { //Pull方案的NanoHTTPD实现，在设备内置一个HTTPServer供外部访问 try { //注册prometheus的采集器 new MemoryUsageCollector(getApplicationContext()).register(); //启动AndroidHttpServer new AndroidHttpServer().start(); } catch (IOException e) { e.printStackTrace(); } //Push方案的PushGateWay实现，使用scheduleWithFixedDelay定时上传数据到PushGateWay的接口 final PushGateWayImpl pushGateWayImp = new PushGateWayImpl(getApplicationContext()); mScheduledExecutorService.scheduleWithFixedDelay(new Runnable() { @Override public void run() { Log.i(TAG, "❤❤❤❤❤❤❤❤❤❤❤❤❤❤"); pushGateWayImp.push(); } }, 0, 10, TimeUnit.SECONDS); return super.onStartCommand(intent, flags, startId); } @Override public IBinder onBind(Intent intent) { // TODO: Return the communication channel to the service. throw new UnsupportedOperationException("Not yet implemented"); } }