feat(actuator):Adding Support for Spring Boot Actuator

dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/QosScopeModelInitializer.java

@@ -17,6 +17,7 @@
 package org.apache.dubbo.qos;
 
 import org.apache.dubbo.common.beans.factory.ScopeBeanFactory;
+import org.apache.dubbo.qos.command.ActuatorCommandExecutor;
 import org.apache.dubbo.qos.command.util.SerializeCheckUtils;
 import org.apache.dubbo.qos.server.Server;
 import org.apache.dubbo.rpc.model.ApplicationModel;
@@ -33,7 +34,10 @@ public void initializeFrameworkModel(FrameworkModel frameworkModel) {
     }
 
     @Override
-    public void initializeApplicationModel(ApplicationModel applicationModel) {}
+    public void initializeApplicationModel(ApplicationModel applicationModel) {
+        ScopeBeanFactory beanFactory = applicationModel.getBeanFactory();
+        beanFactory.registerBean(ActuatorCommandExecutor.class);
+    }
 
     @Override
     public void initializeModuleModel(ModuleModel moduleModel) {}

dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/ActuatorCommandExecutor.java

@@ -0,0 +1,62 @@
+/*
+ * 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.
+ */
+package org.apache.dubbo.qos.command;
+
+import org.apache.dubbo.common.logger.Logger;
+import org.apache.dubbo.common.logger.LoggerFactory;
+import org.apache.dubbo.qos.api.BaseCommand;
+import org.apache.dubbo.qos.api.CommandContext;
+import org.apache.dubbo.rpc.model.ApplicationModel;
+
+import static org.apache.dubbo.common.constants.LoggerCodeConstants.QOS_UNEXPECTED_EXCEPTION;
+
+public class ActuatorCommandExecutor implements ActuatorExecutor {
+    private static final Logger log = LoggerFactory.getLogger(ActuatorCommandExecutor.class);
+    private final ApplicationModel applicationModel;
+
+    public ActuatorCommandExecutor(ApplicationModel applicationModel) {
+        this.applicationModel = applicationModel;
+    }
+
+    @Override
+    public String execute(String commandName, String[] parameters) {
+        CommandContext commandContext;
+
+        if (parameters == null || parameters.length == 0) {
+            commandContext = CommandContextFactory.newInstance(commandName);
+            commandContext.setHttp(true);
+        } else {
+            commandContext = CommandContextFactory.newInstance(commandName, parameters, true);
+        }
+
+        BaseCommand command;
+        try {
+            command = applicationModel
+                    .getExtensionLoader(BaseCommand.class)
+                    .getExtension(commandContext.getCommandName());
+            return command.execute(commandContext, commandContext.getArgs());
+        } catch (Exception qosEx) {
+            log.error(
+                    QOS_UNEXPECTED_EXCEPTION,
+                    "",
+                    "",
+                    "execute commandContext: " + commandContext + " got exception",
+                    qosEx);
+            return qosEx.getMessage();
+        }
+    }
+}

dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/ActuatorExecutor.java

@@ -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.
+ */
+package org.apache.dubbo.qos.command;
+
+public interface ActuatorExecutor {
+
+    String execute(String command, String[] args);
+}

dubbo-spring-boot/dubbo-spring-boot-actuator/README.md

@@ -153,7 +153,39 @@ Actuator endpoint `dubbo` supports Actuator Endpoints :
 | `dubboservices` | `false`     | `/actuator/dubbo/services`            | `GET`       | Exposes all Dubbo's `ServiceBean`   | `application/json` |
 | `dubboreferences` | `false` | `/actuator/dubbo/references` | `GET`       | Exposes all Dubbo's `ReferenceBean` | `application/json` |
 | `dubboconfigs` | `true` | `/actuator/dubbo/configs`    | `GET`       | Exposes all Dubbo's `*Config`       | `application/json` |
