444 Commits

Author SHA1 Message Date
mxsm d070d467a6 [ISSUE #5802]Optimize HashMap and HasSet invoke resize method (#5803) 2023-01-03 10:32:36 +08:00
xiaoyifang e986534728 [ISSUE #5699] remove duplicate code definition of UtilAll.isBlank (#5700)
* [ISSUE #5699] remove duplicate code definition of UtilAll.isBlank

* [ISSUE #5699] remove duplicate code definition of UtilAll.isBlank
2022-12-29 15:17:58 +08:00
rongtong 646d04f425 [ISSUE #5712] Fix the invalid of heartbeat detection after controller switch (#5711)
* Fix the invalid of heartbeat detection after controller switch

* Pass the checkstyle

* Format ReplicasInfoManagerTest code style
2022-12-21 10:36:57 +08:00
mxsm 48848362d6 [ISSUE #5692] Polish Controller headers toString (#5693) 2022-12-14 17:42:50 +08:00
zhouxiang 561fc2e732 [ISSUE #5392] Remove unused method 2022-12-09 19:53:18 +08:00
kaiyi.lk 4c0e06749b [ISSUE #5486] polish MultiProtocolRemotingServer 2022-12-09 19:53:18 +08:00
SSpirits 7cab0a1aad [ISSUSE #5589] record subscription from request (#5590) 2022-12-07 17:26:00 +08:00
rongtong 6f49a1034d Enable AbortProcessException to interrupt RPCHook (#5594) 2022-11-25 20:35:20 +08:00
hzh0425 93e82c8205 [ISSUE #5569]Support broker priority election for controller mode (#5548)
* Support broker priority election for controller mode

* fix comment of brokerElectionPriority

* Set "The lower the value of brokerElectionPriority, the higher the priority of the broker being selected as the master."
2022-11-24 12:59:34 +08:00
Aaron Ai 4469fb51dd Update group id of rocketmq logging (#5564) 2022-11-22 11:31:21 +08:00
Aaron Ai a68078fef8 [ISSUE #5484] Replace logging module with the shaded logback (#5540)
* Replace logging module with the shaded logback

* Add license header

* Fix bazel compile issue
2022-11-21 16:30:15 +08:00
rongtong d781271654 Move the header of the controller to the upper layer (#5550) 2022-11-20 21:51:32 +08:00
Humkum da5a5b6292 [ISSUE #5536] fix:new version name server should be compatible with old version broker 2022-11-19 23:24:04 +08:00
yukon 506b563f55 Revert "[ISSUE #5484] Replace Logging Module with Shaded Logback (#5524)" (#5537)
This reverts commit 809ff6b3e0.
2022-11-17 20:04:17 +08:00
Aaron Ai 809ff6b3e0 [ISSUE #5484] Replace Logging Module with Shaded Logback (#5524)
* Remove ClientLogger

* WIP

* WIP

* Rename logger to log

* Make it compile

* WIP

* Fix bazel to use shaded slf4j

* Fix DeleteExpiredCommitLogSubCommandTest

* Fix pom.xml duplication

* Fix maven deps

* Add test logback configuration file

* Fix unit test output

* Fix logback configuration file

* All logging are made on top of slf4j

* Fix test log configuration file name

* Fix test log configuration file name for test module

* All logging are shaded slf4j targeted

* DLedger has an explicit dependency on slf4j

* Fix DLedger

* Fix DLeader issue

* Move logback configuration files to each module

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
2022-11-17 00:38:28 +08:00
SSpirits ec5d3236f6 invert dependency between remoting and common module (#5503)
* invert dependency between remoting and common module

* fix bazel

* Fix Bazel warning of indirect dependency

* remove duplicate class ServiceThread

* fix conflict

* revert delete class ServiceThread because of introduced by dledger

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
2022-11-11 13:34:31 +08:00
SSpirits 0ae1bd2af6 [ISSUE #5449] [RIP-46] implement remoting stats metrics (#5487)
* implement remoting metrics

* fix bazel

* add metrics view & fix unit test

* move remoting command process timer to NettyDecoder
2022-11-09 19:44:41 +08:00
Zhanhui Li 61fa3b0c23 [ISSUE #5344] Fix Windows and Mac CI pipelines (#5345)
* Skip tests that are not compatible with Windows using org.junit.Assume

* Skip incompatible test case

* Ignore cases that is not compatible with Windows

* Skip a test case on Mac to make CI pass

* Skip test case on Windows if load() fails

* Try to grant more time to TlsTest to make Mac CI pass

* Grant longer potential duration for await
2022-11-03 11:15:55 +08:00
SSpirits 4ba8aa238d [ISSUE #5354] [RIP-46] Implement proxy metrics framework (#5407)
* implement proxy metrics framework

* fix bazel dependency

* fix proxy startup test

* fix warning in bazel test

* minor improve
2022-10-27 17:23:31 +08:00
SSpirits 6e27b54349 [ISSUE ##5354] Implement broker metrics framework (#5355)
* implement broker metrics framework

* update bazel config

* Fix Bazel deps

* Fix unnecessary mocking issue

* Fix bazel compile warning

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-10-19 23:14:45 +08:00
echooymxq dd4ebd0a90 [ISSUE #5291] Optimize the NettyRemotingServer. (#5299) 2022-10-14 13:10:23 +08:00
mxsm db1f1839b9 [ISSUE #5298]Polish code style for jdk8+ (#5308) 2022-10-14 11:44:21 +08:00
Nowinkey 53e0847528 [ISSUE #5204] Enable checkstyle for test code (all module) (#5297)
* delete the checkstyle plugin for child modules

* [ISSUE #5204] Enable checkstyle for test code (all module)

* Exclude generated files

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-10-14 10:58:48 +08:00
echooymxq 9e63f09ad8 [ISSUE #5285] Support vm arguments to set useTLS value. (#5286) 2022-10-12 14:34:01 +08:00
lizhimins d256b88171 [ISSUE #5095] Add some remoting test (#5251)
* [ISSUE #5095] Add some remoting test

* [ISSUE #5095] Add some remoting test

* [ISSUE #5095] Add some remoting test

Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
2022-10-09 16:02:37 +08:00
Nowinkey 0ad7db6956 [ISSUE #5216] Enable checkstyle for test code (rocketmq-controller, rocketmq-remoting and rocketmq-proxy) (#5218)
* style(remoting):Enable checkstyle for test code

* style(controller):Enable checkstyle for test code

* style(proxy):Enable checkstyle for test code
2022-09-29 11:46:00 +08:00
Nowinkey d52be62f71 [ISSUE #5122] Enable checkstyle for test code (rocketmq-broker module) (#5193)
* style(pom):Enable checkstyle for test code

* style(broker):Enable checkstyle for test code

* Update pom.xml

* Enable checkstyle for tests of broker module

* Remove delete tmp file assertion as OS may have cron job to clean them

* Fix bazel issue

Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
2022-09-28 11:26:44 +08:00
lizhimins b8607d917c [ISSUE #5095] Support socks proxy in remoting client (#5123) 2022-09-28 10:22:55 +08:00
Zhanhui Li 5723b97964 [ISSUE #5126]Make all tests in ACL module pass on Windows (#5127)
* Make all tests pass on Windows

* Run in serial
2022-09-26 17:47:19 +08:00
lizhimins e7850f63e5 [ISSUE #5095] [Remoting-D] Not handle more request when channel write ability changed to un-writeable (#5176)
Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
2022-09-23 16:54:38 +08:00
zhoubo 251fc77957 Merge branch 'develop' into release-5.0.0 2022-09-23 10:28:18 +08:00
lizhimins b511e09772 [ISSUE #5095] [Remoting-A] Support logging rpc distribution in remoting protocol (#5114)
* [ISSUE #5087] [Remoting-A] Support logging rpc distribution in remoting protocol

* [ISSUE #5087] [Remoting-A] Support logging rpc distribution in remoting protocol

* [ISSUE #5087] [Remoting-A] Support logging rpc distribution in remoting protocol

* [ISSUE #5087] [Remoting-A] Support logging rpc distribution in remoting protocol

* [ISSUE #5087] [Remoting-A] Support logging rpc distribution in remoting protocol

Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
2022-09-19 17:07:49 +08:00
racoon bfe8f423e5 Update FileRegionEncoder.java (#5111)
* Update FileRegionEncoder.java

fix FileRegionEncoder.java

* Make the return value more accurate

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-09-19 10:44:06 +08:00
hill ac82378aea [maven-release-plugin] prepare for next development iteration 2022-09-19 10:27:17 +08:00
hill f3e113cb1f [maven-release-plugin] prepare release rocketmq-all-5.0.0 2022-09-19 10:26:58 +08:00
rongtong df1226b2d8 Fix too many useless logs when the broker runs normally (#5080) 2022-09-15 14:07:50 +08:00
SSpirits 4fa29b94a9 [ISSUE #5013] allow broker to bind specified network interface (#5014)
* allow broker to bind specified network interface

* remove bind ip check

* Improve pull request

* Log the listening InetAddress on remoting server started

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-09-08 14:08:49 +08:00
Zhanhui Li 35ac588fb5 [ISSUE #4979] Fix flaky integration test NormalMessageSendAndRecvIT (#4980)
* Fix netty warning; Fix flaky integration test NormalMessageSendAndRecvIT; Fix naming typo

* Change log level

* Use awaitability to make everyone happy

* Do not submit tasks when executor has been shut down
2022-09-05 14:27:01 +08:00
CoedPig 8357cff101 [ISSUE #5002]Fix code style in any net modules. (#4989)
* optimize the memory usage in DefaultMappedFile:
use AtomicIntegerFieldUpdater instead of AtomicInteger

* fix code bug:
if the initial cursor of listIterator equals zero,
the previous element will always null.

* modify constant name

* fix excessive nesting

* Update client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java

* update maven-surefire-plugin.version from 2.19.1 to 2.22.1

* Revert "update maven-surefire-plugin.version from 2.19.1 to 2.22.1"

This reverts commit 37fabe6e78.

* Code Style: fix warn info from the code detector.

* fix checkstyle: not use '*' for import.

* Fix code style in any net modules.

* change method name from topicRouteDataIsChange to topicRouteDataChanged in TopicRouteData.java

* revert executeInvokeCallback method

* Fix grammar issues

Co-authored-by: shanpengyu <shanpengyu@bytedance.com>
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-09-05 13:38:26 +08:00
hYang b89a4009cf fix wrong log warning (#4984)
* fix log warning

* Polish log text on network I/O error

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-09-05 10:58:57 +08:00
Aaron Ai f23fdbe016 Replace findbugs by spotbugs (#4931) 2022-08-30 17:45:56 +08:00
Zhanhui Li 3da7ea9c1b [Infra Improvement] Build And Run Unit Tests in Parallel (#4878)
* Support build with Bazel (#4865)

* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.

* Make test cases capable of running in parallel. (#4874)
2022-08-24 20:53:30 +08:00
RongtongJin bbbb96e129 Revert "Support build with Bazel (#4865)"
This reverts commit ec8a93d2f7.
2022-08-23 14:29:46 +08:00
Zhanhui Li ec8a93d2f7 Support build with Bazel (#4865)
* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.
2022-08-23 13:11:53 +08:00
Aaron Ai 61b14c3f4e [ISSUE #4785] Enable misspell check GitHub Action (#4786)
* Enable misspell check GitHub Action

* Fix typo
2022-08-08 09:28:41 +08:00
mxsm 83f64a8b4d [ISSUE #4751] Optimize NettyRemotingAbstract#processRequestCommand code 2022-08-04 08:49:44 +08:00
mxsm b875b3309a [ISSUE #4709] fix method is on the same line as @Override annotation (#4717)
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
2022-08-01 20:42:34 +08:00
RongtongJin dd09f2b782 Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller
# Conflicts:
#	distribution/bin/mqshutdown
#	pom.xml
2022-07-20 10:53:39 +08:00
Qingshan Lin e6b4e15ebf Merge pull request #4225 from drpmma/feature/grpc-develop-v2
[ISSUE #3949] Support gRPC protocol
2022-07-20 10:36:21 +08:00
djlnet 89cb8cce87 [ISSUE #4630] Fix RequestTask's stopRun field concurrency issues(#4631) (#4631)
Co-authored-by: djl <djl.du@huolala.cn>
2022-07-20 10:20:57 +08:00