From 243ee0f0ed98b7115c8db866368b9d7929da47e9 Mon Sep 17 00:00:00 2001 From: shadowsoy Date: Wed, 12 Jun 2024 03:21:13 +0000 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#508]=20=E2=9C=A8Add=20fast=20broker?= =?UTF-8?q?=20server?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-broker/src/broker_runtime.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/rocketmq-broker/src/broker_runtime.rs b/rocketmq-broker/src/broker_runtime.rs index b1008d4b..38fa4f87 100644 --- a/rocketmq-broker/src/broker_runtime.rs +++ b/rocketmq-broker/src/broker_runtime.rs @@ -493,10 +493,16 @@ impl BrokerRuntime { .start() .expect("Message store start error"); - //start broker server + //start nomarl broker server let request_processor = self.init_processor(); + let fast_request_processor = request_processor.clone(); let server = RocketMQServer::new(self.server_config.clone()); tokio::spawn(async move { server.run(request_processor).await }); + //start fast broker server + let mut fast_server_config = (*self.server_config).clone(); + fast_server_config.listen_port = self.server_config.listen_port - 2; + let fast_server = RocketMQServer::new(Arc::new(fast_server_config)); + tokio::spawn(async move { fast_server.run(fast_request_processor).await }); } fn update_namesrv_addr(&mut self) {