[dubbo] branch 3.0 updated: metadata read & write
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.0 by this push:
new 6de9634 metadata read & write
6de9634 is described below
commit 6de9634c53452d94fad8b243e57bda6ab1b9593a
Author: ken.lj
AuthorDate: Mon Jun 15 13:41:07 2020 +0800
metadata read & write
---
.../dubbo/config/bootstrap/DubboBootstrap.java | 4 +-
.../metadata/DefaultMetadataParamsFilter.java | 3 +
.../org/apache/dubbo/metadata/MetadataInfo.java| 47 +++--
.../apache/dubbo/metadata/RevisionResolver.java| 2 +
.../dubbo/metadata/WritableMetadataService.java| 6 +-
.../org/apache/dubbo/metadata/DemoService.java | 30 ++-
.../apache/dubbo/metadata/MetadataInfoTest.java| 27 ++-
.../store/InMemoryWritableMetadataServiceTest.java | 111 ---
.../store/RemoteWritableMeatadataServiceTest.java | 190 --
.../RemoteWritableMetadataServiceDelegateTest.java | 216 -
.../registry/client/ServiceDiscoveryRegistry.java | 3 +-
...MetadataServiceURLParamsMetadataCustomizer.java | 8 +-
.../registry/client/metadata/MetadataUtils.java| 16 +-
.../metadata/ProtocolPortsMetadataCustomizer.java | 7 +-
.../metadata/RefreshServiceMetadataCustomizer.java | 47 -
.../metadata/store/RemoteMetadataServiceImpl.java | 10 +-
...g.apache.dubbo.metadata.WritableMetadataService | 1 +
...ient.metadata.proxy.MetadataServiceProxyFactory | 2 -
.../client/metadata/URLRevisionResolverTest.java | 47 -
.../registry/nacos/NacosServiceDiscovery.java | 3 +-
20 files changed, 84 insertions(+), 696 deletions(-)
diff --git
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java
index 3bdffa9..dd28b81 100644
---
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java
+++
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/bootstrap/DubboBootstrap.java
@@ -97,7 +97,7 @@ import static
org.apache.dubbo.common.constants.CommonConstants.DEFAULT_METADATA
import static
org.apache.dubbo.common.constants.CommonConstants.REMOTE_METADATA_STORAGE_TYPE;
import static org.apache.dubbo.common.function.ThrowableAction.execute;
import static org.apache.dubbo.common.utils.StringUtils.isNotEmpty;
-import static org.apache.dubbo.metadata.WritableMetadataService.getExtension;
+import static
org.apache.dubbo.metadata.WritableMetadataService.getDefaultExtension;
import static
org.apache.dubbo.registry.client.metadata.ServiceInstanceMetadataUtils.setMetadataStorageType;
import static org.apache.dubbo.remoting.Constants.CLIENT_KEY;
@@ -718,7 +718,7 @@ public class DubboBootstrap extends GenericEventListener {
*/
private void initMetadataService() {
startMetadataReport();
-this.metadataService = getExtension(getMetadataType());
+this.metadataService = getDefaultExtension();
this.metadataServiceExporter = new
ConfigurableMetadataServiceExporter(metadataService);
}
diff --git
a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/DefaultMetadataParamsFilter.java
b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/DefaultMetadataParamsFilter.java
index 7f4b85c..0563e43 100644
---
a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/DefaultMetadataParamsFilter.java
+++
b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/DefaultMetadataParamsFilter.java
@@ -16,6 +16,8 @@
*/
package org.apache.dubbo.metadata;
+import org.apache.dubbo.common.extension.Activate;
+
import static org.apache.dubbo.common.constants.CommonConstants.CLUSTER_KEY;
import static
org.apache.dubbo.common.constants.CommonConstants.DUBBO_VERSION_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.GROUP_KEY;
@@ -35,6 +37,7 @@ import static org.apache.dubbo.rpc.Constants.TOKEN_KEY;
import static org.apache.dubbo.rpc.cluster.Constants.WARMUP_KEY;
import static org.apache.dubbo.rpc.cluster.Constants.WEIGHT_KEY;
+@Activate
public class DefaultMetadataParamsFilter implements MetadataParamsFilter {
@Override
public String[] include() {
diff --git
a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataInfo.java
b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataInfo.java
index bf9aa68..01e3c09 100644
---
a/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataInfo.java
+++
b/dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/MetadataInfo.java
@@ -17,15 +17,19 @@
package org.apache.dubbo.metadata;
import org.apache.dubbo.common.U
[dubbo] branch 3.0 updated: metadata read & write
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.0 by this push:
new eea2237 metadata read & write
eea2237 is described below
commit eea22371fec47ce948956c541304ac5bd0b72dfa
Author: ken.lj
AuthorDate: Mon Jun 15 10:21:28 2020 +0800
metadata read & write
---
.../dubbo/config/AbstractInterfaceConfig.java | 2 +
.../apache/dubbo/config/context/ConfigManager.java | 8 +
.../org/apache/dubbo/config/ReferenceConfig.java | 17 +-
.../org/apache/dubbo/config/ServiceConfig.java | 14 +-
.../dubbo/config/bootstrap/DubboBootstrap.java | 35 +++-
.../metadata/DefaultMetadataParamsFilter.java | 47 +
.../org/apache/dubbo/metadata/MetadataInfo.java| 100 +
.../dubbo/metadata/MetadataParamsFilter.java} | 20 +-
.../org/apache/dubbo/metadata/MetadataService.java | 2 +
.../org/apache/dubbo/metadata/MetadataUtil.java| 49 -
.../apache/dubbo/metadata/RevisionResolver.java| 57 +
.../dubbo/metadata/WritableMetadataService.java| 14 --
.../dubbo/metadata/report/MetadataReport.java | 22 +-
.../metadata/report/MetadataReportInstance.java| 24 ++-
.../store/BaseWritableMetadataService.java | 73 ---
.../store/RemoteWritableMetadataService.java | 233 -
.../RemoteWritableMetadataServiceDelegate.java | 100 -
...g.apache.dubbo.metadata.WritableMetadataService | 2 -
.../InMemoryWritableMetadataServiceTest.java | 149 -
.../RemoteWritableMetadataServiceDelegateTest.java | 2 +-
.../registry/client/ServiceDiscoveryRegistry.java | 7 +-
.../registry/client/ServiceInstanceCustomizer.java | 3 -
.../CustomizableServiceInstanceListener.java | 42
.../listener/ServiceInstancesChangedListener.java | 26 ++-
...ExportedServicesRevisionMetadataCustomizer.java | 56 -
.../registry/client/metadata/MetadataUtils.java| 112 ++
.../metadata/ServiceInstanceMetadataUtils.java | 7 +
...bscribedServicesRevisionMetadataCustomizer.java | 57 -
.../client/metadata/URLRevisionResolver.java | 111 --
.../proxy/BaseMetadataServiceProxyFactory.java | 38
.../proxy/DefaultMetadataServiceProxyFactory.java | 85
.../proxy/MetadataServiceProxyFactory.java | 57 -
.../metadata/proxy/RemoteMetadataServiceProxy.java | 95 -
.../proxy/RemoteMetadataServiceProxyFactory.java | 34 ---
.../store/InMemoryWritableMetadataService.java | 18 +-
.../metadata/store/RemoteMetadataServiceImpl.java | 126 +++
.../registry/integration/RegistryDirectory.java| 1 +
.../internal/org.apache.dubbo.event.EventListener | 1 -
.../event/listener/LoggingEventListenerTest.java | 5 +-
.../ServiceInstancesChangedListenerTest.java | 27 ---
40 files changed, 574 insertions(+), 1304 deletions(-)
diff --git
a/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java
b/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java
index 82b5636..970a6ae 100644
---
a/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java
+++
b/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java
@@ -280,6 +280,8 @@ public abstract class AbstractInterfaceConfig extends
AbstractMethodConfig {
RegistryConfig registryConfig = new RegistryConfig();
registryConfig.refresh();
registryConfigs.add(registryConfig);
+} else {
+registryConfigs = new ArrayList<>(registryConfigs);
}
setRegistries(registryConfigs);
}
diff --git
a/dubbo-common/src/main/java/org/apache/dubbo/config/context/ConfigManager.java
b/dubbo-common/src/main/java/org/apache/dubbo/config/context/ConfigManager.java
index ed0188a..c0e4b8c 100644
---
a/dubbo-common/src/main/java/org/apache/dubbo/config/context/ConfigManager.java
+++
b/dubbo-common/src/main/java/org/apache/dubbo/config/context/ConfigManager.java
@@ -164,6 +164,14 @@ public class ConfigManager extends LifecycleAdapter
implements FrameworkExt {
return getConfigs(getTagName(MetadataReportConfig.class));
}
+public Collection getDefaultMetadataConfigs() {
+Collection defaults =
getDefaultConfigs(getConfigsMap(getTagName(MetadataReportConfig.class)));
+if (CollectionUtils.isEmpty(defaults)) {
+return getMetadataConfigs();
+}
+return defaults;
+}
+
// MetadataReportConfig correlative methods
public void addProvider(ProviderConfig providerConfig) {
diff --git
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
b/dubbo-config/dubbo-config-api/src/main/java/o
svn commit: r40036 - in /dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1: ./ dubbo-go-hessian2-v1.6.0-src.tar.gz dubbo-go-hessian2-v1.6.0-src.tar.gz.asc dubbo-go-hessian2-v1.6.0-src.tar.gz.sha512
Author: wongoo Date: Mon Jun 15 01:33:50 2020 New Revision: 40036 Log: Release dubbo-go-hessian2 v1.6.0-rc1 Added: dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/ dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz (with props) dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.asc dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.sha512 Added: dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz == Binary file - no diff available. Propchange: dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.asc == --- dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.asc (added) +++ dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.asc Mon Jun 15 01:33:50 2020 @@ -0,0 +1,17 @@ +-BEGIN PGP SIGNATURE- + +iQJGBAABCAAwFiEEE3ai/2fkxHdXOQm9fbaFUNNm5MAFAl7mz14SHHdvbmdvb0Bh +cGFjaGUub3JnAAoJEH22hVDTZuTAVR8QANzHQix/QZN28cWUqKHsc4+SVyRDVSWM +pKYmjPzCvq+IaJ/rMpHWA6BHEiAxwX4qm+Ksaq1cYiEs/Pb0MZ1jHMiFixjmgSzp +1oMRwgtGKe8Ei1NIthWorspYADsXKVqNje7V097nl6A77iwlEX1/FnpF/R86A2XS +Qgq/ghYX6iLaeM2G+fz7G5NR9EU+NBe05OJ38Xw3NxE6mFFqynUBY+Q7kQ71jcYV +IMtmw5Uc1bicg2XO1pf8PfCRpWV/E9DAkopJECELff1rof5K38qInIgP4+eZ/Cha +i0qLyRtm9kwPiRlXvTlYDikF/6dz4P5nbT8SrOlPN7GIfD1QQN+ubBj1cpm5r2xZ +6ndmdPAX2ZrRqsU+/pAowBzHOKxVIeRdFD74AE+NvtChqc0ayojzF0cb+yw71n6U +QAj4Y4DGGOSi6T5k027ZFBdziGyn7BgzegN3nDLN2bLt96cBesCWYspPQ0owvj5j +SE5UB03ACXANiKXxtOvHp7lj1GE+Lyzfnv7hxairxTnZxM2SglpFss1yewUwITOC +s5p+6vrEiVoD1pWKQDjkarwFUHyTp3/uOaSxbW7SoHdlLrJqW1N751PXU8vDKH2e +zboOxUvSTPNhX7hUD6pmkK/nob+S71z8BhdbKctBfJ/miF+JL/lg/SBd6EwKngEC +PdYLQQ0J7dRZ +=r/UQ +-END PGP SIGNATURE- Added: dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.sha512 == --- dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.sha512 (added) +++ dev/dubbo/dubbo-go-hessian2/v1.6.0-rc1/dubbo-go-hessian2-v1.6.0-src.tar.gz.sha512 Mon Jun 15 01:33:50 2020 @@ -0,0 +1 @@ +15ae7851039df52c9837d2452cce4acb4db7251dc23d5c8960917e14ce87ca20d11ef998726482d9062e80d9d40be33a973e1d2e27ba7e210f13243af1b8a172 dubbo-go-hessian2-v1.6.0-src.tar.gz
[dubbo-go-hessian2] annotated tag v1.6.0-rc1 updated (e026b32 -> 3a24151)
This is an automated email from the ASF dual-hosted git repository. wongoo pushed a change to annotated tag v1.6.0-rc1 in repository https://gitbox.apache.org/repos/asf/dubbo-go-hessian2.git. *** WARNING: tag v1.6.0-rc1 was modified! *** from e026b32 (commit) to 3a24151 (tag) tagging e026b32f47d548e1d8051ac769364aa67678df3f (commit) replaces v1.4.0-rc1 by wongoo on Mon Jun 15 09:30:33 2020 +0800 - Log - v1.6.0 release candidate 1 --- No new revisions were added by this update. Summary of changes:
[dubbo-go-hessian2] branch 1.6 updated: merge for the release of v1.6.0 (#195)
This is an automated email from the ASF dual-hosted git repository. wongoo pushed a commit to branch 1.6 in repository https://gitbox.apache.org/repos/asf/dubbo-go-hessian2.git The following commit(s) were added to refs/heads/1.6 by this push: new f8682e1 merge for the release of v1.6.0 (#195) f8682e1 is described below commit f8682e1eb9f1965da066b01454a2e94d750711ba Author: 望哥 AuthorDate: Mon Jun 15 09:07:14 2020 +0800 merge for the release of v1.6.0 (#195) * add license checker (#175) * add release note for v1.5.0 (#178) Co-authored-by: Xin.Zh * Imp: cache in reflection (#179) * benchmark result * use cache in findField * encode benchmark * call field() once * remove version * fix import sync * cache in registerPOJO * add json bench result * prune unneccessary rtype.Field(index) * cache comment * rename cache * switch to if * remove return value name * findFieldWithCache * remove if check when fieldStruct is nil Co-authored-by: 望哥 * update dependency * rename serialize arg name * Create .asf.yaml * 优化hessian解码string性能，提升54% * optimize code. * optimize code. * fix code review. * optimize codes. * optimize cods. * optimize code. * update license * go.sum * ci go version * testify -> 1.4.0 * testcase * travis.yml * decode value before reflect find * setvalue * decode nilPtr to nilPtr * fix get attachment lost nil key * manually import package * add ToMapStringString unit test * rename test function name with issue * setmap * support for decode emoji. * refactor code * add unit test. * add unit tests. * refactor tests. * Update travis/main.sh (#200) - Remove duplicate key 'webhooks' - Key 'matrix' is an alias for `jobs`, using `jobs` - Specify the os and dist explicitly * Mod: modify * Code format (#199) * .gitignore * code clean * code clean * remove length check * Fix: comments * Fix: format package * Fix #181: float32 accuracy issue (#196) * Fix #181: float32 accuracy issue * Fix go fmt failure * Add the unit test case for Issue181 * Add encFloat32 in double.go to encode float32 type - Call encFloat32 to encode float32 while encoding - Add unit test case to test float32 encoding * Improve encFloat32 of double.go * Fix git fmt failure * add release note for v1.6.0 (#202) * add release note for v1.5.1 * add release note for v1.5.1 * add notice * update notice * =fix release note for v1.6.0 Co-authored-by: Joe Zou Co-authored-by: Xin.Zh Co-authored-by: huiren Co-authored-by: Huang YunKun Co-authored-by: zonghaishang Co-authored-by: fangyincheng Co-authored-by: champly Co-authored-by: wilson chen Co-authored-by: fangyincheng Co-authored-by: gaoxinge --- .asf.yaml | 5 + .gitignore | 1 + .travis.yml| 14 +- CHANGE.md | 13 + LICENSE| 25 ++ README.md | 7 + before_validate_license.sh | 26 ++ binary_test.go | 2 - decode.go | 41 +++ decode_test.go | 1 + double.go | 33 +++ double_test.go | 27 ++ encode.go | 2 +- go.mod | 4 +- go.sum | 6 +- int_test.go| 5 +- object.go | 87 +-- object_test.go | 109 pojo.go| 5 + request.go | 5 + request_test.go| 35 +++ serialize.go | 8 +- string.go | 283 ++--- string_test.go | 37 +++ .../src/main/java/test/TestCustomDecode.java | 5 + .../src/main/java/test/TestCustomReply.java| 28 ++ test_hessian/src/main/java/test/TestString.java
[dubbo-go-hessian2] branch master updated (9cd3b94 -> 025ccae)
This is an automated email from the ASF dual-hosted git repository. wongoo pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/dubbo-go-hessian2.git. from 9cd3b94 add release note for v1.6.0 (#202) add b787792 add release note for v1.5.0 add e026b32 Merge pull request #172 from wongoo/master add 025ccae fix conflict No new revisions were added by this update. Summary of changes: CHANGE.md | 1 - 1 file changed, 1 deletion(-)
[dubbo-go] branch develop updated (b9f71f7 -> 93a655f)
This is an automated email from the ASF dual-hosted git repository. fangyc pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/dubbo-go.git. from b9f71f7 Merge pull request #582 from relaxedCat/feat-grpc-json new 078f44a add comment in all files of protocol directory new ca81e2f add comment for protocol new ef3febf add comment for jsonrpc new b5f8646 fix review comment new 57f75ee Merge branch 'develop' into feature/addProtocolComment new 93a655f Merge pull request #602 from zouyx/feature/addProtocolComment The 2190 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: protocol/dubbo/client.go | 2 +- protocol/dubbo/codec.go| 1 + protocol/dubbo/config.go | 12 ++--- protocol/dubbo/dubbo_protocol.go | 2 +- protocol/dubbo/listener.go | 37 +++--- protocol/grpc/client.go| 4 +- protocol/grpc/grpc_exporter.go | 4 +- protocol/grpc/grpc_invoker.go | 5 +- protocol/grpc/grpc_protocol.go | 12 ++--- protocol/grpc/internal/server.go | 4 +- protocol/grpc/server.go| 13 +++-- protocol/invocation.go | 13 - protocol/invocation/rpcinvocation.go | 57 ++ protocol/invoker.go| 15 +++--- protocol/jsonrpc/http.go | 10 ++-- protocol/jsonrpc/json.go | 17 --- protocol/jsonrpc/jsonrpc_exporter.go | 6 +-- protocol/jsonrpc/jsonrpc_invoker.go| 6 +-- protocol/jsonrpc/jsonrpc_protocol.go | 12 ++--- protocol/jsonrpc/server.go | 8 +-- protocol/protocol.go | 29 ++- protocol/protocolwrapper/mock_protocol_filter.go | 5 +- .../protocolwrapper/protocol_filter_wrapper.go | 8 +-- protocol/result.go | 27 ++ protocol/rpc_status.go | 32 ++-- 25 files changed, 185 insertions(+), 156 deletions(-)
[dubbo-go-hessian2] branch master updated (4eb650b -> 9cd3b94)
This is an automated email from the ASF dual-hosted git repository. wongoo pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/dubbo-go-hessian2.git. from 4eb650b Fix #181: float32 accuracy issue (#196) add 9cd3b94 add release note for v1.6.0 (#202) No new revisions were added by this update. Summary of changes: CHANGE.md | 14 ++ README.md | 7 +++ 2 files changed, 21 insertions(+)
[dubbo-go-hessian2] branch 1.6 created (now e026b32)
This is an automated email from the ASF dual-hosted git repository. wongoo pushed a change to branch 1.6 in repository https://gitbox.apache.org/repos/asf/dubbo-go-hessian2.git. at e026b32 Merge pull request #172 from wongoo/master No new revisions were added by this update.
