我正在使用Spring Boot,REST和JPA构建我的应用程序。在应用程序中,有2个具有一对多关系的实体。
实体1:
@Entity
@Table( name = "report")
@JsonIgnoreProperties(ignoreUnknown = true)
public class CustomReport {
@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "REPORT_SEQ")
@SequenceGenerator(sequenceName = "REPORT_SEQ", allocationSize = 1, name = "REPORT_SEQ")
private Long id;
private String name;
private Long createdBy;
private Timestamp lastModifiedTimestamp;
@OneToMany(mappedBy = "customReport", cascade = CascadeType.ALL)
private Set<CustomReportActivity> customReportActivitySet;
public Set<CustomReportActivity> getCustomReportActivitySet() {
return customReportActivitySet;
}
public void setCustomReportActivitySet(Set<CustomReportActivity> customReportActivitySet) {
this.customReportActivitySet = customReportActivitySet;
}
public Long getId() {
return id;
}
public void setId(Long id) { …Run Code Online (Sandbox Code Playgroud) 我正在使用 @RabbitListener 注释和 SimpleRabbitListenerContainerFactory bean 并行执行rabbitmq 消息并通过以下方式设置最小和最大并发消费者:
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory());
factory.setConcurrentConsumers(MIN_RABBIT_CONCURRENT_CONSUMERS);
factory.setMaxConcurrentConsumers(MAX_RABBIT_CONCURRENT_CONSUMERS);
factory.setConsecutiveActiveTrigger(1);
factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
return factory;
}
Run Code Online (Sandbox Code Playgroud)
最小限制为 3,最大限制为 10。使用此配置,即使队列中有 12 条消息,也只有 3 条消息并行执行。
请告诉我配置有什么问题?
spring ×2
spring-boot ×2
amazon-s3 ×1
java ×1
jpa ×1
one-to-many ×1
rabbitmq ×1
spring-amqp ×1
task ×1