This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 774bc6752 optimize LagCalculationIT
new 934f5b657 [ISSUE #5406] Add processor for remoting messaging module
new 4b9816e4a [ISSUE #5406] Support getConsumerIdList
new b887313bf [ISSUE #5406] Add unit test
new 56551b596 [ISSUE #5485] client connection management
new 6c8233043 [ISSUE #5485] test cases for client connection management
new 48673af76 [ISSUE #5486] Add remoting server
new 8a23c54a9 [ISSUE #5486] polish clean expire request in remoting server
new 4c0e06749 [ISSUE #5486] polish MultiProtocolRemotingServer
new 7e916e3db [ISSUE #5406] support transaction message for remoting proxy
new 832fc57a0 [ISSUE #5486] polish tls config; add tcnative dependency
new 21a01e3c6 [ISSUE #5406] use remotingAccessAddr and ListenPort in
topicRoute for remoting proxy
new 6351e1957 [ISSUE #5485] polish channel management which is been synced
from other proxy
new 96bab46bd [ISSUE #5485] polish channel management
new 834287af0 [ISSUE #5485] add test cases for channel management
new 29c4122d9 [ISSUE #5486] Add AuthenticationPipeline
new 561fc2e73 [ISSUE #5392] Remove unused method
new 274a53132 [ISSUE #5406] Fix brokerName for SEND_MESSAGE_V2
new 9897e74a6 [ISSUE #5406] Overwrite sysFlag to broker
new 416427de1 [ISSUE #5392] Adapt for logging and module refector
new 1e71cd118 [ISSUE #5406] Fix PullMessageActivityTest
new 23c8efd80 [ISSUE #5485] Fix GrpcBaseIT
new b713aebfa [ISSUE #5485] Fix by code review
new 8c9a9d36b [ISSUE #5485] Remove ConsumerManagerInterface and
ProducerManagerInterface
new 4b311ff4d [ISSUE #5485] Use local address, remoting port and grpc port
to build unique local proxy Id
new 373c1bd13 [ISSUE #5485] Fix merge code issue
new bdf5c95ce [ISSUE #5485] Fix ClusterGrpcIT
The 26 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../rocketmq/broker/client/ConsumerManager.java | 2 +-
.../common/attribute/TopicMessageType.java | 17 +
.../rocketmq/common/sysflag/PullSysFlag.java | 4 +
...r.java => FutureTaskExtThreadPoolExecutor.java} | 31 +-
.../rocketmq/common/thread/ThreadPoolMonitor.java | 2 +-
pom.xml | 6 +
proxy/pom.xml | 4 +
.../org/apache/rocketmq/proxy/ProxyStartup.java | 4 +
.../proxy/common/channel/ChannelHelper.java | 49 +++
.../rocketmq/proxy/common/utils/FutureUtils.java | 6 +
.../apache/rocketmq/proxy/config/ProxyConfig.java | 321 +++++++++++++++++-
.../rocketmq/proxy/grpc/GrpcServerBuilder.java | 6 +-
.../proxy/grpc/v2/DefaultGrpcMessingActivity.java | 3 +-
.../proxy/grpc/v2/channel/GrpcChannelManager.java | 7 +-
.../proxy/grpc/v2/channel/GrpcClientChannel.java | 71 +++-
.../proxy/grpc/v2/client/ClientActivity.java | 54 ++-
.../grpc/v2/common/GrpcClientSettingsManager.java | 57 +++-
.../proxy/processor/AbstractProcessor.java | 19 --
.../rocketmq/proxy/processor/ClientProcessor.java | 5 +
.../proxy/processor/DefaultMessagingProcessor.java | 19 ++
.../proxy/processor/MessagingProcessor.java | 8 +
.../proxy/processor/ProducerProcessor.java | 2 +-
.../proxy/processor/ReceiptHandleProcessor.java | 6 +
.../RequestBrokerProcessor.java} | 26 +-
.../channel/ChannelExtendAttributeGetter.java} | 6 +-
.../processor/channel/ChannelProtocolType.java | 24 +-
.../proxy/processor/channel/RemoteChannel.java | 116 +++++++
.../channel/RemoteChannelConverter.java} | 6 +-
.../processor/channel/RemoteChannelSerializer.java | 65 ++++
.../proxy/remoting/ClientHousekeepingService.java | 22 +-
.../remoting/MultiProtocolRemotingServer.java | 82 +++++
.../proxy/remoting/MultiProtocolTlsHelper.java | 113 +++++++
.../proxy/remoting/RemotingProtocolServer.java | 368 +++++++++++++++++++++
.../RemotingProxyOutClient.java} | 9 +-
.../activity/AbstractRemotingActivity.java | 178 ++++++++++
.../activity/AckMessageActivity.java} | 22 +-
.../activity/ChangeInvisibleTimeActivity.java} | 22 +-
.../remoting/activity/ClientManagerActivity.java | 179 ++++++++++
.../remoting/activity/ConsumerManagerActivity.java | 125 +++++++
.../remoting/activity/GetTopicRouteActivity.java | 72 ++++
.../remoting/activity/PopMessageActivity.java | 41 +++
.../remoting/activity/PullMessageActivity.java | 63 ++++
.../remoting/activity/SendMessageActivity.java | 90 +++++
.../remoting/activity/TransactionActivity.java | 68 ++++
.../proxy/remoting/channel/RemotingChannel.java | 231 +++++++++++++
.../remoting/channel/RemotingChannelManager.java | 141 ++++++++
.../common/RemotingConverter.java} | 41 +--
.../remoting/pipeline/AuthenticationPipeline.java | 46 +++
.../proxy/remoting/pipeline/RequestPipeline.java | 20 +-
.../proxy/remoting/protocol/ProtocolHandler.java | 14 +-
.../protocol/ProtocolNegotiationHandler.java | 61 ++++
.../http2proxy/Http2ProtocolProxyHandler.java | 119 +++++++
.../http2proxy/Http2ProxyBackendHandler.java | 67 ++++
.../http2proxy/Http2ProxyFrontendHandler.java | 78 +++++
.../protocol/remoting/RemotingProtocolHandler.java | 60 ++++
.../proxy/service/ClusterServiceManager.java | 29 +-
.../proxy/service/LocalServiceManager.java | 11 +-
.../rocketmq/proxy/service/ServiceManager.java | 3 +
.../rocketmq/proxy/service/admin/AdminService.java | 22 +-
.../proxy/service/admin/DefaultAdminService.java | 146 ++++++++
.../proxy/service/channel/SimpleChannel.java | 13 +
.../service/client/ClusterConsumerManager.java | 69 ++++
.../service/message/ClusterMessageService.java | 34 +-
.../proxy/service/message/LocalMessageService.java | 12 +
.../proxy/service/message/MessageService.java | 6 +
.../sysmessage/AbstractSystemMessageSyncer.java | 182 ++++++++++
.../proxy/service/sysmessage/HeartbeatSyncer.java | 230 +++++++++++++
.../service/sysmessage/HeartbeatSyncerData.java | 176 ++++++++++
.../proxy/service/sysmessage/HeartbeatType.java | 6 +-
.../rocketmq/proxy/grpc/v2/BaseActivityTest.java | 2 +-
.../grpc/v2/channel/GrpcClientChannelTest.java | 82 +++++
.../proxy/processor/channel/RemoteChannelTest.java | 50 +++
.../activity/AbstractRemotingActivityTest.java | 200 +++++++++++
.../remoting/activity/PullMessageActivityTest.java | 165 +++++++++
.../remoting/activity/SendMessageActivityTest.java | 102 ++++++
.../channel/RemotingChannelManagerTest.java | 162 +++++++++
.../remoting/channel/RemotingChannelTest.java | 80 +++++
.../service/admin/DefaultAdminServiceTest.java | 103 ++++++
.../mqclient/ProxyClientRemotingProcessorTest.java | 5 +-
.../service/sysmessage/HeartbeatSyncerTest.java | 319 ++++++++++++++++++
.../remoting/netty/NettyRemotingServer.java | 68 +++-
.../protocol/header/SendMessageRequestHeader.java | 74 -----
.../apache/rocketmq/test/grpc/v2/GrpcBaseIT.java | 1 +
83 files changed, 5323 insertions(+), 307 deletions(-)
copy
common/src/main/java/org/apache/rocketmq/common/thread/{ThreadPoolQueueSizeMonitor.java
=> FutureTaskExtThreadPoolExecutor.java} (52%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/common/channel/ChannelHelper.java
copy
proxy/src/main/java/org/apache/rocketmq/proxy/{service/channel/InvocationContext.java
=> processor/RequestBrokerProcessor.java} (52%)
copy proxy/src/main/java/org/apache/rocketmq/proxy/{config/ConfigFile.java =>
processor/channel/ChannelExtendAttributeGetter.java} (85%)
copy
common/src/main/java/org/apache/rocketmq/common/message/MessageRequestMode.java
=>
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/ChannelProtocolType.java
(73%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannel.java
copy proxy/src/main/java/org/apache/rocketmq/proxy/{config/ConfigFile.java =>
processor/channel/RemoteChannelConverter.java} (85%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelSerializer.java
copy
namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java
=>
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/ClientHousekeepingService.java
(67%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java
copy
proxy/src/main/java/org/apache/rocketmq/proxy/{service/channel/InvocationContextInterface.java
=> remoting/RemotingProxyOutClient.java} (75%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
copy
proxy/src/main/java/org/apache/rocketmq/proxy/{service/mqclient/DoNothingClientRemotingProcessor.java
=> remoting/activity/AckMessageActivity.java} (56%)
copy
proxy/src/main/java/org/apache/rocketmq/proxy/{service/mqclient/DoNothingClientRemotingProcessor.java
=> remoting/activity/ChangeInvisibleTimeActivity.java} (55%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PopMessageActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/TransactionActivity.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManager.java
copy proxy/src/main/java/org/apache/rocketmq/proxy/{grpc/GrpcServer.java =>
remoting/common/RemotingConverter.java} (53%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java
copy
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java
=>
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/RequestPipeline.java
(66%)
copy
test/src/main/java/org/apache/rocketmq/test/clientinterface/MQConsumer.java =>
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolHandler.java
(70%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolNegotiationHandler.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProtocolProxyHandler.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProxyBackendHandler.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProxyFrontendHandler.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/remoting/RemotingProtocolHandler.java
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ProducerTableInfo.java
=>
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/AdminService.java
(59%)
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/DefaultAdminService.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/service/client/ClusterConsumerManager.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerData.java
copy acl/src/main/java/org/apache/rocketmq/acl/AccessResource.java =>
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatType.java
(87%)
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannelTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivityTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivityTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivityTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/service/admin/DefaultAdminServiceTest.java
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java
