Играть 2.1. WebSocket Нет EntityManager, привязанного к этому потоку

Я пытаюсь реализовать WebSocket в Play 2.1. framework вместе с JPA с использованием Hibernate, и я получаю следующее исключение при доступе к БД из WebSocket:

java.lang.RuntimeException: No EntityManager bound to this thread. Try to annotate your action method with @play.db.jpa.Transactional
at play.db.jpa.JPA.em(JPA.java:42)
at model.operations.DistrictOperations.isOwner(DistrictOperations.java:15)
at controllers.security.Secured.isOwnerOf(Secured.java:28)
at controllers.DistrictCommunication.initWebSocket(DistrictCommunication.java:157)
at Routes$$anonfun$routes$1$$anonfun$applyOrElse$20$$anonfun$apply$20.apply(routes_routing.scala:277)
at Routes$$anonfun$routes$1$$anonfun$applyOrElse$20$$anonfun$apply$20.apply(routes_routing.scala:277)
at play.core.j.JavaWebSocket$$anonfun$webSocketWrapper$1$$anonfun$apply$1.apply(JavaWebSocket.scala:20)
at play.core.j.JavaWebSocket$$anonfun$webSocketWrapper$1$$anonfun$apply$1.apply(JavaWebSocket.scala:14)
at play.core.server.netty.PlayDefaultUpstreamHandler.liftedTree1$1(PlayDefaultUpstreamHandler.scala:324)
at play.core.server.netty.PlayDefaultUpstreamHandler.messageReceived(PlayDefaultUpstreamHandler.scala:322)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:75)
at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:565)
at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:793)
at org.jboss.netty.handler.codec.http.HttpContentDecoder.messageReceived(HttpContentDecoder.java:104)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:75)
at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:565)
at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:793)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:296)
at org.jboss.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:455)
at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:538)
at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:437)
at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:75)
at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:565)
at org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:560)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:84)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.processSelectedKeys(AbstractNioWorker.java:472)
at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:333)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
at org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:102)
at org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:680)

Вот мой код:

@Transactional(readOnly = true)
public static WebSocket<JsonNode> initWebSocket(final long id) {

    if (Secured.isOwnerOf(id)) {

        return new WebSocket<JsonNode>() {

            // Called when the Websocket Handshake is done.
            public void onReady(WebSocket.In<JsonNode> in,
                    WebSocket.Out<JsonNode> out) {



                // For each event received on the socket,
                in.onMessage(new Callback<JsonNode>() {
                    public void invoke(JsonNode event) {


                        System.out.println(event);

                    }
                });

                // When the socket is closed.
                in.onClose(new Callback0() {
                    public void invoke() {

                        System.out.println("Disconnected");

                    }
                });

                // Send a single 'Hello!' message
                ObjectNode on = Json.newObject();
                on.put("greeting", "hello");
                out.write(on);
            }

        };

    }else{
        return null;
    }

защищенный метод isOwnerOf():

public static boolean isOwnerOf(Long district) {
    return DistrictOperations.isOwner(district, Context.current().request().username());
}

и метод DistrictOperations.isOwner():

@Transactional(readOnly = true)
public static boolean isOwner(long district, String login){
    Query query = JPA.em().createQuery("SELECT d FROM  District d WHERE d.id = :districtId");   
    District d = (District) query.setParameter("districtId", district).getSingleResult();
    return d.getName().equals(login);
}

Он советует мне добавить аннотацию @Transactional, которая у меня есть в моем коде, поэтому мой вопрос: возможно ли как-то получить доступ к базе данных через EntityManager из WebSocket? Потому что мне кажется, что все остальное, кроме EntityManager, здесь работает нормально.

EDIT Я даже пытался использовать EntityManager внутри WebSocket, но у меня все та же проблема. Так что, может быть, небольшая переформулировка заключается в том, как я должен работать с базой данных, используя WebSocket и JPA? Можно ли как-то использовать оба вместе?

Заранее спасибо.


person ziky90    schedule 10.05.2013    source источник


Ответы (1)


В игре WebSocket не является Action. Аннотация @Transactional не учитывается, поскольку play.db.jpa.TransactionalAction перехватывает только Action вызовов.

В вашем случае вам нужно вручную поместить свой код в транзакцию с чем-то вроде:

boolean isOwnerOf = JPA.withTransaction(new play.libs.F.Function0<Boolean>{
    public Boolean apply() throws Throwable {
        return Secured.isOwnerOf(id);
    }
})

Вам придется сделать то же самое, если вам нужно получить доступ к БД в других обратных вызовах вашего веб-сокета. Эти обратные вызовы будут выполняться в других потоках, и JPA.withTransaction() позаботится о привязке EntityManager к этим потокам.

person mguillermin    schedule 13.05.2013
comment
это применимо, если я пишу разные потоки в методе контроллера? потому что у меня такое же исключение, когда я создаю новый поток, чтобы ускорить процесс. Исключением является java.lang.RuntimeException: EntityManager не привязан к этому потоку. Попробуйте обернуть этот вызов в JPAApi.withTransaction или убедитесь, что tpi.withTransaction, - person Prashanth Debbadwar; 09.10.2017