You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/27 01:26:17 UTC

[rocketmq] branch develop updated (a80070675 -> 3cbb3b8ea)

This is an automated email from the ASF dual-hosted git repository.

yuzhou pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


    from a80070675 [Optimization] Replace Timer to ScheduleExecutorService (#4208)
     add 3cbb3b8ea [ISSUE 3585] [Part B] Improve encode/decode performance (#3588)

No new revisions were added by this update.

Summary of changes:
 .../processor/AbstractSendMessageProcessor.java    |  91 +--------------
 .../broker/processor/SendMessageProcessor.java     |   4 +-
 .../broker/processor/SendMessageProcessorTest.java |  15 +--
 .../protocol/header/PullMessageRequestHeader.java  |  80 ++++++++++++-
 .../protocol/header/PullMessageResponseHeader.java |  38 +++++-
 .../header/SendMessageRequestHeaderV2.java         |  93 ++++++++++++++-
 .../protocol/header/SendMessageResponseHeader.java |  38 +++++-
 .../protocol/header/FastCodesHeaderTest.java       |  31 +++--
 .../rocketmq/example/benchmark/BatchProducer.java  |   3 +
 .../rocketmq/example/benchmark/Consumer.java       |   3 +
 .../rocketmq/example/benchmark/Producer.java       |   3 +
 .../example/benchmark/TransactionProducer.java     |   3 +
 .../rocketmq/remoting/netty/NettyDecoder.java      |   6 +-
 .../rocketmq/remoting/netty/NettyEncoder.java      |   4 +-
 .../remoting/netty/NettyRemotingAbstract.java      |   1 +
 .../remoting/protocol/FastCodesHeader.java         |  50 ++++++++
 .../remoting/protocol/RemotingCommand.java         |  76 ++++++++----
 .../remoting/protocol/RocketMQSerializable.java    | 127 ++++++++++++++-------
 .../remoting/protocol/RemotingCommandTest.java     |  15 ++-
 .../protocol/RocketMQSerializableTest.java         |  68 ++++++++++-
 20 files changed, 552 insertions(+), 197 deletions(-)
 rename broker/src/test/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessorTest.java => common/src/test/java/org/apache/rocketmq/common/protocol/header/FastCodesHeaderTest.java (72%)
 create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/protocol/FastCodesHeader.java