如何解决在 Quarkus Websocket 中阻塞 IO 线程
我有一个接收数据的 websocket,我想用这些数据做一些数据库操作。这是我的代码的简化版本:
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.event.Event;
import javax.inject.Inject;
import javax.websocket.OnMessage;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/my_socket")
@ApplicationScoped
public class MySocket {
@Inject
Event<MySocketMessage> messageEvent;
@OnMessage
public void onMessage(String message) {
messageEvent.fire(new MySocketMessage(message));
}
}
public class MySocketMessage {
private final String message;
public MySocketMessage(String message) {
this.message = message;
}
public String getMessage() {
return this.message;
}
}
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.event.Observes;
import javax.inject.Inject;
import javax.persistence.EntityManager;
@ApplicationScoped
public class MyDatabaseHandler {
@Inject
EntityManager entityManager;
public void handleMessage(@Observes MySocketMessage message) {
// Do some blocking database operations
Object entity = new Object(message.getMessage());
entityManager.persist(entity);
}
}
在单元测试中执行此代码不会导致任何问题。但是当我运行应用程序时,我得到了这个异常:
2021-07-27 15:35:14,667 ERROR [ch.scs.mbv.veg.web.ScannerSocket] (vert.x-eventloop-thread-7) The my socket encountered the following error: : java.lang.IllegalStateException: You have attempted to perform a blocking operation on a IO thread. This is not allowed,as blocking the IO thread will cause major performance issues with your application. If you want to perform blocking EntityManager operations make sure you are doing it from a worker thread.
at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.checkBlocking(TransactionScopedSession.java:110)
at io.quarkus.hibernate.orm.runtime.session.TransactionScopedSession.persist(TransactionScopedSession.java:134)
at io.quarkus.hibernate.orm.runtime.session.ForwardingSession.persist(ForwardingSession.java:53)
at
...
我知道我不应该在 IO 线程上执行阻塞操作,但我不关心程序的性能,因为它只有一个用户。这也是我没有(也不想)让它具有反应性的原因。快速搜索显示这里已经回答了一个非常相似的问题:blocking EntityManager operations 因此,我尝试将 @Blocking 注释放在代码中的多个位置,但这根本没有任何效果,异常不断弹出。我错过了什么?任何帮助将不胜感激!!!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。