Tomcat loadbalancing сериализует исключение PersistenceExceptionTranslationInterceptor: исключение отложенной инициализации

ProgramBox

Tomcat loadbalancing сериализует исключение PersistenceExceptionTranslationInterceptor: исключение отложенной инициализации

Post author:admin
Запись опубликована:29 апреля, 2023
Post category:Вопросы по программированию

#java #tomcat #serialization #load-balancing #session-replication

#java #tomcat #сериализация #балансировка нагрузки #сеанс-репликация

Вопрос:

Я должен поместить два сервера tomcat (tcat01 и tcat02) в архитектуру балансировки нагрузки.

Я использую tomcat 6.x и я отредактировал conf/server.xml как это на tomcat tcat01 :

 <Engine name="Catalina" defaultHost="localhost" jvmRoute="tcat01">
     <Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster" channelSendOptions="6"/>
      ....

На tcat02 conf/server.xml похоже на это :

  <Engine name="Catalina" defaultHost="localhost" jvmRoute="tcat02">
     <Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster" channelSendOptions="6"/>
      ....

Я запустил tcat01, а затем tcat02, il catalina.похоже, что tcat01 хорошо взаимодействует с tcat02.

Затем я подключился к веб-приложению с помощью internet navigator, и затем каждый раз, когда я что-то делаю в веб-приложении (я имею в виду, когда я перемещаюсь), возникает это исключение :

   Nov 24, 2011 12:00:13 AM org.apache.catalina.core.ContainerBase backgroundProcess
WARNING: Exception processing manager org.apache.catalina.ha.session.DeltaManager@278c4835 background process
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: com.mycompany.myproject.model.authentification.Authority.groups, no session or session was closed
    at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:383)
    at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationExceptionIfNotConnected(AbstractPersistentCollection.java:375)
    at org.hibernate.collection.AbstractPersistentCollection.initialize(AbstractPersistentCollection.java:368)
    at org.hibernate.collection.AbstractPersistentCollection.read(AbstractPersistentCollection.java:111)
    at org.hibernate.collection.PersistentSet.toString(PersistentSet.java:332)
    at java.io.ObjectOutputStream.writeOrdinaryObject(Unknown Source)
    at java.io.ObjectOutputStream.writeObject0(Unknown Source)
    at java.io.ObjectOutputStream.defaultWriteFields(Unknown Source)
    at java.io.ObjectOutputStream.writeSerialData(Unknown Source)
    at java.io.ObjectOutputStream.writeOrdinaryObject(Unknown Source)

И вот код класса, который не может быть сегментирован (т. Е. java bean, упомянутый в трассировке стека) :

 import static javax.persistence.GenerationType.IDENTITY;

import java.util.HashSet;
import java.util.Set;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.JoinTable;
import javax.persistence.ManyToMany;
import javax.persistence.PrePersist;
import javax.persistence.Table;
import javax.persistence.UniqueConstraint;
import javax.validation.constraints.Pattern;
import javax.validation.constraints.Size;

@Entity
@Table(name = "authority", uniqueConstraints = @UniqueConstraint(columnNames = "name"))
public class Authority implements java.io.Serializable {

/**
 * 
 */
private static final long serialVersionUID = -7436593455923433675L;

//SYSTEM ROLE CONSTANT
public static final String MANAGER_SYSTEM_ROLE = "ROLE_MANAGER";
public static final String CLIENT_SYSTEM_ROLE = "ROLE_CLIENT";
public static final String PEDAGO_ADMIN_SYSTEM_ROLE = "ROLE_PEDAGO_ADMIN";

private Integer id;
@Size(min=1)
@Pattern(regexp="^ROLE[_a-zA-Z] $", message="{authority.name.pattern.error}")
private String name;
@Size(max=65535)
private String description;


private Boolean isSystem;

private Set<Group> groups = new HashSet<Group>(0);

public Authority() {
    this.isSystem = false;
}

public Authority(String name) {
    this.name = name;
    this.isSystem = false;
}

public Authority(String name, String description, Set<Group> groups) {
    this.name = name;
    this.description = description;
    this.groups = groups;
    this.isSystem = false;
}

@Id
@GeneratedValue(strategy = IDENTITY)
@Column(name = "id", unique = true, nullable = false)
public Integer getId() {
    return this.id;
}

public void setId(Integer id) {
    this.id = id;
}

@Column(name = "name", unique = true, nullable = false, length = 45)
public String getName() {
    return this.name;
}

public void setName(String name) {
    this.name = name;
}

@Column(name = "description")
public String getDescription() {
    return this.description;
}

public void setDescription(String description) {
    this.description = description;
}

public void setIsSystem(Boolean isSystem) {
    this.isSystem = isSystem;
}

@Column(name = "system")
public Boolean getIsSystem() {
    return isSystem;
}

@ManyToMany(fetch = FetchType.LAZY)
@JoinTable(name = "group_authorities", joinColumns = { @JoinColumn(name = "authority_id", nullable = false, updatable = true) }, inverseJoinColumns = { @JoinColumn(name = "group_id", nullable = false, updatable = true) })
public Set<Group> getGroups() {
    return this.groups;
}

public void setGroups(Set<Group> groups) {
    this.groups = groups;
}

@PrePersist
protected void updateSystemField() {
    if(isSystem == null)
        isSystem = false;
}
}

