spring ApplicationAvailabilityBean 源码
springboot ApplicationAvailabilityBean 代码
文件路径:/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/availability/ApplicationAvailabilityBean.java
/*
* Copyright 2012-2022 the original author or authors.
*
* 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
*
* https://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.springframework.boot.availability;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationListener;
import org.springframework.util.Assert;
/**
* Bean that provides an {@link ApplicationAvailability} implementation by listening for
* {@link AvailabilityChangeEvent change events}.
*
* @author Brian Clozel
* @author Phillip Webb
* @since 2.3.0
* @see ApplicationAvailability
*/
public class ApplicationAvailabilityBean
implements ApplicationAvailability, ApplicationListener<AvailabilityChangeEvent<?>> {
private final Map<Class<? extends AvailabilityState>, AvailabilityChangeEvent<?>> events = new ConcurrentHashMap<>();
private final Log logger;
public ApplicationAvailabilityBean() {
this(LogFactory.getLog(ApplicationAvailabilityBean.class));
}
ApplicationAvailabilityBean(Log logger) {
this.logger = logger;
}
@Override
public <S extends AvailabilityState> S getState(Class<S> stateType, S defaultState) {
Assert.notNull(stateType, "StateType must not be null");
Assert.notNull(defaultState, "DefaultState must not be null");
S state = getState(stateType);
return (state != null) ? state : defaultState;
}
@Override
public <S extends AvailabilityState> S getState(Class<S> stateType) {
AvailabilityChangeEvent<S> event = getLastChangeEvent(stateType);
return (event != null) ? event.getState() : null;
}
@Override
@SuppressWarnings("unchecked")
public <S extends AvailabilityState> AvailabilityChangeEvent<S> getLastChangeEvent(Class<S> stateType) {
return (AvailabilityChangeEvent<S>) this.events.get(stateType);
}
@Override
public void onApplicationEvent(AvailabilityChangeEvent<?> event) {
Class<? extends AvailabilityState> type = getStateType(event.getState());
if (this.logger.isDebugEnabled()) {
this.logger.debug(getLogMessage(type, event));
}
this.events.put(type, event);
}
private <S extends AvailabilityState> Object getLogMessage(Class<S> type, AvailabilityChangeEvent<?> event) {
AvailabilityChangeEvent<S> lastChangeEvent = getLastChangeEvent(type);
StringBuilder message = new StringBuilder(
"Application availability state " + type.getSimpleName() + " changed");
message.append((lastChangeEvent != null) ? " from " + lastChangeEvent.getState() : "");
message.append(" to " + event.getState());
message.append(getSourceDescription(event.getSource()));
return message;
}
private String getSourceDescription(Object source) {
if (source == null || source instanceof ApplicationEventPublisher) {
return "";
}
return ": " + ((source instanceof Throwable) ? source : source.getClass().getName());
}
@SuppressWarnings("unchecked")
private Class<? extends AvailabilityState> getStateType(AvailabilityState state) {
Class<?> type = (state instanceof Enum) ? ((Enum<?>) state).getDeclaringClass() : state.getClass();
return (Class<? extends AvailabilityState>) type;
}
}
相关信息
相关文章
spring ApplicationAvailability 源码
0
赞
- 所属分类: 后端技术
- 本文标签: Spring Boot Java Spring
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