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