• 每个入口可承接超1万+TPS常驻型Job请求

    如何实现

    • Entrance的WebSocket处理器,内置一个处理线程池和处理队列,接收Spring Cloud Gateway路由转发的上层请求。

    • Job执行池,只用于提交Job,一旦Job提交给了Engine端,则立马放入Job执行队列,保证每个Job占用执行池线程的时间不超过1毫秒。

      RPC请求接收池,用于接收和处理Engine端推来的日志、进度、状态和结果集,并实时更新Job的相关信息。

    • 如何实时将Job的日志、进度和状态推给上层系统?