ApiBoot Message Push 初版集成.

Author: hengboy

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/pom.xml

@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright [2019] [恒宇少年 - 于起宇]
+  ~
+  ~      Licensed under the Apache License, Version 2.0 (the "License");
+  ~      you may not use this file except in compliance with the License.
+  ~      You may obtain a copy of the License at
+  ~
+  ~          http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~      Unless required by applicable law or agreed to in writing, software
+  ~      distributed under the License is distributed on an "AS IS" BASIS,
+  ~      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~      See the License for the specific language governing permissions and
+  ~      limitations under the License.
+  ~
+  -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>api-boot-plugins</artifactId>
+        <groupId>org.minbox.framework</groupId>
+        <version>2.0.5.RC1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <properties>
+        <main.basedir>${basedir}/../../..</main.basedir>
+    </properties>
+    <description>
+        ApiBoot 消息推送组件集成，目前集成：
+        1. 极光推送
+    </description>
+    <artifactId>api-boot-plugin-message-push</artifactId>
+    <dependencies>
+        <!--ApiBoot Plugin-->
+        <dependency>
+            <groupId>org.minbox.framework</groupId>
+            <artifactId>api-boot-plugin</artifactId>
+        </dependency>
+        <!--JPush Client-->
+        <dependency>
+            <groupId>cn.jpush.api</groupId>
+            <artifactId>jpush-client</artifactId>
+        </dependency>
+        <!--SpringBoot Aop-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/src/main/java/org/minbox/framework/api/boot/plugin/message/push/ApiBootMessagePushService.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright [2019] [恒宇少年 - 于起宇]
+ *
+ *      Licensed under the Apache License, Version 2.0 (the "License");
+ *      you may not use this file except in compliance with the License.
+ *      You may obtain a copy of the License at
+ *
+ *          http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *      Unless required by applicable law or agreed to in writing, software
+ *      distributed under the License is distributed on an "AS IS" BASIS,
+ *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *      See the License for the specific language governing permissions and
+ *      limitations under the License.
+ *
+ */
+
+package org.minbox.framework.api.boot.plugin.message.push;
+
+import org.minbox.framework.api.boot.common.exception.ApiBootException;
+import org.minbox.framework.api.boot.plugin.message.push.model.MessagePushBody;
+import org.minbox.framework.api.boot.plugin.message.push.model.PushClientConfig;
+
+/**
+ * ApiBoot Message Push Service
+ *
+ * @author：恒宇少年 - 于起宇
+ * <p>
+ * DateTime：2019-04-20 15:40
+ * Blog：http://blog.yuqiyu.com
+ * WebSite：http://www.jianshu.com/u/092df3f77bca
+ * Gitee：https://gitee.com/hengboy
+ * GitHub：https://github.com/hengboy
+ */
+public interface ApiBootMessagePushService {
+    /**
+     * execute push message
+     *
+     * @param messagePushBody request body
+     * @throws ApiBootException ApiBoot Exception
+     */
+    void executePush(MessagePushBody messagePushBody) throws ApiBootException;
+
+    /**
+     * get current thread push client name
+     *
+     * @return push client name
+     * @throws ApiBootException ApiBoot Exception
+     */
+    String getCurrentPushClientName() throws ApiBootException;
+
+    /**
+     * get current thread push client
+     *
+     * @return push message client
+     * @throws ApiBootException ApiBoot Exception
+     */
+    PushClientConfig getCurrentPushClient() throws ApiBootException;
+}

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/src/main/java/org/minbox/framework/api/boot/plugin/message/push/annotation/MessagePushSwitch.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright [2019] [恒宇少年 - 于起宇]
+ *
+ *      Licensed under the Apache License, Version 2.0 (the "License");
+ *      you may not use this file except in compliance with the License.
+ *      You may obtain a copy of the License at
+ *
+ *          http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *      Unless required by applicable law or agreed to in writing, software
+ *      distributed under the License is distributed on an "AS IS" BASIS,
+ *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *      See the License for the specific language governing permissions and
+ *      limitations under the License.
+ *
+ */
+
+package org.minbox.framework.api.boot.plugin.message.push.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ * ApiBoot Message Push Switch
+ * Used to configure push client information
+ *
+ * @author：恒宇少年 - 于起宇
+ * <p>
+ * DateTime：2019-04-20 16:19
+ * Blog：http://blog.yuqiyu.com
+ * WebSite：http://www.jianshu.com/u/092df3f77bca
+ * Gitee：https://gitee.com/hengboy
+ * GitHub：https://github.com/hengboy
+ */
+@Target({ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface MessagePushSwitch {
+    /**
+     * jpush client name
+     *
+     * @return client name
+     */
+    String value() default "default";
+}

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/src/main/java/org/minbox/framework/api/boot/plugin/message/push/aop/advistor/ApiBootMessagePushClientSwitchAdvisor.java

@@ -0,0 +1,87 @@
+/*
+ * Copyright [2019] [恒宇少年 - 于起宇]
+ *
+ *      Licensed under the Apache License, Version 2.0 (the "License");
+ *      you may not use this file except in compliance with the License.
+ *      You may obtain a copy of the License at
+ *
+ *          http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *      Unless required by applicable law or agreed to in writing, software
+ *      distributed under the License is distributed on an "AS IS" BASIS,
+ *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *      See the License for the specific language governing permissions and
+ *      limitations under the License.
+ *
+ */
+
+package org.minbox.framework.api.boot.plugin.message.push.aop.advistor;
+
+import org.aopalliance.aop.Advice;
+import org.minbox.framework.api.boot.plugin.message.push.annotation.MessagePushSwitch;
+import org.minbox.framework.api.boot.plugin.message.push.aop.interceptor.ApiBootMessagePushSwitchAnnotationInterceptor;
+import org.springframework.aop.Pointcut;
+import org.springframework.aop.support.AbstractPointcutAdvisor;
+import org.springframework.aop.support.annotation.AnnotationMatchingPointcut;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.BeanFactory;
+import org.springframework.beans.factory.BeanFactoryAware;
+import org.springframework.util.Assert;
+
+/**
+ * ApiBoot DataSource Switch
+ *
+ * @author：恒宇少年 - 于起宇
+ * <p>
+ * DateTime：2019-04-01 16:29
+ * Blog：http://blog.yuqiyu.com
+ * WebSite：http://www.jianshu.com/u/092df3f77bca
+ * Gitee：https://gitee.com/hengboy
+ * GitHub：https://github.com/hengboy
+ */
+public class ApiBootMessagePushClientSwitchAdvisor extends AbstractPointcutAdvisor implements BeanFactoryAware {
+
+    private Advice advice;
+    private Pointcut pointcut;
+    private BeanFactory beanFactory;
+
+    /**
+     * init config
+     */
+    public ApiBootMessagePushClientSwitchAdvisor(ApiBootMessagePushSwitchAnnotationInterceptor apiBootMessagePushSwitchAnnotationInterceptor) {
+        // build pointcut instance
+        this.pointcut = buildPointcut();
+        // build advice instance
+        this.advice = apiBootMessagePushSwitchAnnotationInterceptor;
+        if (this.advice instanceof BeanFactoryAware) {
+            ((BeanFactoryAware) this.advice).setBeanFactory(beanFactory);
+        }
+    }
+
+    @Override
+    public Pointcut getPointcut() {
+        Assert.notNull(this.pointcut, "pointcut is required.");
+        return this.pointcut;
+    }
+
+    @Override
+    public Advice getAdvice() {
+        Assert.notNull(this.advice, "advice is required.");
+        return this.advice;
+    }
+
+    @Override
+    public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
+        this.beanFactory = beanFactory;
+    }
+
+    /**
+     * build pointcut instance
+     */
+    private Pointcut buildPointcut() {
+        // method
+        Pointcut mpc = AnnotationMatchingPointcut.forMethodAnnotation(MessagePushSwitch.class);
+        return mpc;
+    }
+
+}

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/src/main/java/org/minbox/framework/api/boot/plugin/message/push/aop/holder/MessagePushContextHolder.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright [2019] [恒宇少年 - 于起宇]
+ *
+ *      Licensed under the Apache License, Version 2.0 (the "License");
+ *      you may not use this file except in compliance with the License.
+ *      You may obtain a copy of the License at
+ *
+ *          http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *      Unless required by applicable law or agreed to in writing, software
+ *      distributed under the License is distributed on an "AS IS" BASIS,
+ *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *      See the License for the specific language governing permissions and
+ *      limitations under the License.
+ *
+ */
+
+package org.minbox.framework.api.boot.plugin.message.push.aop.holder;
+
+import org.springframework.util.Assert;
+
+/**
+ * Message Push Context Holer
+ *
+ * @author：恒宇少年 - 于起宇
+ * <p>
+ * DateTime：2019-04-20 16:33
+ * Blog：http://blog.yuqiyu.com
+ * WebSite：http://www.jianshu.com/u/092df3f77bca
+ * Gitee：https://gitee.com/hengboy
+ * GitHub：https://github.com/hengboy
+ */
+public class MessagePushContextHolder {
+    /**
+     * current thread data source pool name
+     */
+    private static ThreadLocal<String> MESSAGE_PUSH_CLIENT_NAME = new ThreadLocal();
+
+    /**
+     * setting current thread pool name
+     *
+     * @param dataSourcePoolName datasource pool name
+     */
+    public static void set(String dataSourcePoolName) {
+        Assert.notNull(dataSourcePoolName, "DataSource pool name is required.");
+        MESSAGE_PUSH_CLIENT_NAME.set(dataSourcePoolName);
+    }
+
+    /**
+     * get current thread pool name
+     *
+     * @return data source pool name
+     */
+    public static String get() {
+        return MESSAGE_PUSH_CLIENT_NAME.get();
+    }
+
+    /**
+     * remove current thread pool name
+     */
+    public static void remove() {
+        MESSAGE_PUSH_CLIENT_NAME.remove();
+    }
+}

api-boot-project/api-boot-plugins/api-boot-plugin-message-push/src/main/java/org/minbox/framework/api/boot/plugin/message/push/aop/interceptor/ApiBootMessagePushSwitchAnnotationInterceptor.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright [2019] [恒宇少年 - 于起宇]
+ *
+ *      Licensed under the Apache License, Version 2.0 (the "License");
+ *      you may not use this file except in compliance with the License.
+ *      You may obtain a copy of the License at
+ *
+ *          http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *      Unless required by applicable law or agreed to in writing, software
+ *      distributed under the License is distributed on an "AS IS" BASIS,
+ *      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *      See the License for the specific language governing permissions and
+ *      limitations under the License.
+ *
+ */
+
+package org.minbox.framework.api.boot.plugin.message.push.aop.interceptor;
+
+import org.aopalliance.intercept.MethodInterceptor;
+import org.aopalliance.intercept.MethodInvocation;
+import org.minbox.framework.api.boot.plugin.message.push.annotation.MessagePushSwitch;
+import org.minbox.framework.api.boot.plugin.message.push.aop.holder.MessagePushContextHolder;
+import org.springframework.aop.support.AopUtils;
+import org.springframework.core.BridgeMethodResolver;
+import org.springframework.util.ClassUtils;
+
+import java.lang.reflect.Method;
+
+/**
+ * ApiBoot DataSource Advice
+ * use spring aop
+ *
+ * @author：恒宇少年 - 于起宇
+ * <p>
+ * DateTime：2019-04-01 16:44
+ * Blog：http://blog.yuqiyu.com
+ * WebSite：http://www.jianshu.com/u/092df3f77bca
+ * Gitee：https://gitee.com/hengboy
+ * GitHub：https://github.com/hengboy
+ */
+public class ApiBootMessagePushSwitchAnnotationInterceptor implements MethodInterceptor {
+
+    @Override
+    public Object invoke(MethodInvocation invocation) throws Throwable {
+        try {
+            Class<?> targetClass = (invocation.getThis() != null ? AopUtils.getTargetClass(invocation.getThis()) : null);
+            Method specificMethod = ClassUtils.getMostSpecificMethod(invocation.getMethod(), targetClass);
+            Method declaredMethod = BridgeMethodResolver.findBridgedMethod(specificMethod);
+
+            MessagePushSwitch messagePushSwitch = declaredMethod.getDeclaredAnnotation(MessagePushSwitch.class);
+            // set current thread message push config name
+            MessagePushContextHolder.set(messagePushSwitch.value());
+            return invocation.proceed();
+        } finally {
+            // remove current thread use message push config name
+            MessagePushContextHolder.remove();
+        }
+
+    }
+}