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/ModuleA.java | 19 ++++++++++++++++---
1 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
index 5a3d2f9..190a1cc 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/ModuleA.java
@@ -2,13 +2,23 @@
import com.rabbitmq.client.*;
+import java.util.HashMap;
+import java.util.Map;
+
public class ModuleA {
- private final static String QUEUE_NAME = "hangzhoumes";
+ private static String QUEUE_NAME = "hangzhou2";
+
+ public ModuleA(String QUEUENAME){
+ QUEUE_NAME=QUEUENAME;
+ }
+
+
public static void main(String[] argv) throws Exception {
// 鍒涘缓杩炴帴宸ュ巶
ConnectionFactory factory = new ConnectionFactory();
- factory.setHost("localhost");
+ factory.setHost("10.153.19.150");
+ // factory.setHost("localhost");
try (Connection connection = factory.newConnection();
//channel 鏄�氳繃 connection 鍒涘缓鐨勪竴涓� AMQP 淇￠亾瀵硅薄
@@ -21,7 +31,10 @@
//4. `false`锛氭寚瀹氭槸鍚﹀湪涓嶅啀浣跨敤鏃惰嚜鍔ㄥ垹闄ら槦鍒椼�傚湪杩欓噷璁剧疆涓篳false`锛岃〃绀哄綋娌℃湁娑堣垂鑰呮垨鑰呮墍鏈夋秷璐硅�呮柇寮�杩炴帴鍚庯紝闃熷垪涓嶄細鑷姩鍒犻櫎銆�
//5. `null`锛氭寚瀹氬叾浠栭槦鍒楀睘鎬х殑鍙傛暟銆傚湪杩欓噷璁剧疆涓篳null`锛岃〃绀烘病鏈夊叾浠栧睘鎬ч渶瑕佽缃��
//鎵ц`channel.queueDeclare()`鏂规硶鍚庯紝濡傛灉闃熷垪涓嶅瓨鍦紝灏嗕細鍒涘缓涓�涓柊鐨勯槦鍒楋紝濡傛灉闃熷垪宸茬粡瀛樺湪锛屽垯涓嶅仛浠讳綍鎿嶄綔銆�
- channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+ Map<String, Object> args = new HashMap<>();
+ args.put("x-max-length", 10000);
+ channel.queueDeclare(QUEUE_NAME, true, false, false, args);
+
--
Gitblit v1.8.0