为什么亚马逊sqs不支持交易？

Question

对不起.我又加了一些内容。我在Spring中测试了两个消息队列(rabbitmq、amazon sqs)，如下所示。

我的目的是逻辑处理用户电子邮件到队列发送注册完成电子邮件时，用户完成注册无一例外。

//rabbit mq configuration.class
@Bean
public ConnectionFactory rabbitConnectionFactory() {
    CachingConnectionFactory connectionFactory =
            new CachingConnectionFactory("localhost",5672);
    connectionFactory.setUsername("guest");
    connectionFactory.setPassword("guest");
    return connectionFactory;
}

@Bean
public SimpleMessageListenerContainer messageListenerContainer() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(rabbitConnectionFactory());
    container.setQueueNames(queue);
   container.setMessageListener(exampleListener());
    container.setTransactionManager(platformTransactionManager);
    container.setChannelTransacted(true);
    return container;
}


@Bean
public RabbitTemplate producerRabbitTemplate() {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(rabbitConnectionFactory());
    rabbitTemplate.setQueue(queue);
    rabbitTemplate.setMandatory(true);
    rabbitTemplate.isChannelTransacted();
    rabbitTemplate.setChannelTransacted(true);
    return rabbitTemplate;
}



//UserService.class
@Autowired
private final UserRepository userRepository;
@Autowired
private final RabbitTemplate rabbitTemplate;

@Transactional
public User createUser(final User user){
    rabbitTemplate.convertAndSend("spring-boot", user.getEmail()); // SignUp Completion email
    final User user = userRepository.save(user);
    if(true) throw new RuntimeException();
    return user;
}

但是，上面的逻辑发生RuntimeException。

//amazon sqs configuration.class
@Bean
public QueueMessagingTemplate queueMessagingTemplate(AmazonSQSAsync amazonSqs) {

//UserService.class
@Autowired
private final UserRepository userRepository;
@Autowired
private QueueMessagingTemplate messagingTemplate;


@Transactional
public User createUser(final User user){
    messagingTemplate.convertAndSend("spring-boot", user.getEmail()); // SignUp Completion email
    final User user = userRepository.save(user);
    if(true) throw new RuntimeException();
    return user;
}

有人知道这是为什么吗？

Answer 1

我如何解决这个问题？

不要试图为此使用事务，想出一些方法来使系统最终保持一致。

听起来像是要像执行事务一样执行'Queue.SendMessage'和'Repository.Save'-要么都提交，要么都不提交。问题是“transaction”实际上并不是事务性的，即使在rabbit示例中也是如此。

null

@Transactional
public User createUser(final User user){
    messagingTemplate.convertAndSend("spring-boot", user.getEmail());
    final User user = userRepository.save(user);
    return user;
}

• 当为此启动提交步骤时，它需要使消息（在队列中）和用户（在回购中）都可见
• 为此，需要对队列和repo进行网络调用
  • 这是两个调用这一事实是问题的根源
  • 您可能会说“事务可以回滚”--但回滚将涉及另一个网络调用，这当然会失败。

  有一些方法可以使整个分布式系统事务化，但这是一个非常复杂的问题。允许暂时的不一致性，并建立机制使系统最终保持一致，通常会容易得多，速度也快得多。