From 55dd55dbd7f92199b254131be0d28ccbbc29cf2a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BA=8E=E7=8E=89=E6=A1=94?= <zhaoyuguang@apache.org>
Date: Thu, 20 May 2021 21:11:47 +0800
Subject: [PATCH] feature: support apm with skywalking (#3652)
---
LICENSE | 19 +++-
changes/1.5.0.md | 1 +
changes/en-us/1.5.0.md | 1 +
distribution/LICENSE-BIN | 19 +++-
ext/apm-seata-skywalking-plugin/pom.xml | 88 ++++++++++++++++++
.../ClientProcessorProcessInterceptor.java | 61 ++++++++++++
.../DefaultCoreDoGlobalCommitInterceptor.java | 50 ++++++++++
...ettyRemotingClientSendSyncInterceptor.java | 70 ++++++++++++++
...rOnRequestProcessorProcessInterceptor.java | 61 ++++++++++++
.../plugin/common/SWSeataConstants.java | 53 +++++++++++
.../plugin/common/SWSeataUtils.java | 46 ++++++++++
.../plugin/common/SeataPluginConfig.java | 30 ++++++
.../AbstractNettyRemotingInstrumentation.java | 92 +++++++++++++++++++
...entOnResponseProcessorInstrumentation.java | 73 +++++++++++++++
.../define/DefaultCoreInstrumentation.java | 70 ++++++++++++++
...mBranchCommitProcessorInstrumentation.java | 72 +++++++++++++++
...ranchRollbackProcessorInstrumentation.java | 72 +++++++++++++++
...rverOnRequestProcessorInstrumentation.java | 70 ++++++++++++++
.../src/main/resources/skywalking-plugin.def | 22 +++++
pom.xml | 1 +
20 files changed, 969 insertions(+), 2 deletions(-)
create mode 100644 ext/apm-seata-skywalking-plugin/pom.xml
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ClientProcessorProcessInterceptor.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/DefaultCoreDoGlobalCommitInterceptor.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/NettyRemotingClientSendSyncInterceptor.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ServerOnRequestProcessorProcessInterceptor.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataConstants.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataUtils.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SeataPluginConfig.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/AbstractNettyRemotingInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ClientOnResponseProcessorInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/DefaultCoreInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchCommitProcessorInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchRollbackProcessorInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ServerOnRequestProcessorInstrumentation.java
create mode 100644 ext/apm-seata-skywalking-plugin/src/main/resources/skywalking-plugin.def
diff --git a/LICENSE b/LICENSE
index 7f77f44e7..a51c33776 100644
--- a/LICENSE
+++ b/LICENSE
@@ -198,4 +198,21 @@
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
- limitations under the License.
\ No newline at end of file
+ limitations under the License.
+
+=======================================================================
+Seata Subcomponents:
+
+The Seata project contains subcomponents with separate copyright
+notices and license terms. Your use of the source code for the these
+subcomponents is subject to the terms and conditions of the following
+licenses.
+
+========================================================================
+Apache 2.0 licenses
+========================================================================
+
+The following components are provided under the Apache License. See project link for details.
+The text of each license is the standard Apache 2.0 license.
+
+ Apache: skywalking 8.4.0: https://github.com/apache/skywalking, Apache 2.0
\ No newline at end of file
diff --git a/changes/1.5.0.md b/changes/1.5.0.md
index 4d4b5b24e..f5fd979a5 100644
--- a/changes/1.5.0.md
+++ b/changes/1.5.0.md
@@ -22,6 +22,7 @@ Seata 鏄竴娆惧紑婧愮殑鍒嗗竷寮忎簨鍔¤В鍐虫柟妗堬紝鎻愪緵楂樻€ц兘鍜岀畝鍗�
- [[#3642](https://github.com/seata/seata/pull/3642)] TCC妯″紡鏀寔浣跨敤API鐨勫舰寮忚繘琛屼簩闃舵鍙傛暟浼犻€�
- [[#3064](https://github.com/seata/seata/pull/3064)] 鏀寔鍙厤缃瓽lobalTransactionInterceptor鍜孴ccActionInterceptor鐨刼rder鍊笺€�
- [[#3374](https://github.com/seata/seata/pull/2852)] 鏀寔鑷畾涔塦GlobalTransactionScanner`鐨勬壂鎻忓璞°€�
+ - [[#3652](https://github.com/seata/seata/pull/3652)] 鏀寔APM SkyWalking鐩戞帶銆�
### bugfix锛�
diff --git a/changes/en-us/1.5.0.md b/changes/en-us/1.5.0.md
index 2faeeffd8..b113a7efd 100644
--- a/changes/en-us/1.5.0.md
+++ b/changes/en-us/1.5.0.md
@@ -23,6 +23,7 @@
- [[#3642](https://github.com/seata/seata/pull/3642)] provide an api to share tcc phase-1's params to phase-2
- [[#3064](https://github.com/seata/seata/pull/3064)] support configuring the order of the TM and TCC interceptor
- [[#3374](https://github.com/seata/seata/pull/2852)] support configuring scan target for GlobalTransactionScanner
+ - [[#3652](https://github.com/seata/seata/pull/3652)] support APM with SkyWalking
### bugfix锛�
diff --git a/distribution/LICENSE-BIN b/distribution/LICENSE-BIN
index 7f77f44e7..a51c33776 100644
--- a/distribution/LICENSE-BIN
+++ b/distribution/LICENSE-BIN
@@ -198,4 +198,21 @@
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
- limitations under the License.
\ No newline at end of file
+ limitations under the License.
+
+=======================================================================
+Seata Subcomponents:
+
+The Seata project contains subcomponents with separate copyright
+notices and license terms. Your use of the source code for the these
+subcomponents is subject to the terms and conditions of the following
+licenses.
+
+========================================================================
+Apache 2.0 licenses
+========================================================================
+
+The following components are provided under the Apache License. See project link for details.
+The text of each license is the standard Apache 2.0 license.
+
+ Apache: skywalking 8.4.0: https://github.com/apache/skywalking, Apache 2.0
\ No newline at end of file
diff --git a/ext/apm-seata-skywalking-plugin/pom.xml b/ext/apm-seata-skywalking-plugin/pom.xml
new file mode 100644
index 000000000..b5ad5dcf1
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/pom.xml
@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Copyright 1999-2019 Seata.io Group.
+ ~
+ ~ Licensed under the Apache License, Version 2.0 (the "License");
+ ~ you may not use this file except in compliance with the License.
+ ~ You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing, software
+ ~ distributed under the License is distributed on an "AS IS" BASIS,
+ ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ ~ See the License for the specific language governing permissions and
+ ~ limitations under the License.
+ -->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <parent>
+ <groupId>io.seata</groupId>
+ <artifactId>seata-parent</artifactId>
+ <version>${revision}</version>
+ <relativePath>../../pom.xml</relativePath>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>apm-seata-skywalking-plugin</artifactId>
+ <packaging>jar</packaging>
+ <name>apm-seata-skywalking-plugin ${project.version}</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.skywalking</groupId>
+ <artifactId>apm-agent-core</artifactId>
+ <version>8.4.0</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.seata</groupId>
+ <artifactId>seata-all</artifactId>
+ <version>${revision}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.seata</groupId>
+ <artifactId>seata-server</artifactId>
+ <version>${revision}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>*</groupId>
+ <artifactId>*</artifactId>
+ </exclusion>
+ </exclusions>
+ <scope>provided</scope>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <version>2.4.3</version>
+ <executions>
+ <execution>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <artifactSet>
+ <includes>
+ <include>net.bytebuddy:*</include>
+ </includes>
+ </artifactSet>
+ <relocations>
+ <relocation>
+ <pattern>net.bytebuddy</pattern>
+ <shadedPattern>org.apache.skywalking.apm.dependencies.net.bytebuddy</shadedPattern>
+ </relocation>
+ </relocations>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ClientProcessorProcessInterceptor.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ClientProcessorProcessInterceptor.java
new file mode 100644
index 000000000..f19e2120e
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ClientProcessorProcessInterceptor.java
@@ -0,0 +1,61 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin;
+
+import io.seata.core.protocol.RpcMessage;
+import org.apache.skywalking.apm.agent.core.context.CarrierItem;
+import org.apache.skywalking.apm.agent.core.context.ContextCarrier;
+import org.apache.skywalking.apm.agent.core.context.ContextManager;
+import org.apache.skywalking.apm.agent.core.context.trace.AbstractSpan;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
+import io.seata.apm.skywalking.plugin.common.SWSeataUtils;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author zhaoyuguang
+ */
+public class ClientProcessorProcessInterceptor implements InstanceMethodsAroundInterceptor {
+
+ @Override
+ public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ MethodInterceptResult result) throws Throwable {
+ RpcMessage rpcMessage = (RpcMessage) allArguments[1];
+ ContextCarrier contextCarrier = new ContextCarrier();
+ CarrierItem next = contextCarrier.items();
+ while (next.hasNext()) {
+ next = next.next();
+ next.setHeadValue(rpcMessage.getHeadMap().get(next.getHeadKey()));
+ }
+ String operationName = SWSeataUtils.convertOperationName(rpcMessage);
+ AbstractSpan activeSpan = ContextManager.createEntrySpan(operationName, contextCarrier);
+// activeSpan.setComponent(ComponentsDefine.SEATA);
+ }
+
+ @Override
+ public Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ Object ret) throws Throwable {
+ ContextManager.stopSpan();
+ return ret;
+ }
+
+ @Override
+ public void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments,
+ Class<?>[] argumentsTypes, Throwable t) {
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/DefaultCoreDoGlobalCommitInterceptor.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/DefaultCoreDoGlobalCommitInterceptor.java
new file mode 100644
index 000000000..b3b00571a
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/DefaultCoreDoGlobalCommitInterceptor.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin;
+
+import org.apache.skywalking.apm.agent.core.context.ContextManager;
+import org.apache.skywalking.apm.agent.core.context.trace.AbstractSpan;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
+import io.seata.apm.skywalking.plugin.common.SWSeataConstants;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author zhaoyuguang
+ */
+public class DefaultCoreDoGlobalCommitInterceptor implements InstanceMethodsAroundInterceptor {
+
+ @Override
+ public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ MethodInterceptResult result) throws Throwable {
+ AbstractSpan activeSpan = ContextManager.createLocalSpan(SWSeataConstants.SEATA_NAME + "/TC/doGlobalCommit");
+// activeSpan.setComponent(ComponentsDefine.SEATA);
+ }
+
+ @Override
+ public Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ Object ret) throws Throwable {
+ ContextManager.stopSpan();
+ return ret;
+ }
+
+ @Override
+ public void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments,
+ Class<?>[] argumentsTypes, Throwable t) {
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/NettyRemotingClientSendSyncInterceptor.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/NettyRemotingClientSendSyncInterceptor.java
new file mode 100644
index 000000000..ca1551a9e
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/NettyRemotingClientSendSyncInterceptor.java
@@ -0,0 +1,70 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin;
+
+import io.netty.channel.Channel;
+import io.seata.core.protocol.RpcMessage;
+import org.apache.skywalking.apm.agent.core.context.CarrierItem;
+import org.apache.skywalking.apm.agent.core.context.ContextCarrier;
+import org.apache.skywalking.apm.agent.core.context.ContextManager;
+import org.apache.skywalking.apm.agent.core.context.trace.AbstractSpan;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
+import io.seata.apm.skywalking.plugin.common.SWSeataUtils;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author zhaoyuguang
+ */
+public class NettyRemotingClientSendSyncInterceptor implements InstanceMethodsAroundInterceptor {
+
+ @Override
+ public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ MethodInterceptResult result) throws Throwable {
+ if (allArguments[0] == null) {
+ return;
+ }
+ Channel channel = (Channel) allArguments[0];
+ String peer = SWSeataUtils.convertPeer(channel);
+ RpcMessage rpcMessage = (RpcMessage) allArguments[1];
+ String operationName = SWSeataUtils.convertOperationName(rpcMessage);
+ ContextCarrier contextCarrier = new ContextCarrier();
+ AbstractSpan activeSpan = ContextManager.createExitSpan(operationName, contextCarrier, peer);
+// activeSpan.setComponent(ComponentsDefine.SEATA);
+ activeSpan.setPeer(peer);
+ CarrierItem next = contextCarrier.items();
+ while (next.hasNext()) {
+ next = next.next();
+ rpcMessage.getHeadMap().put(next.getHeadKey(), next.getHeadValue());
+ }
+ }
+
+ @Override
+ public Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ Object ret) throws Throwable {
+ if (allArguments[0] != null) {
+ ContextManager.stopSpan();
+ }
+ return ret;
+ }
+
+ @Override
+ public void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments,
+ Class<?>[] argumentsTypes, Throwable t) {
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ServerOnRequestProcessorProcessInterceptor.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ServerOnRequestProcessorProcessInterceptor.java
new file mode 100644
index 000000000..3ee532c5e
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/ServerOnRequestProcessorProcessInterceptor.java
@@ -0,0 +1,61 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin;
+
+import io.seata.core.protocol.RpcMessage;
+import org.apache.skywalking.apm.agent.core.context.CarrierItem;
+import org.apache.skywalking.apm.agent.core.context.ContextCarrier;
+import org.apache.skywalking.apm.agent.core.context.ContextManager;
+import org.apache.skywalking.apm.agent.core.context.trace.AbstractSpan;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.EnhancedInstance;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstanceMethodsAroundInterceptor;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.MethodInterceptResult;
+import io.seata.apm.skywalking.plugin.common.SWSeataUtils;
+
+import java.lang.reflect.Method;
+
+/**
+ * @author zhaoyuguang
+ */
+public class ServerOnRequestProcessorProcessInterceptor implements InstanceMethodsAroundInterceptor {
+
+ @Override
+ public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ MethodInterceptResult result) throws Throwable {
+ RpcMessage rpcMessage = (RpcMessage) allArguments[1];
+ String operationName = SWSeataUtils.convertOperationName(rpcMessage);
+ ContextCarrier contextCarrier = new ContextCarrier();
+ CarrierItem next = contextCarrier.items();
+ while (next.hasNext()) {
+ next = next.next();
+ next.setHeadValue(rpcMessage.getHeadMap().get(next.getHeadKey()));
+ }
+ AbstractSpan activeSpan = ContextManager.createEntrySpan(operationName, contextCarrier);
+// activeSpan.setComponent(ComponentsDefine.SEATA);
+ }
+
+ @Override
+ public Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
+ Object ret) throws Throwable {
+ ContextManager.stopSpan();
+ return ret;
+ }
+
+ @Override
+ public void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments,
+ Class<?>[] argumentsTypes, Throwable t) {
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataConstants.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataConstants.java
new file mode 100644
index 000000000..d57cccded
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataConstants.java
@@ -0,0 +1,53 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.common;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author zhaoyuguang
+ */
+public class SWSeataConstants {
+
+ public static final Map<String, String> OPERATION_NAME_MAPPING = new HashMap<>();
+ public static final String SEATA_NAME = "SEATA";
+
+ static {
+ OPERATION_NAME_MAPPING.put("GlobalBeginRequest", SEATA_NAME + "/TM/" + "GlobalBeginRequest");
+ OPERATION_NAME_MAPPING.put("GlobalBeginResponse", SEATA_NAME + "/TM/" + "GlobalBeginResponse");
+ OPERATION_NAME_MAPPING.put("GlobalRollbackRequest", SEATA_NAME + "/TM/" + "GlobalRollbackRequest");
+ OPERATION_NAME_MAPPING.put("GlobalRollbackResponse", SEATA_NAME + "/TM/" + "GlobalRollbackResponse");
+ OPERATION_NAME_MAPPING.put("GlobalCommitRequest", SEATA_NAME + "/TM/" + "GlobalCommitRequest");
+ OPERATION_NAME_MAPPING.put("GlobalCommitResponse", SEATA_NAME + "/TM/" + "GlobalCommitResponse");
+ OPERATION_NAME_MAPPING.put("BranchRegisterRequest", SEATA_NAME + "/RM/" + "BranchRegisterRequest");
+ OPERATION_NAME_MAPPING.put("BranchRegisterResponse", SEATA_NAME + "/RM/" + "BranchRegisterResponse");
+ OPERATION_NAME_MAPPING.put("BranchRollbackRequest", SEATA_NAME + "/RM/" + "BranchRollbackRequest");
+ OPERATION_NAME_MAPPING.put("BranchRollbackResponse", SEATA_NAME + "/RM/" + "BranchRollbackResponse");
+ OPERATION_NAME_MAPPING.put("BranchCommitRequest", SEATA_NAME + "/RM/" + "BranchCommitRequest");
+ OPERATION_NAME_MAPPING.put("BranchCommitResponse", SEATA_NAME + "/RM/" + "BranchCommitResponse");
+ OPERATION_NAME_MAPPING.put("BranchReportRequest", SEATA_NAME + "/RM/" + "BranchReportRequest");
+ OPERATION_NAME_MAPPING.put("BranchReportResponse", SEATA_NAME + "/RM/" + "BranchReportResponse");
+ OPERATION_NAME_MAPPING.put("GlobalLockQueryRequest", SEATA_NAME + "/RM/" + "GlobalLockQueryRequest");
+ OPERATION_NAME_MAPPING.put("GlobalLockQueryResponse", SEATA_NAME + "/RM/" + "GlobalLockQueryResponse");
+ OPERATION_NAME_MAPPING.put("UndoLogDeleteRequest", SEATA_NAME + "/RM/" + "UndoLogDeleteRequest");
+ OPERATION_NAME_MAPPING.put("UndoLogDeleteResponse", SEATA_NAME + "/RM/" + "UndoLogDeleteResponse");
+ OPERATION_NAME_MAPPING.put("RegisterRMRequest", SEATA_NAME + "/RM/" + "RegisterRMRequest");
+ OPERATION_NAME_MAPPING.put("RegisterRMResponse", SEATA_NAME + "/RM/" + "RegisterRMResponse");
+ OPERATION_NAME_MAPPING.put("RegisterTMRequest", SEATA_NAME + "/RM/" + "RegisterTMRequest");
+ OPERATION_NAME_MAPPING.put("RegisterTMResponse", SEATA_NAME + "/RM/" + "RegisterTMResponse");
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataUtils.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataUtils.java
new file mode 100644
index 000000000..40040e3fc
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SWSeataUtils.java
@@ -0,0 +1,46 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.common;
+
+import io.netty.channel.Channel;
+import io.seata.core.protocol.RpcMessage;
+
+/**
+ * @author zhaoyuguang
+ */
+public class SWSeataUtils {
+
+ public static String convertPeer(Channel channel) {
+ String peer = channel.remoteAddress().toString();
+ if (peer.startsWith("/")) {
+ peer = peer.substring(1);
+ }
+ return peer;
+ }
+
+ public static String convertOperationName(RpcMessage rpcMessage) {
+ String requestSimpleName = rpcMessage.getBody().getClass().getSimpleName();
+ if (SeataPluginConfig.Plugin.SEATA.SERVER) {
+ return SWSeataConstants.SEATA_NAME + "/TC/" + requestSimpleName;
+ }
+ String operationName = SWSeataConstants.OPERATION_NAME_MAPPING.get(requestSimpleName);
+ if (operationName == null) {
+ operationName = SWSeataConstants.SEATA_NAME + "/" + requestSimpleName;
+ }
+ return operationName;
+
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SeataPluginConfig.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SeataPluginConfig.java
new file mode 100644
index 000000000..8895484aa
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/common/SeataPluginConfig.java
@@ -0,0 +1,30 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.common;
+
+import org.apache.skywalking.apm.agent.core.boot.PluginConfig;
+
+/**
+ * @author zhaoyuguang
+ */
+public class SeataPluginConfig {
+ public static class Plugin {
+ @PluginConfig(root = SeataPluginConfig.class)
+ public static class SEATA {
+ public static boolean SERVER = false;
+ }
+ }
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/AbstractNettyRemotingInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/AbstractNettyRemotingInstrumentation.java
new file mode 100644
index 000000000..e64c5e789
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/AbstractNettyRemotingInstrumentation.java
@@ -0,0 +1,92 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
+import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+public class AbstractNettyRemotingInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS = "io.seata.core.rpc.netty.AbstractNettyRemoting";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.NettyRemotingClientSendSyncInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("sendSync").and(takesArguments(3))
+ .and(takesArgument(0, named("io.netty.channel.Channel")))
+ .and(takesArgument(1, named("io.seata.core.protocol.RpcMessage")))
+ .and(takesArgument(2, long.class));
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ },
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("sendAsync").and(takesArguments(2))
+ .and(takesArgument(0, named("io.netty.channel.Channel")))
+ .and(takesArgument(1, named("io.seata.core.protocol.RpcMessage")));
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ClientOnResponseProcessorInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ClientOnResponseProcessorInstrumentation.java
new file mode 100644
index 000000000..46536097b
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ClientOnResponseProcessorInstrumentation.java
@@ -0,0 +1,73 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
+import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+
+public class ClientOnResponseProcessorInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS = "io.seata.core.rpc.processor.client.ClientOnResponseProcessor";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.ClientProcessorProcessInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("process").and(takesArguments(2))
+ .and(takesArgument(1, named("io.seata.core.protocol.RpcMessage")));
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/DefaultCoreInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/DefaultCoreInstrumentation.java
new file mode 100644
index 000000000..32f9f76f7
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/DefaultCoreInstrumentation.java
@@ -0,0 +1,70 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+
+public class DefaultCoreInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS_TM = "io.seata.server.coordinator.DefaultCore";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.DefaultCoreDoGlobalCommitInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("doGlobalCommit");
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS_TM);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchCommitProcessorInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchCommitProcessorInstrumentation.java
new file mode 100644
index 000000000..3613d4c9a
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchCommitProcessorInstrumentation.java
@@ -0,0 +1,72 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
+import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+public class RmBranchCommitProcessorInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS = "io.seata.core.rpc.processor.client.RmBranchCommitProcessor";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.ClientProcessorProcessInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("process").and(takesArguments(2))
+ .and(takesArgument(1, named("io.seata.core.protocol.RpcMessage")));
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchRollbackProcessorInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchRollbackProcessorInstrumentation.java
new file mode 100644
index 000000000..7127a9fcd
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/RmBranchRollbackProcessorInstrumentation.java
@@ -0,0 +1,72 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
+import static net.bytebuddy.matcher.ElementMatchers.takesArguments;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+public class RmBranchRollbackProcessorInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS = "io.seata.core.rpc.processor.client.RmBranchRollbackProcessor";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.ClientProcessorProcessInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("process").and(takesArguments(2))
+ .and(takesArgument(1, named("io.seata.core.protocol.RpcMessage")));
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ServerOnRequestProcessorInstrumentation.java b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ServerOnRequestProcessorInstrumentation.java
new file mode 100644
index 000000000..eceed2f7f
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/java/io/seata/apm/skywalking/plugin/define/ServerOnRequestProcessorInstrumentation.java
@@ -0,0 +1,70 @@
+/*
+ * Copyright 1999-2019 Seata.io Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.seata.apm.skywalking.plugin.define;
+
+import net.bytebuddy.description.method.MethodDescription;
+import net.bytebuddy.matcher.ElementMatcher;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.ConstructorInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.InstanceMethodsInterceptPoint;
+import org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.ClassInstanceMethodsEnhancePluginDefine;
+import org.apache.skywalking.apm.agent.core.plugin.match.ClassMatch;
+
+import static net.bytebuddy.matcher.ElementMatchers.named;
+import static org.apache.skywalking.apm.agent.core.plugin.match.NameMatch.byName;
+
+/**
+ * @author zhaoyuguang
+ */
+
+public class ServerOnRequestProcessorInstrumentation extends ClassInstanceMethodsEnhancePluginDefine {
+
+ private static final String ENHANCE_CLASS_TM = "io.seata.core.rpc.processor.server.ServerOnRequestProcessor";
+
+ private static final String INTERCEPTOR_CLASS = "io.seata.apm.skywalking.plugin.ServerOnRequestProcessorProcessInterceptor";
+
+ @Override
+ public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
+ return new ConstructorInterceptPoint[0];
+ }
+
+ @Override
+ public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
+ return new InstanceMethodsInterceptPoint[]{
+ new InstanceMethodsInterceptPoint() {
+ @Override
+ public ElementMatcher<MethodDescription> getMethodsMatcher() {
+ return named("process");
+ }
+
+ @Override
+ public String getMethodsInterceptor() {
+ return INTERCEPTOR_CLASS;
+ }
+
+ @Override
+ public boolean isOverrideArgs() {
+ return false;
+ }
+ }
+ };
+ }
+
+ @Override
+ protected ClassMatch enhanceClass() {
+ return byName(ENHANCE_CLASS_TM);
+ }
+
+}
diff --git a/ext/apm-seata-skywalking-plugin/src/main/resources/skywalking-plugin.def b/ext/apm-seata-skywalking-plugin/src/main/resources/skywalking-plugin.def
new file mode 100644
index 000000000..ba552cd9a
--- /dev/null
+++ b/ext/apm-seata-skywalking-plugin/src/main/resources/skywalking-plugin.def
@@ -0,0 +1,22 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+seata=io.seata.apm.skywalking.plugin.define.AbstractNettyRemotingInstrumentation
+seata=io.seata.apm.skywalking.plugin.define.ClientOnResponseProcessorInstrumentation
+seata=io.seata.apm.skywalking.plugin.define.RmBranchCommitProcessorInstrumentation
+seata=io.seata.apm.skywalking.plugin.define.RmBranchRollbackProcessorInstrumentation
+seata=io.seata.apm.skywalking.plugin.define.DefaultCoreInstrumentation
+seata=io.seata.apm.skywalking.plugin.define.ServerOnRequestProcessorInstrumentation
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 09611c383..4311e1411 100644
--- a/pom.xml
+++ b/pom.xml
@@ -49,6 +49,7 @@
<module>compressor</module>
<module>saga</module>
<module>sqlparser</module>
+ <module>ext/apm-seata-skywalking-plugin</module>
</modules>
<packaging>pom</packaging>
--
GitLab