Bibliothèques Akka et Java utilisant ThreadLocals

Ce qui m’a empêché d’utiliser Akka régulièrement (en Java), c’est un problème que j’ai avec les bibliothèques qui utilisent ThreadLocals.

C’est-à-dire que certains répartiteurs d’Akka risquent de laisser les variables ThreadLocal ou de les laisser disparaître. La solution évidente serait donc d’éviter d’utiliser ThreadLocals, mais il y a tellement de bibliothèques qui les utilisent: Spring, Wro4j, Log4j, etc etc …

Les ThreadLocals fonctionnent normalement bien dans le conteneur de servlet. En effet, même si les conteneurs ont des pools de threads, la requête correspond principalement à un cycle de vie synchrone. Ainsi, généralement, à la fin d’une requête, des éléments comme Spring et Wro4J nettoient leurs threadlocals. Certains conteneurs comme Tomcat surveillent même les fuites de threadlocal.

D’après ce que j’ai compris, ce n’est pas le cas à Akka.

• Dans Akka, quel est le moyen recommandé d’accéder aux parameters de configuration depuis un UntypedActor
• Meilleures pratiques avec Akka dans Scala et des bibliothèques Java tierces
• Java 8 MapReduce pour l’informatique dissortingbuée
• Comment appeler correctement le client HTTP Akka pour plusieurs demandes (10 000 à 100 000)?
• Solution pour «UntypedActor» déconseillée dans Akka (Java) Tutorial

Comment les gens résolvent-ils ce problème?

Pour l’instant, j’évite simplement d’utiliser Akka et d’utiliser une file de messages (comme RabbitMQ ou ActiveMQ), mais j’aimerais utiliser Akka car il couvre un plus large éventail de problèmes / solutions asynchrones.

Je pense aussi que Netty a des problèmes similaires, mais je pense que Netty propose un object de type Contexte de canal que vous pouvez utiliser à la place de ThreadLocal et, en théorie, certaines bibliothèques peuvent savoir l’utiliser à la place de ThreadLocal.

• Quelles sont les différences entre Akka et Netty en plus de leur choix de langue (Scala vs Java)?
• Comment puis-je transformer un futur futur en un object futur?
• Comment planifier une tâche quotidienne + onStart () dans Play 2.0.4?
• Scala Futures et java 8 CompletableFuture
• threads akka jvm vs threads os lors de l’exécution de io

def withSecurityContext[T](thunk: => T)(implicit secCtx: SecurityContextFetcher): T = { val old = threadLocalSecurityContext.get threadLocalSecurityContext.set(secCtx.fetch) try thunk finally threadLocalSecurityContext.set(old) } 

 class MyActor extends Actor { def receive = { case "foo" => withSecurityContext { beAwesome() } } }