Spring RabbitMQ：事务管理

使用Spring和RabbitMQ可以轻松地实现事务管理，这对于保证数据的完整性和一致性非常重要。在本文中，我们将介绍如何使用Spring和RabbitMQ来管理事务，并提供一个案例代码来演示其用法。

xml
    
    
        org.springframework.boot
        spring-boot-starter-amqp
    
    
    
        org.springframework.boot
        spring-boot-starter-data-amqp
    

properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

java
@Configuration
public class RabbitMQConfig {
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost("localhost");
        connectionFactory.setPort(5672);
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        return connectionFactory;
    }
    @Bean
    public Queue queue() {
        return new Queue("myQueue");
    }
}

java
@Service
public class MyService {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Transactional
    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("myQueue", message);
    }
    @Transactional
    public String receiveMessage() {
        Object message = rabbitTemplate.receiveAndConvert("myQueue");
        return message != null ? message.toString() : null;
    }
}

java
@RestController
public class MyController {
    @Autowired
    private MyService myService;
    @PostMapping("/sendMessage")
    public void sendMessage(@RequestBody String message) {
        myService.sendMessage(message);
    }
    @GetMapping("/receiveMessage")
    public String receiveMessage() {
        return myService.receiveMessage();
    }
}