Quarkus CDI上下文与Kotlin协程

Question

我试图将一些Hibernate/Hibernate搜索调用卸载到另一个线程，但我收到的错误表明CDI没有在该线程中正确设置。

我已经看过这本指南了https://quarkus.io/guides/context-propagation，但没有提到科特林合作项目。

有什么方法可以通过协同程序进行上下文传播吗？

我正在用

val entityReferences = withContext(Dispatchers.IO ) {
    //hibernate code here
}

javax.enterprise.context.ContextNotActiveException
    at io.quarkus.arc.impl.ClientProxies.getDelegate(ClientProxies.java:40)
    at io.quarkus.hibernate.orm.runtime.RequestScopedSessionHolder_ClientProxy.arc$delegate(RequestScopedSessionHolder_ClientProxy.zig:42)
    at io.quarkus.hibernate.orm.runtime.RequestScopedSessionHolder_ClientProxy.getOrCreateSession(RequestScopedSessionHolder_ClientProxy.zig:102)
    at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.acquireSession(TransactionScopedSession.java:104)
    at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.createQuery(TransactionScopedSession.java:376)
    at io.quarkus.hibernate.orm.runtime.session.ForwardingSession.createQuery(ForwardingSession.java:188)
    at io.quarkus.hibernate.orm.runtime.session.ForwardingSession.createQuery(ForwardingSession.java:47)
    at org.hibernate.Session_5b93bee577ae2f8d76647de04cfab36afbf52958_Synthetic_ClientProxy.createQuery(Session_5b93bee577ae2f8d76647de04cfab36afbf52958_Synthetic_ClientProxy.zig:927)

Answer 1

我通过创建一个定制的协同程序上下文，成功地将请求范围的上下文附加到线程。

class RequestContextElement(private val controller: RequestContextController) : ThreadContextElement<Boolean>, AbstractCoroutineContextElement(Key) {
    companion object Key : CoroutineContext.Key<RequestContextElement>
    override fun updateThreadContext(context: CoroutineContext) = controller.activate()
    override fun restoreThreadContext(context: CoroutineContext, oldState: Boolean) = controller.deactivate()
}

将RequestContextController注入到创建协同路由的bean中。

@Inject
protected lateinit var requestContextController: RequestContextController

然后将自定义上下文添加到协同程序上下文中

val entityReferences = withContext(Dispatchers.IO + RequestContextElement(requestContextController)) {
// Hibernate code
}

我使用了以下资源

• https://codingwithmohit.com/coroutines/custom-coroutine-context-uses-cases/
• https://rmannibucau.metawerx.net/cdi-2.0-request-scope-controller.html

如果有必要，第一个资源也可能是传播事务的一些帮助。