warp Session存储数据不持久问题及相关技术咨询

我正在练习搭建服务器后端，尝试使用warp_sessions::MemoryStore存储数据，参考warp_sessions/examples/shared_mutable_session示例开发。目前能将数据写入会话并立即读取（代码中的_a和_b变量），但跨请求调用时数据无法持久化，连续调用处理器时_a_pre和_b_pre变量返回空字符串。

现咨询以下问题：

1. 我哪里操作出错了？
2. 若要在不同路由使用同一会话，像warp示例中那样传递session_store.clone()，会话修改能否被保存？目前我未使用克隆实例但数据仍丢失，需在多路由共享数据。
3. warp_sessions文档指出MemoryStore不适合生产环境，生产环境应使用什么替代方案？

我的代码 #

路由处理器函数 #

pub async fn verify_handler(body: warp::hyper::body::Bytes, mut session_with_store:SessionWithStore<MemoryStore> ) -> Result<(Html<String>, SessionWithStore<MemoryStore>), Rejection>  {

  session_with_store.cookie_options = warp_sessions::CookieOptions {
    cookie_name: "siwe_minimal",
    cookie_value: None,
    max_age:Some(3600),
    domain: None,
    path: None,
    secure: true,
    http_only: true,
    same_site: Some(SameSiteCookieOption::Strict),
  };
  
  let shared_session = Arc::new(RwLock::new(session_with_store.session));
 
  let _a_pre: String = shared_session
      .read()
      .unwrap()
      .get("nonce")  
      .unwrap_or_default();

  shared_session
      .write()
      .unwrap()
      .insert("nonce", nonce )   
      .unwrap();
    
  let _a: String = shared_session
      .read()
      .unwrap()
      .get("nonce")  
      .unwrap();

  let msgstr = message.to_string();

  let _b_pre: String = shared_session
  .read()
  .unwrap()
  .get("siwe")  
  .unwrap_or_default(); 

  shared_session
      .write()
      .unwrap()
      .insert("siwe", msgstr)  
      .unwrap();

       
  let _b: String = shared_session
  .read()
  .unwrap()
  .get("siwe")  
  .unwrap();

   
  session_with_store.session = Arc::try_unwrap(shared_session)
      .unwrap()
      .into_inner()
      .unwrap(); 


  Ok::<_, Rejection>(
    (
      warp::reply::html("req".to_string()),
      session_with_store
    )
  )

}

路由定义 #

let session_store = MemoryStore::new();
let verify_route 
    = warp::path("verify")
    .and(warp::post())
    .and(warp::body::bytes())
    .and(warp_sessions::request::with_session(session_store, None))
    .and_then( verify_handler)
    .untuple_one()
    .and_then(warp_sessions::reply::with_session)
    .recover(handle_rejection)
    .with(&cors); 

1. 操作错误分析 #

核心问题有两点：

• 存储实例未复用：在路由定义的with_session(session_store, None)中，你直接传递了session_store的所有权，而非克隆实例。这导致存储实例被移动到路由过滤器后无法复用，每个新请求都会创建全新的会话存储，跨请求自然无法保留数据。
• 冗余的会话包装：处理器中手动用Arc<RwLock>包装会话是多余的，warp_sessions的SessionWithStore已经内置了会话的共享访问逻辑，直接操作session_with_store.session即可，这步包装不会影响持久化，但属于无用代码。

2. 多路由共享会话的正确性 #

使用session_store.clone()是完全正确的：

• MemoryStore内部基于Arc实现，克隆操作是轻量的，所有路由会共享同一个底层存储实例。只要在每个路由的with_session中传递session_store.clone()，不同路由的会话修改都会保存到同一个存储中，跨请求、跨路由都能读取到更新后的数据。
• 你之前数据丢失的根本原因是存储实例被移动后无法复用，每个请求使用的都是全新存储，而非共享实例。

3. 生产环境替代方案 #

MemoryStore是内存存储，进程重启或多实例部署时数据会丢失，生产环境可选择以下方案：

• Redis存储：使用warp_sessions_redis crate提供的RedisStore，基于Redis实现分布式会话存储，支持多实例共享，性能和可靠性适配生产场景。
• 数据库存储：自定义实现SessionStore trait，将会话数据存储到PostgreSQL、MySQL等关系型数据库，或MongoDB等NoSQL数据库，适合需要持久化会话且有数据关联需求的场景。
• 分布式键值存储：基于Consul、etcd等分布式键值存储实现会话存储，适合微服务架构下的分布式场景。

内容的提问来源于stack exchange，提问作者Chris