И вот код группы java bean (потому что у нас есть исключение ленивой инициализации для коллекции групп) :

 import static javax.persistence.GenerationType.IDENTITY;

import java.util.HashSet;
import java.util.Set;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.JoinTable;
import javax.persistence.ManyToMany;
import javax.persistence.PrePersist;
import javax.persistence.Table;
import javax.persistence.UniqueConstraint;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Size;


@Entity
@Table(name = "groups", uniqueConstraints = @UniqueConstraint(columnNames = "name"))
public class Group implements java.io.Serializable {

/**
 * 
 */
private static final long serialVersionUID = 7380068327050752558L;

private Integer id;
@NotNull
@Size(min=1)
private String name;
private String description;

private Boolean isSystem;

private Set<Authority> authorities = new HashSet<Authority>(0);
private Set<User> users = new HashSet<User>(0);

public Group() {
    this.isSystem = false;
}

public Group(String name) {
    this.name = name;
    this.isSystem = false;
}

public Group(String name, String description, Set<Authority> authorities, Set<User> users) {
    this.name = name;
    this.description = description;
    this.isSystem = false;
    this.authorities = authorities;
    this.users = users;
}

@Id
@GeneratedValue(strategy = IDENTITY)
@Column(name = "id", unique = true, nullable = false)
public Integer getId() {
    return this.id;
}

public void setId(Integer id) {
    this.id = id;
}

@Column(name = "name", unique = true, nullable = false, length = 45)
public String getName() {
    return this.name;
}

public void setName(String name) {
    this.name = name;
}

@Column(name = "description")
public String getDescription() {
    return this.description;
}

public void setDescription(String description) {
    this.description = description;
}

public void setIsSystem(Boolean isSystem) {
    this.isSystem = isSystem;
}

@Column(name = "system")
public Boolean getIsSystem() {
    return isSystem;
}

@ManyToMany(fetch = FetchType.EAGER)
@JoinTable(name = "group_authorities", joinColumns = { @JoinColumn(name = "group_id", nullable = false, updatable = true) }, inverseJoinColumns = { @JoinColumn(name = "authority_id", nullable = false, updatable = true) })
public Set<Authority> getAuthorities() {
    return this.authorities;
}

public void setAuthorities(Set<Authority> authorities) {
    this.authorities = authorities;
}

@ManyToMany(fetch = FetchType.LAZY)
@JoinTable(name = "group_users", joinColumns = { @JoinColumn(name = "group_id", nullable = false, updatable = true) }, inverseJoinColumns = { @JoinColumn(name = "user_id", nullable = false, updatable = true) })
public Set<User> getUsers() {
    return this.users;
}

public void setUsers(Set<User> users) {
    this.users = users;
}

public void addAuthority(Authority authority) {
    if(authorities == null)
        authorities = new HashSet<Authority>(0);
    authorities.add(authority);
}

public boolean removeAuthority(Authority authority) {
    return authorities == null || authorities.remove(authority);
}

public void addUser(User user) {
    if(users == null)
        users = new HashSet<User>(0);
    users.add(user);
}

public boolean removeUser(User user) {
    return users == null || users.remove(user);
}

@PrePersist
protected void updateSystemField() {
    if(isSystem == null)
        isSystem = false;
}
}

Спасибо за вашу помощь

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

2. Вы правы, я нашел в Google опцию «-Dsun.io.serialization.extendedDebugInfo=true» для JVM. Когда я добавил эту опцию, я увидел, какие объекты не могут быть сериализованы. Я не знаю, могу ли я изменить детали моего вопроса в stackoverflow, если я не могу, я создам другой вопрос. О том, какие объекты не могут быть сериализованы: java bean с отложенной коллекцией, на самом деле у меня есть отложенное исключение! Мои отложенные коллекции не могут быть сериализованы, и я не знаю, как решить эту проблему.

3. можете ли вы опубликовать код для объекта, который вы не можете сериализовать, до тех пор, пока объект реализует интерфейс java.io.Serializable, он будет сериализуемым.

4. хорошо, я сделал это, и я отредактировал свой исходный пост, чтобы улучшить трассировку стека (потому что я активировал параметр JVM sun.io.serialization.extendedDebugInfo= true)

5. Я думаю, @ Chris прав, если вы не хотите изменять отображение, тогда посмотрите на Hibernate.initialize после загрузки полномочий выполните инициализацию. javalobby.org/java/forums/t62077.html

Ответ №1:

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

Измените свое отображение, чтобы ассоциация извлекалась быстро
Измените свой DAO, чтобы перейти в эту коллекцию (или используйте hibernate.initialize), чтобы принудительно выполнить отложенную загрузку до закрытия сеанса
Отсоедините объект от сеанса, а затем явно установите для групп значение null для объекта, прежде чем он будет переведен в сеанс, чтобы заменить находящийся там прокси-сервер гибернации.

Для этого конкретного случая варианты 1 или 2, вероятно, самые чистые.

Вопрос:

Комментарии:

Ответ №1:

Вам также может понравиться

jquery запускает функцию c #

Оптимизация Sidekiq, Redis, Heroku и Rails

Как показать коллекцию объектов, которые будут вставлены в базу данных