我在数据库中有2条记录,因为在其他线程中找不到本地创建和保存的实体。
我的配置是这样的:
@Configuration
@EnableJms
@EnableJpaRepositories
public class MyConfiguration {
@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
configurer.configure(factory, connectionFactory);
factory.setRecoveryInterval(5000);
factory.setSessionTransacted(true);
return factory;
}
}
和此application.properties:
java.naming.factory.initial=weblogic.jndi.WLInitialContextFactory
spring.jms.jndi-name=jms/MyCF
spring.jms.listener.concurrency=5
spring.jms.listener.acknowledge-mode=auto
spring.jms.template.receive-timeout=5000
spring.datasource.jndi-name=jdbc/MyDataSource
spring.jpa.database-platform=org.hibernate.dialect.Oracle10gDialect
spring.jpa.show-sql=false
spring.jpa.properties.hibernate.format_sql=true
spring.jpa.generate-ddl=false
我有带有序列生成器的MyEntity实体
@Getter
@Setter
@Entity
@Table(name = "MY_ENTITY")
public class MyEntity {
@Id
@Column(name = "ID", nullable = false, precision = 0)
@SequenceGenerator(name="SqName", sequenceName="SQ_ID", allocationSize = 1)
@GeneratedValue(strategy=GenerationType.SEQUENCE, generator="SqName")
private long id;
@Basic
@Column(name = "NAME", nullable = true, length = 4000)
private String name;
然后我有我的JMS侦听器:
@JmsListener(destination="jms/MyQueue")
public void onMessage(Message message) throws Exception {
myService.save(myRepository.findOneByName("name1"));
}
然后我有一个MyService类:
@Service
MyServiceImpl implements MyService {
save(MyEntity myEntity) {
if(myEntity == null) myEntity = new MyEntity();
myEntity.setName("name1");
// do something
myRepository.save(myEntity);
}
}
发生了什么情况,当它再次调用save方法时,在一行和一个线程中新创建的实体被保存在myRepository中(本地,尚未在DB中),而在另一行中的另一行中被保存了,它没有找到一个实体名称为“ name1”,所以最后我在数据库中有2条记录为“ name1”。
myRepository.findOneByName("name1") = null;
所以,我应该添加@Transactional批注以将方法保存到MyServicImpl类中还是JmsListener中?
我的意思是,我在MyServiceImpl类的save方法中有@Transactional,虽然它从未发生,但也许只是偶然。
还要在配置中添加JtaTransactionManager吗?
这是实体同名的并发更改,请考虑乐观锁定