ef6a8c917c
[ISSUE #10430 ] Add unit tests for srvutil package ( #10431 )
...
* test: add srvutil regression coverage
* test: fix bazel build issues for srvutil tests
2026-06-09 09:46:32 +08:00
9443c6d9db
[ISSUE #10383 ] Align Bazel dependencies with Maven pom.xml ( #10404 )
2026-05-29 10:04:20 +08:00
d7e27d6d69
[ISSUE #9396 ] Use fastjson2 in all modules ( #9397 )
...
* Use fastjson2 in all modules
* Update test
* Update test
* Update test
* Add serialization compatibility test tool class
* Update RemotingSerializableCompatTest.java
* Update RemotingSerializableCompatTest.java
* Update RemotingSerializableCompatTest.java
* Update BitSet problem
* Update
* Update
* Update test
* Update test
* Update BUILD.bazel
* Update BUILD.bazel
* Update test
* Update BitSet problem
* Add test
* Add compat test
* merge develop
* Update test
* merge develop
2025-12-04 19:09:08 +08:00
1c23a8094a
[ISSUE #9663 ] Adopt Maven's revision mechanism (requires Maven >= 3.5.0) ( #9665 )
...
Co-authored-by: cvictory <shengli.caosl@alibaba-inc.com >
2025-09-04 09:51:02 +08:00
7ab7ddd6d2
[ISSUE #9609 ] Fix bazel CI and reduce dependencies ( #9610 )
2025-08-22 16:35:39 +08:00
832562f028
[ISSUE #8920 ] Refactor SSL context loading process to support multiple protocols dynamic loading ( #9483 )
...
* feat(proxy): 添加 gRPC 和 Remoting 服务器的 TLS 证书热更新支持
- 在 GrpcServer 和 RemotingProtocolServer 中添加文件监视服务，用于监控 TLS 证书和密钥的变化
- 实现证书和密钥变更时重新加载 SSL 上下文的逻辑
- 优化 ProxyAndTlsProtocolNegotiator 中的 SSL 上下文加载过程
- 添加日志记录，方便调试和监控 TLS 相关操作
* refactor(proxy): 重构 gRPC 证书监控逻辑并添加单元测试
- 重构 GrpcServer 中的证书监控逻辑，提取到独立的 GrpcCertKeyFileWatchListener 类中
- 优化证书变更处理流程，提高代码可读性和维护性
- 新增 GrpcServerTest 类，为 gRPC服务器和证书监控添加单元测试- 测试覆盖了各种证书变更场景，包括单独变更和组合变更
- 验证了证书变更时 SSLContext 的重新加载和错误处理
Signed-off-by: Async <raisinata@foxmail.com >
* refactor(proxy): 重构 gRPC 证书监控逻辑并添加单元测试
- 重构 GrpcServer 中的证书监控逻辑，提取到独立的 GrpcCertKeyFileWatchListener 类中
- 优化证书变更处理流程，提高代码可读性和维护性
- 新增 GrpcServerTest 类，为 gRPC服务器和证书监控添加单元测试- 测试覆盖了各种证书变更场景，包括单独变更和组合变更
- 验证了证书变更时 SSLContext 的重新加载和错误处理
Signed-off-by: Async <raisinata@foxmail.com >
* fix: code format
Signed-off-by: Async <raisinata@foxmail.com >
* test: add test cases
Signed-off-by: Async <raisinata@foxmail.com >
* fix: code format
Signed-off-by: Async <raisinata@foxmail.com >
* refactor(proxy): 重构 TLS证书更新逻辑
- 移除 FileWatchService，改用 TlsCertificateManager 统一管理 TLS证书
- 实现 TlsContextReloadListener 接口，响应 TLS 证书更新
- 优化 GrpcServer 和 RemotingProtocolServer 中的 TLS 证书更新逻辑
- 新增单元测试验证 TLS 证书更新功能
Signed-off-by: Async <raisinata@foxmail.com >
* test(proxy): 优化 TLS 相关测试用例
- 重构了多个测试类中的重复代码- 提高了测试的可读性和维护性
- 确保在测试中正确关闭资源
Signed-off-by: Async <raisinata@foxmail.com >
* refactor(proxy): 优化代码导入结构
- 移除了不必要的导入项
- 显式导入了所有活动类，提高了代码的可读性和维护性
Signed-off-by: Async <raisinata@foxmail.com >
* update
* fix: no static
Signed-off-by: Async <raisinata@foxmail.com >
* fix: add SingletonHolder for TlsCertificateManager
Signed-off-by: Async <raisinata@foxmail.com >
* refactor
* refactor(proxy): 重构 TLS证书管理
- 将 TlsCertificateManager 实例化移至 ProxyStartup 类
- 更新 GrpcServer 和 RemotingProtocolServer 类以使用 TlsCertificateManager
- 移除冗余的 TLS 证书管理相关测试用例
- 优化 TLS 上下文重载逻辑
Signed-off-by: Async <raisinata@foxmail.com >
* refactor(proxy): 优化日志信息内容
- 将 cert file changed 日志信息改为更通用的 File changed
- 保持代码风格一致性，提高日志的可读性和维护性
Signed-off-by: Async <raisinata@foxmail.com >
* test(proxy): 重构并增强 TlsCertificateManager 测试用例- 重新设计测试用例，使用临时文件模拟证书和密钥
- 增加对 TlsCertificateManager 各种方法的单元测试
- 涉及到的测试场景包括：
- 构造函数
- 启动和关闭
- 注册和注销监听器
- 文件变更通知（证书、密钥、未知文件等）
- 多个监听器的情况
- 监听器抛出异常的情况
- 增加对内部 CertKeyFileWatchListener 的测试
Signed-off-by: Async <raisinata@foxmail.com >
* refactor
* test(proxy): 优化 TlsCertificateManager 单元测试
-移除了未使用的 import 语句
- 替换了 import static语句，使其更加有序
- 删除了未使用的静态方法断言（verify、times、never）
- 重置了 mock 对象以避免测试之间的干扰
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
* fix format
Signed-off-by: Async <raisinata@foxmail.com >
---------
Signed-off-by: Async <raisinata@foxmail.com >
2025-06-27 09:56:19 +08:00
aecb97ec44
[maven-release-plugin] prepare for next development iteration ( #9389 )
2025-05-07 16:34:04 +08:00
29d90a4ff9
[maven-release-plugin] prepare release rocketmq-all-5.3.3 ( #9388 )
2025-05-07 09:48:32 +08:00
ade18bb076
[ISSUE 9362] [RIP-77] Deprecate and Remove ACL 1.0 ( #9363 )
2025-04-30 15:02:55 +08:00
47fe6b2ba6
[maven-release-plugin] prepare for next development iteration ( #9232 )
2025-03-08 17:20:49 +08:00
2baaf044ea
[maven-release-plugin] prepare release rocketmq-all-5.3.2 ( #9231 )
2025-03-08 14:07:17 +08:00
4571a853a2
reduce duplicate calls ( #9037 )
...
Co-authored-by: noreply <noreply@qq.com >
2024-12-09 14:32:37 +08:00
daf3d1a666
[maven-release-plugin] prepare for next development iteration ( #8750 )
2024-09-26 09:33:52 +08:00
b122c8109d
[maven-release-plugin] prepare release rocketmq-all-5.3.1 ( #8749 )
2024-09-25 23:24:56 +08:00
5dc0c6a8b5
[maven-release-plugin] prepare for next development iteration ( #8382 )
2024-07-09 01:30:43 +08:00
7ee50ec32e
[maven-release-plugin] prepare release rocketmq-all-5.3.0 ( #8379 )
2024-07-08 23:15:33 +08:00
209184339b
[ISSUE #8274 ] Optimize some codestyles and fix some warnings ( #8275 )
2024-06-21 07:55:01 +08:00
f41160210a
[maven-release-plugin] prepare for next development iteration ( #7828 )
2024-02-12 11:07:03 +08:00
281a7b32f0
[maven-release-plugin] prepare release rocketmq-all-5.2.0 ( #7827 )
2024-02-11 17:53:50 +08:00
73b3fde837
[maven-release-plugin] prepare for next development iteration ( #7379 )
2023-09-22 10:08:59 +08:00
1a681bdf9b
[maven-release-plugin] prepare release rocketmq-all-5.1.4 ( #7377 )
2023-09-21 19:58:29 +08:00
f534501855
[Feature 7155] add errlog when cmd err ( #7157 )
...
Co-authored-by: 十真 <shirenchuang.src@cainiao.com >
2023-08-11 10:25:48 +08:00
e369d7deac
[maven-release-plugin] prepare for next development iteration ( #6939 )
2023-06-24 14:31:42 +08:00
f7425f52f9
[maven-release-plugin] prepare release rocketmq-all-5.1.3 ( #6938 )
2023-06-24 12:23:11 +08:00
ad4cc957fb
[maven-release-plugin] prepare for next development iteration ( #6895 )
2023-06-12 19:12:25 +08:00
749967baa8
[maven-release-plugin] prepare release rocketmq-all-5.1.2 ( #6892 )
2023-06-12 17:44:39 +08:00
92ea901d7b
[ISSUE #6765 ] org.apache.rocketmq.util.cache doesn't look like it's being used
...
Co-authored-by: loboxu <loboxu@tencent.com >
2023-05-16 13:36:11 +08:00
8aea26ef8f
[maven-release-plugin] prepare for next development iteration
2023-05-15 19:48:34 +08:00
e244ebb99a
[maven-release-plugin] prepare release rocketmq-all-5.1.1 ( #6763 )
2023-05-15 18:51:01 +08:00
0f878b5157
[maven-release-plugin] prepare for next development iteration
2023-02-16 12:35:58 +08:00
b8e9334d2a
[maven-release-plugin] prepare release rocketmq-all-5.1.0
2023-02-16 12:35:58 +08:00
83d6778747
[ISSUE #6030 ] Update version to 5.1.0-SNAPSHOT
2023-02-16 12:35:58 +08:00
4469fb51dd
Update group id of rocketmq logging ( #5564 )
2022-11-22 11:31:21 +08:00
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
506b563f55
Revert "[ISSUE #5484 ] Replace Logging Module with Shaded Logback ( #5524 )" ( #5537 )
...
This reverts commit 809ff6b3e0
2022-11-17 20:04:17 +08:00
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
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
db1f1839b9
[ISSUE #5298 ]Polish code style for jdk8+ ( #5308 )
2022-10-14 11:44:21 +08:00
ac82378aea
[maven-release-plugin] prepare for next development iteration
2022-09-19 10:27:17 +08:00
f3e113cb1f
[maven-release-plugin] prepare release rocketmq-all-5.0.0
2022-09-19 10:26:58 +08:00
ed9c775ee3
[ISSUE #4999 ] Optimize ConcurrentMap#computeIfAbsent performance on jdk1.8 a workaround ( #5008 )
2022-09-08 20:50:32 +08:00
4661e58ebe
[ISSUE #4934 ] Checking for violations as part of build ( #4935 )
...
* Checking for violations as part of build
* Extend await time for FileWatchServiceTest#watchTwoFiles_ModifyOne
2022-08-31 10:55:04 +08:00
f23fdbe016
Replace findbugs by spotbugs ( #4931 )
2022-08-30 17:45:56 +08:00
a488a0c22d
[ISSUE 4926]Fix FileWatchServiceTest ( #4927 )
...
* Fix FileWatchService
* Fix all warnings and optimize FileWatchService implementation
* Take spurious wakeup into account
2022-08-30 14:24:46 +08:00
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
bbbb96e129
Revert "Support build with Bazel ( #4865 )"
...
This reverts commit ec8a93d2f7
2022-08-23 14:29:46 +08:00
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
8ef151d605
Change rocketmq version to 5.0.0-SNAPSHOT in all pom files
2022-07-08 23:45:55 +08:00
3fadc8f30c
Merge branch '5.0.0-beta' into develop
...
# Conflicts:
# acl/pom.xml
# broker/pom.xml
# broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
# broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
# broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
# broker/src/main/java/org/apache/rocketmq/broker/transaction/jdbc/JDBCTransactionStore.java
# broker/src/test/java/org/apache/rocketmq/broker/processor/SendMessageProcessorTest.java
# client/pom.xml
# client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
# client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
# client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
# client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
# client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
# client/src/test/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumerTest.java
# common/pom.xml
# common/src/main/java/org/apache/rocketmq/common/MQVersion.java
# common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
# common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
# common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
# common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
# common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
# common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java
# common/src/test/java/org/apache/rocketmq/common/message/MessageDecoderTest.java
# distribution/pom.xml
# example/pom.xml
# filter/pom.xml
# logging/pom.xml
# logging/src/main/java/org/apache/rocketmq/logging/inner/Level.java
# namesrv/pom.xml
# namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
# namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
# namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
# openmessaging/pom.xml
# pom.xml
# remoting/pom.xml
# remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
# remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
# remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
# remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java
# srvutil/pom.xml
# store/pom.xml
# store/src/main/java/org/apache/rocketmq/store/CommitLog.java
# store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
# store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
# store/src/main/java/org/apache/rocketmq/store/MultiDispatch.java
# store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
# store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java
# store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
# store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
# store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java
# store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
# store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
# store/src/test/java/org/apache/rocketmq/store/MultiDispatchTest.java
# store/src/test/java/org/apache/rocketmq/store/dledger/DLedgerCommitlogTest.java
# test/pom.xml
# tools/pom.xml
# tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
# tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
# tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java
# tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
# tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
2022-07-08 15:03:54 +08:00
32733e7674
[maven-release-plugin] prepare for next development iteration
2022-06-20 16:17:12 +08:00
lsq3497