[DUBBO-3137]: step2 - seperate constants for config, remoting, rpc

dubbo-common/src/main/java/org/apache/dubbo/common/constants/ConfigConstants.java

@@ -0,0 +1,175 @@
+/*
+ * 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.common.constants;
+
+/**
+ * ConfigConstants
+ */
+public class ConfigConstants {
+    // BEGIN dubbo-config-api
+    public static final String CLUSTER_KEY = "cluster";
+
+    public static final String STATUS_KEY = "status";
+
+    public static final String CONTEXTPATH_KEY = "contextpath";
+
+    public static final String LISTENER_KEY = "listener";
+
+    public static final String LAYER_KEY = "layer";
+
+    /**
+     * General
+     */
+    /**
+     * Application name;
+     */
+    public static final String NAME = "name";
+
+    /**
+     * Application owner name;
+     */
+    public static final String OWNER = "owner";
+
+    /**
+     * Running application organization name.
+     */
+    public static final String ORGANIZATION = "organization";
+
+    /**
+     * Application architecture name.
+     */
+    public static final String ARCHITECTURE = "architecture";
+
+    /**
+     * Environment name
+     */
+    public static final String ENVIRONMENT = "environment";
+
+    /**
+     * Test environment key.
+     */
+    public static final String TEST_ENVIRONMENT = "test";
+
+    /**
+     * Development environment key.
+     */
+    public static final String DEVELOPMENT_ENVIRONMENT = "develop";
+
+    /**
+     * Production environment key.
+     */
+    public static final String PRODUCTION_ENVIRONMENT = "product";
+
+    public static final String CONFIG_CLUSTER_KEY = "config.cluster";
+    public static final String CONFIG_NAMESPACE_KEY = "config.namespace";
+    public static final String CONFIG_GROUP_KEY = "config.group";
+    public static final String CONFIG_CHECK_KEY = "config.check";
+
+    public static final String CONFIG_CONFIGFILE_KEY = "config.config-file";
+    public static final String CONFIG_ENABLE_KEY = "config.highest-priority";
+    public static final String CONFIG_TIMEOUT_KEY = "config.timeout";
+    public static final String CONFIG_APPNAME_KEY = "config.app-name";
+
+    public static final String USERNAME_KEY = "username";
+
+    public static final String PASSWORD_KEY = "password";
+
+    public static final String HOST_KEY = "host";
+
+    public static final String PORT_KEY = "port";
+
+    public static final String MULTICAST = "multicast";
+
+    public static final String REGISTER_IP_KEY = "register.ip";
+
+    public static final String DUBBO_IP_TO_REGISTRY = "DUBBO_IP_TO_REGISTRY";
+
+    public static final String DUBBO_PORT_TO_REGISTRY = "DUBBO_PORT_TO_REGISTRY";
+
+    public static final String DUBBO_IP_TO_BIND = "DUBBO_IP_TO_BIND";
+
+    public static final String DUBBO_PORT_TO_BIND = "DUBBO_PORT_TO_BIND";
+
+    public static final String SCOPE_KEY = "scope";
+
+    public static final String SCOPE_LOCAL = "local";
+
+    public static final String SCOPE_REMOTE = "remote";
+
+    public static final String SCOPE_NONE = "none";
+
+    public static final String ON_CONNECT_KEY = "onconnect";
+
+    public static final String ON_DISCONNECT_KEY = "ondisconnect";
+
+    public static final String ON_INVOKE_METHOD_KEY = "oninvoke.method";
+
+    public static final String ON_RETURN_METHOD_KEY = "onreturn.method";
+
+    public static final String ON_THROW_METHOD_KEY = "onthrow.method";
+
+    public static final String ON_INVOKE_INSTANCE_KEY = "oninvoke.instance";
+
+    public static final String ON_RETURN_INSTANCE_KEY = "onreturn.instance";
+
+    public static final String ON_THROW_INSTANCE_KEY = "onthrow.instance";
+
+    @Deprecated
+    public static final String SHUTDOWN_WAIT_SECONDS_KEY = "dubbo.service.shutdown.wait.seconds";
+
+    public static final String SHUTDOWN_WAIT_KEY = "dubbo.service.shutdown.wait";
+
+    /**
+     * The key name for export URL in register center
+     */
+    public static final String EXPORT_KEY = "export";
+
+    /**
+     * The key name for reference URL in register center
+     */
+    public static final String REFER_KEY = "refer";
+
+    /**
+     * To decide whether to make connection when the client is created
+     */
+    public static final String LAZY_CONNECT_KEY = "lazy";
+
+    public static final String DUBBO_PROTOCOL = "dubbo";
+
+    public static final String ZOOKEEPER_PROTOCOL = "zookeeper";
+
+    // FIXME: is this still useful?
+    public static final String SHUTDOWN_TIMEOUT_KEY = "shutdown.timeout";
+
+    public static final int DEFAULT_SHUTDOWN_TIMEOUT = 1000 * 60 * 15;
+
+    public static final String PROTOCOLS_SUFFIX = "dubbo.protocols.";
+
+    public static final String PROTOCOL_SUFFIX = "dubbo.protocol.";
+
+    public static final String REGISTRIES_SUFFIX = "dubbo.registries.";
+
+    public static final String TELNET = "telnet";
+
+    public static final String QOS_ENABLE = "qos.enable";
+
+    public static final String QOS_PORT = "qos.port";
+
+    public static final String ACCEPT_FOREIGN_IP = "qos.accept.foreign.ip";
+    // END dubbo-congfig-api
+}

