Commit Graph

1398 Commits

Author SHA1 Message Date
icodening df0241b6dd
fix npe (#11830)
* fix npe

* fix npe
2023-03-15 14:03:44 +08:00
earthchen 96dfd20c10
Reactor tri diy exception api (#11829)
* refactor

* fix
2023-03-15 13:14:22 +08:00
dependabot[bot] b4f8c18a1d
Bump protobuf-java from 3.22.0 to 3.22.2 (#11802)
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.22.0 to 3.22.2.
- [Release notes](https://github.com/protocolbuffers/protobuf/releases)
- [Changelog](https://github.com/protocolbuffers/protobuf/blob/main/generate_changelog.py)
- [Commits](https://github.com/protocolbuffers/protobuf/compare/v3.22.0...v3.22.2)

---
updated-dependencies:
- dependency-name: com.google.protobuf:protobuf-java
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-03-13 17:03:57 +08:00
Albumen Kevin 8e3af257b1 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-config/dubbo-config-api/src/test/java/org/apache/dubbo/config/ReferenceConfigTest.java
2023-03-10 16:54:15 +08:00
Albumen Kevin d0a1bd0143
Fix recreate client after destroy (#11780)
* Fix recreate client after destroy

* Fix uts
2023-03-10 16:25:56 +08:00
suncairong163 11f45d8726
Feature/resolve samples dependency conflict (#11705) 2023-03-09 10:40:14 +08:00
Albumen Kevin d7113006ca Merge branch 'apache-3.1' into apache-3.2 2023-03-06 19:50:19 +08:00
icodening cd3ef2a27f
tri create Http2StreamChannel async (#11698)
* tri create Http2StreamChannel async

* tri create Http2StreamChannel async

* tri create Http2StreamChannel async

---------

Co-authored-by: earthchen <earthchen1996@gmail.com>
2023-03-03 16:38:11 +08:00
尔等同学 c272af38c6
Reactor some newInstance method (#11686) 2023-03-03 06:43:37 +08:00
Mengyang Tang a293e7e7c8
Implement service-level payload (#11517) 2023-03-02 20:14:01 +08:00
常珂洁 5483693119
fix: remove redundancy exceptions (#11676) 2023-02-28 13:32:31 +08:00
Albumen Kevin 32ada2487d
Fix heartbeat failed if serialization changed (#11512)
fixes #11268
2023-02-27 20:31:00 +08:00
尔等同学 7e51047cb0
delete never thrown exception (#11674) 2023-02-27 20:09:15 +08:00
一个不知名的Java靓仔 f8f89f2a71
replaced with EN assert (#11670) 2023-02-27 14:38:57 +08:00
一个不知名的Java靓仔 4be3c796cc
optimize the multi params request performance of triple in wrap mode (#11672) 2023-02-27 14:25:39 +08:00
Albumen Kevin 7ac9949b4c Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/manager/DefaultExecutorRepository.java
2023-02-26 15:24:19 +08:00
Ken Liu 8c786cdf01
Add 'label match' support for override and tag rules (#11094) 2023-02-26 15:17:36 +08:00
earthchen 9e38c48b68
fix tri wrapper pack npe (#11656) 2023-02-25 20:12:34 +08:00
一个不知名的Java靓仔 837b9c5515
remove duplicate flowcontroller listener (#11642)
* remove duplicate flowcontroller listener

* remove duplicate flowcontroller listener
2023-02-25 18:26:47 +08:00
aamingaa 848edaa80f
Fix service name mapping check failed (#11643) 2023-02-25 17:13:44 +08:00
jojocodeX 638b193c2c
dubbo-security Jackson error (#11622) 2023-02-23 15:07:38 +08:00
Mengyang Tang c5a03c9458
Rest bugfix & optimization (#11617)
* Modifier optimize

* rawtypes problem optimize

* Remove commented redundant code

* Constants optimize

* Fix consistency bug

* Support exception mapper extension

* resolve conflict
2023-02-23 09:40:25 +08:00
dependabot[bot] b62883c177
Bump protobuf-java from 3.21.12 to 3.22.0 (#11615)
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.21.12 to 3.22.0.
- [Release notes](https://github.com/protocolbuffers/protobuf/releases)
- [Changelog](https://github.com/protocolbuffers/protobuf/blob/main/generate_changelog.py)
- [Commits](https://github.com/protocolbuffers/protobuf/compare/v3.21.12...v3.22.0)

---
updated-dependencies:
- dependency-name: com.google.protobuf:protobuf-java
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-02-22 20:09:55 +08:00
dependabot[bot] 17258a996d
Bump reactor-core from 3.5.2 to 3.5.3 (#11610)
Bumps [reactor-core](https://github.com/reactor/reactor-core) from 3.5.2 to 3.5.3.
- [Release notes](https://github.com/reactor/reactor-core/releases)
- [Commits](https://github.com/reactor/reactor-core/compare/v3.5.2...v3.5.3)

---
updated-dependencies:
- dependency-name: io.projectreactor:reactor-core
  dependency-type: direct:development
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-02-22 19:54:20 +08:00
suncairong163 02a59e2f40
3.2 consumer proxy invocation handler (#11108)
* add dubbo mvc feign client to support mvc remote call

* add dubbo mvc dispatcher servlet

* add dubbo mvc dispatcher servlet

* add   MvcDispatcherServlet  unit test

* add dubbo mvc feign client to support mvc remote call

* add dubbo mvc dispatcher servlet

* add Dubbo mvc Provider RPCInvocation create

* mvc remove unused code

* remove mvc unused test code

* remove unused code

* BodyProviderParamParser param type modify

* modify pom dependency version

* add  dubbo-metadata-api  dependency

* 新增依赖Jakarta支持 tomcat10

* ApplicationModel load  ParamParser

* ParamParser header & param map convert

* ParamParser header & param map convert

* 1 增加mvc协议
2 删除多余的resource包

* 1 增加mvc协议
2 增加netter server for http

* 重构 NettyHttpClient NettyHttpServer

* add path parse util & requestTemplate

* add mvc consumer http-connection

* mvc change  HttpConnectionPreBuildIntercept name and add SerializeBodyIntercept extend

* 1. 迁移mvc代码到rest下,合并http统一解析逻辑
2. 删除多余新增的remoting 调用模块

* 解决报错

* 1 抽象http 调用
2 改造rest调用风格

* 修改方法命名

* 修改方法名

* 删除多余的clients

* 还原restprotocol,逻辑迁移至新分支  3.2_refactor_rest_protocol

* add provider  PathMatcher

* add   ServiceRestMetadata  PathMatcher

* add   ServiceRestMetadata  PathMatcher

* add jax_rs and mvc annotation class constants

* refactor PathMatcher name

* add annotation class

* maintain rest metadata

* maintain  jax_rs and mvc annotation

* maintain  jax_rs and mvc annotation

* remove mvc module

* remove rest mvc code to code review

* add springmvc & rest annotation api module

* add springmvc & rest annotation api module

* add pathMatcher equal  test

* remove mvc module

* rest provider RPCInvocation build

* RPCInvocation build add dubbo-metadata-api dependency

* RestMethodMetadata add method to consumer service map

* RestMethodMetadata add method to consumer service map

* rest consumer HttpInvokeInvocationHandler

* rest consumer HttpInvokeInvocationHandler

* add dubbo-metadata-api dependency

* dubbo-rpc pom fix

* 移动模块

* 删除模块引用

* consumer metadata  resolve

* RestProtocol consumer

* RestProtocol consumer

* requestConvert adaptive

* JSON serializeObject to outputStream

* JsonUtilsTest  serialize & unSerialize

* ok http client

* http client reconstruct

* rest protocol BaseConvert

* rest protocol  ParamParser reconstruct

* rest protocol  addKeepAliveHeader

* requestTemplate isBodyEmpty()

* remove unused code

* create ConsumerParseContext

* body default byte[0]

* rest http message decode

* writeTextContent &  writeJsonContent & writeFormContent

* remove mvc & rest annotation module

* remove provider code

* fix some pr advice

* Add ASF license header for  newly created files

* move RestClientFactory  code  to dubbo-remoting-http

* exact  request convert code to a factory class

* modify  request convert code

* modify dubbo-dependencies-bom

* modify dubbo-remoting-http pom

* refactor spi  resource file  name

* dubbo-metadata-api remove
dubbo-configcenter-zookeeper dependency for
 cyclic reference

* newly create file add ASF

* fix compile error

* Enhance Code

* add rest protocol ConsumerParamParser

* some fix

* rest json content-type test

* RestProtocol merge doRefer code to protocolBindingRefer

* remove restInvoker

* rest protocol add JsonFactory to support custom

* rest protocol add JsonFactory to support custom

* jaxrs rest ParamNoAnnotatedProcessor  support fix

* add rest http message encode

* add rest http message encode

* rest okHttpClient requestBody fix

* rest jaxrs form content-type support

* RestProtocol protocolBindingRefer reconstruct

* RestProtocol protocolBindingRefer reconstruct  object to invoker & Invocation

* move RequestTemplate to remoting-http

* rest unit test

* add httpclient  & url connection rest client

* Enhance invocation

* enhance

* add ParameterTypesComparator  for metadataMap

* add ASF for new file

* Fix conflict

* Fix header

* fix import

* fix import

* fix import

* fix import

* fix import

* Fix json

* revert some change

* Remove jsonfactory

* Remove jsonfactory

* Simplify rest client

* Fix protocol

* fix codec

* tmp disable test

* rest metadata resolver add  interface judge

* add rest metadata  resolve unit test & fix  AbstractServiceRestMetadataResolver

* org.apache.dubbo.metadata.rest.ParamType null exclude & add default accept header

* RestProtocolTest

refer add context path
unit test

* some fix

* ADD TODO

* RESOLVE HTTP client java.net.SocketException: socket closed

* RESOLVE HTTP client java.net.SocketException: socket closed

* add spring mvc rest protocol unit test

* rest protocol http response code deal

* rest protocol http response message

* fix some review advice

* fix some review advice

* add rest metadata  resolve unit test & fix  AbstractServiceRestMetadataResolver

* org.apache.dubbo.metadata.rest.ParamType null exclude & add default accept header

* RestProtocolTest

refer add context path
unit test

* some fix

* fix some review advice

* add spring mvc rest protocol unit test

* rest protocol http response code deal

* rest protocol http response message

* URLConnectionRestClient getMessage

* remove unused import

* import fix

* code merge

* code merge

* code merge

* code merge

* code merge

* Fix conflicts

* change  restResult InputStream to bytes protect from  fd leak

* merge code

* Fix import

* Fix import

* Fix uts

* Remove unused code

* Fix logger

* Update okhttp version

* Update okhttp version

* rest protocol  add AnotherUserRestService service ut

* rest protocol  add String & byteArray codec

* Fix version

* Fix uts

* rest protocol  add XMLCodec

* stream release

* ServiceRestMetadata port change int to Integer

* service RestMetadata service map init

* xml codec change  for xxe

* Fix import

* code style

* code style

* Fix shade

---------

Co-authored-by: suncr <suncairong@moresec.cn>
Co-authored-by: Liujunjie <42363259+LiujunjieALiling@users.noreply.github.com>
Co-authored-by: junjie3.liu <junjie3.liu@ximalaya.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2023-02-22 14:02:16 +08:00
Albumen Kevin 62509fb40f Merge remote-tracking branch 'apache/3.1' into apache-3.2 2023-02-17 13:58:02 +08:00
GuoHao dc068918b3
[Triple] Fix boxed type methods (#11577)
* Fix boxed type methods

* Fix style

* Revert changes to fix it
2023-02-16 14:27:48 +08:00
Albumen Kevin 6c062586b4 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ApplicationModel.java
#	dubbo-common/src/main/java/org/apache/dubbo/rpc/model/ModuleModel.java
#	dubbo-common/src/test/java/org/apache/dubbo/rpc/model/ApplicationModelTest.java
2023-02-16 14:16:12 +08:00
Albumen Kevin 7a774d21a6 Fix conflict 2023-02-16 11:24:20 +08:00
Albumen Kevin 1dfd06b381
Fix concurrent issue in scope model (#11525) 2023-02-16 10:40:31 +08:00
Albumen Kevin 988768e589 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/config/AbstractConfig.java
#	dubbo-common/src/test/java/org/apache/dubbo/common/utils/JsonUtilsTest.java
#	dubbo-config/dubbo-config-api/src/test/java/org/apache/dubbo/config/ServiceConfigTest.java
#	dubbo-metadata/dubbo-metadata-api/src/main/java/org/apache/dubbo/metadata/ServiceNameMapping.java
#	dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/ProfilerServerFilter.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java
2023-02-16 10:09:10 +08:00
Albumen Kevin ee26eb865d
Set timeout value to string (#11565)
* Set timeout value to string

* Fix in AbstractInvoker

* Fix timeout

* Exact code

* Exact code
2023-02-15 16:52:45 +08:00
huazhongming 59a62a66b2
Revert clear response operation of timeoutfilter (#11562)
* revert clear response operation of timeoutfilter

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* remove useless import

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

---------

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2023-02-15 13:36:01 +08:00
aamingaa e78a0b05e6
feat: fix oom (#11571) 2023-02-15 10:29:29 +08:00
earthchen 502b4c86df
Tri grpc compatibility (#11544) 2023-02-13 21:16:52 +08:00
Mengyang Tang 0eb0e01b39
Modifier optimization, add 'final' modifier. (#11503) 2023-02-10 15:31:32 +08:00
Albumen Kevin 90ae7524c0 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-dependencies-bom/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper-curator5/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper/pom.xml
#	pom.xml
2023-02-06 17:44:17 +08:00
Albumen Kevin 63e5bc0033 Merge branch '3.1.6-release' into apache-3.1 2023-02-06 17:41:37 +08:00
earthchen 0489702e1c
Fix tri future (#11455)
* fix tri return future

* fix ut

* fix npe

* fix sonar
2023-02-06 17:29:06 +08:00
一个不知名的Java靓仔 c0b257adac
issue #11458:Triple stub support async mode (#11464)
* issue #11458:Triple stub support async mode

* issue 11458:Triple stub support async mode

* issue 11458:Triple stub support async mode
2023-02-06 17:28:49 +08:00
dependabot[bot] 9f0c57965b
Bump reactor-core from 3.4.19 to 3.5.2 (#11470)
Bumps [reactor-core](https://github.com/reactor/reactor-core) from 3.4.19 to 3.5.2.
- [Release notes](https://github.com/reactor/reactor-core/releases)
- [Commits](https://github.com/reactor/reactor-core/compare/v3.4.19...v3.5.2)

---
updated-dependencies:
- dependency-name: io.projectreactor:reactor-core
  dependency-type: direct:development
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-02-06 17:27:09 +08:00
一个不知名的Java靓仔 c79ed3bf04
optimized sync on channel write (#11440) 2023-02-03 15:11:57 +08:00
Albumen Kevin c44873e9b2 Fix Class Check 2023-02-03 11:49:33 +08:00
Albumen Kevin 6154b1de0b
Enhance check (#11450) 2023-02-03 10:57:08 +08:00
Albumen Kevin 548db9861f Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/config/ApplicationConfig.java
2023-02-03 09:10:44 +08:00
Albumen Kevin 47f7419d56
Fix classname (#11444) 2023-02-02 16:15:47 +08:00
Albumen Kevin c71a05a58c
Enhance Check (#11419) 2023-02-01 16:33:20 +08:00
Albumen Kevin cbcbac9ce6
Introduce Invocation#getInvokedInvokers to get invokers for ClusterFilter (#11359) 2023-01-20 14:01:14 +08:00
mxsm d2eb0ef458
[ISSUE #11294] Optimize ConcurrentHashMap#computeIfAbsent have performance problem in jdk1.8 (#11326) 2023-01-19 23:07:12 +08:00
dependabot[bot] 4836bf7919
Bump protobuf-java from 3.19.6 to 3.21.12 (#11356)
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.19.6 to 3.21.12.
- [Release notes](https://github.com/protocolbuffers/protobuf/releases)
- [Changelog](https://github.com/protocolbuffers/protobuf/blob/main/generate_changelog.py)
- [Commits](https://github.com/protocolbuffers/protobuf/compare/v3.19.6...v3.21.12)

---
updated-dependencies:
- dependency-name: com.google.protobuf:protobuf-java
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-01-19 22:48:56 +08:00
Albumen Kevin 52c4b95466 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ReflectionPackableMethod.java
2023-01-17 11:19:04 +08:00
Albumen Kevin b6c5a26606
Enhance class forname in triple (#11316) 2023-01-17 11:17:34 +08:00
earthchen d5e9c58846
change class loader (#11312) 2023-01-17 11:17:27 +08:00
earthchen 8cc353962f
Serialization and deserialization use classes in the wrapper (#11302) 2023-01-17 11:13:07 +08:00
Albumen Kevin 40827037e1 Fix conflicts 2023-01-12 20:13:57 +08:00
Albumen Kevin c2e5438a43 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboInvoker.java
#	dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ReflectionPackableMethod.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleInvoker.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleProtocol.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/TripleClientCall.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/AbstractStream.java
2023-01-12 19:48:07 +08:00
huazhongming 7a5680b559
Fix countdown assignment problem (#11275) 2023-01-12 17:32:55 +08:00
earthchen fe50ac5d79
Remove grpc-status-details when no pb exists (#11249)
* remove pb status

* fix

* fix

* fix

* fix
2023-01-12 14:54:33 +08:00
earthchen 9b2b71f022
Fix issue 11161 (#11187)
* fix DefaultMultipleSerialization

* fix DefaultMultipleSerialization

* fix error

* fix error

* fix
2023-01-12 14:48:53 +08:00
dependabot[bot] 7c305bbb68
Bump protobuf-java from 3.18.3 to 3.19.6 in /dubbo-rpc/dubbo-rpc-triple (#11282)
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.18.3 to 3.19.6.
- [Release notes](https://github.com/protocolbuffers/protobuf/releases)
- [Changelog](https://github.com/protocolbuffers/protobuf/blob/main/generate_changelog.py)
- [Commits](https://github.com/protocolbuffers/protobuf/compare/v3.18.3...v3.19.6)

---
updated-dependencies:
- dependency-name: com.google.protobuf:protobuf-java
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-01-12 07:51:41 +08:00
Albumen Kevin a278feb372 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/config/ApplicationConfig.java
#	dubbo-config/dubbo-config-spring/src/main/resources/META-INF/dubbo.xsd
#	dubbo-registry/dubbo-registry-nacos/src/main/java/org/apache/dubbo/registry/nacos/NacosNamingServiceWrapper.java
#	dubbo-registry/dubbo-registry-nacos/src/main/java/org/apache/dubbo/registry/nacos/NacosServiceDiscovery.java
#	dubbo-registry/dubbo-registry-nacos/src/main/java/org/apache/dubbo/registry/nacos/util/NacosNamingServiceUtils.java
#	dubbo-registry/dubbo-registry-nacos/src/test/java/org/apache/dubbo/registry/nacos/NacosNamingServiceWrapperTest.java
#	dubbo-registry/dubbo-registry-nacos/src/test/java/org/apache/dubbo/registry/nacos/NacosRegistryTest.java
2023-01-11 15:05:01 +08:00
Albumen Kevin 84c1c35aae
Add serialization check (#11217) 2023-01-11 11:41:52 +08:00
Albumen Kevin 3d64f1192d
Update protobuf-java version in both dependency and plugin (#11261) 2023-01-10 14:13:12 +08:00
Albumen Kevin b8ea46d038 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/DefaultCommandExecutor.java
#	dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/ConnectionHandler.java
#	dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/AbstractServer.java
2023-01-04 17:36:49 +08:00
Andy Cheung 34168e6d0e
Merge error code 3-3 to 3-8, 6-4 to 99-0. (#11225)
* Replace LoggerCodeConstants.java with 3.2 branch.

* Add hints in the constant file.

* Add hints in the constant file. (2)

* Merge 3-3 to 3-8.

* 6-4 -> 99-0.

* 6-4 -> 99-0.

* 6-4 -> 99-0.

* 6-4 -> 99-0. (4)

* 6-4 -> 99-0. (5, Compatible)

* Change AbstractH2TransportListener's error code per @EarthChen's request.
2023-01-03 15:03:55 +08:00
earthchen 2765deb98d
fix tri upper error (#11214)
* fix error

* fix

* fix

* fix

* fix

* fix
2022-12-31 13:41:31 +08:00
ShenFeng312 854d85953d
fix #11033 (#11144) 2022-12-30 16:27:16 +08:00
Albumen Kevin 3375f727e1 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	.github/workflows/build-and-test-pr.yml
#	dubbo-common/src/main/java/org/apache/dubbo/common/constants/LoggerCodeConstants.java
2022-12-30 15:53:09 +08:00
Andy Cheung 2c6a933d3a
Change some test-related error code to a separate series. (#11219)
* Revert changes in FailsafeLoggerTest.

* COMMON_FAILED_REFLECT -> COMMON_REFLECTIVE_OPERATION_FAILED. Add 81-1.

* 1-25 -> 81-2.

* 1-23 / 5-19 -> 81-3 / 81-4.
2022-12-30 15:50:42 +08:00
Albumen Kevin 0e4997b252 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/main/java/org/apache/dubbo/common/constants/LoggerCodeConstants.java
#	dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
#	dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/event/listener/ServiceInstancesChangedListener.java
#	dubbo-rpc/dubbo-rpc-api/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.rpc.Filter
2022-12-29 17:33:02 +08:00
Albumen Kevin 58131051c3
Fix active limit filter not work (#11206) 2022-12-26 20:36:24 +08:00
Albumen Kevin 2a7dd3dc29
Fix error code in 3.2 branch (#11199)
* Fix error code in 3.2 branch

* Fix error code in 3.2 branch
2022-12-25 20:33:15 +08:00
Albumen Kevin 0df34a1a20
Remove ExtensionLoader getExtension usage (#10971) 2022-12-22 10:02:22 +08:00
Albumen Kevin eba39fd65b Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/support/CacheableFailbackRegistry.java
2022-12-21 23:25:53 +08:00
Andy Cheung 1bfd354d3d
Change constant name of error code 0-2, merge 4-19 to 0-2. Add error code of 'port is overridden' hint. (#11181)
* Change 4-19 to 0-2 (same actually).

* Use error code 4-19.

* Add cause.
2022-12-21 23:14:29 +08:00
一个不知名的Java靓仔 3c103d40cd
issue 5900:add bytebuddy support (#11117)
* issue 5900:add bytebuddy support

* remove unused import

* edit comment

* rename CompositeMethodInvoker

* add unit test

* fix ut
2022-12-20 23:38:08 +08:00
Albumen Kevin 80a15197e6 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DecodeableRpcInvocation.java
2022-12-16 12:56:56 +08:00
Albumen Kevin 705b327885
Revert #10839, #11082 and #11086 (#11160) 2022-12-16 12:53:22 +08:00
earthchen 5fdc88d09e
Fix tri convert upper header (#11075) 2022-12-16 11:06:00 +08:00
Albumen Kevin e40edb7081 Fix import 2022-12-15 20:20:41 +08:00
Albumen Kevin 6682df3772 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/Constants.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ReflectionPackableMethod.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleProtocol.java
2022-12-15 20:16:16 +08:00
earthchen 342e4f5bb6
fix tri filter onError (#11133)
* fix tri filter onError

* fix tri filter onError

* fix tri filter onError

* fix ut
2022-12-14 21:34:56 +08:00
Starfish-Ning d17160591c
Adaptive loadbalance (#10745) 2022-12-13 16:32:49 +08:00
wlazjr c768ad8f13
[DUBBO-11047][issue]Remove direct dependency of protobuf-java (#11084)
* replace protobuf depency in triple rpc with customer encoding/decoding

* fix tripleRequestWrapper may has no args then throw npe

* 1 Set BuiltinService to disable by default
2 make protobuf-java provided

* 1 fix triBuiltinServiceTest ut

Co-authored-by: 伴农 <tony.wl@alibaba-inc.com>
2022-12-12 20:41:00 +08:00
Albumen Kevin ab10b8a189 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/deploy/DefaultApplicationDeployer.java
2022-12-12 16:24:01 +08:00
huazhongming e3ee0cc689
Fix TimeoutCountDown objects being passed through and support for method-level configuration of cut-off timeout-count (#11120)
* fix timout-countdown being passed

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* timeout-countdown supports method level shutdown capability

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix triple invoker test

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-12-12 16:03:12 +08:00
Albumen Kevin 9508acdbd8
Fix triple default version (#11068) 2022-12-12 15:34:17 +08:00
shanuo ee9a3d53d4
ssl abstract and remoteapi remove netty (#11099) 2022-12-12 14:35:13 +08:00
Albumen Kevin 20a4444fbe
Fix flow controller trigger application init (#11112) 2022-12-11 09:26:09 +08:00
Albumen Kevin 5c082eaefa Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-native/src/main/java/org/apache/dubbo/remoting/api/pu/PortUnificationTransporter$Adaptive.java
#	dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DecodeableRpcInvocation.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/AbstractServerCallListener.java
2022-12-08 17:44:11 +08:00
earthchen 7cccc4f193
opt some tri code (#11079)
* opt some code

* remove unused if

* fix npe
2022-12-07 20:11:15 +08:00
huazhongming a795ff73df
Get system properties from context (#11082) 2022-12-06 15:45:45 +08:00
Albumen Kevin 0d2cab47c9
Enhance isolate executor (#11069) 2022-12-06 09:58:27 +08:00
huazhongming 1470c7ca1e
Cache jvm system parameters to prevent each call from being executed, affecting performance (#10839)
* Cache jvm system parameters to prevent each call from being executed, affecting performance

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix npe

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* optimization performance

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* remove unused import

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* add default config value

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* change getProperty method

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* change convert method

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* change getInternalProperty by default value

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* add overwrite cache api

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* add clear cache api

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix ut

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix ut

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix ut

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* reset DubboBootstrap

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* change serialization.security.check config to app scopemodel

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix url without scopemodel

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

* fix url without scopemodel

Signed-off-by: crazyhzm <crazyhzm@gmail.com>

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-12-05 15:37:33 +08:00
Andy Cheung 2f55e72ac9
Add error code support of ListenerInvokerWrapper. (#11065) 2022-12-05 11:07:21 +08:00
gold-fisher 3c68e9476e
Fixes #11044,solve remoteApplicationName is null, in mesh mode with t… (#11058)
* Fixes #11044,solve remoteApplicationName is null, in mesh mode with triple protocol.
2022-12-01 18:07:42 +08:00
Albumen Kevin 8c61f9b225 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-dependencies-bom/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper-curator5/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper/pom.xml
#	pom.xml
2022-11-29 20:42:33 +08:00
cnjxzhao d07d89159f
Error code is managed with constants (#10771) (#11054) 2022-11-29 20:36:07 +08:00
huazhongming 4568958ef5
Adjust the logic of timeout, fix triple about timeout countdown function problem (#11030)
Signed-off-by: crazyhzm <crazyhzm@gmail.com>

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-11-28 16:56:31 +08:00
Albumen Kevin 4de9672008 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	.licenserc.yaml
#	dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/AbstractAnnotationBeanPostProcessor.java
#	dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ReferenceAnnotationBeanPostProcessor.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java
2022-11-28 14:24:34 +08:00
xin gu b67db81e2e
client flowcontrol (#11029) 2022-11-28 14:20:19 +08:00
cnjxzhao 791918c471
Error code is managed with constants (#10771) (#11016) 2022-11-25 17:34:38 +08:00
Albumen Kevin 1efe576197 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-common/src/test/java/org/apache/dubbo/common/utils/JsonUtilsTest.java
#	dubbo-registry/dubbo-registry-api/src/test/java/org/apache/dubbo/registry/client/migration/model/MigrationRuleTest.java
#	dubbo-remoting/dubbo-remoting-api/src/test/java/org/apache/dubbo/remoting/api/ConnectionTest.java
#	dubbo-remoting/dubbo-remoting-api/src/test/java/org/apache/dubbo/remoting/api/MultiplexProtocolConnectionManagerTest.java
#	dubbo-remoting/dubbo-remoting-api/src/test/java/org/apache/dubbo/remoting/api/SingleProtocolConnectionManagerTest.java
#	dubbo-remoting/dubbo-remoting-netty4/src/test/java/org/apache/dubbo/remoting/transport/netty4/NettyChannelTest.java
#	dubbo-remoting/dubbo-remoting-netty4/src/test/java/org/apache/dubbo/remoting/transport/netty4/PortUnificationExchangerTest.java
#	dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleInvokerTest.java
#	dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/transport/WriteQueueTest.java
2022-11-22 14:23:29 +08:00
conghuhu 734c9c3f4a
feat: decoupling WireProtocol by netty (#10976) 2022-11-22 11:27:08 +08:00
Albumen Kevin 38e47c2e54
Remove public modifier in dubbo-rpc (#10982) 2022-11-22 10:46:52 +08:00
Albumen Kevin 9d4cb1a59d Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmInvoker.java
2022-11-21 11:33:52 +08:00
Albumen Kevin ae0a371690 Merge branch 'apache-3.0' into apache-3.1 2022-11-21 11:31:37 +08:00
Albumen Kevin bfce75cf66 Revert "Revert "Local references support mergeable (#9645)" (#10707)"
This reverts commit 67d94aea58.
2022-11-21 11:31:29 +08:00
Albumen Kevin 67d94aea58 Revert "Local references support mergeable (#9645)" (#10707)
This reverts commit 72326f42ba.
2022-11-21 11:27:26 +08:00
conghuhu 285d70c26a
feat: Client decoupling of Connection and Netty (#10819) 2022-11-16 10:55:37 +08:00
Albumen Kevin 046bb88d2f Merge branch 'apache-3.1' into apache-3.2 2022-11-15 14:22:01 +08:00
Albumen Kevin 83bccc8b03
Revert #8755 (#10938) 2022-11-15 10:37:40 +08:00
aamingaa ee9d01a6e0
feat: split rpcContext (#10798) 2022-11-10 20:56:26 +08:00
Albumen Kevin 5283f147d6 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-dependencies-bom/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper-curator5/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper/pom.xml
#	pom.xml
2022-11-10 15:09:37 +08:00
Albumen Kevin bb53fde978
Add dependencies check (#10896) 2022-11-08 18:48:48 +08:00
灼华 86e2eb2de9
Fix RpcUtils#getParameterTypes and AccessLogFilter#renameFile method (#10881) 2022-11-08 13:56:36 +08:00
Albumen Kevin 305d290e5f
Fix dubbo get wrong return type when generic impl invoke (#10891) 2022-11-08 11:34:05 +08:00
Albumen Kevin e1f3e63ee6 Merge remote-tracking branch 'apache/3.2' into apache-3.2
# Conflicts:
#	dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyChannel.java
#	dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DecodeableRpcInvocation.java
2022-11-07 17:40:41 +08:00
Albumen Kevin 71b9f6aa06 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/filter/FilterChainBuilder.java
#	dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/MergeableClusterInvoker.java
#	dubbo-common/src/main/java/org/apache/dubbo/common/constants/LoggerCodeConstants.java
#	dubbo-common/src/main/java/org/apache/dubbo/config/ApplicationConfig.java
#	dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/deploy/DefaultApplicationDeployer.java
#	dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/metadata/ConfigurableMetadataServiceExporter.java
#	dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/CodecSupport.java
#	dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/CompatibleFilter.java
#	dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AbstractInvoker.java
#	dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DecodeableRpcResult.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/TripleClientCall.java
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2FrameServerHandler.java
#	dubbo-xds/src/main/java/org/apache/dubbo/registry/xds/istio/IstioEnv.java
2022-11-07 17:40:15 +08:00
earthchen dce55071c7
change tri support upper attachment config to enable by default (#10883) 2022-11-07 16:25:45 +08:00
earthchen 0876d8af1b
Remove `netty-all` dependency (#10818) 2022-11-07 16:15:16 +08:00
一个不知名的Java靓仔 5016f550be
support encode in user thread, optimize decode in user thread (#10854) 2022-11-04 08:28:23 +08:00
cnjxzhao 8acf34d8e3
3.1-Error code is managed with constants (#10771) (#10843) 2022-11-01 07:52:17 +08:00
灼华 c96a3a1af2
Provider supports thread pool isolation between services (#10658) 2022-10-27 17:23:00 +08:00
cnjxzhao 6ed4cc2457
3.1-Error code is managed with constants (#10771) (#10837) 2022-10-27 10:40:13 +08:00
cnjxzhao 6f35df41b5
Error code is managed with constants (#10771) (#10830) 2022-10-26 10:26:46 +08:00
Andy Cheung 393ea1d7e2
Fix assertion error and class cast exception in unit tests. (#10825) 2022-10-26 10:20:48 +08:00
一个不知名的Java靓仔 83f4ad8bfa
encode supports multi message (#10794) 2022-10-25 10:58:54 +08:00
Albumen Kevin c35e82d084 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	.github/workflows/build-and-test-3.1.yml
#	.github/workflows/build-and-test-3.2.yml
#	.github/workflows/build-and-test-scheduled-3.2.yml
#	dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java
2022-10-22 15:54:13 +08:00
一个不知名的Java靓仔 4310ea8bda
issue 10558: optimize performance for triple protocol(3.2) (#10587) 2022-10-22 15:37:51 +08:00
earthchen f37502c005
triple support upper header key (#10761)
* tri support un lower header

* change config only one

* fix ut

* revert format

* revert format

* refactor

* ci
2022-10-21 13:59:33 +08:00
aamingaa 6350b907e5
feat: self define exception (#10667) 2022-10-19 17:44:14 +08:00
huazhongming a66f512674
Should not continue sending requests when it has timed out (#10741)
Signed-off-by: crazyhzm <crazyhzm@gmail.com>

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-10-13 10:43:26 +08:00
Albumen Kevin 898d2996bf
Fix getUrl NPE after setInvokers (#10738) 2022-10-13 10:07:12 +08:00
Albumen Kevin 15f4a7d7cb
Revert "Local references support mergeable (#9645)" (#10707)
This reverts commit 72326f42ba.
2022-10-09 09:08:10 +08:00
XS f2cee0ab89
Enable consumers to request service providers by priority … (#10533)
*  Enable consumers to request service providers by priority using the appropriate serialization type

* ✏️ Fixing PR specification

* ✏️ Optimization of import

* 🎉 Optimization of import and comment

* 🎉 Optimization of import

* 🎉 Optimization of import

* 🎉 fix Junit

* 🎉 Default prefer serialization is `hessian2`

* fix comment
2022-10-08 11:23:01 +08:00
Albumen Kevin 37636f4b35 Merge branch 'apache-3.0' into apache-3.1
# Conflicts:
#	dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/BroadcastClusterInvoker.java
#	dubbo-registry/dubbo-registry-nacos/src/main/java/org/apache/dubbo/registry/nacos/NacosRegistry.java
2022-09-20 15:31:21 +08:00
huazhongming 37b205bd11
fix timeout type cast exception (#10644)
Signed-off-by: crazyhzm <crazyhzm@gmail.com>

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-09-20 15:27:22 +08:00
Albumen Kevin 8f7d1f37ec
Fix ContextFilter not cleanup thread (#10615) 2022-09-19 15:11:51 +08:00
TrueAbc ddd1786578
add dubbo protocol to pu server and port reuse (#10602)
* enable dubbo protocol to use pu server

* wire protocol returns protocol name

* delete default channel group

* export extra protocol

* add url mapper and handler mapper to pu server

* fix ci

* adjust some changes

* default value for url and handler in pu server

* get protocol name using extension loader

* naming readability and code annotations

* ext-protocols change to a multiProtocol string with comma split

* fix ci

* method rename

* don't use pu server by default

* rename method
2022-09-19 14:38:40 +08:00
Kunshuai Zhu 81fe206b42
Move reactive-triple to a stand-alone module (#10605)
* Remove reactive-triple to a stand-alone module

* fix

* move dependency to dubbo-dependencies-bom

* move to dubbo-plugin
2022-09-14 15:57:11 +08:00
qinliujie cd7b7590ac
Ipv6 Support (#10603) 2022-09-14 14:15:19 +08:00
huazhongming 72326f42ba
Local references support mergeable (#9645)
Fix https://github.com/apache/dubbo/issues/8777
2022-09-08 10:08:33 +08:00
Codegass 0b2470286c
Refactoring app response test with JUnit Assume (#10537)
* Remove unused import

* Introduce Junit5 Assume functions to replace the if-return precondition check, FIX #10487

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2022-09-03 14:40:25 +08:00
Albumen Kevin 4579d74218
Remove unused import 2022-09-02 11:15:02 +08:00
Albumen Kevin f35c8d120f
Remove unused import 2022-09-02 11:14:44 +08:00
Albumen Kevin 12f67868a9 Merge branch 'apache-3.0' into apache-3.1 2022-09-02 11:07:47 +08:00
Albumen Kevin af0d2d2b58
Remove useless toString in Timeout Filter (#10530) 2022-09-02 11:03:24 +08:00
Albumen Kevin c90f8700e2
Remove useless toString in Timeout Filter (#10529) 2022-09-02 11:00:53 +08:00
灼华 1630c6d00c
Optimization for reusing existing logic (#10508)
* Optimization for reusing existing logic

* Delele MultiInstanceActivateComparator.java
2022-08-28 10:16:56 +08:00
灼华 f7e87c1445
Add some test cases and optimizations (#10481)
* Add some test cases and optimizations

* Rollback

* Update ClassGenerator.java
2022-08-24 10:34:16 +08:00
Albumen Kevin 6fdc6a5aa9 Merge branch 'apache-3.0' into apache-3.1
# Conflicts:
#	dubbo-dependencies-bom/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper-curator5/pom.xml
#	dubbo-dependencies/dubbo-dependencies-zookeeper/pom.xml
#	pom.xml
2022-08-23 10:17:53 +08:00
FUNKYE a7ced36999
optimize AccessLogFilter (#10488) 2022-08-22 16:08:38 +08:00
Kunshuai Zhu e069a7af9e
Support dubbo reactive stream with project reactor (#10290)
* Support dubbo reactive stream with project reactor

* basically successfully connected

* Solve NPE in first calling CallStreamObserver#request(int)

* Polish code, add comment and license

* Optimize dependency configuration

* Add manyToMany and oneToOne

* Add manyToOne

* Add ReactorDubbo3TripleGenerator

* remove unnecessary commits

* Add lisence header

* Add comment

* remove unused import

* fix npe in TripleInvoker

* Optimize manyToOne

* Polish

* polish

* Fix reduce opration

* Add unit test

* Refactor TripleInvoker#invokeUnary to use UnaryClientCallListener

* merge CancelableStreamObserver and ClientResponseObserver

* discard repeated subscribe silently

* remove AtomicReferenceFieldUpdater

* remove unused volatile

* polish

* polish

* move SafeRequestStreamObserver to CancelableStreamObserver

* remove SafeRequestObserver

* set onStartConsumer empty defultly

* Fix unexpected invoke before subscribe in oneToMany & manyToOne
2022-08-15 10:44:48 +08:00
liufeiyu1002 e528bca7e5
fix GenericFilter get generic value (#10456) 2022-08-14 21:12:00 +08:00
Albumen Kevin 56721482ca Merge branch 'apache-3.0' into apache-3.1 2022-08-14 10:49:45 +08:00
Andy Cheung 213944c03e
Add code that shows error code 2-2, 1-9, 5-1 with code optimization. (#10452)
* Optimize javadoc in Protocol.

* Optimize javadoc in Protocol.

* Add error 2-2 in ReferenceConfig.

* Add error code 5-1 in CuratorZookeeperClient and Curator5ZookeeperClient.

* Optimize Javadoc of ZookeeperClient.

* Forbids the instantiation and optimize comments of UrlUtils.

* Fix typo in FrameworkExecutorRepository.

* Throw created illegalStateException instead of throwing a new one.

* Add error code 1-9 constructor of AbstractRegistry.

* Optimize comments and modifiers.

* Optimize appearance of error code 1-9.
2022-08-14 10:40:44 +08:00
stone lion 4d0f9f4f48
refactor: inspect protocol classes (#10444) 2022-08-12 14:38:15 +08:00
Albumen Kevin 88a568ef7a Merge branch 'apache-3.0' into apache-3.1 2022-08-11 17:07:02 +08:00
Albumen Kevin f66527a73a
Remove to rpcInvocation string (#10441) 2022-08-11 11:54:57 +08:00
yshuoo f5c5dfd2ff
fix issue 10425 (#10432)
Co-authored-by: keshi.ys <keshi.ys@alibaba-inc.com>
2022-08-10 10:05:02 +08:00
Albumen Kevin 61d7389603 Merge branch 'apache-3.0' into apache-3.1 2022-08-09 09:58:20 +08:00
Albumen Kevin ed73fdeed0
Fix triple unexport remove (#10417) 2022-08-09 09:55:47 +08:00
Kunshuai Zhu beeca4a4ab
Abstract the disableAutoFlowControl method of CallStreamObserver (#10406)
* Abstract the disableAutoFlowControl method of CallStreamObserver

* Abstract the disableAutoFlowControl method of CallStreamObserver
2022-08-04 20:24:53 +08:00
Kunshuai Zhu 16fc7b55ef
Remove processing streamObserver in TripleInvoker#invokeUnary (#10398)
* Remove processing streamObserver in TripleInvoker#invokeUnary

* remove unaryCall with streamObserver in StubInvocationUtil

* add Compatible with unaryCall

* add unit test
2022-08-03 14:08:40 +08:00
stone lion 469a0b3c63
refactor: inspect code of protocol classes. (#10390)
* refactor: inspect code of protocol classes.

* refactor: inspect code of protocol classes.
2022-08-01 14:33:02 +08:00
TrueAbc 63848bed74
make configServerPipeline independent (#10361)
* make configServerPipeline independent

* fix comments

* fix comments(trigger workflow)

* comments fix(default codec)

* remove useless if statement

* case test url have null side

* adjust logic of Operator load codec2
2022-08-01 10:50:51 +08:00
Albumen Kevin 73bfa6a61f Merge branch 'apache-3.0' into apache-3.1 2022-08-01 09:26:38 +08:00
Owen.Cai 4195838c68
fix_delete_error_exporter (#10383) 2022-07-29 11:41:41 +08:00
earthchen 5202f87ef0
remove dubbo-compiler (#10381) 2022-07-28 15:21:32 +08:00
Andy Cheung f9eb28cf7e
Adding error code to multiple classes in multiple modules. (#10373)
* Add @Override in DubboConfigDefaultPropertyValueBeanPostProcessor

* Add error code 5-1 in config center module.

* Code optimization.
2022-07-27 17:21:39 +08:00
TrueAbc 9e6517a145
abstraction of port unification server (#10318)
* change ByteBuf parameter to ChannelBuffer

* ChannelBuffers test

* Abstract PortUnificationServer
and make it work on triple protocol

* adjust test cases

* add license to test file
and remove useless code

* resolve conversation

* fix error for CICD check

* update pom file

* comment fix

* adjust config default pu transporter

* delete unused imports

* adjust test cases

* reset SPI default value

* adjust resources file

* fix wrong resources directory
2022-07-22 11:59:40 +08:00
huazhongming 3d25a2abf8
Fix triple protocol thread name (#10342)
Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2022-07-22 09:55:40 +08:00
Albumen Kevin 393084352e Merge branch 'apache-3.0' into apache-3.1 2022-07-15 15:34:05 +08:00
Albumen Kevin f1af604e7e
Fastjson2 Support (#10166) 2022-07-15 10:18:41 +08:00
huazhongming 807fc12203
Decoupling ConfigBase and ServiceModel (#10110) 2022-07-15 09:22:47 +08:00
GuoHao d35127954d
Fix tri timeout not set (#10317) 2022-07-14 10:36:53 +08:00
earthchen 9c1630186f
[3.0-Triple] Fix duplicate wrap executor (#10293)
* fix wrap executor

* fix

* fix
2022-07-11 15:50:07 +08:00
ichenpeng 303cd6924f
interrupt thread when InterruptedException occur (#10299)
Co-authored-by: chenpeng <chenpeng@huiyu.org.cn>
2022-07-11 15:16:22 +08:00
GuoHao 47f7be2fd6
[3.0-Triple] Support reflection api (#10168)
* Add proto

* Update compiler

* Add v1Alpha for compatibility

* Abstract builtin service export

* Try add get fd by name

* get service by symbol now works

* Add type

* Support extension

* Ignore reflection code scan

* Remove v1
2022-06-29 14:19:48 +08:00
Wang Chengming c85195fc36
fix #10202, use getRemoteAddress (#10203)
Co-authored-by: 呈铭 <beck.wcm@antgroup.com>
2022-06-24 19:26:01 +08:00
Wang Chengming 7a33ddf93c
fix #10171, Code optimization (#10190)
Co-authored-by: 呈铭 <beck.wcm@antgroup.com>
2022-06-22 16:55:41 +08:00
ken.lj ab63595800
[optimization]RestProtocol opt, share client pool among services and avoid potential memory leak. (#10023)
* rest protocol client share

* rest protocol optimization

* reference count support

* check and clear
2022-06-17 14:27:46 +08:00
ken.lj 2face28201
register MetadataService as internal service (#10148)
* register MetadataService as internal service

* fix ut

* register consumer model when generating proxy for internal service

* check model type directly

* check by looking up service for model type here is not clear

* unify thread configuration
2022-06-17 14:21:32 +08:00
Albumen Kevin 675cd4bb13
[3.0] Exact json utils (#10156) 2022-06-16 14:54:31 +08:00
Albumen Kevin 89863e048d
[3.0] Add safe foreach in RpcInvocation & Revert synchronizedMap in RpcInvocation (#10160)
* revert

* [3.0] Add safe foreach in RpcInvocation & Revert synchronizedMap in RpcInvocation

* fix ut
2022-06-15 17:40:20 +08:00
huazhongming c9b6e85d03
The compiler version is the same as the trunk version (#10144) 2022-06-14 14:09:14 +08:00
earthchen 162b98f6ba
fix #10105, support serialization optimizer (#10147) 2022-06-13 18:12:54 +08:00
Wang Chengming 6d188d81df
[3.0] fix #9962, recreate RpcInvocation in BroadcastClusterInvoker (#10027) 2022-06-13 11:16:47 +08:00
Wang Chengming d9d87bdab0
fix #10078, Use synchronizedMap to avoid ConcurrentModificationException (#10139) 2022-06-13 10:43:40 +08:00
Wang Chengming 25d9daac52
[3.0] Cherry pick #9978 to 3.0 (#10040) 2022-06-10 14:26:54 +08:00
Hervé Boutemy c35b2ecd3f
use os-maven-plugin as plugin: fixes reproducible build (#10067) 2022-05-23 17:01:44 +08:00
Albumen Kevin d6e14980a5
[3.0] Support Injvm invoke server async (#10026)
* [3.0] Support Injvm invoke server async

* add timeout support

* return async
2022-05-12 13:57:18 +08:00
earthchen b4bc7aaa66
[3.0-Triple] fix tri TheadPool is default (#10019) 2022-05-10 10:46:28 +08:00
ken.lj 5880b02095
[3.0] 'com.alibaba.dubbo' package compatibility (#9993)
fixes #9977
2022-05-07 17:46:35 +08:00
ken.lj 81bad75b7b
fix getAttachment, return default value (#10008) 2022-05-07 14:39:41 +08:00
GuoHao bce439e6a3
Fix hessian4 (#9981) 2022-04-29 18:47:09 +08:00
Albumen Kevin f5e9d03663
[3.0] Clear ThreadLocal before injvm invoke (#9946) 2022-04-20 17:53:53 +08:00
Wang Chengming 95378db853
[3.0] tri support Bzip2 (#9945)
* tri support Bzip2

* add bom inherit

* add bom inherit

* fix conflict

Co-authored-by: 呈铭 <beck.wcm@antgroup.com>
2022-04-20 17:12:16 +08:00
Albumen Kevin 81ac64d7b6
[3.0] Fix some context related issues (#9923) 2022-04-20 16:44:59 +08:00