CMQ改造为rabbitmq

admin

2024-10-16 bd885c7015446c6c0495d3299ef64068a4c9b30e

CMQ改造为rabbitmq

 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>


 facade-push/src/main/java/com/ks/push/utils/JPushUtil.java

New file
@@ -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 创建跳转的intent
     * @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);
    }


}

 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>



 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")