springboot +dubbo專案啟動後獲取ApplicationContext為null
阿新 • • 發佈：2020-07-22
1,springboot+dubbo整合，啟動專案獲取ApplicationContext為空
package org.source.dsmh; import java.util.concurrent.ThreadPoolExecutor; import org.apache.dubbo.config.spring.context.annotation.EnableDubbo; import org.source.dsmh.service.RecordLogToUnifiedDb; import org.source.dsmh.service.impl.RecordLogToUnifiedDbImp;import org.source.dsmh.utils.mongodb.SpringContextUtil; import org.source.dsmh.utils.config.ThreadPoolConfig; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration; import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration; import org.springframework.context.annotation.Bean; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class, HibernateJpaAutoConfiguration.class,MongoAutoConfiguration.class}) @EnableDubbo(scanBasePackages="org.source.dsmh.service") public class DsmhThirdPhserviceWdApplication { @Autowired ThreadPoolTaskExecutor threadPoolTaskExecutor; /** * 非同步執行緒池 * * @return */ @Bean public ThreadPoolTaskExecutor taskExecutor() { ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); taskExecutor.setCorePoolSize(ThreadPoolConfig.getCorePoolSize()); // 執行緒池維護執行緒的最少數量 taskExecutor.setMaxPoolSize(ThreadPoolConfig.getMaxPoolSize()); // 執行緒池維護執行緒的最大數量 taskExecutor.setQueueCapacity(ThreadPoolConfig.getQueueCapacity()); // 快取佇列 taskExecutor.setKeepAliveSeconds(ThreadPoolConfig.getKeepAliveSeconds()); // 允許的空閒時間 // 執行緒池對拒絕任務(無執行緒可用)的處理策略 ThreadPoolExecutor.CallerRunsPolicy策略 // ,呼叫者的執行緒會執行該任務,如果執行器已關閉,則丟棄. taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); return taskExecutor; } @Bean public SpringContextUtil getSpringContextUtil() { return new SpringContextUtil(); } @Bean public RecordLogToUnifiedDb getRecordLogToUnifiedDb() { return new RecordLogToUnifiedDbImp(); } public static void main(String[] args) { SpringApplication.run(DsmhThirdPhserviceWdApplication.class, args); } }
2,pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.source.dsmh</groupId>
<artifactId>dsmh-third-phserviceinfowd</artifactId>
<version>1.0.0</version>
<packaging>jar</packaging>
<repositories>
<!-- ds遠端倉庫 -->
<repository>
<id>maven-nexus-ds</id>
<name>maven-nexus-ds</name>
<layout>default</layout>
<url>http://101.200.214.46:8082/nexus/repository/maven-releases/</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.5.RELEASE</version>
<relativePath />
</parent>
<properties>
<commons-lang3-version>3.4</commons-lang3-version>
<commons-io-version>1.3.2</commons-io-version>
<fastjson-version>1.2.8</fastjson-version>
<boot-dubbo-version>2.0.0</boot-dubbo-version>
<zkclient-version>0.10</zkclient-version>
<dsmh-common-version>[1.0.0,)</dsmh-common-version>
<dsmh-common-mongodb-version>RELEASE</dsmh-common-mongodb-version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<skipTests>true</skipTests>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
<exclusions>
<!-- 排除springboot預設的logback日誌框架 -->
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- 引入log4j日誌依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-log4j</artifactId>
<version>1.3.8.RELEASE</version>
</dependency>
<!-- 引入spring aop依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- jetty -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jetty</artifactId>
</dependency>
<!-- 資源配置 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<!-- apache 工具類 -->
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons-lang3-version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-io</artifactId>
<version>${commons-io-version}</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson-version}</version>
</dependency>
<!-- alibaba dubbo-spring-boot-starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.3</version>
</dependency>
<!-- 因為使用的是 zookeeper 作為註冊中心，所以要新增 zookeeper 依賴 -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.12</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>
<!--使用curator 作為zookeeper客戶端-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.2.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>4.2.0</version>
</dependency>
<dependency>
<groupId>org.source.dsmh</groupId>
<artifactId>dsmh-common</artifactId>
<!-- <version>${dsmh-common-version}</version> -->
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.source.dsmh</groupId>
<artifactId>dsmh-common-mongodb</artifactId>
<version>${dsmh-common-mongodb-version}</version>
</dependency>
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver</artifactId>
</dependency>
<!--Uber MongoDB Java Driver -->
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
</dependency>
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.0.6</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcprov-jdk15on</artifactId>
<version>1.60</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.8</source>
<target>1.8</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<fork>true</fork>
<mainClass>org.source.dsmh.DsmhThirdPhserviceWdApplication</mainClass>
<layout>ZIP</layout>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
<!-- 分離出程式碼包
<configuration>
<classifier>exec</classifier>
</configuration>
-->
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
3,
package org.source.dsmh.service.vaccineorder; import org.apache.dubbo.config.annotation.Service; import org.source.dsmh.service.ThirdDataService; import org.source.dsmh.service.ThirdEnterService; import org.source.dsmh.utils.DataTemplate; import org.source.dsmh.utils.SpringContextUtil; import org.springframework.context.ApplicationContext; /** * third-consult入口，只做功能分發，不處理具體業務 * * @author hzc * */ @Service(group = "third-vaccineorder") public class ThirdVaccineorderServiceImpl implements ThirdEnterService { //private ThirdDataService thirdDataService; @Override public DataTemplate thirdVisit(String paramJson, String function, String method) { ApplicationContext ac=SpringContextUtil.getApplicationContext(); System.out.println(ac.getBeanDefinitionNames()); // 根據方法名獲取例項 ThirdDataService thirdDataService = SpringContextUtil.getBean("third-" + function + "-" + method, ThirdDataService.class); if (thirdDataService == null) { return DataTemplate.error("功能暫未實現！"); } else { return thirdDataService.thirdData(paramJson, function, method); } } }
原因：獲取bean的ApplicationContext引用的包與application包new的不是同一個類檔案
解決方案：將呼叫的ApplicationContext改為同一類檔案引用