[ISSUE #2424]Bump rand from 0.8.5 to 0.9.0 (#2425)

mxsm · Jan 30, 2025 · 2bd684e · 2bd684e
1 parent d0a2cdf
commit 2bd684e
Show file tree

Hide file tree

Showing 11 changed files with 113 additions and 67 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -56,7 +56,7 @@ serde_json = "1.0"
 serde_json_any_key = "2.0.0"
 anyhow = "1.0.95"
 bytes = "1.9.0"
-rand = "0.8"
+rand = "0.9.0"
 lazy_static = "1.5.0"
 num_cpus = "1.16"
 

diff --git a/rocketmq-broker/Cargo.toml b/rocketmq-broker/Cargo.toml
@@ -40,7 +40,7 @@ bytes = { workspace = true }
 parking_lot.workspace = true
 
 clap = { version = "4.5.27", features = ["derive"] }
-rand = "0.8.5"
+rand = { workspace = true }
 
 #tools
 dirs.workspace = true

diff --git a/rocketmq-broker/src/processor/pop_message_processor.rs b/rocketmq-broker/src/processor/pop_message_processor.rs
@@ -27,7 +27,6 @@ use std::sync::Arc;
 use bytes::Bytes;
 use bytes::BytesMut;
 use cheetah_string::CheetahString;
-use rand::thread_rng;
 use rand::Rng;
 use rocketmq_common::common::config::TopicConfig;
 use rocketmq_common::common::constant::consume_init_mode::ConsumeInitMode;
@@ -489,7 +488,7 @@ where
             (subscription_data, None)
         };
 
-        let randomq = thread_rng().gen_range(0..100);
+        let randomq = rand::rng().random_range(0..100);
         let revive_qid = if request_header.order.unwrap_or(false) {
             POP_ORDER_REVIVE_QUEUE
         } else {