-| `dubboshutdown` | `false` | `/actuator/dubbo/shutdown`   | `POST`      | Shutdown Dubbo services             | `application/json` |
+| `dubboshutdown` | `false` | `/actuator/dubbo/shutdown`   | `GET`   | Shutdown Dubbo services             | `application/json` |
+| `dubbohelp` | `true` | `/actuator/dubbo/help` | `GET` | List all commands |  |
+| `dubboready` | `true` | `/actuator/dubbo/ready` | `GET` | Check whether the current process/service is ready for external service | `application/json` |
+| `dubbols` | `true` | `/actuator/dubbo/ls` | `GET` | List consumers and providers | `application/json` |
+| `dubbostartup` | `true` | `/actuator/dubbo/startup` | `GET` | Check if the current framework has been started | `application/json` |
+| `dubbops` | `true` | `/actuator/dubbo/ps` | `GET` | View information about the current process, including `listenable` ports | `application/json` |
+| `dubboversion` | `true` | `/actuator/dubbo/version` | `GET` | Display the version number of the currently running `Dubbo` | `application/json` |
+| `dubbogetaddress` | `true` | `/actuator/dubbo/getaddress?args=xxx.*` | `GET` | View the list of valid `IP` addresses for a service | `application/json` |
+| `dubbogetconfig` | `true` | `/actuator/dubbo/getconfig` | `GET` | View the valid `configuration` of the current application | `application/json` |
+| `dubbometrics` | `true` | `/actuator/dubbo/metrics` | `GET` | View `metrics`(Need to enable metrics statistics) | `application/json` |
+| `dubbometrics_default` | `true` | `/actuator/dubbo/metrics_default` | `GET` | View the default `metrics`(Need to enable metrics statistics) | `application/json` |
+| `dubbopublishmetadata` | `true` | `/actuator/dubbo/publishmetadata` or `/actuator/dubbo/publishmetadata?args=10` | `GET` | Publishes or updates the current application `Metadata` (Delay can be set) | `application/json` |
+| `dubboonline` | `true` | `/actuator/dubbo/online` or `/actuator/dubbo/online?args=xxx.*` | `GET` | Register one or more services to the registry (including application and interface addresses) | `application/json` |
+| `dubboonlineapp` | `true` | `/actuator/dubbo/onlineApp` or `/actuator/dubbo/onlineApp?args=xxx.xxx.*` | `GET` | Register one or more services to the registry (only application addresses) | `application/json` |
+| `dubboonlineinterface` | `true` | `/actuator/dubbo/onlineInterface` or `/actuator/dubbo/onlineInterface?args=xxx.*` | `GET` | Register one or more services to the registry (only interface addresses) | `application/json` |
+| `dubbooffline` | `true` | `/actuator/dubbo/offline` or `/actuator/dubbo/offline?args=xxx.*` | `GET` | Unregister one or more services from the registry (including application and interface addresses) | `application/json` |
+| `dubboofflineapp` | `true` | `/actuator/dubbo/offlineApp` or `/actuator/dubbo/offlineApp?args=xxx.*` | `GET` | Unregister one or more services from the registry (only application addresses) | `application/json` |
+| `dubboofflineinterface` | `true` | `/actuator/dubbo/offlineInterface` or `/actuator/dubbo/offlineInterface?args=xxx.*` | `GET` | Unregister one or more services from the registry (only interface addresses) | `application/json` |
+| `dubbologgerinfo` | `true` | `/actuator/dubbo/loggerInfo` | `GET` | Query log configuration | `application/json` |
+| `dubboswitchlogger` | `true` | `/actuator/dubbo/switchLogger?args={loggerAdapterName}` | `GET` | Modify the log output framework，`loggerAdapterName`: `slf4j`, `jcl`, `log4j`, `jdk`, `log4j2` | `application/json` |
+| `dubboswitchloglevel` | `true` | `/actuator/dubbo/switchLogLevel?args={level}` | `GET` | Modify log level，level: `ALL`, `TRACE`, `DEBUG`, `INFO`, `WARN`, `ERROR`, `OFF` | `application/json` |
+| `dubbodisabledetailprofiler` | `true` | `/actuator/dubbo/disableDetailProfiler` | `GET` | Turn off `detail profiler` mode, it will not affect `simple profiler` | `application/json` |
+| `dubboenabledetailprofiler` | `true` | `/actuator/dubbo/enableDetailProfiler` | `GET` | Enable the `detail profiler` mode, which is disabled by default, you need to enable the `simple profiler` mode to actually enable it | `application/json` |
+| `dubbodisablesimpleprofiler` | `false` | `/actuator/dubbo/disableSimpleProfiler` | `GET` | Turn off the `simple profiler` mode, and the `detail profiler` will not be enabled after it is turned off | `application/json` |
+| `dubboenablesimpleprofiler` | `true` | `/actuator/dubbo/enableSimpleProfiler` | `GET` | Enable `simple profiler` mode, enabled by default | `application/json` |
+| `dubbosetprofilerwarnpercent` | `true` | `/actuator/dubbo/setProfilerWarnPercent?args={percent}` | `GET` | Control `serialization` alarm frequency (only for classes in the warning list) | `application/json` |
+| `dubboserializecheckstatus` | `true` | `/actuator/dubbo/dubboserializecheckstatus` | `GET` | View the current configuration information | `application/json` |
+| `dubboserializewarnedclasses` | `true` | `/actuator/dubbo/dubboserializewarnedclasses` | `GET` | View the real-time alarm list | `application/json` |
+| `dubbodisableroutersnapshot` | `true` | `/actuator/dubbo/disableRouterSnapshot` or `/actuator/dubbo/disableRouterSnapshot?args=xxx.*` | `GET` | Disable routing result collection mode | `application/json` |
+| `dubboenableroutersnapshot` | `true` | `/actuator/dubbo/enableRouterSnapshot` or `/actuator/dubbo/enableRouterSnapshot?args=xxx.*` | `GET` | Enable routing result collection mode | `application/json` |
+| `dubbogetrecentroutersnapshot` | `true` | `/actuator/dubbo/getRecentRouterSnapshot` | `GET` | Obtain the historical routing status (up to 32 results stored) | `application/json` |
+| `dubbogetenabledroutersnapshot` | `true` | `/actuator/dubbo/getEnabledRouterSnapshot` | `GET` | Get the services that are currently collecting | `application/json` |
+| `dubbogracefulshutdown` | `false` | `/actuator/dubbo/gracefulShutdown` | `GET` | Unregister all services registered by the current IP instance from the registry | `application/json` |
 
 
 
