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/ModuleB.java | 57 +++++++++++++++++++++++++++++++--------------------------
1 files changed, 31 insertions(+), 26 deletions(-)
diff --git a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
index f4c49d7..a258779 100644
--- a/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
+++ b/UnLoadGlassModule/src/main/java/com/mes/service/ModuleB.java
@@ -1,38 +1,43 @@
package com.mes.service;
-import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.ConnectionFactory;
-import com.rabbitmq.client.DeliverCallback;
-
-import java.util.HashMap;
-import java.util.Map;
+import com.mes.common.RabbitMQUtils;
public class ModuleB {
private final static String QUEUE_NAME = "hangzhou2";
public static void main(String[] argv) throws Exception {
- // 鍒涘缓杩炴帴宸ュ巶
- ConnectionFactory factory = new ConnectionFactory();
- factory.setHost("10.153.19.150");
- //factory.setHost("localhost");
- try (Connection connection = factory.newConnection();
- Channel channel = connection.createChannel()) {
- // 澹版槑闃熷垪
- Map<String, Object> args = new HashMap<>();
- args.put("x-max-length-bytes",20000);
-// args.put("x-max-length",5000);
- channel.queueDeclare(QUEUE_NAME, false, false, false, args);
- // 鍒涘缓娑堣垂鑰�
- DeliverCallback deliverCallback = (consumerTag, delivery) -> {
- String receivedMessage = new String(delivery.getBody(), "UTF-8");
- System.out.println(" [x] Received '" + receivedMessage + "'");
- };
- // 寮�濮嬫秷璐规秷鎭�
- channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {
- });
+
+
+ RabbitMQUtils receiver = new RabbitMQUtils();
+
+ try {
+ String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
+ System.out.println("Received message: " + receivedMessage);
+ } catch (Exception e) {
+ e.printStackTrace();
}
+// // 鍒涘缓杩炴帴宸ュ巶
+// ConnectionFactory factory = new ConnectionFactory();
+// factory.setHost("10.153.19.150");
+// //factory.setHost("localhost");
+// try (Connection connection = factory.newConnection();
+// Channel channel = connection.createChannel()) {
+// // 澹版槑闃熷垪
+// Map<String, Object> args = new HashMap<>();
+// args.put("x-max-length-bytes",1024 * 1024);
+//// args.put("x-max-length",5000);
+// channel.queueDeclare(QUEUE_NAME, false, false, false, args);
+//
+// // 鍒涘缓娑堣垂鑰�
+// DeliverCallback deliverCallback = (consumerTag, delivery) -> {
+// String receivedMessage = new String(delivery.getBody(), "UTF-8");
+// System.out.println(" [x] Received '" + receivedMessage + "'");
+// };
+// // 寮�濮嬫秷璐规秷鎭�
+// channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {
+// });
+// }
}
}
--
Gitblit v1.8.0