Блог

У меня возникли проблемы с сохранением данных в базе данных, когда я использую сокет java. Я покажу вам ниже …

Этот класс вызывается для создания соединения, когда соединение с клиентом завершено, вызывается прослушиватель

  public Response connect(int port) throws IOException {
    
    this.port = port;
    
    serverSocket = new ServerSocket(this.port);     
    clientSocket = serverSocket.accept();
    
    this.listenClient();        
}
 

Ниже приведен упрощенный пример того, как должна работать сохраняемость в базе данных, когда клиент отправляет сообщение, которое мне нужно сохранить в базе данных, проблема возникает в этом методе прослушивания.

 private void listenClient() throws IOException {

    BufferedReader in = new BufferedReader( new InputStreamReader( 
   clientSocket.getInputStream() ) );

    String line = in.readLine();
    
    while( this.running() amp;amp; !serverSocket.isClosed() )
    {
        if (line != null) {
            
            String msgDecript = decryptData(line);
                        
            Entity entity = new Entity()
            entity.setName(msgDecript);
            entityService.persist(entity);

            line = in.readLine();
        }
    }
}
 

Когда я пытаюсь сохранить объект в списке, это не работает, видите, что я пытаюсь запустить сохранение в прослушивателе, я не знаю, может ли это повлиять на эту проблему.

Если я попытаюсь сохранить эту же сущность где-либо еще в классе, настойчивость работает, только в слушателе настойчивость не работает, только когда я пытаюсь выполнить это действие в слушателе, я не могу сохранить, кто-нибудь имеет представление, что это может быть?

Ошибки на стороне java нет, сохранение, по-видимому, завершено, идентификатор сущности сгенерирован, и запрос выполнен, но база данных застряла на некоторое время, я не могу открыть таблицу в базе данных, затем публикуется ошибка тайм-аута.

Если я вызову EntityManager и попытаюсь сохранить, произойдет та же проблема

 this.entityManager.persist(entity);
this.entityManager.flush();