[ISSUE #140]🎨Add Broker bootstrap (#143)

rocketmq-broker/Cargo.toml

@@ -16,6 +16,7 @@ description.workspace = true
 rocketmq-rust = { version = "0.2.0", path = "../rocketmq" }
 rocketmq-common = { version = "0.2.0", path = "../rocketmq-common" }
 rocketmq-remoting = { version = "0.2.0", path = "../rocketmq-remoting" }
+rocketmq-store = { version = "0.2.0", path = "../rocketmq-store" }
 
 anyhow.workspace = true
 env_logger.workspace = true

rocketmq-broker/src/bin/broker_bootstrap_server.rs

@@ -16,12 +16,25 @@
  */
 
 use clap::Parser;
-use rocketmq_broker::command::Args;
+use rocketmq_broker::{broker_controller::BrokerController, command::Args};
+use rocketmq_common::common::broker::broker_config::BrokerConfig;
 use rocketmq_rust::rocketmq;
 
 #[rocketmq::main]
 async fn main() -> anyhow::Result<()> {
     rocketmq_common::log::init_logger();
+    let controller = create_broker_controller()?;
+    start_broker_controller(controller)?;
+    Ok(())
+}
+
+fn create_broker_controller() -> anyhow::Result<BrokerController> {
     let _args = Args::parse();
+    Ok(BrokerController::new(BrokerConfig::default()))
+}
+
+fn start_broker_controller(broker_controller: BrokerController) -> anyhow::Result<()> {
+    let mut broker_controller = broker_controller;
+    broker_controller.start();
     Ok(())
 }

rocketmq-broker/src/broker_controller.rs

@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+use rocketmq_common::common::broker::broker_config::BrokerConfig;
+
+pub struct BrokerController {
+    pub(crate) broker_config: BrokerConfig,
+}
+
+impl BrokerController {
+    pub fn new(broker_config: BrokerConfig) -> Self {
+        Self { broker_config }
+    }
+}
+
+impl BrokerController {
+    pub fn start(&mut self) {}
+}

rocketmq-broker/src/lib.rs

@@ -15,4 +15,6 @@
  * limitations under the License.
  */
 
+#![allow(dead_code)]
+pub mod broker_controller;
 pub mod command;

rocketmq-common/src/common.rs

@@ -28,6 +28,7 @@ pub mod mq_version;
 pub mod namesrv;
 mod sys_flag;
 pub use crate::common::sys_flag::topic_sys_flag as TopicSysFlag;
+pub mod broker;
 pub mod message;
 pub mod topic;
 

rocketmq-common/src/common/broker.rs

@@ -0,0 +1 @@
+pub mod broker_config;

rocketmq-common/src/common/broker/broker_config.rs

@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+use crate::common::mix_all;
+
+#[derive(Debug, Default)]
+pub struct BrokerIdentity {
+    broker_name: String,
+    broker_cluster_name: String,
+    broker_id: u64,
+    is_broker_container: bool,
+    is_in_broker_container: bool,
+}
+
+impl BrokerIdentity {
+    fn new() -> Self {
+        let broker_name = default_broker_name();
+        let broker_cluster_name = String::from("DefaultCluster");
+        let broker_id = mix_all::MASTER_ID;
+        let is_broker_container = false;
+
+        BrokerIdentity {
+            broker_name,
+            broker_cluster_name,
+            broker_id,
+            is_broker_container,
+            is_in_broker_container: false,
+        }
+    }
+
+    fn new_with_container(is_broker_container: bool) -> Self {
+        let mut identity = BrokerIdentity::new();
+        identity.is_broker_container = is_broker_container;
+        identity
+    }
+
+    fn new_with_params(broker_cluster_name: String, broker_name: String, broker_id: u64) -> Self {
+        BrokerIdentity {
+            broker_name,
+            broker_cluster_name,
+            broker_id,
+            is_broker_container: false,
+            is_in_broker_container: false,
+        }
+    }
+
+    fn new_with_container_params(
+        broker_cluster_name: String,
+        broker_name: String,
+        broker_id: u64,
+        is_in_broker_container: bool,
+    ) -> Self {
+        BrokerIdentity {
+            broker_name,
+            broker_cluster_name,
+            broker_id,
+            is_broker_container: true,
+            is_in_broker_container,
+        }
+    }
+}
+
+fn default_broker_name() -> String {
+    // Implement logic to obtain default broker name
+    // For example, use local hostname
+    // ...
+
+    // Placeholder value for demonstration
+    String::from("DefaultBrokerName")
+}
+
+#[derive(Debug, Default)]
+pub struct BrokerConfig {
+    pub broker_identity: BrokerIdentity,
+}