Commit Graph

785 Commits

Author SHA1 Message Date
aofall 473ea36b04
fix: Support close the Curator EnsembleTracker (#14281) 2024-06-04 12:54:44 +08:00
Kaiyao Ke 8e2eb332a1
fixed non-idempotent unit tests (#14172) 2024-05-11 00:27:46 +08:00
hanpen24 9d659eba44
Fix channel leakage in onConnected and onGoaway methods (#14100) 2024-05-08 11:36:08 +08:00
YuLuo a3e43fe99b
optimise: create http client by connection pool (#14079) 2024-05-08 11:19:49 +08:00
hanpen24 f03823eec1
Use ExecutorService instead of event loop for Netty connection (#13904)
* Use ExecutorService instead of event loop for Netty connection

This change addresses the issue of the event loop being blocked for an extended period, improving overall performance and responsiveness.

* fix log getConnectAddress

* applay format

* applay format

* applay format

* applay format

* applay format

* Use an independent ExecutorService

* Use ScheduledExecutorService for scheduling tasks

* delete unnecessary files

* Modify to stop ExecutorService using shutdownNow

* Modify to use ScheduledExecutor managed by FrameworkExecutorRepository

* Synchronize reconnectDuration with HeaderExchangeClient's reconnectDuration

* get framework model directly

use awaitility
2024-04-07 10:31:23 +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
Albumen Kevin 392260a30e
Fix NPE in NettyConnectionClient.toString (#13934) 2024-03-19 09:37:28 +08:00
hyhnet d50adb7c83
fix typos (#13858)
Co-authored-by: Cyrus <yecity@gmail.com>
2024-03-10 11:22:59 +08:00
namelessssssssssss 29b0c7298d
Fix port unification issue in triple and dubbo protocol (#13696)
* Fix issue of tri Portunification

* style fix
2024-01-31 10:59:25 +08:00
icodening 2cf54f7947
Close the connection but not the client (#13600)
* Close the connection but not the client

* Close the connection but not the client
2024-01-19 18:19:57 +08:00
Bernardo Sauer 7a3ad4ab41
Hotfix rest Chinese encoding (#13617)
* decode uri in RequestFacade

* supplement the unit test

* fix code style violations

* remove duplicate codes

* consider Accept-Charset as enc

* run mvn spotless apply

* add comment

* take weight into consideration

* fix code style violations according sonar

* add DEFAULT_CHARSET

---------

Co-authored-by: chenxinyuan1 <chenxinyuan1@xiaomi.com>
2024-01-19 11:19:35 +08:00
icodening e26a22d163
fix complete already (#13546)
* fix complete already

* fix complete already
2023-12-25 20:06:32 +08:00
yizhenqiang 71a1ed3cae
if SSL auth policy is set to AuthPolicy.NONE, SslServerTlsHandler#decode should remove and return instead of printing the error log. (#13468)
Co-authored-by: yizhenqiang <yizhenqiang@corp.netesase.com>
2023-12-14 19:12:04 +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
Albumen Kevin 02e486a1dc
Fix unable to receive go away frame (#13228)
* Fix unable to receive go away frame

* Rename

* rename
2023-10-18 11:38:57 +08:00
dependabot[bot] 14d68e51f7
Bump org.apache.zookeeper:zookeeper (#13195)
Bumps org.apache.zookeeper:zookeeper from 3.7.0 to 3.7.2.

---
updated-dependencies:
- dependency-name: org.apache.zookeeper:zookeeper
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2023-10-13 16:54:35 +08:00
TomlongTK 069fd5e1ce
Fix triple client stream executor (#13178)
* Fix error stream executor

* add ping pong for tri protocol (#12955)

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* Revert "add ping pong for tri protocol (#12955)"

This reverts commit 5a3be17bf1.

---------

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
Co-authored-by: icodening <cleverbn96@gmail.com>
2023-10-11 23:23:25 +08:00
icodening b84c1386bb
add ping pong for tri protocol (#12955)
* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol

* add ping pong for tri protocol
2023-10-11 11:17:41 +08:00
Albumen Kevin bd5d158d1b Fix ReplierDispatcherTest test case in Windows platform 2023-09-26 16:30:03 +08:00
Albumen Kevin e0ca51d0b0 Update ReplierDispatcherTest test case 2023-09-26 15:29:31 +08:00
Albumen Kevin 327b808689
Enhance unit test cases in netty4 (#13124) 2023-09-26 09:42:21 +08:00
Albumen Kevin 0fb1e4c4c6
Enhance unit test cases from scheduled tasks (#13099) 2023-09-22 20:23:32 +08:00
Poison 52250b8a20
Fix incorrect timeout message (#13001)
* Fix incorrect timeout message

* Remove @Disabled annotation to enable unit test
2023-09-12 12:45:03 +08:00
aofall 35746aaf5a
Fix rest protocol NPE when using apache-http-client (#12916) (#12984) 2023-09-05 11:22:21 +08:00
Albumen Kevin 0bfd54cea4
Cleanup and throw exception if bind failed (#12987) 2023-09-01 13:03:33 +08:00
Albumen Kevin 0de4c395e8
Fix shouldReconnect check (#12949) 2023-08-23 11:27:10 +08:00
BigXin0109 345e58fc59
fix: CuratorWatch unwatch , childListener is null (#12742) 2023-07-18 18:46:45 +08:00
Albumen Kevin 630e14ae40
Fix netty close when init count is 0 (#12737) 2023-07-17 11:35:03 +08:00
Albumen Kevin bd76d044ba Disable secure random request id by default 2023-07-16 21:28:38 +08:00
Albumen Kevin 976ffda33b
Support skip use secure random id (#12724) 2023-07-14 11:00:01 +08:00
Albumen Kevin 0138ea87a4 Merge branch 'apache-3.1' into apache-3.2 2023-07-11 10:13:17 +08:00
Albumen Kevin c45ce1974d Use secure random 2023-07-11 10:10:38 +08:00
Albumen Kevin e026b5bb59 Merge branch 'apache-3.1' into apache-3.2
# Conflicts:
#	dubbo-remoting/dubbo-remoting-api/src/test/java/org/apache/dubbo/remoting/exchange/RequestTest.java
2023-07-06 17:57:11 +08:00
Albumen Kevin f882cbdd80
Use random id (#12663)
* Use random id

* Fix uts
2023-07-06 17:54:47 +08:00
Albumen Kevin 271d5eff29
Update minimal reconnect period (#12639) 2023-07-03 10:27:56 +08:00
Albumen Kevin 6ad735d74a
Fix server shutdown await timeout (#12644) 2023-07-03 10:16:14 +08:00
Albumen Kevin 5f39404b07
Support set actual content length to inv/res attributes (#12521) 2023-06-13 21:42:27 +08:00
Albumen Kevin e6e68f6b84
Fix channel close event cause hanging thread (#12503)
* Fix channel close event cause hanging thread

* Fix check

* fix npe

* fix ut

* fix check

* fix uts

* fix testing
2023-06-13 10:27:38 +08:00
Albumen Kevin e92f85d980
Support client gracefully shutdown (#12504)
* Support client gracefully shutdown

* fix check

* Fix init
2023-06-12 20:27:55 +08:00
Albumen Kevin 0f7a62a8ff
Fix long time await in ThreadlessExecutor (#12484)
* Fix long time await in ThreadlessExecutor

* Fix uts
2023-06-10 18:14:30 +08:00
wxbty 3d02e9c789
serialization RpcException bug pr rebase (#12357)
* rebase seri error

* fix style

* wrapper seriation exception by IOException

* fix ci

* use exception

* Multiple encode/decode conversion exceptions

* use wrapper to handle seri exp

* add licence

* move seriExp path

* revert demo

* use static proxy

* fix ci

* fix ci

* Update dubbo-serialization/dubbo-serialization-api/src/main/java/org/apache/dubbo/common/serialize/DefaultSerializationExceptionWrapper.java

Co-authored-by: Albumen Kevin <jhq0812@gmail.com>

* simplefy throwable type

* judge IOException

---------

Co-authored-by: xuziyang <767637918@qq.com>
Co-authored-by: x-shadow-man <1494445739@qq.com>
Co-authored-by: Albumen Kevin <jhq0812@gmail.com>
2023-06-03 14:52:52 +08:00
Albumen Kevin 8c2c672f81
Fix netty4 server close timeout (#12387) 2023-05-23 15:31:39 +08:00
Albumen Kevin e5d2a5798e
Support config close timeout (#12386)
* Support config close timeout

* Fix spell

* fix ut
2023-05-23 14:52:49 +08:00
AYue 1671332337
fix: PortUnification+encodeInIOThread=false cause server response empty buffer(#12353) (#12355) 2023-05-20 13:54:29 +08:00
Albumen Kevin 0a7a960f39
Default heartbeat configurable (#12241) 2023-05-07 20:30:52 +08:00
Albumen Kevin 25a08a2b40
Support offline notify (#12211)
* Support offline notify

* Add log
2023-05-02 21:25:11 +08:00
Albumen Kevin 830c460c0a
Fix port unification channel leak (#12212) 2023-04-28 17:14:01 +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
Albumen Kevin bc34399771 Merge branch 'apache-3.1' into apache-3.2 2023-04-11 22:58:05 +08:00
Albumen Kevin 7facd5be19
Fix memory leak when hashed wheel time re-put (#12022) 2023-04-11 19:00:02 +08:00