@@ -429,6 +461,191 @@ The key is the simple name of Dubbo `*Config`  Class , the value is`*Config` Bea
 
 
 
+`/actuator/dubbo/online`
+
+```json
+{
+    "org.apache.dubbo.springboot.demo.DemoService:null": "online"
+}
+```
+
+
+
+`/actuator/dubbo/offline`
+
+```json
+{
+    "org.apache.dubbo.springboot.demo.DemoService:null": "offline"
+}
+```
+
+
+
+`/actuator/dubbo/ready`
+
+`/actuator/dubbo/ready` Detect whether the current framework can provide services normally (may be temporarily offline) :
+
+```json
+{
+    "dubbo-springboot-demo-provider": "true"
+}
+```
+
+
+
+`/actuator/dubbo/ls`
+
+`/actuator/dubbo/ls `List consumers and providers :
+
+```json
+{
+    "Providers": {
+        "DubboInternal - dubbo-springboot-demo-provider/org.apache.dubbo.metadata.MetadataService:1.0.0": "",
+        "DubboInternal - dubbo-springboot-demo-provider/org.apache.dubbo.metadata.MetadataServiceV2:2.0.0": "",
+        "DubboInternal - dubbo-springboot-demo-provider/org.apache.dubbo.metrics.service.MetricsService:1.0.0": "",
+        "org.apache.dubbo.springboot.demo.DemoService": "zookeeper-A(Y)/zookeeper-I(Y)"
+    },
+    "Consumers": {}
+}
+```
+
+- Services prefixed with `DubboInternal` are built-in services of Dubbo, and are not registered with the registry by default.
+
+- The first part of `zookeeper-A(Y)` in the service publishing status is the corresponding registry name, and the second part is the registration mode (`A` stands for application-level address registration, `I` stands for interface-level address registration), The third part represents whether the corresponding mode has been registered
+
+- The first part of `zookeeper-AF(I-2,A-2)` in the service subscription status is the corresponding registration center name, and the second part is the subscription mode (`AF` stands for dual subscription mode, `FA` stands for only Application-level subscription, `FI` stands for interface-level subscription only), the first half of the third part represents the source of the address mode (`A` stands for application-level address, `I` stands for interface-level address), and the second half represents the corresponding number of addresses
+
+
+
+`/actuator/dubbo/loggerInfo`
+
+`/actuator/dubbo/loggerInfo` show available logging framework, the logging framework and log level ：
+
+```json
+{
+    "Available logger adapters": [
+        "log4j2",
+        "slf4j",
+        "jcl",
+        "jdk"
+    ],
+    "Current Adapter": "slf4j",
+    "Log level": "INFO"
+}
+```
+
+
+
+`/actuator/dubbo/switchLogger?logger={loggerAdapterName}`
+
+`/actuator/dubbo/switchLogger?logger={loggerAdapterName}` allows switching between available logger adapters, and the parameter cannot be empty :
+
+```json
+{
+    "Current Adapter": "log4j2"
+}
+```
+
+
+
+`/actuator/dubbo/switchLogLevel?level={level}`
+
+`/actuator/dubbo/loggerInfo` allows switching between permitted log levels, and the parameter cannot be empty :
+
+```json
+{
+    "Current Log Level": "WARN"
+}
+```
+
+The log configuration modified by `switchLogger`/`switchLogLevel` is not stored persistently and will become invalid after the application is restarted.
+
+
+
+`/actuator/dubbo/disableSimpleProfiler`
+
+`/actuator/dubbo/disableSimpleProfiler` turn off the `simple profiler` mode, and the `detail profiler` will not be enabled after it is turned off :
+
+```json
+{
+    "WARN": "Dubbo Invocation Profiler has been disabled"
+}
+```
+
+The performance sampling function can detect the time consumption of various parts of the Dubbo processing link,where `simple profiler` mode is enabled by default.
+
+
+
+`/actuator/dubbo/enableDetailProfiler`
+
+`/actuator/dubbo/enableDetailProfiler` enable the `detail profiler` mode, which is disabled by default, you need to enable the `simple profiler` mode to actually enable it :
+
+```json
+{
+    "WARN": "Dubbo Invocation Profiler has been enabled, This will cause performance degradation"
+}
+```
+
+Compared with the `simple profiler` mode, the `detail profiler` collects more time-consuming processing of each filter, specific time-consuming protocols, etc. In the `simple profiler` mode, if you find that there is a long time-consuming situation inside the Dubbo framework, you can enable the `detail profiler` mode to better troubleshoot the problem.
+
+`/actuator/dubbo/setProfilerPercent?p={precent}`
+
+`/actuator/dubbo/setProfilerPercent?p={precent}` Control serialization alarm frequency (only for classes in the warning list) :
+```json
+{
+    "Current Dubbo Invocation Profiler warn percent": 0.4
+}
+```
+
+
+
+`/actuator/dubbo/disableRouterSnapshot{?service={servicePatern}}`
+
+`/actuator/dubbo/disableRouterSnapshot?service={servicePatern}` disable routing result collection mode, `servicePatern` is the name of the service to be collected, which supports matching :
+
+```json
+{
+    "org.apache.dubbo.springboot.demo.DemoService": "Router snapshot disabled"
+}
+```
+
+
+
+`/actuator/dubbo/enableRouterSnapshot`
+
+`/actuator/dubbo/enableRouterSnapshot?service={servicePatern}` enable routing result collection mode, `servicePatern` is the name of the service to be collected, which supports matching :
+
+```json
+{
+    "WARN": "Enable router snapshot will cause performance degradation, please be careful!",
+    "org.apache.dubbo.springboot.demo.DemoService": "Router snapshot enabled"
+}
+```
+
+
+
+`/actuator/dubbo/getEnabledRouterSnapshot`
+
+`/actuator/dubbo/getEnabledRouterSnapshot` get the services that are currently collecting
+
+```json
+{
+    "Enabled router snapshot": [
+        "org.apache.dubbo.springboot.demo.DemoService"
+    ]
+}
+```
+
+`/actuator/dubbo/gracefulShutdown` unregister all services registered by the current IP instance from the registry. The difference from 'offline' is that this command will also notify all consumers via TCP connection to stop calling this instance :
+```json
+{
+ "org.apache.dubbo.springboot.demo.DemoService:null": "offline"
+}
+```
+To restore, please execute 'online' to bring all services back online.
+
+
+
 ## Externalized Configuration
 
 
