MongoSessionStore.java 文件源码

@Override
public void save(final Session session) {
  syncTtl();

  String id = session.id();
  Bson filter = Filters.eq("_id", id);

  Document doc = new Document()
      .append("_id", id)
      .append("_accessedAt", new Date(session.accessedAt()))
      .append("_createdAt", new Date(session.createdAt()))
      .append("_savedAt", new Date(session.savedAt()));
  // dump attributes
  Map<String, String> attributes = session.attributes();
  attributes.forEach((k, v) -> doc.append(encode(k), v));

  sessions.updateOne(filter, new Document("$set", doc), new UpdateOptions().upsert(true));
}