[dubbo] branch cloud-native updated: Remove ConfigManager operations in sub Configs, leave it to DubboBootstrap
This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git The following commit(s) were added to refs/heads/cloud-native by this push: new 48c1cc4 Remove ConfigManager operations in sub Configs, leave it to DubboBootstrap 48c1cc4 is described below commit 48c1cc4bfebcf3a66e4143862e87581ab6615d43 Author: ken.lj AuthorDate: Fri Aug 9 12:47:03 2019 +0800 Remove ConfigManager operations in sub Configs, leave it to DubboBootstrap --- .../dubbo/config/AbstractInterfaceConfig.java | 14 +- .../dubbo/config/AbstractReferenceConfig.java | 4 +- .../apache/dubbo/config/AbstractServiceConfig.java | 2 - .../org/apache/dubbo/config/ReferenceConfig.java | 11 +- .../org/apache/dubbo/config/ServiceConfig.java | 19 ++ .../apache/dubbo/config/spring/ReferenceBean.java | 160 .../apache/dubbo/config/spring/ServiceBean.java| 206 - 7 files changed, 40 insertions(+), 376 deletions(-) diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java index 874e38b..5819a50 100644 --- a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java +++ b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java @@ -462,6 +462,7 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } private void convertRegistryIdsToRegistries() { +computeValidRegistryIds(); if (StringUtils.isEmpty(registryIds)) { if (CollectionUtils.isEmpty(registries)) { List registryConfigs = ConfigManager.getInstance().getDefaultRegistries(); @@ -492,6 +493,14 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } +protected void computeValidRegistryIds() { +if (StringUtils.isEmpty(getRegistryIds())) { +if (getApplication() != null && StringUtils.isNotEmpty(getApplication().getRegistryIds())) { +setRegistryIds(getApplication().getRegistryIds()); +} +} +} + private void loadRegistriesFromBackwardConfig() { // for backward compatibility // -Ddubbo.registry.address is now deprecated. @@ -620,7 +629,6 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } public void setApplication(ApplicationConfig application) { -ConfigManager.getInstance().setApplication(application); this.application = application; } @@ -645,7 +653,6 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } public void setModule(ModuleConfig module) { -ConfigManager.getInstance().setModule(module); this.module = module; } @@ -665,7 +672,6 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { @SuppressWarnings({"unchecked"}) public void setRegistries(List registries) { -ConfigManager.getInstance().addRegistries((List) registries); this.registries = (List) registries; } @@ -687,7 +693,6 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } public void setMonitor(MonitorConfig monitor) { -ConfigManager.getInstance().setMonitor(monitor); this.monitor = monitor; } @@ -705,7 +710,6 @@ public abstract class AbstractInterfaceConfig extends AbstractMethodConfig { } public void setConfigCenter(ConfigCenterConfig configCenter) { -ConfigManager.getInstance().addConfigCenter(configCenter); this.configCenter = configCenter; } diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java index 545c2bc..7dcb70f 100644 --- a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java +++ b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractReferenceConfig.java @@ -21,13 +21,13 @@ import org.apache.dubbo.remoting.Constants; import org.apache.dubbo.rpc.InvokerListener; import org.apache.dubbo.rpc.support.ProtocolUtils; -import static org.apache.dubbo.rpc.cluster.Constants.CLUSTER_STICKY_KEY; import static org.apache.dubbo.common.constants.CommonConstants.GROUP_KEY; import static org.apache.dubbo.common.constants.CommonConstants.VERSION_KEY; -import static org.apache.dubbo.rpc.Constants.LAZY_CONNECT_KEY; import static org.apache.dubbo.rpc.Constants.INVOKER_LISTENER_KEY; +import static org.apache.dubbo.rpc.Constants.LAZY_CONNECT_KEY; import static
[dubbo] branch cloud-native updated (4a3f8ab -> 05ce087)
This is an automated email from the ASF dual-hosted git repository. liujun pushed a change to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git. from 4a3f8ab modify metadata new 550b404 Change how service instance is created. new b7b34b6 Merge branch 'cloud-native' of https://github.com/apache/dubbo into cloud-native new 2245cf7 Introduce ProtocolServer to distinguish from RemotingServer new 05ce087 Merge remote-tracking branch 'origin/cloud-native' into cloud-native The 4 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: dubbo-bootstrap/pom.xml| 7 + .../org/apache/dubbo/bootstrap/DubboBootstrap.java | 153 + .../bootstrap/DubboServiceProviderBootstrap.java | 4 +- .../DefaultGovernanceRuleRepositoryImpl.java | 52 +-- .../governance/GovernanceRuleRepository.java | 94 + .../dubbo/rpc/cluster/router/AbstractRouter.java | 13 +- .../cluster/router/condition/config/AppRouter.java | 5 +- .../router/condition/config/AppRouterFactory.java | 3 +- .../router/condition/config/ListenableRouter.java | 8 +- .../router/condition/config/ServiceRouter.java | 4 +- .../condition/config/ServiceRouterFactory.java | 3 +- .../dubbo/rpc/cluster/router/tag/TagRouter.java| 10 +- .../rpc/cluster/router/tag/TagRouterFactory.java | 3 +- ...rpc.cluster.governance.GovernanceRuleRepository | 1 + .../apache/dubbo/common/config/Configuration.java | 49 +++ .../configcenter/AbstractDynamicConfiguration.java | 5 - .../config/configcenter/DynamicConfiguration.java | 26 .../file/FileSystemDynamicConfiguration.java | 5 - .../configcenter/nop/NopDynamicConfiguration.java | 6 - .../wrapper/CompositeDynamicConfiguration.java | 7 +- .../file/FileSystemDynamicConfigurationTest.java | 2 +- .../apache/dubbo/config/AbstractServiceConfig.java | 2 +- .../org/apache/dubbo/config/RegistryConfig.java| 32 - .../dubbo/config/builders/ConfigCenterBuilder.java | 1 - .../apache/dubbo/config/context/ConfigManager.java | 2 +- .../ConfigurableMetadataServiceExporter.java | 1 + .../dubbo/config/DubboProviderBootstrap.java | 5 +- .../org/apache/dubbo/config/mock/MockProtocol.java | 8 ++ .../apache/dubbo/config/mock/MockProtocol2.java| 8 ++ .../apache/dubbo/config/mock/MockTransporter.java | 6 +- .../src/main/resources/META-INF/compat/dubbo.xsd | 10 ++ .../src/main/resources/META-INF/dubbo.xsd | 10 ++ .../support/apollo/ApolloDynamicConfiguration.java | 2 +- .../consul/ConsulDynamicConfiguration.java | 15 +- .../support/etcd/EtcdDynamicConfiguration.java | 12 +- .../support/nacos/NacosDynamicConfiguration.java | 5 - .../zookeeper/ZookeeperDynamicConfiguration.java | 10 -- .../dubbo/metadata/WritableMetadataService.java| 1 + .../dubbo/qos/protocol/QosProtocolWrapper.java | 7 + .../client/AbstractServiceDiscoveryFactory.java| 71 ++ .../EventPublishingServiceDiscoveryFactory.java| 47 --- .../registry/client/ServiceDiscoveryFactory.java | 17 +-- ...ExportedServicesRevisionMetadataCustomizer.java | 5 +- ...MetadataServiceURLParamsMetadataCustomizer.java | 5 +- .../integration/AbstractConfiguratorListener.java | 8 +- .../registry/integration/RegistryDirectory.java| 3 +- .../registry/integration/RegistryProtocol.java | 11 +- .../registry/support/AbstractRegistryFactory.java | 1 - .../registry/support/ServiceOrientedRegistry.java | 5 +- ...e.dubbo.registry.client.ServiceDiscoveryFactory | 1 - .../client/InMemoryServiceDiscoveryFactory.java| 4 +- .../client/ServiceDiscoveryFactoryTest.java| 55 .../registry/etcd/EtcdServiceDiscoveryFactory.java | 6 +- .../nacos/NacosServiceDiscoveryFactory.java| 5 +- .../ZookeeperServiceDiscoveryFactory.java | 5 +- .../java/org/apache/dubbo/remoting/Channel.java| 4 +- .../java/org/apache/dubbo/remoting/Endpoint.java | 2 +- .../remoting/{Server.java => RemotingServer.java} | 116 .../org/apache/dubbo/remoting/Transporter.java | 2 +- .../org/apache/dubbo/remoting/Transporters.java| 4 +- .../dubbo/remoting/exchange/ExchangeServer.java| 4 +- .../support/header/HeaderExchangeServer.java | 8 +- .../dubbo/remoting/transport/AbstractServer.java | 8 +- .../dubbo/remoting/transport/ServerDelegate.java | 12 +- .../transport/grizzly/GrizzlyTransporter.java | 4 +- .../org/apache/dubbo/remoting/http/HttpServer.java | 3 +- .../remoting/http/support/AbstractHttpServer.java | 48 +++ .../remoting/transport/mina/MinaTransporter.java
[dubbo] 03/04: Introduce ProtocolServer to distinguish from RemotingServer
This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git commit 2245cf70bc89c229a387fd9aa59339bdb947f8d6 Author: ken.lj AuthorDate: Fri Aug 9 10:36:28 2019 +0800 Introduce ProtocolServer to distinguish from RemotingServer --- .../org/apache/dubbo/bootstrap/DubboBootstrap.java | 1 + .../DefaultGovernanceRuleRepositoryImpl.java | 52 ++-- .../governance/GovernanceRuleRepository.java | 94 ++ .../dubbo/rpc/cluster/router/AbstractRouter.java | 13 ++- .../cluster/router/condition/config/AppRouter.java | 5 +- .../router/condition/config/AppRouterFactory.java | 3 +- .../router/condition/config/ListenableRouter.java | 8 +- .../router/condition/config/ServiceRouter.java | 4 +- .../condition/config/ServiceRouterFactory.java | 3 +- .../dubbo/rpc/cluster/router/tag/TagRouter.java| 10 +-- .../rpc/cluster/router/tag/TagRouterFactory.java | 3 +- ...rpc.cluster.governance.GovernanceRuleRepository | 1 + .../apache/dubbo/common/config/Configuration.java | 49 +++ .../configcenter/AbstractDynamicConfiguration.java | 5 -- .../config/configcenter/DynamicConfiguration.java | 26 -- .../file/FileSystemDynamicConfiguration.java | 5 -- .../configcenter/nop/NopDynamicConfiguration.java | 6 -- .../wrapper/CompositeDynamicConfiguration.java | 5 -- .../file/FileSystemDynamicConfigurationTest.java | 2 +- .../support/apollo/ApolloDynamicConfiguration.java | 2 +- .../consul/ConsulDynamicConfiguration.java | 15 ++-- .../support/etcd/EtcdDynamicConfiguration.java | 12 +-- .../support/nacos/NacosDynamicConfiguration.java | 5 -- .../zookeeper/ZookeeperDynamicConfiguration.java | 10 --- .../dubbo/qos/protocol/QosProtocolWrapper.java | 7 ++ .../integration/AbstractConfiguratorListener.java | 8 +- .../registry/integration/RegistryDirectory.java| 3 +- .../registry/integration/RegistryProtocol.java | 5 +- .../java/org/apache/dubbo/rpc/ProtocolServer.java | 5 +- .../dubbo/rpc/protocol/AbstractProxyProtocol.java | 2 +- .../rpc/protocol/dubbo/DubboProtocolServer.java| 2 +- .../rpc/protocol/rest/BaseRestProtocolServer.java | 12 +++ ...ttpServer.java => DubboHttpProtocolServer.java} | 4 +- .../dubbo/rpc/protocol/rest/RestProtocol.java | 1 + .../dubbo/rpc/protocol/rest/RestServerFactory.java | 2 +- .../dubbo/rpc/protocol/thrift/ThriftProtocol.java | 2 +- 36 files changed, 224 insertions(+), 168 deletions(-) diff --git a/dubbo-bootstrap/src/main/java/org/apache/dubbo/bootstrap/DubboBootstrap.java b/dubbo-bootstrap/src/main/java/org/apache/dubbo/bootstrap/DubboBootstrap.java index fbc523a..005f11d 100644 --- a/dubbo-bootstrap/src/main/java/org/apache/dubbo/bootstrap/DubboBootstrap.java +++ b/dubbo-bootstrap/src/main/java/org/apache/dubbo/bootstrap/DubboBootstrap.java @@ -59,6 +59,7 @@ import org.apache.dubbo.rpc.ProtocolServer; import java.io.IOException; import java.util.ArrayList; import java.util.Collection; +import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/config/configcenter/nop/NopDynamicConfiguration.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/governance/DefaultGovernanceRuleRepositoryImpl.java similarity index 53% copy from dubbo-common/src/main/java/org/apache/dubbo/common/config/configcenter/nop/NopDynamicConfiguration.java copy to dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/governance/DefaultGovernanceRuleRepositoryImpl.java index 7940101..64ddb02 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/config/configcenter/nop/NopDynamicConfiguration.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/governance/DefaultGovernanceRuleRepositoryImpl.java @@ -14,67 +14,27 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.dubbo.common.config.configcenter.nop; +package org.apache.dubbo.rpc.cluster.governance; -import org.apache.dubbo.common.URL; import org.apache.dubbo.common.config.configcenter.ConfigurationListener; import org.apache.dubbo.common.config.configcenter.DynamicConfiguration; -import java.util.SortedSet; +public class DefaultGovernanceRuleRepositoryImpl implements GovernanceRuleRepository { -import static java.util.Collections.emptySortedSet; - -/** - * The default extension of {@link DynamicConfiguration}. If user does not specify a config centre, or specifies one - * that is not a valid extension, it will default to this one. - */ -@Deprecated -public class NopDynamicConfiguration implements DynamicConfiguration { - -public NopDynamicConfiguration(URL url) { -// no-op -} - -@Override -public Object getInternalProperty(String key) {
[dubbo] 04/04: Merge remote-tracking branch 'origin/cloud-native' into cloud-native
This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git commit 05ce0879067ff6010362049aed81b5f3def89c4f Merge: 2245cf7 4a3f8ab Author: ken.lj AuthorDate: Fri Aug 9 10:40:02 2019 +0800 Merge remote-tracking branch 'origin/cloud-native' into cloud-native dubbo-all/pom.xml | 2 +- .../ConfigurableMetadataServiceExporter.java | 4 ++ .../dubbo/metadata/MetadataServiceExporter.java| 1 + .../dubbo/metadata/WritableMetadataService.java| 9 .../store/InMemoryWritableMetadataService.java | 57 +- .../store/RemoteWritableMetadataService.java | 18 ++- .../DefaultMetadataServiceProxyFactory.java| 42 .../metadata/MetadataServiceProxyFactory.java | 51 --- .../metadata/RefreshServiceMetadataCustomizer.java | 24 + ...dubbo.registry.client.ServiceInstanceCustomizer | 3 +- 10 files changed, 103 insertions(+), 108 deletions(-)
[dubbo] 02/04: Merge branch 'cloud-native' of https://github.com/apache/dubbo into cloud-native
This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git commit b7b34b6c475912c4c805b389954fd897bdd9f769 Merge: 550b404 03173f8 Author: ken.lj AuthorDate: Thu Aug 8 16:22:48 2019 +0800 Merge branch 'cloud-native' of https://github.com/apache/dubbo into cloud-native .travis.yml| 2 +- dubbo-bom/pom.xml | 1 + dubbo-bootstrap/pom.xml| 40 +-- .../org/apache/dubbo/bootstrap/DubboBootstrap.java | 25 +- .../bootstrap/DubboServiceConsumerBootstrap.java | 3 +- ...ap.java => DubboServiceProvider2Bootstrap.java} | 34 +-- dubbo-cluster/pom.xml | 1 + .../router/condition/config/ListenableRouter.java | 2 +- .../dubbo/rpc/cluster/router/tag/TagRouter.java| 2 +- .../support/wrapper/MockClusterInvoker.java| 2 +- .../dubbo/rpc/cluster/router/TagRouterTest.java| 5 +- .../support/AbstractClusterInvokerTest.java| 2 +- dubbo-common/pom.xml | 1 + .../apache/dubbo/common/config/Configuration.java | 2 - .../configcenter/AbstractDynamicConfiguration.java | 182 .../config/configcenter/DynamicConfiguration.java | 86 -- .../file/FileSystemDynamicConfiguration.java | 23 +- .../configcenter/nop/NopDynamicConfiguration.java | 6 +- .../wrapper/CompositeDynamicConfiguration.java | 5 + .../dubbo/common/constants/CommonConstants.java| 2 +- .../extension/AdaptiveClassCodeGenerator.java | 10 +- .../apache/dubbo/common/bytecode/MixinTest.java| 1 - .../common/config/InmemoryConfigurationTest.java | 6 +- .../threadlocal/InternalThreadLocalTest.java | 1 - .../apache/dubbo/common/utils/PojoUtilsTest.java | 5 +- dubbo-compatible/pom.xml | 1 + .../dubbo/rpc/protocol/dubbo/FutureAdapter.java| 6 +- .../org/apache/dubbo/config/MethodConfigTest.java | 1 - .../org/apache/dubbo/filter/LegacyInvoker.java | 2 +- .../java/org/apache/dubbo/rpc/RpcContextTest.java | 6 +- dubbo-config/dubbo-config-api/pom.xml | 1 + .../org/apache/dubbo/config/ApplicationConfig.java | 1 - .../org/apache/dubbo/config/ReferenceConfig.java | 14 +- .../org/apache/dubbo/config/RegistryConfig.java| 10 +- .../org/apache/dubbo/config/ServiceConfig.java | 5 +- .../apache/dubbo/config/ReferenceConfigTest.java | 8 +- .../ConfigurableMetadataServiceExporterTest.java | 5 +- dubbo-config/dubbo-config-spring/pom.xml | 1 + .../factory/annotation/ReferenceBeanBuilder.java | 9 + .../ServiceAnnotationBeanPostProcessor.java| 14 + .../dubbo/config/spring/util/AnnotationUtils.java | 20 +- .../ReferenceAnnotationBeanPostProcessorTest.java | 89 +++--- .../ServiceAnnotationBeanPostProcessorTest.java| 13 + .../context/annotation/EnableDubboConfigTest.java | 11 + .../annotation/provider/DemoServiceImpl.java | 4 +- .../DubboComponentScanRegistrarTest.java | 118 .../DubboConfigBindingRegistrarTest.java | 88 -- .../DubboConfigBindingsRegistrarTest.java | 63 - .../annotation/DubboConfigConfigurationTest.java | 99 --- .../context/annotation/EnableDubboConfigTest.java | 120 .../context/annotation/EnableDubboTest.java| 162 --- .../annotation/consumer/ConsumerConfiguration.java | 126 - .../consumer/test/TestConsumerConfiguration.java | 96 --- .../annotation/provider/DemoServiceImpl.java | 55 .../annotation/provider/ProviderConfiguration.java | 109 .../properties/DefaultDubboConfigBinderTest.java | 94 --- dubbo-config/pom.xml | 1 + .../support/nop/NopDynamicConfigurationTest.java | 70 - .../dubbo-configcenter-apollo/pom.xml | 1 + .../support/apollo/ApolloDynamicConfiguration.java | 10 +- .../dubbo-configcenter-consul/pom.xml | 3 +- .../consul/ConsulDynamicConfiguration.java | 6 +- dubbo-configcenter/dubbo-configcenter-etcd/pom.xml | 3 +- .../support/etcd/EtcdDynamicConfiguration.java | 20 +- .../dubbo-configcenter-nacos/pom.xml | 3 +- .../support/nacos/NacosDynamicConfiguration.java | 8 +- .../nacos/NacosDynamicConfigurationTest.java | 6 +- .../dubbo-configcenter-zookeeper/pom.xml | 1 + .../zookeeper/ZookeeperDynamicConfiguration.java | 84 +++--- .../ZookeeperDynamicConfigurationTest.java | 2 +- dubbo-configcenter/pom.xml | 1 + dubbo-container/dubbo-container-api/pom.xml| 1 + dubbo-container/dubbo-container-log4j/pom.xml | 1 + dubbo-container/dubbo-container-logback/pom.xml| 1 +
[dubbo] 01/04: Change how service instance is created.
This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git commit 550b40461197fbd9d1e6dc7ba5cb6ade8d7be77f Author: ken.lj AuthorDate: Thu Aug 8 16:03:27 2019 +0800 Change how service instance is created. --- dubbo-bootstrap/pom.xml| 7 ++ .../org/apache/dubbo/bootstrap/DubboBootstrap.java | 139 + .../bootstrap/DubboServiceProviderBootstrap.java | 3 +- .../wrapper/CompositeDynamicConfiguration.java | 2 +- .../apache/dubbo/config/AbstractServiceConfig.java | 2 +- .../org/apache/dubbo/config/RegistryConfig.java| 32 +++-- .../dubbo/config/builders/ConfigCenterBuilder.java | 1 - .../apache/dubbo/config/context/ConfigManager.java | 2 +- .../ConfigurableMetadataServiceExporter.java | 1 + .../dubbo/config/DubboProviderBootstrap.java | 5 +- .../org/apache/dubbo/config/mock/MockProtocol.java | 8 ++ .../apache/dubbo/config/mock/MockProtocol2.java| 8 ++ .../apache/dubbo/config/mock/MockTransporter.java | 6 +- .../src/main/resources/META-INF/compat/dubbo.xsd | 10 ++ .../src/main/resources/META-INF/dubbo.xsd | 10 ++ .../dubbo/metadata/WritableMetadataService.java| 1 + .../client/AbstractServiceDiscoveryFactory.java| 71 +++ .../EventPublishingServiceDiscoveryFactory.java| 47 --- .../registry/client/ServiceDiscoveryFactory.java | 17 +-- ...ExportedServicesRevisionMetadataCustomizer.java | 5 +- ...MetadataServiceURLParamsMetadataCustomizer.java | 5 +- .../registry/integration/RegistryProtocol.java | 6 + .../registry/support/AbstractRegistryFactory.java | 1 - .../registry/support/ServiceOrientedRegistry.java | 5 +- ...e.dubbo.registry.client.ServiceDiscoveryFactory | 1 - .../client/InMemoryServiceDiscoveryFactory.java| 4 +- .../client/ServiceDiscoveryFactoryTest.java| 55 .../registry/etcd/EtcdServiceDiscoveryFactory.java | 6 +- .../nacos/NacosServiceDiscoveryFactory.java| 5 +- .../ZookeeperServiceDiscoveryFactory.java | 5 +- .../java/org/apache/dubbo/remoting/Channel.java| 4 +- .../java/org/apache/dubbo/remoting/Endpoint.java | 2 +- .../remoting/{Server.java => RemotingServer.java} | 116 - .../org/apache/dubbo/remoting/Transporter.java | 2 +- .../org/apache/dubbo/remoting/Transporters.java| 4 +- .../dubbo/remoting/exchange/ExchangeServer.java| 4 +- .../support/header/HeaderExchangeServer.java | 8 +- .../dubbo/remoting/transport/AbstractServer.java | 8 +- .../dubbo/remoting/transport/ServerDelegate.java | 12 +- .../transport/grizzly/GrizzlyTransporter.java | 4 +- .../org/apache/dubbo/remoting/http/HttpServer.java | 3 +- .../remoting/http/support/AbstractHttpServer.java | 48 +++ .../remoting/transport/mina/MinaTransporter.java | 4 +- .../remoting/transport/netty/NettyServer.java | 4 +- .../remoting/transport/netty/NettyTransporter.java | 4 +- .../transport/netty/ClientReconnectTest.java | 8 +- .../remoting/transport/netty/NettyClientTest.java | 6 +- .../remoting/transport/netty4/NettyServer.java | 4 +- .../transport/netty4/NettyTransporter.java | 4 +- .../transport/netty4/ClientReconnectTest.java | 8 +- .../transport/netty4/NettyTransporterTest.java | 4 +- .../java/org/apache/dubbo/remoting/p2p/Peer.java | 4 +- .../exchange/support/AbstractExchangeGroup.java| 4 +- .../dubbo/remoting/p2p/support/AbstractGroup.java | 8 +- .../dubbo/remoting/p2p/support/ServerPeer.java | 4 +- .../main/java/org/apache/dubbo/rpc/Protocol.java | 9 ++ .../java/org/apache/dubbo/rpc/ProtocolServer.java | 33 +++-- .../dubbo/rpc/protocol/AbstractProtocol.java | 12 ++ .../dubbo/rpc/protocol/AbstractProxyProtocol.java | 38 ++ .../dubbo/rpc/protocol/ProtocolFilterWrapper.java | 6 + .../rpc/protocol/ProtocolListenerWrapper.java | 9 +- .../dubbo/rpc/protocol/dubbo/DubboProtocol.java| 22 ++-- .../rpc/protocol/dubbo/DubboProtocolServer.java| 62 + .../protocol/dubbo/status/ServerStatusChecker.java | 10 +- .../protocol/dubbo/telnet/PortTelnetHandler.java | 12 +- .../rpc/protocol/dubbo/support/ProtocolUtils.java | 8 +- .../rpc/protocol/hessian/HessianProtocol.java | 25 ++-- .../dubbo/rpc/protocol/http/HttpProtocol.java | 14 +-- .../rpc/protocol/jsonrpc/JsonRpcProtocol.java | 21 ++-- ...RestServer.java => BaseRestProtocolServer.java} | 2 +- .../dubbo/rpc/protocol/rest/DubboHttpServer.java | 4 +- ...ttyServer.java => NettyRestProtocolServer.java} | 6 +- .../dubbo/rpc/protocol/rest/RestProtocol.java | 16 ++- .../{RestServer.java => RestProtocolServer.java} | 4 +- .../dubbo/rpc/protocol/rest/RestServerFactory.java | 4 +-
[dubbo-admin] branch develop updated: Fix some UI bug on test module (#341)
This is an automated email from the ASF dual-hosted git repository. dlive pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-admin.git The following commit(s) were added to refs/heads/develop by this push: new a21b125 Fix some UI bug on test module (#341) a21b125 is described below commit a21b125e77fce903993dd863f7cfea8ee20e63ed Author: Rudolf AuthorDate: Fri Aug 9 10:31:35 2019 +0800 Fix some UI bug on test module (#341) 1. The service test page will throw undefined exception in console if the "service" parameter in url is null. 2. Keep the style of service test page consistent with other pages --- dubbo-admin-ui/src/components/test/ServiceTest.vue | 58 -- 1 file changed, 33 insertions(+), 25 deletions(-) diff --git a/dubbo-admin-ui/src/components/test/ServiceTest.vue b/dubbo-admin-ui/src/components/test/ServiceTest.vue index 7902526..95cff5e 100644 --- a/dubbo-admin-ui/src/components/test/ServiceTest.vue +++ b/dubbo-admin-ui/src/components/test/ServiceTest.vue @@ -20,8 +20,7 @@ - - + @@ -45,29 +44,37 @@ - - -{{$t('methods')}} - - - -{{ props.item.name }} -{{ type }} -{{ props.item.returnType }} - - - - edit - -{{$t('test')}} - - - - + + +{{$t('methods')}} + + + + + +{{ props.item.name }} + + {{ type }} + + + {{ props.item.returnType }} + + + + + edit + +{{$t('test')}} + + + + + + @@ -231,7 +238,7 @@ mounted () { this.$store.dispatch('loadServiceItems') let query = this.$route.query - this.filter = query['service'] + this.filter = query['service'] || '' if ('group' in query) { this.filter = query['group'] + '/' + this.filter } @@ -241,6 +248,7 @@ if (this.filter) { this.search(this.filter.replace('/', '*')) } + this.setHeaders() } }
[dubbo-go] branch master updated (a14701b -> f169566)
This is an automated email from the ASF dual-hosted git repository. alexstocks pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from a14701b Merge pull request #159 from fangyincheng/master new 320c0e1 remove ineffassign new 8017536 remove ineffassign new f169566 Merge pull request #160 from xujianhai666/feat-remove-ineffassign The 523 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: cluster/cluster_impl/failback_cluster_invoker.go | 2 -- cluster/cluster_impl/failsafe_cluster_invoker.go | 1 - 2 files changed, 3 deletions(-)
[dubbo] branch cloud-native updated: modify metadata
This is an automated email from the ASF dual-hosted git repository. victory pushed a commit to branch cloud-native in repository https://gitbox.apache.org/repos/asf/dubbo.git The following commit(s) were added to refs/heads/cloud-native by this push: new 4a3f8ab modify metadata 4a3f8ab is described below commit 4a3f8ab3994e34413f479cc582d13bce9b5bad61 Author: cvictory AuthorDate: Thu Aug 8 17:33:18 2019 +0800 modify metadata --- dubbo-all/pom.xml | 2 +- .../ConfigurableMetadataServiceExporter.java | 4 ++ .../dubbo/metadata/MetadataServiceExporter.java| 1 + .../dubbo/metadata/WritableMetadataService.java| 9 .../store/InMemoryWritableMetadataService.java | 57 +- .../store/RemoteWritableMetadataService.java | 18 ++- .../DefaultMetadataServiceProxyFactory.java| 42 .../metadata/MetadataServiceProxyFactory.java | 51 --- .../metadata/RefreshServiceMetadataCustomizer.java | 24 + ...dubbo.registry.client.ServiceInstanceCustomizer | 3 +- 10 files changed, 103 insertions(+), 108 deletions(-) diff --git a/dubbo-all/pom.xml b/dubbo-all/pom.xml index f9932a1..dd68787 100644 --- a/dubbo-all/pom.xml +++ b/dubbo-all/pom.xml @@ -784,7 +784,7 @@ - META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.MetadataServiceProxyFactory + META-INF/dubbo/internal/org.apache.dubbo.registry.client.metadata.proxy.MetadataServiceProxyFactory diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/metadata/ConfigurableMetadataServiceExporter.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/metadata/ConfigurableMetadataServiceExporter.java index 8806f03..6fbd33b 100644 --- a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/metadata/ConfigurableMetadataServiceExporter.java +++ b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/metadata/ConfigurableMetadataServiceExporter.java @@ -21,6 +21,7 @@ import org.apache.dubbo.common.logger.Logger; import org.apache.dubbo.common.logger.LoggerFactory; import org.apache.dubbo.config.AbstractConfig; import org.apache.dubbo.config.ApplicationConfig; +import org.apache.dubbo.config.MetadataReportConfig; import org.apache.dubbo.config.ProtocolConfig; import org.apache.dubbo.config.RegistryConfig; import org.apache.dubbo.config.ServiceConfig; @@ -28,6 +29,7 @@ import org.apache.dubbo.config.context.ConfigManager; import org.apache.dubbo.metadata.MetadataService; import org.apache.dubbo.metadata.MetadataServiceExporter; import org.apache.dubbo.metadata.WritableMetadataService; +import org.apache.dubbo.metadata.store.RemoteWritableMetadataService; import java.util.Collection; import java.util.LinkedList; @@ -55,6 +57,7 @@ public class ConfigurableMetadataServiceExporter implements MetadataServiceExpor private volatile ServiceConfig serviceConfig; private ApplicationConfig applicationConfig; +private MetadataReportConfig metadataReportConfig; private List registries = new LinkedList<>(); @@ -98,6 +101,7 @@ public class ConfigurableMetadataServiceExporter implements MetadataServiceExpor } this.serviceConfig = serviceConfig; + } else { if (logger.isWarnEnabled()) { logger.warn("The MetadataService has been exported : " + serviceConfig.getExportedUrls()); diff --git a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataServiceExporter.java b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataServiceExporter.java index 6ba99de..e256268 100644 --- a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataServiceExporter.java +++ b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataServiceExporter.java @@ -17,6 +17,7 @@ package org.apache.dubbo.metadata; import org.apache.dubbo.common.URL; +import org.apache.dubbo.common.extension.SPI; import java.util.List; diff --git a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/WritableMetadataService.java b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/WritableMetadataService.java index 0af2163..5398fc5 100644 --- a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/WritableMetadataService.java +++ b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/WritableMetadataService.java @@ -60,6 +60,15 @@ public interface WritableMetadataService extends MetadataService { boolean