Commit Graph

257 Commits

Author SHA1 Message Date
caoyanan666 95f9984571
fix triple reactor call throws "Too many response for unary method" exception (#14261)
Co-authored-by: caoyanan <caoyanan@growingio.com>
2024-05-31 16:26:59 +08:00
caoyanan666 5d1c0eae1c
fix(3.2): Triple Reactor OneToMany Handler null pointer fix and DubboFilter support (#14125)
* ReactorDubbo3TripleStub.mustache add schema registry

* Triple Reactor OneToMany Handler null pointer fix and DubboFilter support

* trigger ci

* Adjust the order

* trigger ci

* ServerTripleReactorSubscriber meaningful

---------

Co-authored-by: caoyanan <caoyanan@growingio.com>
Co-authored-by: Ken Liu <ken.lj.hz@gmail.com>
2024-05-11 14:49:28 +08:00
Kaiyao Ke 8e2eb332a1
fixed non-idempotent unit tests (#14172) 2024-05-11 00:27:46 +08:00
caoyanan666 1abe9f8087
fix(3.2): The oneToOne method of the ReactorServerCalls class will cause the request to hang when the result is Mono Empty (#14121)
* Fix triple reactor request hung when result is Mono Empty

* code format

* fix compile

---------

Co-authored-by: caoyanan <caoyanan@growingio.com>
2024-05-08 14:17:18 +08:00
jean pierre Lerbscher 00812ce41c
Fix Sonar issue s2293 The diamond operator ('<>') should be used (#14005) 2024-03-29 11:40:06 +08:00
kaze 0553d70899
Add condition to match serviceKey. (#13869) 2024-03-12 17:26:18 +08:00
huazhongming 730695a7a2
[3.2]Use spotless to format the code (#13320)
* Use spotless to format the code

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

* Support develop with JDK 21

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

---------

Signed-off-by: crazyhzm <crazyhzm@gmail.com>
2023-11-07 15:40:13 +08:00
TomlongTK 1a6dbbe2ca
Judging qos is in started state when stopping qos (#13271) 2023-11-01 20:04:31 +08:00
Albumen Kevin fa11b68a16
Only throws exception when exporting service (#13217) 2023-10-18 11:52:46 +08:00
gzhao9 5d979c18f2
Refactor the test in the package org. Apache. Dubbo. Reactive. (#13175) 2023-10-10 15:52:47 +08:00
Albumen Kevin 70600eb632
Add metrics version compare (#13104) 2023-09-30 10:06:21 +08:00
Albumen Kevin 9dc5bf1944
Enhance spring security class check (#13136)
* Enhance spring security class check

* Catch exception
2023-09-29 09:44:41 +08:00
Albumen Kevin e436f1eee9
Cleanup resoruce if qos start failed (#12993) 2023-09-01 15:07:39 +08:00
Albumen Kevin 0bfd54cea4
Cleanup and throw exception if bind failed (#12987) 2023-09-01 13:03:33 +08:00
Albumen Kevin 2a5b437d58
Support check if qos server is started (#12952) 2023-08-23 19:00:07 +08:00
Albumen Kevin 85b03bca56
Support keep running on spring closed with properties (#12912)
* Support keep running on spring closed with properties

* name
2023-08-16 15:15:13 +08:00
Albumen Kevin 1dd248affa
Service offline speedup (#12869)
* Service offline speedup

* Service offline speedup
2023-08-09 17:11:16 +08:00
Albumen Kevin 2e04208405
Disable QoS as Port Unification protocol (#12813) 2023-07-29 20:46:28 +08:00
Albumen Kevin 4778d131f8
Enhance CommandContext toString (#12677)
* Enhance CommandContext toString

* Fix change
2023-07-06 14:29:13 +08:00
Albumen Kevin 85d45b959d
Check if jackson2 security dependency existed (#12568) 2023-06-19 18:56:13 +08:00
Albumen Kevin e07e5e294b
Fix get method name from invocation (#12519)
* Fix get method name from invocation

* fix compile
2023-06-13 20:25:25 +08:00
Albumen Kevin 0e77a42fa7
Update grpc version (#12441) 2023-06-01 15:04:42 +08:00
胡俊 1697a331c3
Display indicator data in KEY, VALUE format (#12273)
* metrics default.

* check style

* test fail

* metrics default update

* qos

* test

* default metrics reporter

* native image

* If no specific metrics type is configured and there is no Prometheus dependency in the dependencies.

* prometheus set

* MeterRegistry dependency check

* errorcode check fail

* CHECKSTYLE

* 1.null check
2.method replace

* default metricsreport register

* format response

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: songxiaosheng <songxiaosheng@elastic.link>
2023-05-26 15:28:07 +08:00
trytocatch c916b82ab5
clean the RpcContext in ThreadLocal after QoS invoke, synchronously get the result while async started (#12291)
* clean the context in ThreadLocal after qos invoke, and synchronously get the result while async started, so the invoke command could get the correct result instead of null

* add Thread.interrupt to the catch block

add Thread.interrupt to the catch block

* add Thread.interrupt to the catch block

add Thread.interrupt to the catch block
2023-05-11 19:07:45 +08:00
Albumen Kevin 25a08a2b40
Support offline notify (#12211)
* Support offline notify

* Add log
2023-05-02 21:25:11 +08:00
jojocodeX 69bd2639f5
Spring-security codec ignore error (#12192) 2023-04-27 11:51:19 +08:00
Albumen Kevin 1b838281a4
QoS Support anonymous command allow list (#12082)
* QoS Support anonymous command allow list

* Fix test
2023-04-19 10:13:09 +08:00
Albumen Kevin 7e3064f9b6
Deny allow (#12068)
* Deny allow

* Fix test

* Fix test

* trust metadata info

* trust hessian

* Fix compile

* Fix compile

* Fix test

* Fix test

* Fix test
2023-04-12 00:15:07 +08:00
aamingaa 718bdc1a65
feat: triple exception self (#12039)
* feat: triple exception self

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: test default

* feat: change protobuf version

* fix compile

* feat: fix equals

* feat: fix ut。。。

* feat: deserialize

* feat: remove unuse

* Revert "feat: remove unuse"

This reverts commit e72f713319.

* remove unused code

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: earthchen <earthchen@apache.org>
2023-04-11 22:56:58 +08:00
Albumen Kevin 463ec03e51 Fix compile 2023-04-11 14:29:12 +08:00
Albumen Kevin ffb28bc85e
Introduce get address command (#11682)
* Introduce get address command

* Fix import
2023-04-11 14:19:43 +08:00
KamTo Hung f05662a66d
optimize JsonUtils (#12057) 2023-04-11 11:24:55 +08:00
dependabot[bot] 9b01940d30
Bump os-maven-plugin from 1.6.2 to 1.7.1 (#12048)
Bumps [os-maven-plugin](https://github.com/trustin/os-maven-plugin) from 1.6.2 to 1.7.1.
- [Release notes](https://github.com/trustin/os-maven-plugin/releases)
- [Commits](https://github.com/trustin/os-maven-plugin/compare/os-maven-plugin-1.6.2...os-maven-plugin-1.7.1)

---
updated-dependencies:
- dependency-name: kr.motd.maven:os-maven-plugin
  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-04-10 19:13:05 +08:00
Albumen Kevin 17887768d0
Add onInitialize Support (#11962)
* Add onInitialize Support

* Fix compile
2023-04-02 14:03:30 +08:00
conghuhu 8fc267ba9b
feat: add tracing config (#11959)
* feat: add TracingConfig

* fix: fix conflict

* fix: fix enum nested error

* fix: fix unit test
2023-03-30 10:23:23 +08:00
wxbty 06605365c5
splits qos-api pkg (#11853)
* init

* add licence

* fix path name

* add api for depall

* add bom pom

---------

Co-authored-by: x-shadow-man <1494445739@qq.com>
2023-03-17 13:33:49 +08:00
Mengyang Tang d061b29b39
Some code optimization (#11825)
* Code optimization

* Code optimization: modifier optimization, condition simplification, etc.

* Fix CI error

* Fix CI error
2023-03-16 09:43:57 +08:00
wxbty 9ea6094349
Reuse qos port for metrics (#11719)
* init

* init

* reuse qos port for metrics

* reuse qos port for metrics

* fix

* fix

* add logResult

* allow all&&use exist

* remove unuse

* fix testcase

* fix testcase

* public permission level

* revert permission level

* fix

---------

Co-authored-by: x-shadow-man <1494445739@qq.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2023-03-13 17:05:57 +08:00
wxbty 5d50209404
Cert npe bug fix (#11800)
* fix npe

* fix npe

---------

Co-authored-by: x-shadow-man <1494445739@qq.com>
2023-03-13 15:44:13 +08:00
Albumen Kevin 0a9b19c306
Exact to support dynamic cert (#11578) 2023-03-08 20:11:07 +08:00
Albumen Kevin d7113006ca Merge branch 'apache-3.1' into apache-3.2 2023-03-06 19:50:19 +08:00
Mengyang Tang a21d04255a
Fix issue 11708 (#11714) 2023-03-06 15:26:15 +08:00
尔等同学 c272af38c6
Reactor some newInstance method (#11686) 2023-03-03 06:43:37 +08:00
常珂洁 5483693119
fix: remove redundancy exceptions (#11676) 2023-02-28 13:32:31 +08:00
尔等同学 7e51047cb0
delete never thrown exception (#11674) 2023-02-27 20:09:15 +08:00
Albumen Kevin c4d6f94b2c
Introduce getConfig QoS Command (#11664)
* Introduce getConfig QoS Command

* Fix NPE

* Fix NPE
2023-02-27 12:33:04 +08:00
Albumen Kevin 57c58de0ad
Fix qos command remote check (#11506)
* Fix qos command remote check

* update

* Fix NPE
2023-02-26 18:30:32 +08:00
jojocodeX 638b193c2c
dubbo-security Jackson error (#11622) 2023-02-23 15:07:38 +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 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