Skip to content

Commit

Permalink
application startup update register order (#1325)
Browse files Browse the repository at this point in the history
* application startup update register order

* application startup update register order

---------

Co-authored-by: 致节 <hzj266771@antgroup.com>
  • Loading branch information
HzjNeverStop and 致节 authored May 23, 2024
1 parent 9bfbb73 commit c743030
Show file tree
Hide file tree
Showing 2 changed files with 54 additions and 23 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,29 +42,24 @@
*/
public class StartupSpringApplicationRunListener implements SpringApplicationRunListener, Ordered {

private final SpringApplication application;
private final SpringApplication application;

private final String[] args;
private final String[] args;

private final StartupReporter startupReporter;
private final StartupReporter startupReporter;

private final ApplicationStartup userApplicationStartup;
private BaseStat jvmStartingStage;

private BufferingApplicationStartup applicationStartup;
private BaseStat environmentPrepareStage;

private BaseStat jvmStartingStage;
private ChildrenStat<BaseStat> applicationContextPrepareStage;

private BaseStat environmentPrepareStage;

private ChildrenStat<BaseStat> applicationContextPrepareStage;

private BaseStat applicationContextLoadStage;
private BaseStat applicationContextLoadStage;

public StartupSpringApplicationRunListener(SpringApplication springApplication, String[] args) {
this.application = springApplication;
this.args = args;
this.startupReporter = new StartupReporter();
this.userApplicationStartup = springApplication.getApplicationStartup();
}

@Override
Expand All @@ -84,16 +79,12 @@ public void environmentPrepared(ConfigurableBootstrapContext bootstrapContext,
environmentPrepareStage.setEndTime(System.currentTimeMillis());
startupReporter.setAppName(environment.getProperty(SofaBootConstants.APP_NAME_KEY));
startupReporter.bindToStartupReporter(environment);
bootstrapContext.register(StartupReporter.class, key -> startupReporter);

// create BufferingApplicationStartup if user not custom.
ApplicationStartup userApplicationStartup = application.getApplicationStartup();
if (ApplicationStartup.DEFAULT == userApplicationStartup || userApplicationStartup == null) {
this.applicationStartup = new BufferingApplicationStartup(startupReporter.getBufferSize());
} else if (userApplicationStartup instanceof BufferingApplicationStartup userApplicationStartup) {
// use user custom BufferingApplicationStartup
this.applicationStartup = userApplicationStartup;
} else {
// disable startup static when user custom other type ApplicationStartup;
this.applicationStartup = null;
application.setApplicationStartup(new BufferingApplicationStartup(startupReporter.getBufferSize()));
}
}

Expand All @@ -109,9 +100,6 @@ public void contextPrepared(ConfigurableApplicationContext context) {
applicationContextPrepareStage.setChildren(new ArrayList<>(baseStatList));
baseStatList.clear();
}
if (applicationStartup != null) {
context.setApplicationStartup(applicationStartup);
}
}

@Override
Expand Down Expand Up @@ -156,7 +144,7 @@ public void started(ConfigurableApplicationContext context, Duration timeTaken)

@Override
public int getOrder() {
return Ordered.LOWEST_PRECEDENCE;
return Ordered.LOWEST_PRECEDENCE - 10;
}

private String getStartedMessage(Environment environment, Duration timeTakenToStartup) {
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You 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 com.alipay.sofa.smoke.tests.boot;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.metrics.buffering.BufferingApplicationStartup;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.core.metrics.ApplicationStartup;

import static org.assertj.core.api.Assertions.assertThat;

/**
* @author huzijie
* @version StartupApplicationStartupTests.java, v 0.1 2024年05月23日 17:40 huzijie Exp $
*/
@SpringBootTest
public class StartupApplicationStartupTests {

@Autowired
private ConfigurableApplicationContext context;

@Test
public void checkBufferApplicationStartup() {
ApplicationStartup applicationStartup = context.getApplicationStartup();
assertThat(applicationStartup).isInstanceOf(BufferingApplicationStartup.class);
}
}

0 comments on commit c743030

Please sign in to comment.