// 導入必要的類庫
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;

public class OrderService {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void createOrder() {
        // 處理創(chuàng)建訂單的邏輯...
        
        // 訂單創(chuàng)建后，發(fā)送消息給庫存服務進行庫存扣減并通知用戶
        rabbitTemplate.convertAndSend("inventory_queue", "deduct");
        // 發(fā)送消息給通知服務進行通知
        rabbitTemplate.convertAndSend("notification_queue", "notify");
        
        System.out.println("訂單已創(chuàng)建，并成功發(fā)送扣減庫存和用戶通知的消息。");
    }
}

public class RegisterService {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void handleRegister() {
        // 負責處理用戶注冊的主要流程...
        
        // 注冊成功后，把發(fā)送歡迎信的任務發(fā)送給消息隊列，異步處理
        rabbitTemplate.convertAndSend("email_service_queue", "sendWelcomeEmail");
        
        System.out.println("用戶注冊成功，歡迎郵件發(fā)送任務已經(jīng)放入消息隊列。");
    }
}

public class EmailService {
    // 消息監(jiān)聽器，負責監(jiān)聽消息隊列，收到消息后發(fā)送歡迎郵件
    public void sendWelcomeEmail(String message) {
        // 實現(xiàn)發(fā)送歡迎郵件的邏輯...
        
        System.out.println("歡迎郵件已經(jīng)發(fā)送成功！");
    }
}