From 7ae0f94bb63f16369fdb1e177ba4994fdf983ab4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=89=AF=28004796=29?= Date: Fri, 29 Dec 2023 18:46:55 +0800 Subject: [PATCH] =?UTF-8?q?websocket=20=E6=95=B4=E5=90=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ruoyi-admin/src/main/resources/application-dev.yml | 8 +++++--- .../main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java | 9 +++++++-- .../cai/ws/handler/message/RefuseMessageHandler.java | 2 +- 3 files changed, 13 insertions(+), 6 deletions(-) diff --git a/ruoyi-admin/src/main/resources/application-dev.yml b/ruoyi-admin/src/main/resources/application-dev.yml index f1cea25a..67a0f4ef 100644 --- a/ruoyi-admin/src/main/resources/application-dev.yml +++ b/ruoyi-admin/src/main/resources/application-dev.yml @@ -164,9 +164,11 @@ sms: territory: ap-guangzhou spring: rabbitmq: - addresses: 127.0.0.1 #ip地址 - username: admin # 账号 - password: admin # 密码 + addresses: 124.222.254.188 #ip地址 + username: admin # 账号 + password: 383200134 # 密码 + port: 5672 + virtual-host: /cai agora: app-id: app key: key diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java index 1aee875f..17edd4ae 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/mq/CheckTimeOutMqConfig.java @@ -4,6 +4,8 @@ import org.springframework.amqp.core.*; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import java.util.HashMap; + @Configuration public class CheckTimeOutMqConfig { @@ -14,10 +16,13 @@ public class CheckTimeOutMqConfig { @Bean public CustomExchange delayedExchange() { + HashMap args = new HashMap<>(); + args.put("x-delayed-type", "direct"); return new CustomExchange(EXCHANGE_NAME, "x-delayed-message", // 消息类型 true, // 是否持久化 - false); // 是否自动删除 + false,// 是否自动删除 + args); } @Bean @@ -29,7 +34,7 @@ public class CheckTimeOutMqConfig { @Bean public Binding delayedBinding(Queue delayedQueue,CustomExchange delayedExchange) { - return BindingBuilder.bind(delayedQueue).to(delayedExchange).with(ROUTING_KEY).noargs(); + return BindingBuilder.bind(delayedQueue()).to(delayedExchange()).with(ROUTING_KEY).noargs(); } } diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/RefuseMessageHandler.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/RefuseMessageHandler.java index 05c6c14b..c63d46d3 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/RefuseMessageHandler.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/RefuseMessageHandler.java @@ -22,7 +22,7 @@ import org.springframework.stereotype.Component; /** * 被叫方拒绝通话 */ -@Component("cancalltime") +@Component("refuse") public class RefuseMessageHandler extends AbstractMessageHandle implements IMessageHandler { @Autowired private RoomDataCache roomDataCache;