From bd885c7015446c6c0495d3299ef64068a4c9b30e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 15:00:34 +0800
Subject: [PATCH] CMQ改造为rabbitmq

---
 facade-push/src/main/java/com/ks/push/utils/JPushUtil.java                  |   25 ++++++++++++
 service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java |   31 ++++++++++-----
 facade-push/pom.xml                                                         |    2 
 pom.xml                                                                     |    6 +++
 4 files changed, 53 insertions(+), 11 deletions(-)

diff --git a/facade-push/pom.xml b/facade-push/pom.xml
index 506bcb4..eaa4a59 100644
--- a/facade-push/pom.xml
+++ b/facade-push/pom.xml
@@ -8,7 +8,7 @@
     <!--<version>0.0.1-SNAPSHOT</version>-->
     <!--</parent>-->
     <modelVersion>4.0.0</modelVersion>
-    <version>0.0.1-SNAPSHOT</version>
+    <version>0.0.2-SNAPSHOT</version>
     <groupId>com.ks</groupId>
     <artifactId>facade-push</artifactId>
 
diff --git a/facade-push/src/main/java/com/ks/push/utils/JPushUtil.java b/facade-push/src/main/java/com/ks/push/utils/JPushUtil.java
new file mode 100644
index 0000000..7754c03
--- /dev/null
+++ b/facade-push/src/main/java/com/ks/push/utils/JPushUtil.java
@@ -0,0 +1,25 @@
+package com.ks.push.utils;
+
+/**
+ * @author hxh
+ * @title: JPushUtil
+ * @description: 鏋佸厜鎺ㄩ�佸府鍔╃被
+ * @date 2022/5/5 11:03
+ */
+public class JPushUtil {
+
+
+    /**
+     * @return java.lang.String
+     * @author hxh
+     * @description 鍒涘缓璺宠浆鐨刬ntent
+     * @date 11:05 2022/5/5
+     * @param: activity
+     * @param: packageName
+     **/
+    public static String createIntent(String activity, String packageName) {
+        return String.format("intent:#Intent;component=%s/%s;end", packageName, activity.startsWith(packageName) ? activity.replace(packageName, "") : activity);
+    }
+
+
+}
diff --git a/pom.xml b/pom.xml
index d08c831..dc861fd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -51,6 +51,12 @@
             <name>nexus</name>
             <url>http://193.112.35.168:8889/nexus/content/groups/public/</url>
         </repository>
+
+        <repository>
+            <id>nexus-local</id>
+            <name>nexus-local</name>
+            <url>http://193.112.35.168:8889/nexus/content/repositories/thirdparty/</url>
+        </repository>
     </repositories>
 
 
diff --git a/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java b/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
index a94001f..71c8470 100644
--- a/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
+++ b/service-push/src/main/java/com/ks/push/manager/rabbitmq/RabbitmqConfig.java
@@ -9,6 +9,7 @@
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.lang.Nullable;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -22,44 +23,54 @@
 @Configuration
 public class RabbitmqConfig {
 
-    @Bean
-    public Queue tokenInvalidQueue() {
-        return new Queue("bpush-token-invalid");
+
+    private Queue createQueue(String queueName) {
+        Map<String, Object> arguments = new HashMap<>();
+        // 璁剧疆娑堟伅鐨勬湁鏁堟椂闂�
+        arguments.put("x-message-ttl", 1000 * 60 * 60 * 24L);
+        return new Queue(queueName, true, false, false, arguments);
     }
 
     @Bean
+    public Queue tokenInvalidQueue() {
+        return createQueue("bpush-token-invalid");
+    }
+
+
+
+    @Bean
     public Queue xmPushQueue() {
-        return new Queue("bpush-xm");
+        return createQueue("bpush-xm");
     }
 
     @Bean
     public Queue vivoPushQueue() {
-        return new Queue("bpush-vivo");
+        return createQueue("bpush-vivo");
     }
 
     @Bean
     public Queue oppoPushQueue() {
-        return new Queue("bpush-oppo");
+        return createQueue("bpush-oppo");
     }
 
     @Bean
     public Queue mzPushQueue() {
-        return new Queue("bpush-mz");
+        return createQueue("bpush-mz");
     }
 
     @Bean
     public Queue ipushPushQueue() {
-        return new Queue("bpush-jpush");
+        return createQueue("bpush-jpush");
     }
 
     @Bean
     public Queue huaweiPushQueue() {
-        return new Queue("bpush-huawei");
+        return createQueue("bpush-huawei");
     }
 
     @Bean
     public Queue testQueue() {
-        return new Queue("test");
+        return createQueue("test");
     }
 
     @Bean("pluginDelayExchange")

--
Gitblit v1.8.0