Spring Boot的底层原理
之前学习过了Spring Boot（在88章博客），但是并没有很深入的了解，这里致力于在原来的基础上学习更多Spring Boot知识
<?xml version="1.0" encoding="UTF-8"?>
< projectxmlns = " 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 https://maven.apache.org/xsd/maven-4.0.0.xsd" > < modelVersion> </ modelVersion> < parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < relativePath/> </ parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < name> </ name> < description> </ description> < properties> < java.version> </ java.version> </ properties> < dependencies> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> </ dependencies> < build> < plugins> < plugin> < groupId> </ groupId> < artifactId> </ artifactId> </ plugin> </ plugins> </ build> </ project>
package com. boot. controller ; import org. springframework. web. bind. annotation. RequestMapping ;
import org. springframework. web. bind. annotation. RestController ; @RestController
@RequestMapping ( "hello" )
public class HelloController { @RequestMapping ( "/boot" ) public String helloBoot ( ) { return "Hello Spring Boot" ; } }
package com. boot ; import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
public class BootApplication { public static void main ( String [ ] args) { SpringApplication . run ( BootApplication . class , args) ; } } < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> package com. boot ; import com. boot. controller. HelloController ;
import org. junit. jupiter. api. Test ;
import org. junit. runner. RunWith ;
import org. springframework. beans. factory. annotation. Autowired ;
import org. springframework. boot. test. context. SpringBootTest ;
import org. springframework. test. context. junit4. SpringRunner ; @RunWith ( SpringRunner . class )
@SpringBootTest
class BootApplicationTests { @Autowired private HelloController helloController; @Test public void contextLoads ( ) { String s = helloController. helloBoot ( ) ; System . out. println ( s) ; } } < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency>
#修改tomcat的端口号（有些时候也可以说是版本号）
server.port=8888
#注意：
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver中
#他后面不能有空格，否则报错，这是一个特殊的地方，当然可以不写，会根据驱动默认加上的（这一般是spring boot自身的处理，其他的如单纯的spring可能还是需要指定）
#其他的基本都可以有空格（且空格无影响，相当于没有什么，基本不会参与到数值里面去）
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/ceshi
spring.datasource.username=root
spring.datasource.password=123456
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> package com. boot. controller ; import org. springframework. beans. factory. annotation. Autowired ;
import org. springframework. jdbc. core. JdbcTemplate ;
import org. springframework. web. bind. annotation. RequestMapping ;
import org. springframework. web. bind. annotation. RestController ; @RestController
@RequestMapping ( "hello" )
public class HelloController { @RequestMapping ( "/boot" ) public String helloBoot ( ) { return "Hello Spring Boot" ; } @Autowired private JdbcTemplate jdbcTemplate; @RequestMapping ( "/jdbc" ) public String jdbc ( ) { return jdbcTemplate. toString ( ) ; }
}
package com. boot. pojo ; public class Pet { private String type; private String name; @Override public String toString ( ) { return "Pet{" + "type='" + type + '\'' + ", name='" + name + '\'' + '}' ; } public String getType ( ) { return type; } public void setType ( String type) { this . type = type; } public String getName ( ) { return name; } public void setName ( String name) { this . name = name; }
} package com. boot. pojo ; import org. springframework. boot. context. properties. ConfigurationProperties ;
import org. springframework. stereotype. Component ; import java. util. Arrays ;
import java. util. List ;
import java. util. Map ; @Component
@ConfigurationProperties ( prefix = "person" )
public class Person { private int id; private String name; private List hobby; private String [ ] family; private Map map; private Pet pet; @Override public String toString ( ) { return "Person{" + "id=" + id + ", name='" + name + '\'' + ", hobby=" + hobby + ", family=" + Arrays . toString ( family) + ", map=" + map + ", pet=" + pet + '}' ; } public int getId ( ) { return id; } public void setId ( int id) { this . id = id; } public String getName ( ) { return name; } public void setName ( String name) { this . name = name; } public List getHobby ( ) { return hobby; } public void setHobby ( List hobby) { this . hobby = hobby; } public String [ ] getFamily ( ) { return family; } public void setFamily ( String [ ] family) { this . family = family; } public Map getMap ( ) { return map; } public void setMap ( Map map) { this . map = map; } public Pet getPet ( ) { return pet; } public void setPet ( Pet pet) { this . pet = pet; }
}
#自定义配置信息注入到Person对象中
person.id=100
person.name=哈哈
#list
person.hobby=喝水,吃早餐
#String[]
person.family=儿子,老婆
#集合和对象，一般都需要多一个层（多了.）
#Map
person.map.k1=v1
person.map.k2=v2
#Pet对象
person.pet.type=狗
person.pet.name=旺财
#他们可以使用@Value注解来进行注入（对应的参数获取），因为他们是全局的
@Autowired private Person person; @Test public void configurationTest ( ) { System . out. println ( person) ; }
< includes> < include> </ include> < include> </ include> < include> </ include> </ includes> server : port : 8080 servlet : context-path : /hello
@Value ( "${person.id}" )
private int id;
#对实体类对象MyProperties进行属性配置
test.id=110
test.name=test
package com. boot. pojo ; import org. springframework. boot. context. properties. ConfigurationProperties ;
import org. springframework. context. annotation. PropertySource ;
import org. springframework. stereotype. Component ; @Component
@PropertySource ( "classpath:test.properties" )
@ConfigurationProperties ( prefix = "test" )
public class MyProperties { private int id; private String name; @Override public String toString ( ) { return "MyProperties{" + "id=" + id + ", name='" + name + '\'' + '}' ; } public int getId ( ) { return id; } public void setId ( int id) { this . id = id; } public String getName ( ) { return name; } public void setName ( String name) { this . name = name; }
}
@Autowired private MyProperties myProperties; @Test public void myPropertiesTest ( ) { System . out. println ( myProperties) ; }
@Configuration
public class MyConfig { @Bean public MyService myService ( ) { return new MyService ( ) ; } }
@Autowired private MyService myService; @Autowired private MyConfig myConfig; @Test public void iocTest ( ) { System . out. println ( myService) ; System . out. println ( myConfig) ; }
@Autowired
private ApplicationContext applicationContext;
@Test public void Test ( ) { System . out. println ( applicationContext. getBean ( "myService2" ) ) ; System . out. println ( applicationContext. containsBean ( "myService2" ) ) ; }
my.secret=${random.value} // 配置随机值
my.number=${random.int} // 配置随机整数
my.bignumber=${random.long} // 配置随机long类型数
my.uuid=${random.uuid} // 配置随机uuid类型数
my.number.less.than.ten=${random.int(10)} // 配置小于10的随机整数
my.number.in.range=${random.int[1024,65536]} // 配置范围在[1024,65536]之间的随机整数
package com. boot. pojo ; import org. springframework. boot. context. properties. ConfigurationProperties ;
import org. springframework. stereotype. Component ; @Component
@ConfigurationProperties ( prefix = "test" )
public class MyTest { private int id; private String name; @Override public String toString ( ) { return "MyTest{" + "id=" + id + ", name='" + name + '\'' + '}' ; } public int getId ( ) { return id; } public void setId ( int id) { this . id = id; } public String getName ( ) { return name; } public void setName ( String name) { this . name = name; }
} test : id : ${ random.int} name : ${ random.int[ 1024 , 65536 ] }
@Autowired private MyTest myTest; @Test public void fa ( ) { System . out. println ( myTest) ; }
app.name=MyApp
app.description=${app.name} is a Spring Boot application
test : ui : 8 id : ${ random.int} name : ${ random.int[ 1024 , 65536 ] } de : ${ test.id} is ${ test.ui}
private String de; public String getDe ( ) { return de; } public void setDe ( String de) { this . de = de; } @Override public String toString ( ) { return "MyTest{" + "id=" + id + ", name='" + name + '\'' + ", de='" + de + '\'' + '}' ; }
test : ui : 8 id : ${ random.int} name : ${ random.int[ 1024 , 65536 ] } de : ${ test.id} is ${ test.ui}
< parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < relativePath/> </ parent> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> < parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ parent> < properties> < activemq.version> </ activemq.version> < antlr2.version> </ antlr2.version> < appengine-sdk.version> </ appengine-sdk.version> < artemis.version> </ artemis.version> < aspectj.version> </ aspectj.version> package com. boot ; import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
public class BootApplication { public static void main ( String [ ] args) { SpringApplication . run ( BootApplication . class , args) ; } }
package org. springframework. boot. autoconfigure ; import java. lang. annotation. Documented ;
import java. lang. annotation. ElementType ;
import java. lang. annotation. Inherited ;
import java. lang. annotation. Retention ;
import java. lang. annotation. RetentionPolicy ;
import java. lang. annotation. Target ;
import org. springframework. beans. factory. support. BeanNameGenerator ;
import org. springframework. boot. SpringBootConfiguration ;
import org. springframework. boot. context. TypeExcludeFilter ;
import org. springframework. context. annotation. ComponentScan ;
import org. springframework. context. annotation. Configuration ;
import org. springframework. context. annotation. FilterType ;
import org. springframework. context. annotation. ComponentScan . Filter ;
import org. springframework. core. annotation. AliasFor ; @Target ( { ElementType . TYPE } )
@Retention ( RetentionPolicy . RUNTIME )
@Documented
@Inherited
@SpringBootConfiguration
@EnableAutoConfiguration
@ComponentScan ( excludeFilters = { @Filter ( type = FilterType . CUSTOM , classes = { TypeExcludeFilter . class }
) , @Filter ( type = FilterType . CUSTOM , classes = { AutoConfigurationExcludeFilter . class }
) }
)
public @interface SpringBootApplication { @AliasFor ( annotation = EnableAutoConfiguration . class ) Class < ? > [ ] exclude ( ) default { } ; @AliasFor ( annotation = EnableAutoConfiguration . class ) String [ ] excludeName ( ) default { } ; @AliasFor ( annotation = ComponentScan . class , attribute = "basePackages" ) String [ ] scanBasePackages ( ) default { } ; @AliasFor ( annotation = ComponentScan . class , attribute = "basePackageClasses" ) Class < ? > [ ] scanBasePackageClasses ( ) default { } ; @AliasFor ( annotation = ComponentScan . class , attribute = "nameGenerator" ) Class < ? extends BeanNameGenerator > nameGenerator ( ) default BeanNameGenerator . class ; @AliasFor ( annotation = Configuration . class ) boolean proxyBeanMethods ( ) default true ;
}
package org. springframework. boot ; import java. lang. annotation. Documented ;
import java. lang. annotation. ElementType ;
import java. lang. annotation. Retention ;
import java. lang. annotation. RetentionPolicy ;
import java. lang. annotation. Target ;
import org. springframework. context. annotation. Configuration ;
import org. springframework. core. annotation. AliasFor ;
import org. springframework. stereotype. Indexed ; @Target ( { ElementType . TYPE } )
@Retention ( RetentionPolicy . RUNTIME )
@Documented
@Configuration
@Indexed
public @interface SpringBootConfiguration { @AliasFor ( annotation = Configuration . class ) boolean proxyBeanMethods ( ) default true ;
}
package org. springframework. boot. autoconfigure ; import java. lang. annotation. Documented ;
import java. lang. annotation. ElementType ;
import java. lang. annotation. Inherited ;
import java. lang. annotation. Retention ;
import java. lang. annotation. RetentionPolicy ;
import java. lang. annotation. Target ;
import org. springframework. context. annotation. Import ; @Target ( { ElementType . TYPE } )
@Retention ( RetentionPolicy . RUNTIME )
@Documented
@Inherited
@AutoConfigurationPackage
@Import ( { AutoConfigurationImportSelector . class } )
public @interface EnableAutoConfiguration { String ENABLED_OVERRIDE_PROPERTY = "spring.boot.enableautoconfiguration" ; Class < ? > [ ] exclude ( ) default { } ; String [ ] excludeName ( ) default { } ;
}
package org. springframework. boot. autoconfigure ; import java. lang. annotation. Documented ;
import java. lang. annotation. ElementType ;
import java. lang. annotation. Inherited ;
import java. lang. annotation. Retention ;
import java. lang. annotation. RetentionPolicy ;
import java. lang. annotation. Target ;
import org. springframework. boot. autoconfigure. AutoConfigurationPackages . Registrar ;
import org. springframework. context. annotation. Import ; @Target ( { ElementType . TYPE } )
@Retention ( RetentionPolicy . RUNTIME )
@Documented
@Inherited
@Import ( { Registrar . class } )
public @interface AutoConfigurationPackage { String [ ] basePackages ( ) default { } ; Class < ? > [ ] basePackageClasses ( ) default { } ;
} @Import ( { Registrar . class } )
@Import ( { AutoConfigurationImportSelector . class } )
static class Registrar implements ImportBeanDefinitionRegistrar , DeterminableImports { Registrar ( ) { } public void registerBeanDefinitions ( AnnotationMetadata metadata, BeanDefinitionRegistry registry) { AutoConfigurationPackages . register ( registry, ( String [ ] ) ( new AutoConfigurationPackages. PackageImports ( metadata) ) . getPackageNames ( ) . toArray ( new String [ 0 ] ) ) ; } public Set < Object > determineImports ( AnnotationMetadata metadata) { return Collections . singleton ( new AutoConfigurationPackages. PackageImports ( metadata) ) ; } }
public class AutoConfigurationImportSelector implements DeferredImportSelector , BeanClassLoaderAware , ResourceLoaderAware , BeanFactoryAware , EnvironmentAware , Ordered { public String [ ] selectImports ( AnnotationMetadata annotationMetadata) { if ( ! this . isEnabled ( annotationMetadata) ) { return NO_IMPORTS ; } else { AutoConfigurationImportSelector. AutoConfigurationEntry autoConfigurationEntry = this . getAutoConfigurationEntry ( annotationMetadata) ; return StringUtils . toStringArray ( autoConfigurationEntry. getConfigurations ( ) ) ; } }
}
this . autoConfigurationMetadata = AutoConfigurationMetadataLoader . loadMetadata ( this . beanClassLoader) ;
final class AutoConfigurationMetadataLoader { static AutoConfigurationMetadata loadMetadata ( ClassLoader classLoader) { return loadMetadata ( classLoader, "META-INF/spring-autoconfigure-metadata.properties" ) ; } static AutoConfigurationMetadata loadMetadata ( ClassLoader classLoader, String path) { try { Enumeration < URL> = classLoader != null ? classLoader. getResources ( path) : ClassLoader . getSystemResources ( path) ; Properties properties = new Properties ( ) ; while ( urls. hasMoreElements ( ) ) { properties. putAll ( PropertiesLoaderUtils . loadProperties ( new UrlResource ( ( URL ) urls. nextElement ( ) ) ) ) ; } return loadMetadata ( properties) ; } catch ( IOException var4) { throw new IllegalArgumentException ( "Unable to load @ConditionalOnClass location [" + path + "]" , var4) ; } } static AutoConfigurationMetadata loadMetadata ( Properties properties) { return new AutoConfigurationMetadataLoader. PropertiesAutoConfigurationMetadata ( properties) ; }
}
org.springframework.boot.autoconfigure.AutoConfiguration=
org.springframework.boot.autoconfigure.admin.SpringApplicationAdminJmxAutoConfiguration=
org.springframework.boot.autoconfigure.admin.SpringApplicationAdminJmxAutoConfiguration.AutoConfigureAfter=org.springframework.boot.autoconfigure.jmx.JmxAutoConfiguration
org.springframework.boot.autoconfigure.amqp.RabbitAnnotationDrivenConfiguration=
org.springframework.boot.autoconfigure.amqp.RabbitAnnotationDrivenConfiguration.ConditionalOnClass=org.springframework.amqp.rabbit.annotation.EnableRabbit
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration=
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration$MessagingTemplateConfiguration=
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration$MessagingTemplateConfiguration.ConditionalOnClass=org.springframework.amqp.rabbit.core.RabbitMessagingTemplate
org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration.ConditionalOnClass=com.rabbitmq.client.Channel,org.springframework.amqp.rabbit.core.RabbitTemplate
org.springframework.boot.autoconfigure.amqp.RabbitStreamConfiguration=
org.springframework.boot.autoconfigure.amqp.RabbitStreamConfiguration.ConditionalOnClass=org.springframework.rabbit.stream.config.StreamRabbitListenerContainerFactory
org.springframework.boot.autoconfigure.aop.AopAutoConfiguration=
org.springframework.boot.autoconfigure.aop.AopAutoConfiguration$AspectJAutoProxyingConfiguration=
org.springframework.boot.autoconfigure.aop.AopAutoConfiguration$AspectJAutoProxyingConfiguration.ConditionalOnClass=org.aspectj.weaver.Advice
org.springframework.boot.autoconfigure.availability.ApplicationAvailabilityAutoConfiguration=
org.springframework.boot.autoconfigure.batch.BatchAutoConfiguration=
#其中org.springframework.boot.autoconfigure.amqp.RabbitAnnotationDrivenConfiguration
#第一个点，往前推
#代表进行自动配置的类，后面的ConditionalOnClass是一个注解，该注解一般表示的是条件（=后面的）
#如果要向ioc容器中注入我们自动配置的类需要满足=号后面的条件
#具体条件是
#当该注解里面出现了后面的org.springframework.amqp.rabbit.annotation.EnableRabbit（EnableRabbit这个类时，因为约定，所以存在某个地方统一获取的）
#就进行该RabbitAnnotationDrivenConfiguration类的自动注入
#自动注入：可以说成是自动的创建实例，放在ioc容器里面
#即使得可以被注入得到，所以我们导入对应的依赖，spring boot会帮我们生成实例，就是这样的原因，但并不是所有依赖，因为该文件的内容是有限的，这是肯定的#其他的基本都是这样的说明
@Import ( { Registrar . class } )
@Import ( { AutoConfigurationImportSelector . class } )
public String [ ] selectImports ( AnnotationMetadata annotationMetadata) { if ( ! this . isEnabled ( annotationMetadata) ) { return NO_IMPORTS ; } else { AutoConfigurationImportSelector. AutoConfigurationEntry autoConfigurationEntry = this . getAutoConfigurationEntry ( annotationMetadata) ; return StringUtils . toStringArray ( autoConfigurationEntry. getConfigurations ( ) ) ; } }
protected AutoConfigurationImportSelector. AutoConfigurationEntry getAutoConfigurationEntry ( AnnotationMetadata annotationMetadata) { if ( ! this . isEnabled ( annotationMetadata) ) { return EMPTY_ENTRY ; } else { AnnotationAttributes attributes = this . getAttributes ( annotationMetadata) ; List < String > = this . getCandidateConfigurations ( annotationMetadata, attributes) ; configurations = this . removeDuplicates ( configurations) ; Set < String > = this . getExclusions ( annotationMetadata, attributes) ; this . checkExcludedClasses ( configurations, exclusions) ; configurations. removeAll ( exclusions) ; configurations = this . getConfigurationClassFilter ( ) . filter ( configurations) ; this . fireAutoConfigurationImportEvents ( configurations, exclusions) ; return new AutoConfigurationImportSelector. AutoConfigurationEntry ( configurations, exclusions) ; } }
protected List < String > getCandidateConfigurations ( AnnotationMetadata metadata, AnnotationAttributes attributes) { List < String > = new ArrayList ( SpringFactoriesLoader . loadFactoryNames ( this . getSpringFactoriesLoaderFactoryClass ( ) , this . getBeanClassLoader ( ) ) ) ; ImportCandidates . load ( AutoConfiguration . class , this . getBeanClassLoader ( ) ) . forEach ( configurations:: add ) ; Assert . notEmpty ( configurations, "No auto configuration classes found in META-INF/spring.factories nor in META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports. If you are using a custom packaging, make sure that file is correct." ) ; return configurations; }
public final class SpringFactoriesLoader { public static List < String > loadFactoryNames ( Class < ? > , @Nullable ClassLoader classLoader) { ClassLoader classLoaderToUse = classLoader; if ( classLoader == null ) { classLoaderToUse = SpringFactoriesLoader . class . getClassLoader ( ) ; } String factoryTypeName = factoryType. getName ( ) ; return ( List ) loadSpringFactories ( classLoaderToUse) . getOrDefault ( factoryTypeName, Collections . emptyList ( ) ) ; } }
private static Map < String , List < String > > loadSpringFactories ( ClassLoader classLoader) { Map < String , List < String > > = ( Map ) cache. get ( classLoader) ; if ( result != null ) { return result; } else { HashMap result = new HashMap ( ) ; try { Enumeration urls = classLoader. getResources ( "META-INF/spring.factories" ) ; while ( urls. hasMoreElements ( ) ) { URL url = ( URL ) urls. nextElement ( ) ; UrlResource resource = new UrlResource ( url) ; Properties properties = PropertiesLoaderUtils . loadProperties ( resource) ; Iterator var6 = properties. entrySet ( ) . iterator ( ) ; while ( var6. hasNext ( ) ) { Entry < ? , ? > = ( Entry ) var6. next ( ) ; String factoryTypeName = ( ( String ) entry. getKey ( ) ) . trim ( ) ; String [ ] factoryImplementationNames = StringUtils . commaDelimitedListToStringArray ( ( String ) entry. getValue ( ) ) ; String [ ] var10 = factoryImplementationNames; int var11 = factoryImplementationNames. length; for ( int var12 = 0 ; var12 < var11; ++ var12) { String factoryImplementationName = var10[ var12] ; ( ( List ) result. computeIfAbsent ( factoryTypeName, ( key) -> { return new ArrayList ( ) ; } ) ) . add ( factoryImplementationName. trim ( ) ) ; } } } result. replaceAll ( ( factoryType, implementations) -> { return ( List ) implementations. stream ( ) . distinct ( ) . collect ( Collectors . collectingAndThen ( Collectors . toList ( ) , Collections :: unmodifiableList ) ) ; } ) ; cache. put ( classLoader, result) ; return result; } catch ( IOException var14) { throw new IllegalArgumentException ( "Unable to load factories from location [META-INF/spring.factories]" , var14) ; } } }
public final class SpringFactoriesLoader { public static final String FACTORIES_RESOURCE_LOCATION = "META-INF/spring.factories" ;
@Import ( { Registrar . class } )
@Import ( { AutoConfigurationImportSelector . class } )
<?xml version="1.0" encoding="UTF-8"?>
< projectxmlns = " 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" > < modelVersion> </ modelVersion> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < properties> < maven.compiler.source> </ maven.compiler.source> < maven.compiler.target> </ maven.compiler.target> </ properties> < dependencies> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> </ dependencies> </ project> configurations = this . removeDuplicates ( configurations) ;
package com. pojo ; import org. springframework. boot. context. properties. ConfigurationProperties ;
import org. springframework. boot. context. properties. EnableConfigurationProperties ;
@EnableConfigurationProperties ( SimpleBean . class )
@ConfigurationProperties ( prefix = "simplebean" )
public class SimpleBean { private int id; private String name; public int getId ( ) { return id; } public void setId ( int id) { this . id = id; } public String getName ( ) { return name; } public void setName ( String name) { this . name = name; } @Override public String toString ( ) { return "SimpleBean{" + "id=" + id + ", name='" + name + '\'' + '}' ; }
} package com. config ; import com. pojo. SimpleBean ;
import org. springframework. boot. autoconfigure. condition. ConditionalOnClass ;
import org. springframework. context. annotation. Bean ;
import org. springframework. context. annotation. Configuration ; @Configuration
@ConditionalOnClass
public class MyAutoConfiguration { static { System . out. println ( "MyAutoConfiguration init...." ) ; }
} org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.config.MyAutoConfiguration#之所以是EnableAutoConfiguration：是因为对应的启动类注解中，默认创建实例的部分是EnableAutoConfiguration对应的列表
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> simplebean : id : 1 name : 自定义starter @Autowired private SimpleBean simpleBean; @Test public void zdyStarterTest ( ) { System . out. println ( simpleBean) ; } @Bean public SimpleBean simpleBean ( ) { return new SimpleBean ( ) ; }
package com ; import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
public class BootApplication { public static void main ( String [ ] args) { SpringApplication . run ( BootApplication . class , args) ; } } public class xxx{ xxx
}
public class SpringApplication { public static ConfigurableApplicationContext run ( Class < ? > , String . . . args) { return run ( new Class [ ] { primarySource} , args) ; } public static ConfigurableApplicationContext run ( Class < ? > [ ] primarySources, String [ ] args) { return ( new SpringApplication ( primarySources) ) . run ( args) ; }
} public SpringApplication ( Class < ? > . . . primarySources) { this ( ( ResourceLoader ) null , primarySources) ; } public SpringApplication ( ResourceLoader resourceLoader, Class < ? > . . . primarySources) { this . sources = new LinkedHashSet ( ) ; this . bannerMode = Mode . CONSOLE ; this . logStartupInfo = true ; this . addCommandLineProperties = true ; this . addConversionService = true ; this . headless = true ; this . registerShutdownHook = true ; this . additionalProfiles = Collections . emptySet ( ) ; this . isCustomEnvironment = false ; this . lazyInitialization = false ; this . applicationContextFactory = ApplicationContextFactory . DEFAULT ; this . applicationStartup = ApplicationStartup . DEFAULT ; this . resourceLoader = resourceLoader; Assert . notNull ( primarySources, "PrimarySources must not be null" ) ; this . primarySources = new LinkedHashSet ( Arrays . asList ( primarySources) ) ; this . webApplicationType = WebApplicationType . deduceFromClasspath ( ) ; this . bootstrapRegistryInitializers = new ArrayList ( this . getSpringFactoriesInstances ( BootstrapRegistryInitializer . class ) ) ; this . setInitializers ( this . getSpringFactoriesInstances ( ApplicationContextInitializer . class ) ) ; this . setListeners ( this . getSpringFactoriesInstances ( ApplicationListener . class ) ) ; this . mainApplicationClass = this . deduceMainApplicationClass ( ) ; }
this . webApplicationType = WebApplicationType . deduceFromClasspath ( ) ; public enum WebApplicationType { static WebApplicationType deduceFromClasspath ( ) { if ( ClassUtils . isPresent ( "org.springframework.web.reactive.DispatcherHandler" , ( ClassLoader ) null ) && ! ClassUtils . isPresent ( "org.springframework.web.servlet.DispatcherServlet" , ( ClassLoader ) null ) && ! ClassUtils . isPresent ( "org.glassfish.jersey.servlet.ServletContainer" , ( ClassLoader ) null ) ) { return REACTIVE ; } else { String [ ] var0 = SERVLET_INDICATOR_CLASSES ; int var1 = var0. length; for ( int var2 = 0 ; var2 < var1; ++ var2) { String className = var0[ var2] ; if ( ! ClassUtils . isPresent ( className, ( ClassLoader ) null ) ) { return NONE ; } } return SERVLET ; } } }
public enum WebApplicationType { NONE , SERVLET , REACTIVE ;
}
this . setInitializers ( this . getSpringFactoriesInstances ( ApplicationContextInitializer . class ) ) ; private < T > Collection < T > getSpringFactoriesInstances ( Class < T > ) { return this . getSpringFactoriesInstances ( type, new Class [ 0 ] ) ; } private < T > Collection < T > getSpringFactoriesInstances ( Class < T > , Class < ? > [ ] parameterTypes, Object . . . args) { ClassLoader classLoader = this . getClassLoader ( ) ; Set < String > = new LinkedHashSet ( SpringFactoriesLoader . loadFactoryNames ( type, classLoader) ) ; List < T > = this . createSpringFactoriesInstances ( type, parameterTypes, classLoader, args, names) ; AnnotationAwareOrderComparator . sort ( instances) ; return instances; } public static List < String > loadFactoryNames ( Class < ? > , @Nullable ClassLoader classLoader) { ClassLoader classLoaderToUse = classLoader; if ( classLoader == null ) { classLoaderToUse = SpringFactoriesLoader . class . getClassLoader ( ) ; } String factoryTypeName = factoryType. getName ( ) ; return ( List ) loadSpringFactories ( classLoaderToUse) . getOrDefault ( factoryTypeName, Collections . emptyList ( ) ) ; }
private static Map < String , List < String > > loadSpringFactories ( ClassLoader classLoader) {
}
Set < String > = new LinkedHashSet ( SpringFactoriesLoader . loadFactoryNames ( type, classLoader) ) ; List < T > = this . createSpringFactoriesInstances ( type, parameterTypes, classLoader, args, names) ; AnnotationAwareOrderComparator . sort ( instances) ; return instances;
this . setInitializers ( this . getSpringFactoriesInstances ( ApplicationContextInitializer . class ) ) ;
this . setInitializers ( this . getSpringFactoriesInstances ( ApplicationContextInitializer . class ) ) ; this . setListeners ( this . getSpringFactoriesInstances ( ApplicationListener . class ) ) ;
public class SpringApplication {
public ConfigurableApplicationContext run ( String . . . args) { long startTime = System . nanoTime ( ) ; DefaultBootstrapContext bootstrapContext = this . createBootstrapContext ( ) ; ConfigurableApplicationContext context = null ; this . configureHeadlessProperty ( ) ; SpringApplicationRunListeners listeners = this . getRunListeners ( args) ; listeners. starting ( bootstrapContext, this . mainApplicationClass) ; try { ApplicationArguments applicationArguments = new DefaultApplicationArguments ( args) ; ConfigurableEnvironment environment = this . prepareEnvironment ( listeners, bootstrapContext, applicationArguments) ; this . configureIgnoreBeanInfo ( environment) ; Banner printedBanner = this . printBanner ( environment) ; context = this . createApplicationContext ( ) ; context. setApplicationStartup ( this . applicationStartup) ; this . prepareContext ( bootstrapContext, context, environment, listeners, applicationArguments, printedBanner) ; this . refreshContext ( context) ; this . afterRefresh ( context, applicationArguments) ; Duration timeTakenToStartup = Duration . ofNanos ( System . nanoTime ( ) - startTime) ; if ( this . logStartupInfo) { ( new StartupInfoLogger ( this . mainApplicationClass) ) . logStarted ( this . getApplicationLog ( ) , timeTakenToStartup) ; } listeners. started ( context, timeTakenToStartup) ; this . callRunners ( context, applicationArguments) ; } catch ( Throwable var12) { this . handleRunFailure ( context, var12, listeners) ; throw new IllegalStateException ( var12) ; } try { Duration timeTakenToReady = Duration . ofNanos ( System . nanoTime ( ) - startTime) ; listeners. ready ( context, timeTakenToReady) ; return context; } catch ( Throwable var11) { this . handleRunFailure ( context, var11, ( SpringApplicationRunListeners ) null ) ; throw new IllegalStateException ( var11) ; } }
}
SpringApplicationRunListeners listeners = this . getRunListeners ( args) ; listeners. starting ( bootstrapContext, this . mainApplicationClass) ;
public class SpringApplication { private SpringApplicationRunListeners getRunListeners ( String [ ] args) { Class < ? > [ ] types = new Class [ ] { SpringApplication . class , String [ ] . class } ; return new SpringApplicationRunListeners ( logger, this . getSpringFactoriesInstances ( SpringApplicationRunListener . class , types, this , args) , this . applicationStartup) ; }
} private < T > Collection < T > getSpringFactoriesInstances ( Class < T > , Class < ? > [ ] parameterTypes, Object . . . args) { ClassLoader classLoader = this . getClassLoader ( ) ; Set < String > = new LinkedHashSet ( SpringFactoriesLoader . loadFactoryNames ( type, classLoader) ) ; List < T > = this . createSpringFactoriesInstances ( type, parameterTypes, classLoader, args, names) ; AnnotationAwareOrderComparator . sort ( instances) ; return instances; }
class SpringApplicationRunListeners { SpringApplicationRunListeners ( Log log, Collection < ? extends SpringApplicationRunListener > , ApplicationStartup applicationStartup) { this . log = log; this . listeners = new ArrayList ( listeners) ; this . applicationStartup = applicationStartup; } }
SpringApplicationRunListeners listeners = this . getRunListeners ( args) ;
listeners. starting ( bootstrapContext, this . mainApplicationClass) ; ApplicationArguments applicationArguments = new DefaultApplicationArguments ( args) ;
ConfigurableEnvironment environment = this . prepareEnvironment ( listeners, bootstrapContext, applicationArguments) ;
private ConfigurableEnvironment prepareEnvironment ( SpringApplicationRunListeners listeners, DefaultBootstrapContext bootstrapContext, ApplicationArguments applicationArguments) { ConfigurableEnvironment environment = this . getOrCreateEnvironment ( ) ; this . configureEnvironment ( ( ConfigurableEnvironment ) environment, applicationArguments. getSourceArgs ( ) ) ; ConfigurationPropertySources . attach ( ( Environment ) environment) ; listeners. environmentPrepared ( bootstrapContext, ( ConfigurableEnvironment ) environment) ; DefaultPropertiesPropertySource . moveToEnd ( ( ConfigurableEnvironment ) environment) ; Assert . state ( ! ( ( ConfigurableEnvironment ) environment) . containsProperty ( "spring.main.environment-prefix" ) , "Environment prefix cannot be set via properties." ) ; this . bindToSpringApplication ( ( ConfigurableEnvironment ) environment) ; if ( ! this . isCustomEnvironment) { EnvironmentConverter environmentConverter = new EnvironmentConverter ( this . getClassLoader ( ) ) ; environment = environmentConverter. convertEnvironmentIfNecessary ( ( ConfigurableEnvironment ) environment, this . deduceEnvironmentClass ( ) ) ; } ConfigurationPropertySources . attach ( ( Environment ) environment) ; return ( ConfigurableEnvironment ) environment; }
ConfigurableEnvironment environment = this . prepareEnvironment ( listeners, bootstrapContext, applicationArguments) ; this . configureIgnoreBeanInfo ( environment) ;
Banner printedBanner = this . printBanner ( environment) ; context = this . createApplicationContext ( ) ;
context. setApplicationStartup ( this . applicationStartup) ; this . prepareContext ( bootstrapContext, context, environment, listeners, applicationArguments, printedBanner) ;
protected ConfigurableApplicationContext createApplicationContext ( ) { return this . applicationContextFactory. create ( this . webApplicationType) ; }
package org. springframework. boot ; import java. util. Iterator ;
import java. util. function. Supplier ;
import org. springframework. beans. BeanUtils ;
import org. springframework. context. ConfigurableApplicationContext ;
import org. springframework. context. annotation. AnnotationConfigApplicationContext ;
import org. springframework. core. io. support. SpringFactoriesLoader ; @FunctionalInterface
public interface ApplicationContextFactory { ApplicationContextFactory DEFAULT = ( webApplicationType) -> { try { Iterator var1 = SpringFactoriesLoader . loadFactories ( ApplicationContextFactory . class , ApplicationContextFactory . class . getClassLoader ( ) ) . iterator ( ) ; ConfigurableApplicationContext context; do { if ( ! var1. hasNext ( ) ) { return new AnnotationConfigApplicationContext ( ) ; } ApplicationContextFactory candidate = ( ApplicationContextFactory ) var1. next ( ) ; context = candidate. create ( webApplicationType) ; } while ( context == null ) ; return context; } catch ( Exception var4) { throw new IllegalStateException ( "Unable create a default ApplicationContext instance, you may need a custom ApplicationContextFactory" , var4) ; } } ; ConfigurableApplicationContext create ( WebApplicationType webApplicationType) ; static ApplicationContextFactory ofContextClass ( Class < ? extends ConfigurableApplicationContext > ) { return of ( ( ) -> { return ( ConfigurableApplicationContext ) BeanUtils . instantiateClass ( contextClass) ; } ) ; } static ApplicationContextFactory of ( Supplier < ConfigurableApplicationContext > ) { return ( webApplicationType) -> { return ( ConfigurableApplicationContext ) supplier. get ( ) ; } ; }
} public class AnnotationConfigServletWebServerApplicationContext extends ServletWebServerApplicationContext implements AnnotationConfigRegistry { public ConfigurableApplicationContext create ( WebApplicationType webApplicationType) { return webApplicationType != WebApplicationType . SERVLET ? null : new AnnotationConfigServletWebServerApplicationContext ( ) ; }
} public class ServletWebServerApplicationContext extends GenericWebApplicationContext implements ConfigurableWebServerApplicationContext {
} public class GenericWebApplicationContext extends GenericApplicationContext implements ConfigurableWebApplicationContext , ThemeSource {
} public class GenericApplicationContext extends AbstractApplicationContext implements BeanDefinitionRegistry {
}
public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
}
public interface ConfigurableApplicationContext extends ApplicationContext , Lifecycle , Closeable {
}
public interface ConfigurableWebServerApplicationContext extends ConfigurableApplicationContext , WebServerApplicationContext { void setServerNamespace ( String serverNamespace) ;
}
public class GenericWebApplicationContext extends GenericApplicationContext implements ConfigurableWebApplicationContext , ThemeSource {
}
public class GenericApplicationContext extends AbstractApplicationContext implements BeanDefinitionRegistry {
}
this . prepareContext ( bootstrapContext, context, environment, listeners, applicationArguments, printedBanner) ;
private void prepareContext ( DefaultBootstrapContext bootstrapContext, ConfigurableApplicationContext context, ConfigurableEnvironment environment, SpringApplicationRunListeners listeners, ApplicationArguments applicationArguments, Banner printedBanner) { context. setEnvironment ( environment) ; this . postProcessApplicationContext ( context) ; this . applyInitializers ( context) ; listeners. contextPrepared ( context) ; bootstrapContext. close ( context) ; if ( this . logStartupInfo) { this . logStartupInfo ( context. getParent ( ) == null ) ; this . logStartupProfileInfo ( context) ; } ConfigurableListableBeanFactory beanFactory = context. getBeanFactory ( ) ; beanFactory. registerSingleton ( "springApplicationArguments" , applicationArguments) ; if ( printedBanner != null ) { beanFactory. registerSingleton ( "springBootBanner" , printedBanner) ; } if ( beanFactory instanceof AbstractAutowireCapableBeanFactory ) { ( ( AbstractAutowireCapableBeanFactory ) beanFactory) . setAllowCircularReferences ( this . allowCircularReferences) ; if ( beanFactory instanceof DefaultListableBeanFactory ) { ( ( DefaultListableBeanFactory ) beanFactory) . setAllowBeanDefinitionOverriding ( this . allowBeanDefinitionOverriding) ; } } if ( this . lazyInitialization) { context. addBeanFactoryPostProcessor ( new LazyInitializationBeanFactoryPostProcessor ( ) ) ; } context. addBeanFactoryPostProcessor ( new SpringApplication. PropertySourceOrderingBeanFactoryPostProcessor ( context) ) ; Set < Object > = this . getAllSources ( ) ; Assert . notEmpty ( sources, "Sources must not be empty" ) ; this . load ( context, sources. toArray ( new Object [ 0 ] ) ) ; listeners. contextLoaded ( context) ; }
protected void load ( ApplicationContext context, Object [ ] sources) { if ( logger. isDebugEnabled ( ) ) { logger. debug ( "Loading source " + StringUtils . arrayToCommaDelimitedString ( sources) ) ; } BeanDefinitionLoader loader = this . createBeanDefinitionLoader ( this . getBeanDefinitionRegistry ( context) , sources) ; if ( this . beanNameGenerator != null ) { loader. setBeanNameGenerator ( this . beanNameGenerator) ; } if ( this . resourceLoader != null ) { loader. setResourceLoader ( this . resourceLoader) ; } if ( this . environment != null ) { loader. setEnvironment ( this . environment) ; } loader. load ( ) ; }
void load ( ) { Object [ ] var1 = this . sources; int var2 = var1. length; for ( int var3 = 0 ; var3 < var2; ++ var3) { Object source = var1[ var3] ; this . load ( source) ; } } private void load ( Object source) { Assert . notNull ( source, "Source must not be null" ) ; if ( source instanceof Class ) { this . load ( ( Class ) source) ; } else if ( source instanceof Resource ) { this . load ( ( Resource ) source) ; } else if ( source instanceof Package ) { this . load ( ( Package ) source) ; } else if ( source instanceof CharSequence ) { this . load ( ( CharSequence ) source) ; } else { throw new IllegalArgumentException ( "Invalid source type " + source. getClass ( ) ) ; } } private void load ( Class < ? > ) { if ( this . isGroovyPresent ( ) && BeanDefinitionLoader. GroovyBeanDefinitionSource . class . isAssignableFrom ( source) ) { BeanDefinitionLoader. GroovyBeanDefinitionSource loader = ( BeanDefinitionLoader. GroovyBeanDefinitionSource ) BeanUtils . instantiateClass ( source, BeanDefinitionLoader. GroovyBeanDefinitionSource . class ) ; ( ( GroovyBeanDefinitionReader ) this . groovyReader) . beans ( loader. getBeans ( ) ) ; } if ( this . isEligible ( source) ) { this . annotatedReader. register ( new Class [ ] { source} ) ; } }
public void register ( Class < ? > . . . componentClasses) { Class [ ] var2 = componentClasses; int var3 = componentClasses. length; for ( int var4 = 0 ; var4 < var3; ++ var4) { Class < ? > = var2[ var4] ; this . registerBean ( componentClass) ; } } public void registerBean ( Class < ? > ) { this . doRegisterBean ( beanClass, ( String ) null , ( Class [ ] ) null , ( Supplier ) null , ( BeanDefinitionCustomizer [ ] ) null ) ; }
private < T > void doRegisterBean ( Class < T > , @Nullable String name, @Nullable Class < ? extends Annotation > [ ] qualifiers, @Nullable Supplier < T > , @Nullable BeanDefinitionCustomizer [ ] customizers) { AnnotatedGenericBeanDefinition abd = new AnnotatedGenericBeanDefinition ( beanClass) ; if ( ! this . conditionEvaluator. shouldSkip ( abd. getMetadata ( ) ) ) { abd. setInstanceSupplier ( supplier) ; ScopeMetadata scopeMetadata = this . scopeMetadataResolver. resolveScopeMetadata ( abd) ; abd. setScope ( scopeMetadata. getScopeName ( ) ) ; String beanName = name != null ? name : this . beanNameGenerator. generateBeanName ( abd, this . registry) ; AnnotationConfigUtils . processCommonDefinitionAnnotations ( abd) ; int var10; int var11; if ( qualifiers != null ) { Class [ ] var9 = qualifiers; var10 = qualifiers. length; for ( var11 = 0 ; var11 < var10; ++ var11) { Class < ? extends Annotation > = var9[ var11] ; if ( Primary . class == qualifier) { abd. setPrimary ( true ) ; } else if ( Lazy . class == qualifier) { abd. setLazyInit ( true ) ; } else { abd. addQualifier ( new AutowireCandidateQualifier ( qualifier) ) ; } } } if ( customizers != null ) { BeanDefinitionCustomizer [ ] var13 = customizers; var10 = customizers. length; for ( var11 = 0 ; var11 < var10; ++ var11) { BeanDefinitionCustomizer customizer = var13[ var11] ; customizer. customize ( abd) ; } } BeanDefinitionHolder definitionHolder = new BeanDefinitionHolder ( abd, beanName) ; definitionHolder = AnnotationConfigUtils . applyScopedProxyMode ( scopeMetadata, definitionHolder, this . registry) ; BeanDefinitionReaderUtils . registerBeanDefinition ( definitionHolder, this . registry) ; } } public static void registerBeanDefinition ( BeanDefinitionHolder definitionHolder, BeanDefinitionRegistry registry) throws BeanDefinitionStoreException { String beanName = definitionHolder. getBeanName ( ) ; registry. registerBeanDefinition ( beanName, definitionHolder. getBeanDefinition ( ) ) ; String [ ] aliases = definitionHolder. getAliases ( ) ; if ( aliases != null ) { String [ ] var4 = aliases; int var5 = aliases. length; for ( int var6 = 0 ; var6 < var5; ++ var6) { String alias = var4[ var6] ; registry. registerAlias ( beanName, alias) ; } } }
public void registerBeanDefinition ( String beanName, BeanDefinition beanDefinition) throws BeanDefinitionStoreException { this . beanFactory. registerBeanDefinition ( beanName, beanDefinition) ; }
this . prepareContext ( bootstrapContext, context, environment, listeners, applicationArguments, printedBanner) ; this . refreshContext ( context) ; this . afterRefresh ( context, applicationArguments) ; Duration timeTakenToStartup = Duration . ofNanos ( System . nanoTime ( ) - startTime) ;
this . refreshContext ( context) ;
private void refreshContext ( ConfigurableApplicationContext context) { if ( this . registerShutdownHook) { shutdownHook. registerApplicationContext ( context) ; } this . refresh ( context) ; } protected void refresh ( ConfigurableApplicationContext applicationContext) { applicationContext. refresh ( ) ; }
this . refreshContext ( context) ; this . afterRefresh ( context, applicationArguments) ;
protected void afterRefresh ( ConfigurableApplicationContext context, ApplicationArguments args) { }
public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext { public void refresh ( ) throws BeansException , IllegalStateException { synchronized ( this . startupShutdownMonitor) { StartupStep contextRefresh = this . applicationStartup. start ( "spring.context.refresh" ) ; this . prepareRefresh ( ) ; ConfigurableListableBeanFactory beanFactory = this . obtainFreshBeanFactory ( ) ; this . prepareBeanFactory ( beanFactory) ; try { this . postProcessBeanFactory ( beanFactory) ; StartupStep beanPostProcess = this . applicationStartup. start ( "spring.context.beans.post-process" ) ; this . invokeBeanFactoryPostProcessors ( beanFactory) ; this . registerBeanPostProcessors ( beanFactory) ; beanPostProcess. end ( ) ; this . initMessageSource ( ) ; this . initApplicationEventMulticaster ( ) ; this . onRefresh ( ) ; this . registerListeners ( ) ; this . finishBeanFactoryInitialization ( beanFactory) ; this . finishRefresh ( ) ; } catch ( BeansException var10) { if ( this . logger. isWarnEnabled ( ) ) { this . logger. warn ( "Exception encountered during context initialization - cancelling refresh attempt: " + var10) ; } this . destroyBeans ( ) ; this . cancelRefresh ( var10) ; throw var10; } finally { this . resetCommonCaches ( ) ; contextRefresh. end ( ) ; } } }
}
public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {
protected void finishRefresh ( ) { this . clearResourceCaches ( ) ; this . initLifecycleProcessor ( ) ; this . getLifecycleProcessor ( ) . onRefresh ( ) ; this . publishEvent ( ( ApplicationEvent ) ( new ContextRefreshedEvent ( this ) ) ) ; if ( ! NativeDetector . inNativeImage ( ) ) { LiveBeansView . registerApplicationContext ( this ) ; } }
} public class DefaultLifecycleProcessor implements LifecycleProcessor , BeanFactoryAware { public void onRefresh ( ) { this . startBeans ( true ) ; this . running = true ; }
} this . initLifecycleProcessor ( ) ; this . getLifecycleProcessor ( ) . onRefresh ( ) ;
protected void initLifecycleProcessor ( ) { ConfigurableListableBeanFactory beanFactory = this . getBeanFactory ( ) ; if ( beanFactory. containsLocalBean ( "lifecycleProcessor" ) ) { this . lifecycleProcessor = ( LifecycleProcessor ) beanFactory. getBean ( "lifecycleProcessor" , LifecycleProcessor . class ) ; if ( this . logger. isTraceEnabled ( ) ) { this . logger. trace ( "Using LifecycleProcessor [" + this . lifecycleProcessor + "]" ) ; } } else { DefaultLifecycleProcessor defaultProcessor = new DefaultLifecycleProcessor ( ) ; defaultProcessor. setBeanFactory ( beanFactory) ; this . lifecycleProcessor = defaultProcessor; beanFactory. registerSingleton ( "lifecycleProcessor" , this . lifecycleProcessor) ; if ( this . logger. isTraceEnabled ( ) ) { this . logger. trace ( "No 'lifecycleProcessor' bean, using [" + this . lifecycleProcessor. getClass ( ) . getSimpleName ( ) + "]" ) ; } } }
public class DefaultLifecycleProcessor implements LifecycleProcessor , BeanFactoryAware {
private void startBeans ( boolean autoStartupOnly) { Map < String , Lifecycle > = this . getLifecycleBeans ( ) ; Map < Integer , DefaultLifecycleProcessor. LifecycleGroup > = new TreeMap ( ) ; lifecycleBeans. forEach ( ( beanName, bean) -> { if ( ! autoStartupOnly || bean instanceof SmartLifecycle && ( ( SmartLifecycle ) bean) . isAutoStartup ( ) ) { int phase = this . getPhase ( bean) ; ( ( DefaultLifecycleProcessor. LifecycleGroup ) phases. computeIfAbsent ( phase, ( p) -> { return new DefaultLifecycleProcessor. LifecycleGroup ( phase, this . timeoutPerShutdownPhase, lifecycleBeans, autoStartupOnly) ; } ) ) . add ( beanName, bean) ; } } ) ; if ( ! phases. isEmpty ( ) ) { phases. values ( ) . forEach ( DefaultLifecycleProcessor. LifecycleGroup :: start ) ; } }
}
public class DefaultLifecycleProcessor implements LifecycleProcessor , BeanFactoryAware { public void start ( ) { if ( ! this . members. isEmpty ( ) ) { if ( DefaultLifecycleProcessor . this . logger. isDebugEnabled ( ) ) { DefaultLifecycleProcessor . this . logger. debug ( "Starting beans in phase " + this . phase) ; } Collections . sort ( this . members) ; Iterator var1 = this . members. iterator ( ) ; while ( var1. hasNext ( ) ) { DefaultLifecycleProcessor. LifecycleGroupMember member = ( DefaultLifecycleProcessor. LifecycleGroupMember ) var1. next ( ) ; DefaultLifecycleProcessor . this . doStart ( this . lifecycleBeans, member. name, this . autoStartupOnly) ; } } }
}
DefaultLifecycleProcessor . this . doStart ( this . lifecycleBeans, member. name, this . autoStartupOnly) ;
private void doStart ( Map < String , ? extends Lifecycle > , String beanName, boolean autoStartupOnly) { Lifecycle bean = ( Lifecycle ) lifecycleBeans. remove ( beanName) ; if ( bean != null && bean != this ) { String [ ] dependenciesForBean = this . getBeanFactory ( ) . getDependenciesForBean ( beanName) ; String [ ] var6 = dependenciesForBean; int var7 = dependenciesForBean. length; for ( int var8 = 0 ; var8 < var7; ++ var8) { String dependency = var6[ var8] ; this . doStart ( lifecycleBeans, dependency, autoStartupOnly) ; } if ( ! bean. isRunning ( ) && ( ! autoStartupOnly || ! ( bean instanceof SmartLifecycle ) || ( ( SmartLifecycle ) bean) . isAutoStartup ( ) ) ) { if ( this . logger. isTraceEnabled ( ) ) { this . logger. trace ( "Starting bean '" + beanName + "' of type [" + bean. getClass ( ) . getName ( ) + "]" ) ; } try { bean. start ( ) ; } catch ( Throwable var10) { throw new ApplicationContextException ( "Failed to start bean '" + beanName + "'" , var10) ; } if ( this . logger. isDebugEnabled ( ) ) { this . logger. debug ( "Successfully started bean '" + beanName + "'" ) ; } } } }
Tomcat started on port ( s) : 8080 ( http) with context path '/hello'
public class AnnotationConfigServletWebServerApplicationContext extends ServletWebServerApplicationContext implements AnnotationConfigRegistry {
}
class WebServerStartStopLifecycle implements SmartLifecycle { public void start ( ) { this . webServer. start ( ) ; this . running = true ; this . applicationContext. publishEvent ( new ServletWebServerInitializedEvent ( this . webServer, this . applicationContext) ) ; } }
public class TomcatWebServer implements WebServer {
public void start ( ) throws WebServerException { synchronized ( this . monitor) { if ( ! this . started) { boolean var10 = false ; try { var10 = true ; this . addPreviouslyRemovedConnectors ( ) ; Connector var2 = this . tomcat. getConnector ( ) ; if ( var2 != null && this . autoStart) { this . performDeferredLoadOnStartup ( ) ; } this . checkThatConnectorsHaveStarted ( ) ; this . started = true ; logger. info ( "Tomcat started on port(s): " + this . getPortsDescription ( true ) + " with context path '" + this . getContextPath ( ) + "'" ) ; var10 = false ; } catch ( ConnectorStartFailedException var11) { this . stopSilently ( ) ; throw var11; } catch ( Exception var12) { PortInUseException . throwIfPortBindingException ( var12, ( ) -> { return this . tomcat. getConnector ( ) . getPort ( ) ; } ) ; throw new WebServerException ( "Unable to start embedded Tomcat server" , var12) ; } finally { if ( var10) { Context context = this . findContext ( ) ; ContextBindings . unbindClassLoader ( context, context. getNamingToken ( ) , this . getClass ( ) . getClassLoader ( ) ) ; } } Context context = this . findContext ( ) ; ContextBindings . unbindClassLoader ( context, context. getNamingToken ( ) , this . getClass ( ) . getClassLoader ( ) ) ; } } }
}
Connector var2 = this . tomcat. getConnector ( ) ; if ( var2 != null && this . autoStart) { this . performDeferredLoadOnStartup ( ) ; }
public class Tomcat { public Connector getConnector ( ) { Service service = this . getService ( ) ; if ( service. findConnectors ( ) . length > 0 ) { return service. findConnectors ( ) [ 0 ] ; } else { Connector connector = new Connector ( "HTTP/1.1" ) ; connector. setPort ( this . port) ; service. addConnector ( connector) ; return connector; } }
}
this . performDeferredLoadOnStartup ( ) ;
public class TomcatWebServer implements WebServer { private void performDeferredLoadOnStartup ( ) { try { Container [ ] var1 = this . tomcat. getHost ( ) . findChildren ( ) ; int var2 = var1. length; for ( int var3 = 0 ; var3 < var2; ++ var3) { Container child = var1[ var3] ; if ( child instanceof TomcatEmbeddedContext ) { ( ( TomcatEmbeddedContext ) child) . deferredLoadOnStartup ( ) ; } } } catch ( Exception var5) { if ( var5 instanceof WebServerException ) { throw ( WebServerException ) var5; } else { throw new WebServerException ( "Unable to start embedded Tomcat connectors" , var5) ; } } }
}
public TomcatWebServer ( Tomcat tomcat, boolean autoStart, Shutdown shutdown) { this . monitor = new Object ( ) ; this . serviceConnectors = new HashMap ( ) ; Assert . notNull ( tomcat, "Tomcat Server must not be null" ) ; this . tomcat = tomcat; this . autoStart = autoStart; this . gracefulShutdown = shutdown == Shutdown . GRACEFUL ? new GracefulShutdown ( tomcat) : null ; this . initialize ( ) ; } private void initialize ( ) throws WebServerException { logger. info ( "Tomcat initialized with port(s): " + this . getPortsDescription ( false ) ) ; synchronized ( this . monitor) { try { this . addInstanceIdToEngineName ( ) ; Context context = this . findContext ( ) ; context. addLifecycleListener ( ( event) -> { if ( context. equals ( event. getSource ( ) ) && "start" . equals ( event. getType ( ) ) ) { this . removeServiceConnectors ( ) ; } } ) ; this . tomcat. start ( ) ; this . rethrowDeferredStartupExceptions ( ) ; try { ContextBindings . bindClassLoader ( context, context. getNamingToken ( ) , this . getClass ( ) . getClassLoader ( ) ) ; } catch ( NamingException var5) { } this . startDaemonAwaitThread ( ) ; } catch ( Exception var6) { this . stopSilently ( ) ; this . destroySilently ( ) ; throw new WebServerException ( "Unable to start embedded Tomcat" , var6) ; } } }
this . checkThatConnectorsHaveStarted ( ) ;
private void checkThatConnectorsHaveStarted ( ) { this . checkConnectorHasStarted ( this . tomcat. getConnector ( ) ) ; Connector [ ] var1 = this . tomcat. getService ( ) . findConnectors ( ) ; int var2 = var1. length; for ( int var3 = 0 ; var3 < var2; ++ var3) { Connector connector = var1[ var3] ; this . checkConnectorHasStarted ( connector) ; } }
for ( int var3 = 0 ; var3 < var2; ++ var3) { Container child = var1[ var3] ; if ( child instanceof TomcatEmbeddedContext ) { ( ( TomcatEmbeddedContext ) child) . deferredLoadOnStartup ( ) ; } }
this . started = true ;
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < scope> </ scope> </ dependency> public class TomcatWebServer implements WebServer { private final Tomcat tomcat;
} package org. apache. catalina. startup ;
public class Tomcat {
}
< dependencies> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> </ dependencies> package com ; import org. apache. catalina. Context ;
import org. apache. catalina. connector. Connector ;
import org. apache. catalina. startup. Tomcat ; import javax. servlet. ServletException ;
import javax. servlet. http. HttpServlet ;
import javax. servlet. http. HttpServletRequest ;
import javax. servlet. http. HttpServletResponse ;
import java. io. IOException ; public class EmbeddedTomcat { public static void main ( String [ ] args) throws Exception { Tomcat tomcat = new Tomcat ( ) ; tomcat. setHostname ( "localhost" ) ; Connector connector = new Connector ( "org.apache.coyote.http11.Http11NioProtocol" ) ; connector. setPort ( 8081 ) ; tomcat. getConnector ( ) . setAttribute ( "enableNaming" , false ) ; tomcat. getService ( ) . addConnector ( connector) ; Context ctx = tomcat. addWebapp ( "" , System . getProperty ( "java.io.tmpdir" ) ) ; Tomcat . addServlet ( ctx, "helloServlet" , new HttpServlet ( ) { @Override protected void doGet ( HttpServletRequest req, HttpServletResponse resp) throws ServletException , IOException { System . out. println ( 1 ) ; resp. setContentType ( "text/html" ) ; resp. getWriter ( ) . println ( "<h1>Hello, World!</h1>" ) ; } } ) ; ctx. addServletMappingDecoded ( "/hello" , "helloServlet" ) ; tomcat. start ( ) ; System . out. println ( 2 ) ; tomcat. getServer ( ) . await ( ) ; System . out. println ( 3 ) ; }
} <?xml version="1.0" encoding="UTF-8"?>
< projectxmlns = " 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" > < modelVersion> </ modelVersion> < parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < relativePath/> </ parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < properties> < maven.compiler.source> </ maven.compiler.source> < maven.compiler.target> </ maven.compiler.target> </ properties> < dependencies> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> </ dependencies> </ project> package com ; import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
public class BootApplication { public static void main ( String [ ] args) { SpringApplication . run ( BootApplication . class , args) ; }
} package com. boot. controller ; import org. springframework. stereotype. Controller ;
import org. springframework. web. bind. annotation. RequestMapping ;
import org. springframework. web. bind. annotation. RestController ; @RestController
public class HelloController { @RequestMapping ( "/boot" ) public void helloBoot ( int num) throws InterruptedException { System . out. println ( Thread . currentThread ( ) . getName ( ) + "位：" + num) ; Thread . sleep ( 1000 ) ; } }
package com. test ; public class url { public static void main ( String [ ] args) { for ( int i = 0 ; i < 1000 ; i++ ) { int finalI = i; new Thread ( ( ) -> { HttpUtil . get ( "http://localhost:8080/boot?num=" + finalI) ; } ) . start ( ) ; } Thread . yield ( ) ; }
} < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> package com. test ; import okhttp3. OkHttpClient ;
import okhttp3. Request ;
import okhttp3. Response ; import java. io. IOException ; public class HttpUtil { private static final OkHttpClient httpClient = new OkHttpClient ( ) ; public static String get ( String url) { Request request = new Request. Builder ( ) . url ( url) . build ( ) ; try ( Response response = httpClient. newCall ( request) . execute ( ) ) { return response. body ( ) . string ( ) ; } catch ( IOException e) { e. printStackTrace ( ) ; return null ; } }
}
this . callRunners ( context, applicationArguments) ;
private void callRunners ( ApplicationContext context, ApplicationArguments args) {
List < Object > = new ArrayList ( ) ; runners. addAll ( context. getBeansOfType ( ApplicationRunner . class ) . values ( ) ) ; runners. addAll ( context. getBeansOfType ( CommandLineRunner . class ) . values ( ) ) ; AnnotationAwareOrderComparator . sort ( runners) ; Iterator var4 = ( new LinkedHashSet ( runners) ) . iterator ( ) ; while ( var4. hasNext ( ) ) { Object runner = var4. next ( ) ; if ( runner instanceof ApplicationRunner ) { this . callRunner ( ( ApplicationRunner ) runner, args) ; } if ( runner instanceof CommandLineRunner ) { this . callRunner ( ( CommandLineRunner ) runner, args) ; } } }
CREATE DATABASE springbootdata;
USE springbootdata;
DROP TABLE IF EXISTS t_article;
CREATE TABLE t_article ( id int ( 20 ) NOT NULL AUTO_INCREMENT COMMENT '文章id' , title varchar ( 200 ) DEFAULT NULL COMMENT '文章标题' , content longtext COMMENT '文章内容' , PRIMARY KEY ( id)
) ENGINE = InnoDB AUTO_INCREMENT = 2 DEFAULT CHARSET = utf8; INSERT INTO t_article VALUES ( '1' , 'Spring Boot基础入门' , '从入门到精通讲解...' ) ;
INSERT INTO t_article VALUES ( '2' , 'Spring Cloud基础入门' , '从入门到精通讲解...' ) ;
DROP TABLE IF EXISTS t_comment;
CREATE TABLE t_comment ( id int ( 20 ) NOT NULL AUTO_INCREMENT COMMENT '评论id' , content longtext COMMENT '评论内容' , author varchar ( 200 ) DEFAULT NULL COMMENT '评论作者' , a_id int ( 20 ) DEFAULT NULL COMMENT '关联的文章id' , PRIMARY KEY ( id)
) ENGINE = InnoDB AUTO_INCREMENT = 3 DEFAULT CHARSET = utf8; INSERT INTO t_comment VALUES ( '1' , '很全、很详细' , 'lucy' , '1' ) ;
INSERT INTO t_comment VALUES ( '2' , '赞一个' , 'tom' , '1' ) ;
INSERT INTO t_comment VALUES ( '3' , '很详细' , 'eric' , '1' ) ;
INSERT INTO t_comment VALUES ( '4' , '很好，非常详细' , '张三' , '1' ) ;
INSERT INTO t_comment VALUES ( '5' , '很不错' , '李四' , '2' ) ;
<?xml version="1.0" encoding="UTF-8"?>
< projectxmlns = " 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" > < modelVersion> </ modelVersion> < parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < relativePath/> </ parent> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> < properties> < maven.compiler.source> </ maven.compiler.source> < maven.compiler.target> </ maven.compiler.target> </ properties> < dependencies> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> </ dependencies> < build> < plugins> < plugin> < groupId> </ groupId> < artifactId> </ artifactId> </ plugin> </ plugins> </ build> </ project> package com ; import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
public class boot { public static void main ( String [ ] args) { SpringApplication . run ( boot. class , args) ; }
} package com. pojo ; public class Comment { private Integer id; private String content; private String author; private Integer aId; @Override public String toString ( ) { return "Comment{" + "id=" + id + ", content='" + content + '\'' + ", author='" + author + '\'' + ", aId=" + aId + '}' ; } public Integer getId ( ) { return id; } public void setId ( Integer id) { this . id = id; } public String getContent ( ) { return content; } public void setContent ( String content) { this . content = content; } public String getAuthor ( ) { return author; } public void setAuthor ( String author) { this . author = author; } public Integer getaId ( ) { return aId; } public void setaId ( Integer aId) { this . aId = aId; }
}
package com. pojo ; public class Article { private Integer id; private String title; private String content; @Override public String toString ( ) { return "Article{" + "id=" + id + ", title='" + title + '\'' + ", content='" + content + '\'' + '}' ; } public Integer getId ( ) { return id; } public void setId ( Integer id) { this . id = id; } public String getTitle ( ) { return title; } public void setTitle ( String title) { this . title = title; } public String getContent ( ) { return content; } public void setContent ( String content) { this . content = content; }
}
spring : datasource : url : jdbc: mysql: //localhost: 3306/springbootdata? serverTimezone=UTC&characterEncoding=UTF- 8 username : rootpassword : 123456
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> < scope> </ scope> </ dependency> package com ; import org. junit. jupiter. api. Test ;
import org. junit. runner. RunWith ;
import org. springframework. boot. test. context. SpringBootTest ;
import org. springframework. test. context. junit4. SpringRunner ; @RunWith ( SpringRunner . class )
@SpringBootTest
class test { @Test public void contextLoads ( ) { System . out. println ( 1 ) ; }
} package com. mapper ; import com. pojo. Comment ;
import org. apache. ibatis. annotations. Select ; public interface CommentMapper { @Select ( "select * from t_comment where id = #{id}" ) public Comment findById ( Integer id) ; }
package com ; import org. mybatis. spring. annotation. MapperScan ;
import org. springframework. boot. SpringApplication ;
import org. springframework. boot. autoconfigure. SpringBootApplication ; @SpringBootApplication
@MapperScan ( "com.mapper" )
public class boot { public static void main ( String [ ] args) { SpringApplication . run ( boot. class , args) ; }
} @Autowired private CommentMapper commentMapper; @Test public void mtbatis ( ) { Comment byId = commentMapper. findById ( 1 ) ; System . out. println ( byId) ; }
因为这时控制台中查询的Comment的aId属性值为null，没有映射成功
这是因为编写的实体类Comment中使用了驼峰命名方式将t_comment表中的a_id字段设计成了aId属性，所以无法正确映射查询结果了
mybatis : configuration : map-underscore-to-camel-case : true
package com. mapper ; import com. pojo. Article ; public interface ArticleMapper { public Article selectArticle ( Integer id) ;
}
<?xml version="1.0" encoding="UTF-8" ?>
<! DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" > < mappernamespace = " com.mapper.ArticleMapper" > < selectid = " selectArticle" resultType = " com.pojo.Article" > </ select> </ mapper> @Autowired private ArticleMapper articleMapper; @Test public void artice ( ) { Article byId = articleMapper. selectArticle ( 1 ) ; System . out. println ( byId) ; }
mybatis : configuration : map-underscore-to-camel-case : true mapper-locations : classpath: mapper/*.xml type-aliases-package : com.pojo< dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency>
spring : datasource : url : jdbc: mysql: //localhost: 3306/springbootdata? serverTimezone=UTC&characterEncoding=UTF- 8 username : rootpassword : 123456 package com. pojo ; import javax. persistence. * ; @Entity ( name = "t_comment" )
public class Comment { @Id @GeneratedValue ( strategy = GenerationType . IDENTITY ) private Integer id; private String content; private String author; @Column ( name = "a_id" ) private Integer aId; public Integer getId ( ) { return id; } public void setId ( Integer id) { this . id = id; } public String getContent ( ) { return content; } public void setContent ( String content) { this . content = content; } public String getAuthor ( ) { return author; } public void setAuthor ( String author) { this . author = author; } public Integer getaId ( ) { return aId; } public void setaId ( Integer aId) { this . aId = aId; } @Override public String toString ( ) { return "Comment{" + "id=" + id + ", content='" + content + '\'' + ", author='" + author + '\'' + ", aId=" + aId + '}' ; }
} package com. mapper ; import com. pojo. Comment ;
import org. springframework. data. jpa. repository. JpaRepository ; public interface CommentRepository extends JpaRepository < Comment , Integer > {
} @Autowired private CommentRepository repository; @Test public void selectComment ( ) { Optional < Comment > = repository. findById ( 1 ) ; if ( optional. isPresent ( ) ) { System . out. println ( optional. get ( ) ) ; } System . out. println ( ) ; }
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> < dependency> < groupId> </ groupId> < artifactId> </ artifactId> </ dependency> package com. pojo ; import org. springframework. data. redis. core. RedisHash ;
import org. springframework. data. redis. core. index. Indexed ; import javax. persistence. Id ; @RedisHash ( "persons" )
public class Person { @Id private String id; @Indexed private String firstname; @Indexed private String lastname; private Address address; public Person ( String id, String firstname, String lastname, Address address) { this . id = id; this . firstname = firstname; this . lastname = lastname; this . address = address; } public Person ( ) { } public String getId ( ) { return id; } public void setId ( String id) { this . id = id; } public String getFirstname ( ) { return firstname; } public void setFirstname ( String firstname) { this . firstname = firstname; } public String getLastname ( ) { return lastname; } public void setLastname ( String lastname) { this . lastname = lastname; } public Address getAddress ( ) { return address; } public void setAddress ( Address address) { this . address = address; }
} package com. pojo ; import org. springframework. data. redis. core. index. Indexed ; public class Address { @Indexed private String city; @Indexed private String country; public Address ( String city, String country) { this . city = city; this . country = country; } public Address ( ) { } public String getCity ( ) { return city; } public void setCity ( String city) { this . city = city; } public String getCountry ( ) { return country; } public void setCountry ( String country) { this . country = country; }
}
package com. mapper ; import com. pojo. Person ;
import org. springframework. data. repository. CrudRepository ; import java. util. List ; public interface PersonRepository extends CrudRepository < Person , String > { List < Person > findByAddress_City ( String name) ;
}
spring : redis : host : 192.168.136.128 port : 6379 @Autowired private PersonRepository repository;
@Test public void savePerson ( ) { Person person = new Person ( ) ; person. setFirstname ( "张" ) ; person. setLastname ( "三" ) ; Address address = new Address ( ) ; address. setCity ( "北京" ) ; address. setCountry ( "中国" ) ; person. setAddress ( address) ; Person save = repository. save ( person) ; }
package com. util ; import org. springframework. beans. factory. annotation. Autowired ;
import org. springframework. data. redis. core. RedisTemplate ;
import org. springframework. stereotype. Component ; import java. util. concurrent. TimeUnit ; @Component
public class RedisUtils { @Autowired private RedisTemplate redisTemplate; public Object get ( final String key) { return redisTemplate. opsForValue ( ) . get ( key) ; } public boolean set ( String key, Object value) { boolean result = false ; try { redisTemplate. opsForValue ( ) . set ( key, value, 1 , TimeUnit . DAYS ) ; result = true ; } catch ( Exception e) { e. printStackTrace ( ) ; } return result; } public boolean getAndSet ( final String key, String value) { boolean result = false ; try { redisTemplate. opsForValue ( ) . getAndSet ( key, value) ; result = true ; } catch ( Exception e) { e. printStackTrace ( ) ; } return result; } public boolean delete ( final String key) { boolean result = false ; try { redisTemplate. delete ( key) ; result = true ; } catch ( Exception e) { e. printStackTrace ( ) ; } return result; }
} @Autowired private RedisUtils redisUtils; @Test public void writeRedis ( ) { boolean set = redisUtils. set ( "1" , "1" ) ; System . out. println ( set) ; } @Test public void readRedis ( ) { Object o = redisUtils. get ( "1" ) ; System . out. println ( o) ; }
public boolean set ( String key, Object value) { boolean result = false ; try { redisTemplate. setKeySerializer ( new StringRedisSerializer ( ) ) ; redisTemplate. setValueSerializer ( new GenericJackson2JsonRedisSerializer ( ) ) ; redisTemplate. opsForValue ( ) . set ( key, value, 1 , TimeUnit . DAYS ) ; result = true ; } catch ( Exception e) { e. printStackTrace ( ) ; } return result; }
< dependency> < groupId> </ groupId> < artifactId> </ artifactId> < version> </ version> </ dependency>
package com. config ; import org. springframework. data. redis. serializer. RedisSerializer ;
import org. springframework. data. redis. serializer. SerializationException ; import java. io. UnsupportedEncodingException ; public class keyValueConfig implements RedisSerializer { @Override public byte [ ] serialize ( Object string) throws SerializationException { if ( string instanceof String ) { try { return string == null ? null : ( ( String ) string) . getBytes ( "UTF-8" ) ; } catch ( UnsupportedEncodingException e) { e. printStackTrace ( ) ; } } if ( string instanceof Integer ) { try { return string == null ? null : ( String . valueOf ( string) ) . getBytes ( "UTF-8" ) ; } catch ( UnsupportedEncodingException e) { e. printStackTrace ( ) ; } } return null ; } @Override public Object deserialize ( byte [ ] bytes) throws SerializationException { try { return bytes == null ? null : new String ( bytes, "UTF-8" ) ; } catch ( UnsupportedEncodingException e) { e. printStackTrace ( ) ; } return null ; }
} public Object get ( final Object key) { redisTemplate. setKeySerializer ( new keyValueConfig ( ) ) ; return redisTemplate. opsForValue ( ) . get ( key) ; } public boolean set ( Object key, Object value) { boolean result = false ; try { redisTemplate. setKeySerializer ( new keyValueConfig ( ) ) ; redisTemplate. setValueSerializer ( new keyValueConfig ( ) ) ; redisTemplate. opsForValue ( ) . set ( key, value, 1 , TimeUnit . DAYS ) ; result = true ; } catch ( Exception e) { e. printStackTrace ( ) ; } return result; }
@Test public void selectPerson ( ) { List < Person > = ( List < Person > ) repository. findByAddress_City ( "北 京" ) ; for ( Person person : list) { System . out. println ( person) ; } }
