// 導(dǎo)入必要的類庫
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ā)送消息給庫存服務(wù)進(jìn)行庫存扣減并通知用戶
        rabbitTemplate.convertAndSend("inventory_queue", "deduct");
        // 發(fā)送消息給通知服務(wù)進(jìn)行通知
        rabbitTemplate.convertAndSend("notification_queue", "notify");
        
        System.out.println("訂單已創(chuàng)建，并成功發(fā)送扣減庫存和用戶通知的消息。");
    }
}

public class RegisterService {
    @Autowired
    private RabbitTemplate rabbitTemplate;

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

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