Перехватчики/фильтры в спрее

Question

Я занят переносом одного из наших приложений Spring/Groovy на Spray/Scala. Я довольно новичок в Spray, так что простите меня, если это вопрос для начинающих.

Целью является эмулировать наш регистрационный перехватчик, который регистрирует различные данные для каждого запроса/ответа. В этой части кода существует довольно много логики, поэтому это не простая строка журнала. Кроме того, я хотел бы обернуть ВСЕ запросы, которые входят в эту логику.

Существующие Groovy/Spring Interceptor:

boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler { 
    //do some logging logic 
} 


void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { 
    //do some more logging logic 
} 

Мой Scala актер выглядит так

class BootServiceActor extends Actor with ViewingController with LazyLogging with ViewingWire { 

def actorRefFactory = context 

implicit val ctx = context.dispatcher 

def receive = runRoute(route)(exceptionHandler, RejectionHandler.Default, context, 
    RoutingSettings.default, LoggingContext.fromActorRefFactory) 
} 

Answer 1

Одна из больших пунктов продажи Spray/Scala является то, что вы можете избежать "магии", невидимый такие вещи, как перехватчики. Вы достигаете одних и тех же вещей, используя типы и/или директивы, но все, что вы делаете, становится видимым в коде и рефакторинге благодаря системе типов. Например. вы можете использовать scalaz Writer для накопления сообщений журнала, связанных с конкретным запросом, а затем определить «метамаршаллер», который предоставил Marshaller[Writer[MyLogStructure, A]] для любого A, который имел существующий маршаллер, и написал все журналы для этого конкретного запроса в правильной структуре , Я рад углубиться в этот подход, если хотите.

«Предварительно обработанная» часть, вероятно, лучше всего обрабатывается простым Directive; так как спрей реагирует и асинхронно, на самом деле нет концепции сопряженной обработки «до и после». Скорее, вы делаете что-то для запроса и передаете его на следующий шаг обработки, который в конечном итоге отправит ответ. Если вам нужно передать какой-то «контекст» через пре-дескриптор в пост-дескриптор, снова это, вероятно, лучше всего сделать с «типом контекста» (я стараюсь избегать говорить страшное слово m), например State.

Answer 2

Решение I осуществляется на основе ввода LMM в

я в конечном итоге делает пользовательские директивы, то вдоль этих линий:

trait LoggingDirectives { 

    val logger = LoggerFactory.getLogger(classOf[LoggingDirective]) 

    import spray.routing.directives.BasicDirectives._ 

    def logResponseInfo(user : String): Directive0 = 
    mapRouteResponse { response ⇒ 
     //... 
     logger.info("RESPONSE >> "+user+":"+response) 
     response 
    } 

    def logRequestInfo: Directive0 = 
    mapRequest { request ⇒ 
     //... 
     logger.info("REQUEST << " + request); 
     request 
    } 
} 

Я тогда обернутый вокруг моего маршрута:

val route = logRequestInfo { 
    accountAuthenicationValidator { profileId:String => 
    logResponseInfo(profileId) { 
     controllerRoute(profileId) 
    } 
    } 
} 

где accountAuthenicationValidator - другая настраиваемая директива, а controllerRoute - основной маршрут, который обрабатывает ВСЕ paths и является (String => Route)