Aqueduct框架中如何将授权中间件获取的用户信息传递至后续请求控制器

核心实现逻辑 #

Aqueduct 的请求管道机制本身就支持跨链路组件的上下文共享：每一次独立请求都会专属创建一个唯一的请求上下文实例，所有通过.link()绑定的管道组件拿到的都是同一个上下文引用，完全不需要额外的全局传参或者特殊的注入逻辑，直接借助上下文自带的共享属性字典，就能把授权中间件生成的信息传递给后续的业务控制器。

具体操作步骤 #

• 第一步：修正链路组件的初始化写法
  你示例中原先的写法没有接收框架自动注入的上下文参数，容易出现跨请求数据串扰、组件间上下文不互通的问题，正确的路由配置应该显式接收链路闭包传入的上下文实例：

  router
    .route('/events/[:id]')
    // 闭包入参即为框架传入的当前请求专属上下文，所有链路组件共享同一个引用
    .link((context) => SecretKeyAuthorizer(context))
    .link((context) => EventsController(context));
  

• 第二步：在授权中间件中将查询到的用户实例挂载到共享上下文
  SecretKeyAuthorizer完成秘钥校验、查询匹配User实例后，不需要通过复杂的返回值结构传递对象，直接将User写入上下文的properties属性字典即可：

  class SecretKeyAuthorizer extends Controller {
    final RequestContext context;
    SecretKeyAuthorizer(this.context);
  
    @override
    Future<Response> handle(Request request) async {
      // 原有逻辑：从请求头提取秘钥、查询匹配的User实例
      final secretKey = request.headers.value('x-secret-key');
      final currentUser = await userRepository.matchBySecretKey(secretKey);
      
      if (currentUser == null) {
        return Response.unauthorized(body: '秘钥校验失败');
      }
  
      // 将已登录User实例存入上下文共享属性，供后续链路组件读取
      context.properties['authenticated_user'] = currentUser;
  
      // 放行请求，流转到下一个链路组件
      return super.handle(request);
    }
  }
  

• 第三步：在业务控制器中直接读取上下文挂载的用户信息
  EventsController因为和授权中间件共享同一个上下文引用，直接从properties字典中取出提前存入的User实例即可使用，不需要在控制器层重复做一次用户查询：

  class EventsController extends Controller {
    final RequestContext context;
    EventsController(this.context);
  
    @Operation.get()
    Future<Response> listUserEvents() async {
      // 直接读取授权中间件存入的User实例
      final currentUser = context.properties['authenticated_user'] as User;
      
      // 正常编写业务逻辑，比如查询当前用户有权限查看的事件列表
      final events = await eventRepository.listAccessibleEvents(currentUser.id);
      return Response.ok(events);
    }
  }
  

优化技巧 #

• 可以针对上下文封装扩展方法，避免每次使用都写重复的类型断言代码，提升可读性：

  extension AuthenticatedUserExtension on RequestContext {
    User get authenticatedUser => properties['authenticated_user'] as User;
  }
  

  封装后控制器内的取值逻辑可以简化为：final currentUser = context.authenticatedUser;

注意事项 #

• 不要使用全局变量存储当前登录用户，Aqueduct基于异步IO多并发处理请求，全局变量会导致不同请求的用户信息互相串扰，所有请求作用域的临时数据必须存入当前请求的上下文属性中
• 不要在链路组件初始化时新建独立的上下文实例，必须使用框架在链路闭包中传入的上下文引用，否则两个组件的上下文完全独立，无法实现属性共享

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