You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/12/21 06:46:21 UTC
[rocketmq] branch master updated (9f95a97 -> 39bb938)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 9f95a97 [maven-release-plugin] prepare release rocketmq-all-4.7.1
add fac30c3 [maven-release-plugin] prepare for next development iteration
add 336f55c [ISSUE #2171] fix the spell error in ACL (#2175)
add 8c71dee [ISSUE #2162] Fix getBrokerConfig help info wrong description (#2163)
add f98567f [ISSUE #2190] Fix import mistakes in RocketMQ_Example.md
add 5002de0 [ISSUE #2192] Typo fix in DefaultMQProducerImpl.java
add c91a2f4 [ISSUE #2180] Polish jvm options when starting nameserver failed
add d91e7a9 [ISSUE #1435] Fix discarded mqadmin subcommand document description
add ea7acf4 docs(readme):fix the typo (#2202)
add e58a6b2 [ISSUE #2196] code style(acl): correct spell mistake, remove redundant code (#2197)
add 3e5008f refactor(build): Remove duplicated logback-core dependency and update some modules to 1.8 compiler lever
add 67a1b51 fix(build): remove warning when maven build
add 30766d2 [ISSUE #1576] Delete redundant if statment in select MessageQueue (#1607)
add 064d4c3 [ISSUE#2176] Fix the issue of redundancy parameters in method
add 83cc99a Merge branch 'develop' of github.com:apache/rocketmq into develop
add f5b7958 [ISSUE #2217] Upgrade dledger version (#2218)
add 3774a22 [ISSUE #2231] Fix document(cn/msg_trace/user_guide.md) formal error
add bbfdd92 [ISSUE #2170] Update BrokerOuterAPI (#2203)
add 915424c [ISSUE#2172] Fix the issue of ArrayIndexOutOfBoundsException
add a093f8a [ISSUE #2067] Add logs when collecting disk space usage
add e23f586 [ISSUE#2233] Enhancement MQBrokerException include broker information(such as broker ip) for troubleshooting
add e088f2e keep compatibility
add 9d34fad Merge pull request #2236 from Demogorgon314/develop
add 6a46640 [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser for DefaultLitePullConsumer (#2246)
add 4d073af doc(rocketmq) add a recommendation to PR template
add 2abda6d Merge pull request #2258 from imaffe/affe-0819-prtemplate
add f07bc79 [ISSUE #2283] Fix the spelling mistake in ProducerManager & some code optimization
add ba5e0e5 [ISSUE #2272] Fix spelling mistakes
add 2f14aa5 [ISSUE #2280] Disk ratio return -1.0 when cluster deployed on DLedger mode
add 3eaabee [ISSUE #2293] Add clientID for warning log message in MQClientInstance (#2294)
add 2a8ba5a [ISSUE #1473] Trace message`s clientHost was wrong (#1474)
add 9ddcab4 [ISSUE apache#2152] Add isRunning method in DefaultLitePullConsumerImpl class and test suit (#2302)
add a460c5c [ISSUE #1770] Add a query message trace command in mqadmin. (#2303)
add 28e6b55 [ISSUE #2299]modify the error character of the Example_Filter.md
add b29209e [ISSUE #2152] Use mock style in unit test for time-consuming (#2308)
add 742ba50 fix(dependency): remove Imcompatible plugin with jdk15
add 73f2071 [ISSUE #2219] Add some asynchronous API for batch messages (#2315)
add f58dbc3 [ISSUE #2300] Enhancement: Benchmark support acl and msg trace (#2301)
add 77d24de [ISSUE# 2325] Use CopyOnWriteArrayList to avoid possible thread safety issues
add c932941 [ISSUE #2334] Polish the log and response remark when service not available (#2335)
add d5cb67f [ISSUE #2165] Slave read enable not work sometimes When cluster deployed on DLedger mode (#2167)
add 3f48c17 [ISSUE# 2330] Store the properties of MessageBatch (#2343)
add fd7da35 [ISSUE #2338] use commitLeastPages parameters and substitute 'lastCommittedPosition' for duplicated 'this.committedPosition.get()' in 'commit0' method (#2338) (#2346)
add 3be7033 [ISSUE #2146] Add benchmark shutdown script, add more print info, add consumer threand count command option (#2150)
add 845c5fd [ISSUE #1846] Dledger model change into pipeline manner to improve performance (#1847)
add f5a119f [ISSUE #2366] Fix tproducer start faild with parameter w
add 03c1f11 [ISSUE #2378] FIx `NullPointerException` when Consumer shutdown in the ClientRemotingProcessor.
add 872f37d [ISSUE#2415] Delete the useless code (#2416)
add 0b60048 [ISSUE #2421] Fix SelectMessageQueueByHash in case hashcode is Integer.MIN
add c286600 Fix error in ipCheck method (#2376)
add 2defd08 Redirect the twitter account
add 6588063 Writing style optimization
add 3cc7f09 [ISSUE #2477] Fix allocate algorithm in AllocateMessageQueueByMachineRoom
add b69ad17 [ISSUE #2459] Fix the error in best practice doc
add ac3adc5 [ISSUE#2468] Fix DefaultLayout SimpleDateFormat Pattern (#2469)
add ac356f1 [ISSUE #2412] Support to add TAG when producing message
add bd67f7a [ISSUE #2402] Update directory for RocketMQ_Example.md
add 912ceda [ISSUE #2223] Polish the selectOneMessageQueue method (#2253)
add bb9f106 [ISSUE #1904] Print log when flush timeout (#1903)
add 7f49ce4 [ISSUE #1678] Use thread safe CopyOnWriteArrayList for registerBrokerResultList
add 48f076f fix(test):temporary fix on Mac OS when pid greater than short type max value (#2492)
add 4730987 [ISSUE #690] Support batch msgs in dledger mode (#2406)
add 84da462 chore(release): prepare to release rocketmq 4.8.0
add 39bb938 [maven-release-plugin] prepare release rocketmq-all-4.8.0
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 3 +
README.md | 4 +-
acl/pom.xml | 11 +-
.../org/apache/rocketmq/acl/common/AclUtils.java | 4 +-
.../org/apache/rocketmq/acl/common/Permission.java | 1 -
.../rocketmq/acl/plain/PlainPermissionManager.java | 13 +-
.../acl/plain/RemoteAddressStrategyFactory.java | 14 +-
.../apache/rocketmq/acl/common/AclUtilsTest.java | 18 +-
.../acl/plain/RemoteAddressStrategyTest.java | 10 +
broker/pom.xml | 6 +-
.../rocketmq/broker/client/ProducerManager.java | 12 +-
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 15 +-
.../broker/processor/ReplyMessageProcessor.java | 17 +-
.../broker/processor/SendMessageProcessor.java | 3 +-
.../AbstractTransactionalMessageCheckListener.java | 2 +-
.../broker/client/ProducerManagerTest.java | 8 +-
client/pom.xml | 7 +-
.../rocketmq/client/common/ThreadLocalIndex.java | 5 -
.../client/consumer/DefaultLitePullConsumer.java | 21 +
.../rocketmq/client/consumer/LitePullConsumer.java | 7 +
.../AllocateMessageQueueByMachineRoom.java | 2 +-
.../client/exception/MQBrokerException.java | 16 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 74 +--
.../consumer/ConsumeMessageOrderlyService.java | 4 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 4 +
.../impl/consumer/DefaultMQPushConsumerImpl.java | 6 -
.../client/impl/consumer/ProcessQueue.java | 2 +-
.../client/impl/consumer/PullAPIWrapper.java | 4 +-
.../client/impl/factory/MQClientInstance.java | 18 +-
.../impl/producer/DefaultMQProducerImpl.java | 2 +-
.../client/impl/producer/TopicPublishInfo.java | 4 +-
.../rocketmq/client/latency/MQFaultStrategy.java | 6 +-
.../client/producer/DefaultMQProducer.java | 23 +
.../rocketmq/client/producer/MQProducer.java | 14 +-
.../selector/SelectMessageQueueByHash.java | 4 +-
.../rocketmq/client/trace/TraceDataEncoder.java | 25 +-
.../apache/rocketmq/client/trace/TraceView.java | 180 ++++++
.../trace/hook/ConsumeMessageTraceHookImpl.java | 2 +
.../trace/hook/SendMessageTraceHookImpl.java | 1 +
.../client/common/ThreadLocalIndexTest.java | 7 +
.../consumer/DefaultLitePullConsumerTest.java | 33 +-
.../store/RemoteBrokerOffsetStoreTest.java | 2 +-
.../client/impl/factory/MQClientInstanceTest.java | 68 +++
.../client/producer/DefaultMQProducerTest.java | 45 ++
.../selector/SelectMessageQueueByHashTest.java | 8 +
.../selector/SelectMessageQueueRetryTest.java | 66 +++
.../client/trace/TraceDataEncoderTest.java | 93 +++
.../rocketmq/client/trace/TraceViewTest.java | 57 ++
common/pom.xml | 7 +-
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../java/org/apache/rocketmq/common/UtilAll.java | 41 +-
.../rocketmq/common/message/MessageDecoder.java | 1 +
.../common/message/MessageClientIDSetterTest.java | 6 +-
distribution/benchmark/runclass.sh | 2 +-
distribution/benchmark/shutdown.sh | 63 ++
distribution/benchmark/tproducer.sh | 2 +-
distribution/bin/runserver.sh | 19 +-
distribution/pom.xml | 2 +-
docs/cn/RocketMQ_Example.md | 46 +-
docs/cn/architecture.md | 10 +-
docs/cn/best_practice.md | 4 +-
docs/cn/msg_trace/user_guide.md | 2 +-
docs/en/Example_Filter.md | 2 +-
example/pom.xml | 26 +-
.../rocketmq/example/benchmark/AclClient.java | 18 +-
.../rocketmq/example/benchmark/Consumer.java | 30 +-
.../rocketmq/example/benchmark/Producer.java | 31 +-
.../example/benchmark/TransactionProducer.java | 13 +-
filter/pom.xml | 2 +-
logappender/pom.xml | 7 +-
logging/pom.xml | 7 +-
.../rocketmq/logging/inner/LoggingBuilder.java | 2 +-
namesrv/pom.xml | 10 +-
openmessaging/pom.xml | 6 +-
pom.xml | 39 +-
remoting/pom.xml | 7 +-
srvutil/pom.xml | 2 +-
store/pom.xml | 9 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 50 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 21 +-
.../java/org/apache/rocketmq/store/MappedFile.java | 2 +-
.../rocketmq/store/config/MessageStoreConfig.java | 20 +
.../rocketmq/store/dledger/DLedgerCommitLog.java | 651 ++++++++++++++++++---
.../apache/rocketmq/store/BatchPutMessageTest.java | 10 +-
.../org/apache/rocketmq/store/StoreTestBase.java | 68 ++-
.../store/dledger/DLedgerCommitlogTest.java | 160 ++++-
.../store/dledger/MessageStoreTestBase.java | 4 +-
test/pom.xml | 3 +-
tools/pom.xml | 6 +-
.../rocketmq/tools/command/MQAdminStartup.java | 2 +
.../command/broker/GetBrokerConfigCommand.java | 4 +-
.../message/QueryMsgTraceByIdSubCommand.java | 148 +++++
.../QueryMsgTraceByIdSubCommandTest.java} | 18 +-
93 files changed, 2069 insertions(+), 467 deletions(-)
create mode 100644 client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java
create mode 100644 client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueRetryTest.java
create mode 100644 client/src/test/java/org/apache/rocketmq/client/trace/TraceDataEncoderTest.java
create mode 100644 client/src/test/java/org/apache/rocketmq/client/trace/TraceViewTest.java
create mode 100644 distribution/benchmark/shutdown.sh
copy tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java => example/src/main/java/org/apache/rocketmq/example/benchmark/AclClient.java (65%)
create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java
copy tools/src/test/java/org/apache/rocketmq/tools/command/{broker/UpdateBrokerConfigSubCommandTest.java => message/QueryMsgTraceByIdSubCommandTest.java} (88%)