RabbitMQ的簡單模式怎么實現

這篇文章主要介紹了RabbitMQ的簡單模式怎么實現的相關知識，內容詳細易懂，操作簡單快捷，具有一定借鑒價值，相信大家閱讀完這篇RabbitMQ的簡單模式怎么實現文章都會有所收獲，下面我們一起來看看吧。

Springboot RabbitMQ 簡單模式

生產者聲明隊列并向隊列發送消息

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.core.Queue；
導入 org.springframework.context.annotation.Bean；
導入 org.springframework.context.annotation.Configuration；
@Configuration public class RabbitSimpleProvider { 
    @Bean 
    public Queue simpleQueue() { 
        return new Queue(RabbitConstant.SIMPLE_QUEUE_NAME); 
    } 
}

消費者監聽隊列并消費消息

導入 com.example.rabbitmq.constant.RabbitConstant；
導入 org.springframework.amqp.rabbit.annotation.RabbitHandler；
導入 org.springframework.amqp.rabbit.annotation.RabbitListener；
導入 org.springframework.stereotype.Component；
@Component public class RabbitSimpleConsumer { 
    @RabbitHandler 
    @RabbitListener(queues = RabbitConstant.SIMPLE_QUEUE_NAME) 
    public void simpleListener(String context) { 
        System.out.println("rabbit receiver: " + context); 
    } 
}

單元測試

@Test public void simple() { 
    rabbitTemplate.convertAndSend(RabbitConstant.SIMPLE_QUEUE_NAME, "hello world!"); 
}

響應結果

關于“RabbitMQ的簡單模式怎么實現”這篇文章的內容就介紹到這里，感謝各位的閱讀！相信大家對“RabbitMQ的簡單模式怎么實現”知識都有一定的了解，大家如果還想學習更多知識，歡迎關注億速云行業資訊頻道。