@@ -495,5 +712,42 @@ management.endpoint.dubboconfigs.enabled = true
 management.endpoint.dubboservices.enabled = true
 management.endpoint.dubboreferences.enabled = true
 management.endpoint.dubboproperties.enabled = true
+management.endpoint.dubbohelp.enabled = true
+management.endpoint.dubbocd.enabled = true
+management.endpoint.dubbocount.enabled = true
+management.endpoint.dubbopwd.enabled = true
+management.endpoint.dubboinvoke.enabled = true
+management.endpoint.dubboselect.enabled = true
+management.endpoint.dubboready.enabled = true
+management.endpoint.dubbols.enabled = true
+management.endpoint.dubbostartup.enabled = true
+management.endpoint.dubbops.enabled = true
+management.endpoint.dubboversion.enabled = true
+management.endpoint.dubbogetaddress.enabled = true
+management.endpoint.dubbogetconfig.enabled = true
+management.endpoint.dubbometrics.enabled = true
+management.endpoint.dubbometrics_default.enabled = true
+management.endpoint.dubbopublishMetadata.enabled = true
+management.endpoint.dubboonline.enabled = true
+management.endpoint.dubboonlineapp.enabled = true
+management.endpoint.dubboonlineinterface.enabled = true
+management.endpoint.dubbooffline.enabled = true
+management.endpoint.dubboofflineapp.enabled = true
+management.endpoint.dubboofflineinterface.enabled = true
+management.endpoint.dubbologgerinfo.enabled = true
+management.endpoint.dubboswitchlogger.enabled = true
+management.endpoint.dubboswitchloglevel.enabled = true
+management.endpoint.dubbodisabledetailprofiler.enabled = true
+management.endpoint.dubbodisablesimpleprofiler.enabled = true
+management.endpoint.dubboenabledetailprofiler.enabled = true
+management.endpoint.dubboenablesimpleprofiler.enabled = true
+management.endpoint.dubbosetprofilerwarnpercent.enabled = true
+management.endpoint.dubboserializecheckstatus.enabled = true
+management.endpoint.dubboserializewarnedclasses.enabled = true
+management.endpoint.dubbodisableroutersnapshot.enabled = true
+management.endpoint.dubboenableroutersnapshot.enabled = true
+management.endpoint.dubbogetrecentroutersnapshot.enabled = true
+management.endpoint.dubbogetenabledroutersnapshot.enabled = true
+management.endpoint.dubbogracefulshutdown.enabled = true
 ```
 

dubbo-spring-boot/dubbo-spring-boot-actuator/pom.xml

@@ -111,6 +111,13 @@
       <optional>true</optional>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.dubbo</groupId>
+      <artifactId>dubbo-qos</artifactId>
+      <version>${project.version}</version>
+      <optional>true</optional>
+    </dependency>
+
     <!-- Test Dependencies -->
     <dependency>
       <groupId>org.springframework.boot</groupId>