Merge pull request #74 from reactivegroup/feature/metrics

Feature/metrics

Author: dgzpg

examples/pom.xml

@@ -61,17 +61,17 @@
             </exclusions>
         </dependency>
         <!-- slf4j -->
-        <dependency>
+       <!-- <dependency>
             <groupId>org.apache.logging.log4j</groupId>
             <artifactId>log4j-slf4j-impl</artifactId>
             <version>${log4j.version}</version>
-        </dependency>
+        </dependency>-->
         <!-- logback -->
-         <!--<dependency>
+         <dependency>
              <groupId>ch.qos.logback</groupId>
              <artifactId>logback-classic</artifactId>
              <version>${logback.version}</version>
-         </dependency>-->
+         </dependency>
         <!--lombok-->
         <dependency>
             <groupId>org.projectlombok</groupId>

examples/src/main/resources/log4j2.xml examples/src/main/resources/logback.xmlexamples/src/main/resources/log4j2.xml renamed to examples/src/main/resources/logback.xml

@@ -15,17 +15,12 @@
   See the License for the specific language governing permissions and
   limitations under the License.
   -->
-<Configuration status="DEBUG">
-    <Appenders>
-        <Console name="Console" target="SYSTEM_OUT">
-            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
-        </Console>
-        <CapaLog4jAppender name="log"/>
-    </Appenders>
-    <Loggers>
-        <Root level="INFO">
-            <AppenderRef ref="Console"/>
-            <AppenderRef ref="log"/>
-        </Root>
-    </Loggers>
-</Configuration>
+<configuration>
+    <!--Log-->
+    <appender name="Log" class="group.rxcloud.capa.component.log.CapaLogbackAppenderAgent">
+    </appender>
+
+    <root level="INFO">
+        <appender-ref ref="Log"/>
+    </root>
+</configuration>

sdk-component/src/main/java/group/rxcloud/capa/component/log/CapaLogbackAppenderAgent.java

@@ -24,7 +24,6 @@
  * The agent of the logback impl.
  */
 public class CapaLogbackAppenderAgent extends UnsynchronizedAppenderBase<ILoggingEvent> {
-
     /**
      * The log component type.
      */
@@ -53,6 +52,12 @@ public static CapaLogbackAppender buildCapaLogbackAppender() {
                 CapaLogbackAppender.class);
     }
 
+    @Override
+    public void start() {
+        logbackAppender.doStart();
+        super.start();
+    }
+
     /**
      * Deal with the log.
      *
@@ -74,6 +79,12 @@ public interface CapaLogbackAppender {
          * @param event The log event.
          */
         void append(ILoggingEvent event);
+
+        /**
+         *
+         Do some initialization operations when the appender starts.
+         */
+        void doStart();
     }
 }
 

sdk-component/src/test/java/group/rxcloud/capa/component/log/TestCapaLogbackAppender.java

@@ -30,5 +30,10 @@ public TestCapaLogbackAppender() {
     public void append(ILoggingEvent event) {
         System.out.println("test logback log and content is " + event.getFormattedMessage());
     }
+
+    @Override
+    public void doStart() {
+        System.out.println("Init config...");
+    }
 }
 

sdk-spi-demo/src/main/java/group/rxcloud/capa/spi/demo/log/DemoLogbackAppender.java

@@ -28,4 +28,9 @@ public DemoLogbackAppender() {
     public void appendLog(ILoggingEvent event) {
         System.out.println("Test logback log and content is " + event.getFormattedMessage());
     }
+
+    @Override
+    public void doStart() {
+        System.out.println("Init config...");
+    }
 }

sdk-spi/src/main/java/group/rxcloud/capa/spi/log/CapaLogbackAppenderSpi.java

@@ -38,4 +38,9 @@ public void append(ILoggingEvent event) {
     }
 
     protected abstract void appendLog(ILoggingEvent event);
+
+    @Override
+    public void doStart() {
+        // do nothing
+    }
 }