dubbo-common/src/main/java/org/apache/dubbo/common/constants/RemotingConstants.java

@@ -0,0 +1,154 @@
+/*
+ * 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.common.constants;
+
+import java.util.concurrent.ExecutorService;
+
+/**
+ * RemotingConstants
+ */
+public class RemotingConstants {
+
+    public static final String PAYLOAD_KEY = "payload";
+    /**
+     * 8M
+     */
+    public static final int DEFAULT_PAYLOAD = 8 * 1024 * 1024;
+
+    public static final String BUFFER_KEY = "buffer";
+
+    /**
+     * default buffer size is 8k.
+     */
+    public static final int DEFAULT_BUFFER_SIZE = 8 * 1024;
+
+    public static final int MAX_BUFFER_SIZE = 16 * 1024;
+
+    public static final int MIN_BUFFER_SIZE = 1 * 1024;
+
+    public static final String CONNECT_TIMEOUT_KEY = "connect.timeout";
+
+    public static final int DEFAULT_CONNECT_TIMEOUT = 3000;
+
+    public static final String HEARTBEAT_KEY = "heartbeat";
+
+    public static final int DEFAULT_HEARTBEAT = 60 * 1000;
+
+    public static final String IDLE_TIMEOUT_KEY = "idle.timeout";
+
+    public static final int DEFAULT_IDLE_TIMEOUT = 600 * 1000;
+
+    public static final String ACCEPTS_KEY = "accepts";
+
+    public static final int DEFAULT_ACCEPTS = 0;
+
+    public static final String SERIALIZATION_KEY = "serialization";
+
+    public static final String DEFAULT_REMOTING_SERIALIZATION = "hessian2";
+
+    public static final String CODEC_KEY = "codec";
+
+    public static final String DEFAULT_REMOTING_CODEC = "dubbo";
+
+    public static final String SERVER_KEY = "server";
+
+    public static final String DEFAULT_REMOTING_SERVER = "netty";
+
+    public static final String CLIENT_KEY = "client";
+
+    public static final String DEFAULT_REMOTING_CLIENT = "netty";
+
+    public static final String TRANSPORTER_KEY = "transporter";
+
+    public static final String DEFAULT_TRANSPORTER = "netty";
+
+    public static final String EXCHANGER_KEY = "exchanger";
+
+    public static final String DEFAULT_EXCHANGER = "header";
+
+    public static final String DISPACTHER_KEY = "dispacther";
+
+    public static final int DEFAULT_IO_THREADS = Math.min(Runtime.getRuntime().availableProcessors() + 1, 32);
+
+    public static final String BIND_IP_KEY = "bind.ip";
+
+    public static final String BIND_PORT_KEY = "bind.port";
+
+    public static final String SENT_KEY = "sent";
+
+    public static final boolean DEFAULT_SENT = false;
+
+    public static final String DISPATCHER_KEY = "dispatcher";
+
+    public static final String CHANNEL_HANDLER_KEY = "channel.handler";
+
+    public static final String DEFAULT_CHANNEL_HANDLER = "default";
+
+    public static final String SERVICE_DESCIPTOR_KEY = "serviceDescriptor";
+
+    public static final String CONNECT_QUEUE_CAPACITY = "connect.queue.capacity";
+
+    public static final String CONNECT_QUEUE_WARNING_SIZE = "connect.queue.warning.size";
+
+    public static final int DEFAULT_CONNECT_QUEUE_WARNING_SIZE = 1000;
+
+    public static final String CHANNEL_ATTRIBUTE_READONLY_KEY = "channel.readonly";
+
+    public static final String CHANNEL_READONLYEVENT_SENT_KEY = "channel.readonly.sent";
+
+    public static final String CHANNEL_SEND_READONLYEVENT_KEY = "channel.readonly.send";
+
+    public static final String EXECUTOR_SERVICE_COMPONENT_KEY = ExecutorService.class.getName();
+
+    public static final String CHARSET_KEY = "charset";
+
+    public static final String DEFAULT_CHARSET = "UTF-8";
+
+    public static final String BACKUP_KEY = "backup";
+
+    /**
+     * Every heartbeat duration / HEATBEAT_CHECK_TICK, check if a heartbeat should be sent. Every heartbeat timeout
+     * duration / HEATBEAT_CHECK_TICK, check if a connection should be closed on server side, and if reconnect on
+     * client side
+     */
+    public static final int HEARTBEAT_CHECK_TICK = 3;
+
+    /**
+     * the least heartbeat during is 1000 ms.
+     */
+    public static final long LEAST_HEARTBEAT_DURATION = 1000;
+
+    /**
+     * ticks per wheel.
+     */
+    public static final int TICKS_PER_WHEEL = 128;
+
+    public static final String HEARTBEAT_TIMEOUT_KEY = "heartbeat.timeout";
+
+    public static final String RECONNECT_KEY = "reconnect";
+
+    public static final int DEFAULT_RECONNECT_PERIOD = 2000;
+
+    public static final String SEND_RECONNECT_KEY = "send.reconnect";
+
+    public static final String CHECK_KEY = "check";
+
+    public static final String PROMPT_KEY = "prompt";
+
+    public static final String DEFAULT_PROMPT = "dubbo>";
+}