From d765f491fe415a218975892c6f4651c13764e1f3 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期三, 28 二月 2024 10:51:11 +0800
Subject: [PATCH] 增加实体类、 Mapper，websocket服务类、封装rabbitmq 发送接收等方法
---
UnLoadGlassModule/src/main/java/com/mes/service/ModuleA.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleA.java b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleA.java
index 72999c7..5a21355 100644
--- a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleA.java
+++ b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleA.java
@@ -33,13 +33,13 @@
//5. `null`锛氭寚瀹氬叾浠栭槦鍒楀睘鎬х殑鍙傛暟銆傚湪杩欓噷璁剧疆涓篳null`锛岃〃绀烘病鏈夊叾浠栧睘鎬ч渶瑕佽缃��
//鎵ц`channel.queueDeclare()`鏂规硶鍚庯紝濡傛灉闃熷垪涓嶅瓨鍦紝灏嗕細鍒涘缓涓�涓柊鐨勯槦鍒楋紝濡傛灉闃熷垪宸茬粡瀛樺湪锛屽垯涓嶅仛浠讳綍鎿嶄綔銆�
Map<String, Object> args = new HashMap<>();
- args.put("x-max-length-bytes",20000);
+ args.put("x-max-length-bytes",1024 * 1024);
// args.put("x-max-length",5000);
channel.queueDeclare(QUEUE_NAME, false, false, false, args);
String message = "浣�";
- for ( int i=1;i< 5000;i++)
+ for ( int i=1;i< 20000;i++)
{
message+="浣�";
@@ -52,6 +52,10 @@
// 灏嗘秷鎭彂甯冨埌鎸囧畾鐨勯槦鍒椾腑銆傜┖瀛楃涓�""琛ㄧず榛樿鐨勪氦鎹㈡満锛孮UEUE_NAME鎸囧畾浜嗙洰鏍囬槦鍒楀悕绉帮紝null琛ㄧず娌℃湁鎸囧畾鍏朵粬灞炴�э紝message.getBytes()灏嗘秷鎭唴瀹硅浆鎹负瀛楄妭鏁扮粍杩涜浼犺緭銆�
channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
+
+// DownGlassInfo downGlassInfo = new DownGlassInfo();
+// downGlassInfo.setId(1);
+// System.out.println(" id'" + downGlassInfo.getId() + "'");
}
}
}
--
Gitblit v1.8.0