diff --git a/CHANGELOG.md b/CHANGELOG.md index f78f5319f..2f825cb31 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -22,3 +22,4 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - **refactor(common):** Replace `lazy_static!` with `std::sync::LazyLock` in `broker_config.rs` ([#5056](https://github.com/mxsm/rocketmq-rust/issues/5056)) - **refactor(remoting):** Replace `lazy_static!` with `std::sync::LazyLock` in `remoting_command.rs` and remove `lazy_static` dependency from `rocketmq-remoting` ([#5060](https://github.com/mxsm/rocketmq-rust/issues/5060)) - **perf(ArcMut):** Add the `#[inline]` attribute to the `mut_from_ref`, `downgrade`, and `get_inner` methods for `ArcMut`, improving performance ([#2876](https://github.com/mxsm/rocketmq-rust/pull/2876)) +- **chore(controller):** Update default controller listen address to use port 60109 ([#5527](https://github.com/mxsm/rocketmq-rust/issues/5527)) diff --git a/rocketmq-common/src/common/controller/controller_config.rs b/rocketmq-common/src/common/controller/controller_config.rs index 229a42f9d..c42cdb43a 100644 --- a/rocketmq-common/src/common/controller/controller_config.rs +++ b/rocketmq-common/src/common/controller/controller_config.rs @@ -241,7 +241,7 @@ impl Default for ControllerConfig { metrics_in_delta: false, config_black_list: "configBlackList;configStorePath".to_string(), node_id: 1, - listen_addr: "127.0.0.1:9876".parse().unwrap(), + listen_addr: "127.0.0.1:60109".parse().unwrap(), raft_peers: Vec::new(), election_timeout_ms: 1000, heartbeat_interval_ms: 300, @@ -418,7 +418,7 @@ impl ControllerConfig { /// Test config helper pub fn test_config() -> Self { - Self::default().with_node_info(1, "127.0.0.1:9876".parse().unwrap()) + Self::default().with_node_info(1, "127.0.0.1:60109".parse().unwrap()) } /// Check if a configuration key is in the blacklist diff --git a/rocketmq-controller/examples/controller_metrics_example.rs b/rocketmq-controller/examples/controller_metrics_example.rs index 4b309cc40..3538a1110 100644 --- a/rocketmq-controller/examples/controller_metrics_example.rs +++ b/rocketmq-controller/examples/controller_metrics_example.rs @@ -37,7 +37,7 @@ async fn main() { // 1. Initialize controller configuration println!("1. Initializing controller configuration..."); - let config = Arc::new(ControllerConfig::new_node(1, "127.0.0.1:9876".parse().unwrap())); + let config = Arc::new(ControllerConfig::new_node(1, "127.0.0.1:60109".parse().unwrap())); // 2. Initialize metrics manager (singleton) println!("2. Initializing metrics manager..."); diff --git a/rocketmq-controller/examples/single_node.rs b/rocketmq-controller/examples/single_node.rs index 2d7a2670b..a8ba8769a 100644 --- a/rocketmq-controller/examples/single_node.rs +++ b/rocketmq-controller/examples/single_node.rs @@ -40,7 +40,7 @@ async fn main() -> Result<(), Box> { // Step 1: Create configuration println!("1. Creating node configuration..."); let node_id = 1; - let listen_addr = "127.0.0.1:9876".parse()?; + let listen_addr = "127.0.0.1:60109".parse()?; let config = Arc::new( ControllerConfig::new_node(node_id, listen_addr)