From e9bfa1396ff47d171b3052a606e0931e6f93cc9c Mon Sep 17 00:00:00 2001
From: houzhongjian <houzhongyi@126.com>
Date: 星期四, 10 四月 2025 12:05:23 +0800
Subject: [PATCH] 还原framework代码
---
iailab-framework/iailab-common-websocket/src/main/java/com/iailab/framework/websocket/core/sender/rabbitmq/RabbitMQWebSocketMessageConsumer.java | 39 +++++++++++++++++++++++++++++++++++++++
1 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/iailab-framework/iailab-common-websocket/src/main/java/com/iailab/framework/websocket/core/sender/rabbitmq/RabbitMQWebSocketMessageConsumer.java b/iailab-framework/iailab-common-websocket/src/main/java/com/iailab/framework/websocket/core/sender/rabbitmq/RabbitMQWebSocketMessageConsumer.java
new file mode 100644
index 0000000..9505bfb
--- /dev/null
+++ b/iailab-framework/iailab-common-websocket/src/main/java/com/iailab/framework/websocket/core/sender/rabbitmq/RabbitMQWebSocketMessageConsumer.java
@@ -0,0 +1,39 @@
+package com.iailab.framework.websocket.core.sender.rabbitmq;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.amqp.core.ExchangeTypes;
+import org.springframework.amqp.rabbit.annotation.*;
+
+/**
+ * {@link RabbitMQWebSocketMessage} 广播消息的消费者，真正把消息发送出去
+ *
+ * @author iailab
+ */
+@RabbitListener(
+ bindings = @QueueBinding(
+ value = @Queue(
+ // 在 Queue 的名字上，使用 UUID 生成其后缀。这样，启动的 Consumer 的 Queue 不同，以达到广播消费的目的
+ name = "${iailab.websocket.sender-rabbitmq.queue}" + "-" + "#{T(java.util.UUID).randomUUID()}",
+ // Consumer 关闭时，该队列就可以被自动删除了
+ autoDelete = "true"
+ ),
+ exchange = @Exchange(
+ name = "${iailab.websocket.sender-rabbitmq.exchange}",
+ type = ExchangeTypes.TOPIC,
+ declare = "false"
+ )
+ )
+)
+@RequiredArgsConstructor
+public class RabbitMQWebSocketMessageConsumer {
+
+ private final RabbitMQWebSocketMessageSender rabbitMQWebSocketMessageSender;
+
+ @RabbitHandler
+ public void onMessage(RabbitMQWebSocketMessage message) {
+ rabbitMQWebSocketMessageSender.send(message.getSessionId(),
+ message.getUserType(), message.getUserId(),
+ message.getMessageType(), message.getMessageContent());
+ }
+
+}
--
Gitblit v1.9.3