From 4601fbc2c8f20497010a7d938a8a051efb88f004 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期二, 19 三月 2024 08:37:39 +0800
Subject: [PATCH] 删除mq示例
---
springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java | 13 ++-----------
1 files changed, 2 insertions(+), 11 deletions(-)
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java b/springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java
index da7ce81..ce0aa92 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/MessageQueueReader.java
@@ -13,28 +13,19 @@
public static void main(String[] args) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
-
List<String> messages = new ArrayList<>();
-
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
boolean autoAck = false;
- // autoAck 鍙傛暟璁剧疆涓� false锛岀劧鍚庢墜鍔ㄧ‘璁ゆ秷鎭鐞嗗畬鎴�
- // 寰幆鑾峰彇闃熷垪涓殑鎵�鏈夋秷鎭�
-// while (true) {
- GetResponse response = channel.basicGet(QUEUE_NAME, autoAck);
+ GetResponse response = channel.basicGet(QUEUE_NAME, autoAck);
if (response != null) {
String message = new String(response.getBody(), "UTF-8");
messages.add(message);
-
// 鎵嬪姩纭娑堟伅澶勭悊瀹屾垚
long deliveryTag = response.getEnvelope().getDeliveryTag();
channel.basicAck(deliveryTag, false);
-// } else {
-// // 濡傛灉闃熷垪涓虹┖锛屽垯閫�鍑哄惊鐜�
-// break;
-// }
+
}
}
--
Gitblit v1.8.0