msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

阿里巴巴代码规约扫描修改.

Browse Source
pull/110/head
chen.ma 3 years ago
parent c9dbeaab3b
commit 0f3287403d
18 changed files with 70 additions and 70 deletions
Show Stats Download Patch File Download Diff File

2
hippo4j-config/src/main/java/cn/hippo4j/config/event/Event.java → hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractEvent.java
Unescape View File

@ -9,7 +9,7 @@ import java.util.concurrent.atomic.AtomicLong;
* @author chen.ma
* @date 2021/6/23 18:59
*/
public abstract class Event implements Serializable {
public abstract class AbstractEvent implements Serializable {
private static final AtomicLong SEQUENCE = new AtomicLong(0);

2
hippo4j-config/src/main/java/cn/hippo4j/config/event/SlowEvent.java → hippo4j-config/src/main/java/cn/hippo4j/config/event/AbstractSlowEvent.java
Unescape View File

@ -6,7 +6,7 @@ package cn.hippo4j.config.event;
* @author chen.ma
* @date 2021/6/23 19:05
*/
public abstract class SlowEvent extends Event {
public abstract class AbstractSlowEvent extends AbstractEvent {
@Override
public long sequence() {

2
hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java
Unescape View File

@ -8,7 +8,7 @@ import org.springframework.util.StringUtils;
* @author chen.ma
* @date 2021/6/24 23:35
*/
public class ConfigDataChangeEvent extends Event {
public class ConfigDataChangeEvent extends AbstractEvent {
public final String tenantId;

2
hippo4j-config/src/main/java/cn/hippo4j/config/event/LocalDataChangeEvent.java
Unescape View File

@ -6,7 +6,7 @@ package cn.hippo4j.config.event;
* @author chen.ma
* @date 2021/6/23 19:13
*/
public class LocalDataChangeEvent extends Event {
public class LocalDataChangeEvent extends AbstractEvent {
/**
* 租户+项目+线程池

22
hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java
Unescape View File

@ -1,8 +1,8 @@
package cn.hippo4j.config.notify;
import cn.hippo4j.config.event.AbstractEvent;
import cn.hutool.core.collection.ConcurrentHashSet;
import cn.hippo4j.config.notify.listener.Subscriber;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.notify.listener.AbstractSubscriber;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.CollectionUtils;
@ -20,9 +20,9 @@ import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
@Slf4j
public class DefaultPublisher extends Thread implements EventPublisher {
protected final ConcurrentHashSet<Subscriber> subscribers = new ConcurrentHashSet();
protected final ConcurrentHashSet<AbstractSubscriber> subscribers = new ConcurrentHashSet();
private BlockingQueue<Event> queue;
private BlockingQueue<AbstractEvent> queue;
private volatile boolean initialized = false;
@ -36,7 +36,7 @@ public class DefaultPublisher extends Thread implements EventPublisher {
.newUpdater(DefaultPublisher.class, Long.class, "lastEventSequence");
@Override
public void init(Class<? extends Event> type, int bufferSize) {
public void init(Class<? extends AbstractEvent> type, int bufferSize) {
setDaemon(true);
setName("dynamic.thread-pool.publisher-" + type.getName());
this.queueMaxSize = bufferSize;
@ -80,7 +80,7 @@ public class DefaultPublisher extends Thread implements EventPublisher {
if (shutdown) {
break;
}
final Event event = queue.take();
final AbstractEvent event = queue.take();
receiveEvent(event);
UPDATER.compareAndSet(this, lastEventSequence, Math.max(lastEventSequence, event.sequence()));
}
@ -90,12 +90,12 @@ public class DefaultPublisher extends Thread implements EventPublisher {
}
@Override
public void addSubscriber(Subscriber subscriber) {
public void addSubscriber(AbstractSubscriber subscriber) {
subscribers.add(subscriber);
}
@Override
public boolean publish(Event event) {
public boolean publish(AbstractEvent event) {
boolean success = this.queue.offer(event);
if (!success) {
log.warn("Unable to plug in due to interruption, synchronize sending time, event :: {}", event);
@ -106,7 +106,7 @@ public class DefaultPublisher extends Thread implements EventPublisher {
}
@Override
public void notifySubscriber(Subscriber subscriber, Event event) {
public void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event) {
final Runnable job = () -> subscriber.onEvent(event);
final Executor executor = subscriber.executor();
@ -126,8 +126,8 @@ public class DefaultPublisher extends Thread implements EventPublisher {
return !CollectionUtils.isEmpty(subscribers);
}
void receiveEvent(Event event) {
for (Subscriber subscriber : subscribers) {
void receiveEvent(AbstractEvent event) {
for (AbstractSubscriber subscriber : subscribers) {
notifySubscriber(subscriber, event);
}
}

18
hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultSharePublisher.java
Unescape View File

@ -1,9 +1,9 @@
package cn.hippo4j.config.notify;
import cn.hippo4j.config.event.AbstractEvent;
import cn.hutool.core.collection.ConcurrentHashSet;
import cn.hippo4j.config.notify.listener.Subscriber;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.SlowEvent;
import cn.hippo4j.config.notify.listener.AbstractSubscriber;
import cn.hippo4j.config.event.AbstractSlowEvent;
import java.util.Map;
import java.util.Set;
@ -19,21 +19,21 @@ import java.util.concurrent.locks.ReentrantLock;
*/
public class DefaultSharePublisher extends DefaultPublisher {
private final Map<Class<? extends SlowEvent>, Set<Subscriber>> subMappings = new ConcurrentHashMap();
private final Map<Class<? extends AbstractSlowEvent>, Set<AbstractSubscriber>> subMappings = new ConcurrentHashMap();
protected final ConcurrentHashSet<Subscriber> subscribers = new ConcurrentHashSet();
protected final ConcurrentHashSet<AbstractSubscriber> subscribers = new ConcurrentHashSet();
private final Lock lock = new ReentrantLock();
public void addSubscriber(Subscriber subscriber, Class<? extends Event> subscribeType) {
Class<? extends SlowEvent> subSlowEventType = (Class<? extends SlowEvent>) subscribeType;
public void addSubscriber(AbstractSubscriber subscriber, Class<? extends AbstractEvent> subscribeType) {
Class<? extends AbstractSlowEvent> subSlowEventType = (Class<? extends AbstractSlowEvent>) subscribeType;
subscribers.add(subscriber);
lock.lock();
try {
Set<Subscriber> sets = subMappings.get(subSlowEventType);
Set<AbstractSubscriber> sets = subMappings.get(subSlowEventType);
if (sets == null) {
Set<Subscriber> newSet = new ConcurrentHashSet();
Set<AbstractSubscriber> newSet = new ConcurrentHashSet();
newSet.add(subscriber);
subMappings.put(subSlowEventType, newSet);
return;

12
hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java
Unescape View File

@ -1,7 +1,7 @@
package cn.hippo4j.config.notify;
import cn.hippo4j.config.notify.listener.Subscriber;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.AbstractEvent;
import cn.hippo4j.config.notify.listener.AbstractSubscriber;
/**
* Event publisher.
@ -17,14 +17,14 @@ public interface EventPublisher {
* @param type
* @param bufferSize
*/
void init(Class<? extends Event> type, int bufferSize);
void init(Class<? extends AbstractEvent> type, int bufferSize);
/**
* Add subscriber.
*
* @param subscriber
*/
void addSubscriber(Subscriber subscriber);
void addSubscriber(AbstractSubscriber subscriber);
/**
* Publish.
@ -32,7 +32,7 @@ public interface EventPublisher {
* @param event
* @return
*/
boolean publish(Event event);
boolean publish(AbstractEvent event);
/**
* Notify subscriber.
@ -40,6 +40,6 @@ public interface EventPublisher {
* @param subscriber
* @param event
*/
void notifySubscriber(Subscriber subscriber, Event event);
void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event);
}

36
hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java
Unescape View File

@ -1,11 +1,11 @@
package cn.hippo4j.config.notify;
import cn.hippo4j.config.notify.listener.SmartSubscriber;
import cn.hippo4j.config.notify.listener.Subscriber;
import cn.hippo4j.config.event.AbstractEvent;
import cn.hippo4j.config.notify.listener.AbstractSmartSubscriber;
import cn.hippo4j.config.notify.listener.AbstractSubscriber;
import cn.hippo4j.config.toolkit.ClassUtil;
import cn.hippo4j.config.toolkit.MapUtil;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.SlowEvent;
import cn.hippo4j.config.event.AbstractSlowEvent;
import lombok.extern.slf4j.Slf4j;
import java.util.Map;
@ -33,7 +33,7 @@ public class NotifyCenter {
private static EventPublisher eventPublisher = new DefaultPublisher();
private static BiFunction<Class<? extends Event>, Integer, EventPublisher> publisherFactory = null;
private static BiFunction<Class<? extends AbstractEvent>, Integer, EventPublisher> publisherFactory = null;
private final Map<String, EventPublisher> publisherMap = new ConcurrentHashMap(16);
@ -50,13 +50,13 @@ public class NotifyCenter {
};
INSTANCE.sharePublisher = new DefaultSharePublisher();
INSTANCE.sharePublisher.init(SlowEvent.class, shareBufferSize);
INSTANCE.sharePublisher.init(AbstractSlowEvent.class, shareBufferSize);
}
public static void registerSubscriber(final Subscriber consumer) {
if (consumer instanceof SmartSubscriber) {
for (Class<? extends Event> subscribeType : ((SmartSubscriber) consumer).subscribeTypes()) {
if (ClassUtil.isAssignableFrom(SlowEvent.class, subscribeType)) {
public static void registerSubscriber(final AbstractSubscriber consumer) {
if (consumer instanceof AbstractSmartSubscriber) {
for (Class<? extends AbstractEvent> subscribeType : ((AbstractSmartSubscriber) consumer).subscribeTypes()) {
if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, subscribeType)) {
INSTANCE.sharePublisher.addSubscriber(consumer, subscribeType);
} else {
addSubscriber(consumer, subscribeType);
@ -65,8 +65,8 @@ public class NotifyCenter {
return;
}
final Class<? extends Event> subscribeType = consumer.subscribeType();
if (ClassUtil.isAssignableFrom(SlowEvent.class, subscribeType)) {
final Class<? extends AbstractEvent> subscribeType = consumer.subscribeType();
if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, subscribeType)) {
INSTANCE.sharePublisher.addSubscriber(consumer, subscribeType);
return;
}
@ -74,7 +74,7 @@ public class NotifyCenter {
addSubscriber(consumer, subscribeType);
}
private static void addSubscriber(final Subscriber consumer, Class<? extends Event> subscribeType) {
private static void addSubscriber(final AbstractSubscriber consumer, Class<? extends AbstractEvent> subscribeType) {
final String topic = ClassUtil.getCanonicalName(subscribeType);
synchronized (NotifyCenter.class) {
MapUtil.computeIfAbsent(INSTANCE.publisherMap, topic, publisherFactory, subscribeType, ringBufferSize);
@ -83,7 +83,7 @@ public class NotifyCenter {
publisher.addSubscriber(consumer);
}
public static boolean publishEvent(final Event event) {
public static boolean publishEvent(final AbstractEvent event) {
try {
return publishEvent(event.getClass(), event);
} catch (Throwable ex) {
@ -92,8 +92,8 @@ public class NotifyCenter {
}
}
private static boolean publishEvent(final Class<? extends Event> eventType, final Event event) {
if (ClassUtil.isAssignableFrom(SlowEvent.class, eventType)) {
private static boolean publishEvent(final Class<? extends AbstractEvent> eventType, final AbstractEvent event) {
if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, eventType)) {
return INSTANCE.sharePublisher.publish(event);
}
@ -107,8 +107,8 @@ public class NotifyCenter {
return false;
}
public static EventPublisher registerToPublisher(final Class<? extends Event> eventType, final int queueMaxSize) {
if (ClassUtil.isAssignableFrom(SlowEvent.class, eventType)) {
public static EventPublisher registerToPublisher(final Class<? extends AbstractEvent> eventType, final int queueMaxSize) {
if (ClassUtil.isAssignableFrom(AbstractSlowEvent.class, eventType)) {
return INSTANCE.sharePublisher;
}

6
hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/SmartSubscriber.java → hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSmartSubscriber.java
Unescape View File

@ -1,6 +1,6 @@
package cn.hippo4j.config.notify.listener;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.AbstractEvent;
import java.util.List;
@ -10,13 +10,13 @@ import java.util.List;
* @author chen.ma
* @date 2021/6/23 19:02
*/
public abstract class SmartSubscriber extends Subscriber {
public abstract class AbstractSmartSubscriber extends AbstractSubscriber {
/**
* Subscribe types.
*
* @return
*/
public abstract List<Class<? extends Event>> subscribeTypes();
public abstract List<Class<? extends AbstractEvent>> subscribeTypes();
}

6
hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/Subscriber.java → hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java
Unescape View File

@ -1,6 +1,6 @@
package cn.hippo4j.config.notify.listener;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.AbstractEvent;
import java.util.concurrent.Executor;
@ -10,7 +10,7 @@ import java.util.concurrent.Executor;
* @author chen.ma
* @date 2021/6/23 19:02
*/
public abstract class Subscriber<T extends Event> {
public abstract class AbstractSubscriber<T extends AbstractEvent> {
/**
* Event callback.
@ -24,7 +24,7 @@ public abstract class Subscriber<T extends Event> {
*
* @return
*/
public abstract Class<? extends Event> subscribeType();
public abstract Class<? extends AbstractEvent> subscribeType();
public Executor executor() {
return null;

10
hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java
Unescape View File

@ -3,10 +3,10 @@ package cn.hippo4j.config.service;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.common.toolkit.Md5Util;
import cn.hippo4j.common.web.base.Results;
import cn.hippo4j.config.event.Event;
import cn.hippo4j.config.event.AbstractEvent;
import cn.hippo4j.config.event.LocalDataChangeEvent;
import cn.hippo4j.config.notify.NotifyCenter;
import cn.hippo4j.config.notify.listener.Subscriber;
import cn.hippo4j.config.notify.listener.AbstractSubscriber;
import cn.hippo4j.config.toolkit.ConfigExecutor;
import cn.hippo4j.config.toolkit.MapUtil;
import cn.hippo4j.config.toolkit.Md5ConfigUtil;
@ -58,10 +58,10 @@ public class LongPollingService {
NotifyCenter.registerToPublisher(LocalDataChangeEvent.class, NotifyCenter.ringBufferSize);
NotifyCenter.registerSubscriber(new Subscriber() {
NotifyCenter.registerSubscriber(new AbstractSubscriber() {
@Override
public void onEvent(Event event) {
public void onEvent(AbstractEvent event) {
if (isFixedPolling()) {
// Ignore.
} else {
@ -73,7 +73,7 @@ public class LongPollingService {
}
@Override
public Class<? extends Event> subscribeType() {
public Class<? extends AbstractEvent> subscribeType() {
return LocalDataChangeEvent.class;
}
});

6
hippo4j-example/src/main/java/cn/hippo4j/example/config/ThreadPoolConfig.java
Unescape View File

@ -2,9 +2,9 @@ package cn.hippo4j.example.config;
import cn.hippo4j.example.inittest.TaskDecoratorTest;
import cn.hippo4j.starter.core.DynamicThreadPool;
import cn.hippo4j.starter.core.DynamicThreadPoolExecutor;
import cn.hippo4j.starter.toolkit.thread.ThreadPoolBuilder;
import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
import cn.hippo4j.core.executor.DynamicThreadPoolExecutor;
import cn.hippo4j.core.executor.support.ThreadPoolBuilder;
import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

2
hippo4j-example/src/main/java/cn/hippo4j/example/handler/ErrorLogRejectedExecutionHandler.java
Unescape View File

@ -1,6 +1,6 @@
package cn.hippo4j.example.handler;
import cn.hippo4j.starter.spi.CustomRejectedExecutionHandler;
import cn.hippo4j.core.spi.CustomRejectedExecutionHandler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

4
hippo4j-example/src/main/java/cn/hippo4j/example/inittest/AlarmSendMessageTest.java
Unescape View File

@ -2,8 +2,8 @@ package cn.hippo4j.example.inittest;
import cn.hippo4j.example.constant.GlobalTestConstant;
import cn.hutool.core.thread.ThreadUtil;
import cn.hippo4j.starter.core.GlobalThreadPoolManage;
import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

2
hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java
Unescape View File

@ -1,6 +1,6 @@
package cn.hippo4j.example.inittest;
import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
import cn.hutool.core.thread.ThreadUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

6
hippo4j-example/src/main/java/cn/hippo4j/example/inittest/TaskDecoratorTest.java
Unescape View File

@ -1,8 +1,8 @@
package cn.hippo4j.example.inittest;
import cn.hippo4j.example.constant.GlobalTestConstant;
import cn.hippo4j.starter.core.GlobalThreadPoolManage;
import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
import cn.hutool.core.thread.ThreadUtil;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;
@ -25,8 +25,8 @@ public class TaskDecoratorTest {
/**
* 测试动态线程池传递 {@link TaskDecorator}
* 如果需要运行此单测, 方法上添加 @PostConstruct
*/
// @PostConstruct
public void taskDecoratorTest() {
new Thread(() -> {
MDC.put(PLACEHOLDER, "查看官网: https://www.hippox.cn");

1
hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.core.spi.CustomRejectedExecutionHandler
Unescape View File

@ -0,0 +1 @@
cn.hippo4j.example.handler.ErrorLogRejectedExecutionHandler

1
hippo4j-example/src/main/resources/META-INF/services/cn.hippo4j.starter.spi.CustomRejectedExecutionHandler
Unescape View File

@ -1 +0,0 @@
cn.hippo4j.example.handler.ErrorLogRejectedExecutionHandler
Write Preview
Loading…
Cancel
Save