Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix default setting #5067

Closed
wants to merge 19 commits into from
Closed
Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
5f15355
fix default setting
brucelwl Sep 16, 2019
9fd6782
fix register config not take effect because of url simplified (#4397)
imsunv Sep 16, 2019
f8cfff9
[Dubbo-4984]Fix: type definition for String class (#5032)
moriadry Sep 16, 2019
0378fee
tag router supports anyhost (#4431)
cvictory Sep 17, 2019
dc359ef
fix 4694: consumer return quickly, when the provider interrupts abnor…
bigwg Sep 17, 2019
ef058ee
throw exception whenever SPI extensions are in abnormal status when l…
chickenlj Sep 17, 2019
c5f6b49
try to fix travis javax.ex dependency issue
chickenlj Sep 18, 2019
83d097f
try to fix travis javax.ex dependency issue
chickenlj Sep 18, 2019
8dfb078
try to fix travis javax.ex dependency issue
chickenlj Sep 18, 2019
d00788b
[Dubbo-4882] Add support for overriding Map properties in AbstractCon…
mzorro Sep 18, 2019
94fd72e
fix set generic method error (#5079)
chickenlj Sep 18, 2019
f20cc7f
delete 'config.' prefix for url generated from ConfigCenterConfig (#5…
chickenlj Sep 18, 2019
c1e49db
[Dubbo-4331] Improve api doc (#5070)
sonymoon Sep 19, 2019
7a6d985
resolve conflicts
brucelwl Sep 23, 2019
1b9ce4d
Stabilize EtcdMetadataReportTest (#5088)
biyuhao Sep 20, 2019
c78acd9
修复 CollectionUtils类toStringMap方法没有检查 pairs 参数是否为空. (#5102)
xiaoheng1 Sep 22, 2019
2f1d035
解决冲突
brucelwl Sep 24, 2019
5c55e80
Merge remote-tracking branch 'upstream/master'
brucelwl Oct 8, 2019
acc43a0
修复nacos默认设置weight=1.0,导致权重获取bug
brucelwl Oct 8, 2019
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
delete 'config.' prefix for url generated from ConfigCenterConfig (#5078
)
chickenlj authored and brucelwl committed Sep 23, 2019
commit f20cc7f117794e3cf72ffa651148060273ac86e2
Original file line number Diff line number Diff line change
@@ -184,4 +184,9 @@ public interface CommonConstants {

String DUBBO_LABELS = "dubbo.labels";
String DUBBO_ENV_KEYS = "dubbo.env.keys";

String CONFIG_CONFIGFILE_KEY = "config-file";
String CONFIG_ENABLE_KEY = "highest-priority";
String CONFIG_NAMESPACE_KEY = "namespace";
String CHECK_KEY = "check";
}
Original file line number Diff line number Diff line change
@@ -36,7 +36,6 @@ public class Constants implements CommonConstants,
org.apache.dubbo.rpc.Constants,
org.apache.dubbo.rpc.protocol.dubbo.Constants,
org.apache.dubbo.common.serialize.Constants,
org.apache.dubbo.configcenter.Constants,
org.apache.dubbo.metadata.support.Constants,
org.apache.dubbo.rpc.protocol.rest.Constants,
org.apache.dubbo.registry.Constants {
Original file line number Diff line number Diff line change
@@ -28,16 +28,11 @@
import java.util.concurrent.atomic.AtomicBoolean;

import static org.apache.dubbo.common.constants.CommonConstants.ANYHOST_VALUE;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_CONFIGFILE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_ENABLE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PATH_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PROTOCOL_KEY;
import static org.apache.dubbo.config.Constants.CONFIG_CONFIGFILE_KEY;
import static org.apache.dubbo.config.Constants.CONFIG_ENABLE_KEY;
import static org.apache.dubbo.config.Constants.CONFIG_TIMEOUT_KEY;
import static org.apache.dubbo.config.Constants.ZOOKEEPER_PROTOCOL;
import static org.apache.dubbo.configcenter.Constants.CONFIG_CHECK_KEY;
import static org.apache.dubbo.configcenter.Constants.CONFIG_CLUSTER_KEY;
import static org.apache.dubbo.configcenter.Constants.CONFIG_GROUP_KEY;
import static org.apache.dubbo.configcenter.Constants.CONFIG_NAMESPACE_KEY;

/**
* ConfigCenterConfig
@@ -82,7 +77,7 @@ public class ConfigCenterConfig extends AbstractConfig {
/* If the Config Center product you use have some special parameters that is not covered by this class, you can add it to here.
For example, with XML:
<dubbo:config-center>
<dubbo:parameter key="config.{your key}" value="{your value}" />
<dubbo:parameter key="{your key}" value="{your value}" />
</dubbo:config-center>
*/
private Map<String, String> parameters;
@@ -133,7 +128,6 @@ public void setAddress(String address) {
this.address = address;
}

@Parameter(key = CONFIG_CLUSTER_KEY)
public String getCluster() {
return cluster;
}
@@ -142,7 +136,6 @@ public void setCluster(String cluster) {
this.cluster = cluster;
}

@Parameter(key = CONFIG_NAMESPACE_KEY)
public String getNamespace() {
return namespace;
}
@@ -151,7 +144,6 @@ public void setNamespace(String namespace) {
this.namespace = namespace;
}

@Parameter(key = CONFIG_GROUP_KEY)
public String getGroup() {
return group;
}
@@ -160,7 +152,6 @@ public void setGroup(String group) {
this.group = group;
}

@Parameter(key = CONFIG_CHECK_KEY)
public Boolean isCheck() {
return check;
}
@@ -194,7 +185,6 @@ public void setPassword(String password) {
this.password = password;
}

@Parameter(key = CONFIG_TIMEOUT_KEY)
public Long getTimeout() {
return timeout;
}
Original file line number Diff line number Diff line change
@@ -73,11 +73,6 @@ public interface Constants {
*/
String PRODUCTION_ENVIRONMENT = "product";

String CONFIG_CONFIGFILE_KEY = "config.config-file";
String CONFIG_ENABLE_KEY = "config.highest-priority";
String CONFIG_TIMEOUT_KEY = "config.timeout";
String CONFIG_APPNAME_KEY = "config.app-name";

String MULTICAST = "multicast";


Original file line number Diff line number Diff line change
@@ -37,9 +37,9 @@ public void testToUrl() {
config.setGroup("group");
config.setAddress("zookeeper://127.0.0.1:2181");

Assertions.assertEquals("zookeeper://127.0.0.1:2181/ConfigCenterConfig?config.check=true&" +
"config.config-file=dubbo.properties&config.group=group&config.highest-priority=true&" +
"config.namespace=namespace&config.timeout=3000",
Assertions.assertEquals("zookeeper://127.0.0.1:2181/ConfigCenterConfig?check=true&" +
"config-file=dubbo.properties&group=group&highest-priority=true&" +
"namespace=namespace&timeout=3000",
config.toUrl().toFullString()
);
}

This file was deleted.

Original file line number Diff line number Diff line change
@@ -44,10 +44,10 @@

import static org.apache.dubbo.common.constants.CommonConstants.ANYHOST_VALUE;
import static org.apache.dubbo.common.constants.CommonConstants.APPLICATION_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.CHECK_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.CLUSTER_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.COMMA_SPLIT_PATTERN;
import static org.apache.dubbo.configcenter.Constants.CONFIG_CHECK_KEY;
import static org.apache.dubbo.configcenter.Constants.CONFIG_CLUSTER_KEY;
import static org.apache.dubbo.configcenter.Constants.CONFIG_NAMESPACE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_NAMESPACE_KEY;

/**
* Apollo implementation, https://github.com/ctripcorp/apollo
@@ -70,7 +70,7 @@ public class ApolloDynamicConfiguration implements DynamicConfiguration {
// Instead of using Dubbo's configuration, I would suggest use the original configuration method Apollo provides.
String configEnv = url.getParameter(APOLLO_ENV_KEY);
String configAddr = getAddressWithProtocolPrefix(url);
String configCluster = url.getParameter(CONFIG_CLUSTER_KEY);
String configCluster = url.getParameter(CLUSTER_KEY);
if (configEnv != null) {
System.setProperty(APOLLO_ENV_KEY, configEnv);
}
@@ -84,7 +84,7 @@ public class ApolloDynamicConfiguration implements DynamicConfiguration {
dubboConfig = ConfigService.getConfig(url.getParameter(CONFIG_NAMESPACE_KEY, DEFAULT_GROUP));
dubboConfigFile = ConfigService.getConfigFile(url.getParameter(CONFIG_NAMESPACE_KEY, DEFAULT_GROUP), ConfigFileFormat.Properties);
// Decide to fail or to continue when failed to connect to remote server.
boolean check = url.getParameter(CONFIG_CHECK_KEY, true);
boolean check = url.getParameter(CHECK_KEY, true);
if (dubboConfig.getSourceType() != ConfigSourceType.REMOTE) {
if (check) {
throw new IllegalStateException("Failed to connect to config center, the config center is Apollo, " +
Original file line number Diff line number Diff line change
@@ -39,9 +39,9 @@
import java.util.concurrent.ExecutorService;

import static java.util.concurrent.Executors.newCachedThreadPool;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_NAMESPACE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PATH_SEPARATOR;
import static org.apache.dubbo.configcenter.ConfigChangeType.ADDED;
import static org.apache.dubbo.configcenter.Constants.CONFIG_NAMESPACE_KEY;

/**
* config center implementation for consul
Original file line number Diff line number Diff line change
@@ -40,8 +40,8 @@
import java.util.concurrent.ConcurrentMap;

import static java.nio.charset.StandardCharsets.UTF_8;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_NAMESPACE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PATH_SEPARATOR;
import static org.apache.dubbo.configcenter.Constants.CONFIG_NAMESPACE_KEY;

/**
* The etcd implementation of {@link DynamicConfiguration}
Original file line number Diff line number Diff line change
@@ -32,8 +32,8 @@
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_NAMESPACE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PATH_SEPARATOR;
import static org.apache.dubbo.configcenter.Constants.CONFIG_NAMESPACE_KEY;

/**
*
Original file line number Diff line number Diff line change
@@ -32,7 +32,6 @@ public void setZookeeperTransporter(ZookeeperTransporter zookeeperTransporter) {
this.zookeeperTransporter = zookeeperTransporter;
}


@Override
protected DynamicConfiguration createDynamicConfiguration(URL url) {
return new ZookeeperDynamicConfiguration(url, zookeeperTransporter);