feat(sequence): 添加序列相关接口并更新 AppShareData 结构

- 在 AppShareData 结构中添加 SequenceDbManager 和 SequenceManager
- 新增序列调试接口 /rnacos/debug/sequence/next_id
- 实现获取下一个序列 ID 的功能
- 优化命名服务日志输出

Author: heqingpan

src/common/appdata.rs

@@ -16,6 +16,8 @@ use crate::raft::db::table::TableManager;
 use crate::raft::filestore::core::FileStore;
 use crate::raft::network::factory::RaftClusterRequestSender;
 use crate::raft::NacosRaft;
+use crate::sequence::core::SequenceDbManager;
+use crate::sequence::SequenceManager;
 use crate::transfer::reader::TransferImportManager;
 use crate::transfer::writer::TransferWriterManager;
 use crate::user::UserManager;
@@ -50,4 +52,6 @@ pub struct AppShareData {
     pub transfer_import_manager: Addr<TransferImportManager>,
     pub health_manager: Addr<HealthManager>,
     pub ldap_manager: Addr<LdapManager>,
+    pub sequence_db_manager: Addr<SequenceDbManager>,
+    pub sequence_manager: Addr<SequenceManager>,
 }

src/naming/core.rs

@@ -1110,8 +1110,8 @@ impl Handler<NamingCmd> for NamingActor {
     type Result = anyhow::Result<NamingResult>;
 
     fn handle(&mut self, msg: NamingCmd, ctx: &mut Context<Self>) -> Self::Result {
-        #[cfg(feature = "debug")]
-        log::info!("NamingActor handle:{:?}", &msg);
+        //#[cfg(feature = "debug")]
+        //log::info!("NamingActor handle:{:?}", &msg);
         match msg {
             NamingCmd::Update(instance, tag) => {
                 let tag = self.update_instance(&instance.get_service_key(), instance, tag, false);

src/openapi/debug/mod.rs

@@ -1,10 +1,16 @@
 use actix_web::web;
 
 pub(crate) mod naming_api;
+pub(crate) mod sequence_api;
 
 pub fn debug_config(config: &mut web::ServiceConfig) {
-    config.service(
-        web::resource("/rnacos/debug/naming/common")
-            .route(web::get().to(naming_api::naming_debug_req)),
-    );
+    config
+        .service(
+            web::resource("/rnacos/debug/naming/common")
+                .route(web::get().to(naming_api::naming_debug_req)),
+        )
+        .service(
+            web::resource("/rnacos/debug/sequence/next_id")
+                .route(web::get().to(sequence_api::next_id)),
+        );
 }

src/openapi/debug/sequence_api.rs

@@ -0,0 +1,35 @@
+use crate::common::appdata::AppShareData;
+use crate::common::model::ApiResult;
+use crate::sequence::{SequenceRequest, SequenceResult};
+use actix_web::{web, HttpResponse, Responder};
+use serde::{Deserialize, Serialize};
+use std::sync::Arc;
+
+#[derive(Debug, Deserialize, Serialize)]
+pub struct SequenceParam {
+    pub key: String,
+}
+
+async fn get_next_id(share_data: &Arc<AppShareData>, key: String) -> anyhow::Result<u64> {
+    let result = share_data
+        .sequence_manager
+        .send(SequenceRequest::GetNextId(Arc::new(format!("o_{}", &key))))
+        .await??;
+    match result {
+        SequenceResult::NextId(id) => Ok(id),
+        _ => Err(anyhow::anyhow!("get next id error,key:{}", &key)),
+    }
+}
+
+pub async fn next_id(
+    app_share_data: web::Data<Arc<AppShareData>>,
+    web::Query(param): web::Query<SequenceParam>,
+) -> impl Responder {
+    match get_next_id(&app_share_data, param.key).await {
+        Ok(id) => HttpResponse::Ok().json(ApiResult::success(Some(id))),
+        Err(e) => HttpResponse::Ok().json(ApiResult::<()>::error(
+            "SEQUENCE_ERROR".to_string(),
+            Some(e.to_string()),
+        )),
+    }
+}

src/starter.rs

@@ -14,6 +14,7 @@ use crate::raft::filestore::raftindex::RaftIndexManager;
 use crate::raft::filestore::raftlog::RaftLogManager;
 use crate::raft::filestore::raftsnapshot::RaftSnapshotManager;
 use crate::sequence::core::SequenceDbManager;
+use crate::sequence::SequenceManager;
 use crate::transfer::reader::TransferImportManager;
 use crate::transfer::writer::TransferWriterManager;
 use crate::{
@@ -186,6 +187,10 @@ pub async fn config_factory(sys_config: Arc<AppSysConfig>) -> anyhow::Result<Fac
     factory.register(BeanDefinition::from_obj(raft_request_route));
     let sequence_db_addr = SequenceDbManager::new().start();
     factory.register(BeanDefinition::actor_from_obj(sequence_db_addr.clone()));
+    factory.register(BeanDefinition::actor_with_inject_from_obj(
+        SequenceManager::new().start(),
+    ));
+    factory.register(BeanDefinition::actor_from_obj(sequence_db_addr.clone()));
 
     let raft_data_wrap = Arc::new(RaftDataHandler {
         sequence_db: sequence_db_addr,
@@ -242,6 +247,8 @@ pub fn build_share_data(factory_data: FactoryData) -> anyhow::Result<Arc<AppShar
         transfer_import_manager: factory_data.get_actor().unwrap(),
         health_manager: factory_data.get_actor().unwrap(),
         ldap_manager: factory_data.get_actor().unwrap(),
+        sequence_manager: factory_data.get_actor().unwrap(),
+        sequence_db_manager: factory_data.get_actor().unwrap(),
         factory_data,
     });
     Ok(app_data)