SpringAMQP消息隊列實戰(zhàn)教程
更新時間:2024年02月27日 11:46:42 作者:zhyaw56zhu
這篇文章主要介紹了SpringAMQP消息隊列的相關知識,本文通過實例代碼給大家介紹的非常詳細,感興趣的朋友一起看看吧
安裝RabbitMQ
在linux上安裝RabbitMQ,并運行
docker run \ -e RABBITMQ_DEFAULT_USER=zywzy \ -e RABBITMQ_DEFAULT_PASS=123321 \ --name mq \ --hostname mq1 \ -p 15672:15672 \ -p 5672:5672 \ -d \ rabbitmq:3-management
http://ip:15672 訪問控制臺, 用戶名zywzy,密碼123321
引入依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>配置文件
spring:
rabbitmq:
host: 172.27.99.52 # rabbitMQ的ip地址
port: 5672 # 端口
username: abc
password: 123321
virtual-host: /發(fā)送消息
@SpringBootTest
public class SpringAmqpTest {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testSendMessage2SimpleQueue() {
String queueName = "simple.queue";
String message = "hello, spring amqp!";
rabbitTemplate.convertAndSend(queueName, message);
}
}消費消息
@RabbitListener(queues = "simple.queue")
public void listenWorkQueue1(String msg) throws InterruptedException {
System.out.println("消費者1接收到消息:【" + msg + "】" + LocalTime.now());
}消息預取
每次只能取一條消息,處理完成才能取下一條消息
spring:
rabbitmq:
listener:
simple:
prefetch: 1到此這篇關于SpringAMQP消息隊列的文章就介紹到這了,更多相關SpringAMQP消息隊列內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
SpringBoot3.x使用es進行數(shù)據(jù)查詢的方式
SpringBoot3中,Elasticsearch的版本升級至8.x,相關寫法有所改變,SpringBoot2中的ElasticsearchRestTemplate已被移除,推薦使用ElasticsearchTemplate或ElasticsearchClient進行交互,本文介紹這兩個類的使用方式,并說明了依賴引入和自動裝配的配置,感興趣的朋友一起看看吧2025-12-12
javaweb實現(xiàn)百度GPS定位接口(經(jīng)緯度)
這篇文章主要介紹了javaweb實現(xiàn)百度GPS定位接口(經(jīng)緯度),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-02-02

