SpringBoot 2.X 整合 RocketMQ遇到的问题2

继续上一篇文章的学习，测试用例时又出现问题。
列一下最后修改的pom

<?xml version="1.0" encoding="UTF-8"?>
<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><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.1.RELEASE</version></parent><groupId>cn.itcast.rocketmq</groupId><artifactId>itcast-rocketmq</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.3</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.4.0</version></dependency><dependency><groupId>com.fasterxml</groupId><artifactId>classmate</artifactId><version>1.0.0</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.9.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId><version>2.9.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId><version>2.9.9</version></dependency></dependencies><build><plugins><!-- java编译插件 --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.2</version><configuration><source>1.8</source><target>1.8</target><encoding>UTF-8</encoding></configuration></plugin></plugins></build></project>

application.properties配置

# Spring boot application
application.name = itcast-rocketmq
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group

代码

package cn.itcast.rocketmq.spring;import org.junit.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
public class TestSpringRocketMQ {@Autowiredprivate SpringProducer springProducer;@Testpublic void testSendMsg() {springProducer.sendMsg("my-topic", "我的第2个spring消息");}}

然后关键来了，项目启动后报错

Description:Field rocketMQTemplate in com.tanhua.sso.service.UserService required a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' that could not be found.The injection point has the following annotations:- @org.springframework.beans.factory.annotation.Autowired(required=true)The following candidates were found but could not be injected:- Bean method 'rocketMQTemplate' in 'RocketMQAutoConfiguration' not loaded because @ConditionalOnProperty (rocketmq.name-server) did not find property 'name-server'Action:Consider revisiting the entries above or defining a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' in your configuration.

定位到问题的原因是因为org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration类的问题

@Configuration
@EnableConfigurationProperties(RocketMQProperties.class)
@ConditionalOnClass({ MQAdmin.class, ObjectMapper.class })
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@Import({ JacksonFallbackConfiguration.class, ListenerContainerConfiguration.class })
@AutoConfigureAfter(JacksonAutoConfiguration.class)
public class RocketMQAutoConfiguration {@Bean@ConditionalOnMissingBean(DefaultMQProducer.class)@ConditionalOnProperty(prefix = "rocketmq", value = {"name-server", "producer.group"})public DefaultMQProducer defaultMQProducer(RocketMQProperties rocketMQProperties) {RocketMQProperties.Producer producerConfig = rocketMQProperties.getProducer();String nameServer = rocketMQProperties.getNameServer();String groupName = producerConfig.getGroup();Assert.hasText(nameServer, "[rocketmq.name-server] must not be null");Assert.hasText(groupName, "[rocketmq.producer.group] must not be null");DefaultMQProducer producer;String ak = rocketMQProperties.getProducer().getAccessKey();String sk = rocketMQProperties.getProducer().getSecretKey();if (!StringUtils.isEmpty(ak) && !StringUtils.isEmpty(sk)) {producer = new DefaultMQProducer(groupName, new AclClientRPCHook(new SessionCredentials(ak, sk)),rocketMQProperties.getProducer().isEnableMsgTrace(),rocketMQProperties.getProducer().getCustomizedTraceTopic());producer.setVipChannelEnabled(false);} else {producer = new DefaultMQProducer(groupName, rocketMQProperties.getProducer().isEnableMsgTrace(),rocketMQProperties.getProducer().getCustomizedTraceTopic());}producer.setNamesrvAddr(nameServer);producer.setSendMsgTimeout(producerConfig.getSendMessageTimeout());producer.setRetryTimesWhenSendFailed(producerConfig.getRetryTimesWhenSendFailed());producer.setRetryTimesWhenSendAsyncFailed(producerConfig.getRetryTimesWhenSendAsyncFailed());producer.setMaxMessageSize(producerConfig.getMaxMessageSize());producer.setCompressMsgBodyOverHowmuch(producerConfig.getCompressMessageBodyThreshold());producer.setRetryAnotherBrokerWhenNotStoreOK(producerConfig.isRetryNextServer());return producer;}

从报错信息发现可能是nameSever不匹配name-server导致，对应类中是@ConditionalOnProperty(prefix = “rocketmq”, value = “name-server”)这个注解

下面列一下@ConditionalOnProperty注解参数的意思
prefix application.properties配置的前缀
name 属性是从application.properties配置文件中读取属性值
所以猜测配置文件要修改成对应的参数才行

改完后启动再次报错

.   ____          _            __ _ _/\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \\\/  ___)| |_)| | | | | || (_| |  ) ) ) )'  |____| .__|_| |_|_| |_\__, | / / / /=========|_|==============|___/=/_/_/_/:: Spring Boot ::        (v2.1.1.RELEASE)2020-10-20 09:30:40.191  INFO 5700 --- [           main] cn.itcast.rocketmq.spring.MyApplication  : Starting MyApplication on DESKTOP-KJBU4QT with PID 5700 (D:\Users\Sunny\eclipse-workspace\itcast-rocketmq\target\classes started by Sunny in D:\Users\Sunny\eclipse-workspace\itcast-rocketmq)
2020-10-20 09:30:40.201  INFO 5700 --- [           main] cn.itcast.rocketmq.spring.MyApplication  : No active profile set, falling back to default profiles: default
2020-10-20 09:30:41.396  WARN 5700 --- [           main] s.c.a.AnnotationConfigApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'springProducer': Unsatisfied dependency expressed through field 'rocketMQTemplate'; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {@org.springframework.beans.factory.annotation.Autowired(required=true)}
2020-10-20 09:30:41.407  INFO 5700 --- [           main] ConditionEvaluationReportLoggingListener : Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-10-20 09:30:41.690 ERROR 5700 --- [           main] o.s.b.d.LoggingFailureAnalysisReporter   : ***************************
APPLICATION FAILED TO START
***************************Description:Field rocketMQTemplate in cn.itcast.rocketmq.spring.SpringProducer required a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' that could not be found.The injection point has the following annotations:- @org.springframework.beans.factory.annotation.Autowired(required=true)The following candidates were found but could not be injected:- Bean method 'rocketMQTemplate' in 'RocketMQAutoConfiguration' not loaded because @ConditionalOnClass did not find required class 'com.fasterxml.jackson.databind.ObjectMapper'Action:Consider revisiting the entries above or defining a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' in your configuration.

did not find required class 'com.fasterxml.jackson.databind.ObjectMapper’
添加依赖：

 <dependency><groupId>com.fasterxml</groupId><artifactId>classmate</artifactId><version>1.0.0</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.9.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId><version>2.9.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId><version>2.9.9</version></dependency>

改完后启动再次报错

.   ____          _            __ _ _/\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \\\/  ___)| |_)| | | | | || (_| |  ) ) ) )'  |____| .__|_| |_|_| |_\__, | / / / /=========|_|==============|___/=/_/_/_/:: Spring Boot ::        (v2.1.1.RELEASE)2020-10-20 13:02:57.746  INFO 5728 --- [           main] cn.itcast.rocketmq.spring.MyApplication  : Starting MyApplication on DESKTOP-KJBU4QT with PID 5728 (D:\Users\Sunny\eclipse-workspace\itcast-rocketmq\target\classes started by Sunny in D:\Users\Sunny\eclipse-workspace\itcast-rocketmq)
2020-10-20 13:02:57.757  INFO 5728 --- [           main] cn.itcast.rocketmq.spring.MyApplication  : No active profile set, falling back to default profiles: default
2020-10-20 13:02:58.863  INFO 5728 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration' of type [org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration$$EnhancerBySpringCGLIB$$eecaa5cc] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:02:58.915  INFO 5728 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'rocketmq-org.apache.rocketmq.spring.autoconfigure.RocketMQProperties' of type [org.apache.rocketmq.spring.autoconfigure.RocketMQProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:02:58.945  WARN 5728 --- [           main] s.c.a.AnnotationConfigApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'org.springframework.rocketmq.spring.starter.internalRocketMQTransAnnotationProcessor' defined in class path resource [org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.class]: Unsatisfied dependency expressed through method 'transactionAnnotationProcessor' parameter 0; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'transactionHandlerRegistry' defined in class path resource [org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.class]: Unsatisfied dependency expressed through method 'transactionHandlerRegistry' parameter 0; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'rocketMQTemplate' defined in class path resource [org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.class]: Unsatisfied dependency expressed through method 'rocketMQTemplate' parameter 0; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'defaultMQProducer' defined in class path resource [org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.rocketmq.client.producer.DefaultMQProducer]: Factory method 'defaultMQProducer' threw exception; nested exception is java.lang.NoSuchMethodError: org.apache.rocketmq.client.producer.DefaultMQProducer.<init>(Ljava/lang/String;ZLjava/lang/String;)V
2020-10-20 13:02:58.964  INFO 5728 --- [           main] ConditionEvaluationReportLoggingListener : Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2020-10-20 13:02:58.970 ERROR 5728 --- [           main] o.s.b.d.LoggingFailureAnalysisReporter   : ***************************
APPLICATION FAILED TO START
***************************Description:An attempt was made to call the method org.apache.rocketmq.client.producer.DefaultMQProducer.<init>(Ljava/lang/String;ZLjava/lang/String;)V but it does not exist. Its class, org.apache.rocketmq.client.producer.DefaultMQProducer, is available from the following locations:jar:file:/C:/Users/Sunny/.m2/repository/org/apache/rocketmq/rocketmq-client/4.3.2/rocketmq-client-4.3.2.jar!/org/apache/rocketmq/client/producer/DefaultMQProducer.classIt was loaded from the following location:file:/C:/Users/Sunny/.m2/repository/org/apache/rocketmq/rocketmq-client/4.3.2/rocketmq-client-4.3.2.jarAction:Correct the classpath of your application so that it contains a single, compatible version of org.apache.rocketmq.client.producer.DefaultMQProducer

这次的报错是版本冲突问题，最终将RocketMQ-client使用的版本是4.3.2改为4.4.0解决

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.4.0</version></dependency>

然后启动项目还是报错

13:19:25.116 [main] DEBUG org.springframework.test.context.junit4.SpringJUnit4ClassRunner - SpringJUnit4ClassRunner constructor called with [class cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.141 [main] DEBUG org.springframework.test.context.BootstrapUtils - Instantiating CacheAwareContextLoaderDelegate from class [org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate]
13:19:25.162 [main] DEBUG org.springframework.test.context.BootstrapUtils - Instantiating BootstrapContext using constructor [public org.springframework.test.context.support.DefaultBootstrapContext(java.lang.Class,org.springframework.test.context.CacheAwareContextLoaderDelegate)]
13:19:25.193 [main] DEBUG org.springframework.test.context.BootstrapUtils - Instantiating TestContextBootstrapper for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ] from class [org.springframework.boot.test.context.SpringBootTestContextBootstrapper]
13:19:25.218 [main] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Neither @ContextConfiguration nor @ContextHierarchy found for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ], using SpringBootContextLoader
13:19:25.227 [main] DEBUG org.springframework.test.context.support.AbstractContextLoader - Did not detect default resource location for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]: class path resource [cn/itcast/rocketmq/spring/TestSpringRocketMQ-context.xml] does not exist
13:19:25.228 [main] DEBUG org.springframework.test.context.support.AbstractContextLoader - Did not detect default resource location for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]: class path resource [cn/itcast/rocketmq/spring/TestSpringRocketMQContext.groovy] does not exist
13:19:25.228 [main] INFO org.springframework.test.context.support.AbstractContextLoader - Could not detect default resource locations for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]: no resource found for suffixes {-context.xml, Context.groovy}.
13:19:25.230 [main] INFO org.springframework.test.context.support.AnnotationConfigContextLoaderUtils - Could not detect default configuration classes for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]: TestSpringRocketMQ does not declare any static, non-private, non-final, nested classes annotated with @Configuration.
13:19:25.308 [main] DEBUG org.springframework.test.context.support.ActiveProfilesUtils - Could not find an 'annotation declaring class' for annotation type [org.springframework.test.context.ActiveProfiles] and class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.490 [main] DEBUG org.springframework.context.annotation.ClassPathScanningCandidateComponentProvider - Identified candidate component class: file [D:\Users\Sunny\eclipse-workspace\itcast-rocketmq\target\classes\cn\itcast\rocketmq\spring\MyApplication.class]
13:19:25.493 [main] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Found @SpringBootConfiguration cn.itcast.rocketmq.spring.MyApplication for test class cn.itcast.rocketmq.spring.TestSpringRocketMQ
13:19:25.866 [main] DEBUG org.springframework.boot.test.context.SpringBootTestContextBootstrapper - @TestExecutionListeners is not present for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]: using defaults.
13:19:25.868 [main] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Loaded default TestExecutionListener class names from location [META-INF/spring.factories]: [org.springframework.boot.test.mock.mockito.MockitoTestExecutionListener, org.springframework.boot.test.mock.mockito.ResetMocksTestExecutionListener, org.springframework.boot.test.autoconfigure.restdocs.RestDocsTestExecutionListener, org.springframework.boot.test.autoconfigure.web.client.MockRestServiceServerResetTestExecutionListener, org.springframework.boot.test.autoconfigure.web.servlet.MockMvcPrintOnlyOnFailureTestExecutionListener, org.springframework.boot.test.autoconfigure.web.servlet.WebDriverTestExecutionListener, org.springframework.test.context.web.ServletTestExecutionListener, org.springframework.test.context.support.DirtiesContextBeforeModesTestExecutionListener, org.springframework.test.context.support.DependencyInjectionTestExecutionListener, org.springframework.test.context.support.DirtiesContextTestExecutionListener, org.springframework.test.context.transaction.TransactionalTestExecutionListener, org.springframework.test.context.jdbc.SqlScriptsTestExecutionListener]
13:19:25.884 [main] DEBUG org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Skipping candidate TestExecutionListener [org.springframework.test.context.web.ServletTestExecutionListener] due to a missing dependency. Specify custom listener classes or make the default listener classes and their required dependencies available. Offending class: [javax/servlet/ServletContext]
13:19:25.888 [main] DEBUG org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Skipping candidate TestExecutionListener [org.springframework.test.context.transaction.TransactionalTestExecutionListener] due to a missing dependency. Specify custom listener classes or make the default listener classes and their required dependencies available. Offending class: [org/springframework/transaction/interceptor/TransactionAttributeSource]
13:19:25.890 [main] DEBUG org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Skipping candidate TestExecutionListener [org.springframework.test.context.jdbc.SqlScriptsTestExecutionListener] due to a missing dependency. Specify custom listener classes or make the default listener classes and their required dependencies available. Offending class: [org/springframework/transaction/interceptor/TransactionAttribute]
13:19:25.890 [main] INFO org.springframework.boot.test.context.SpringBootTestContextBootstrapper - Using TestExecutionListeners: [org.springframework.test.context.support.DirtiesContextBeforeModesTestExecutionListener@cd3fee8, org.springframework.boot.test.mock.mockito.MockitoTestExecutionListener@3e2e18f2, org.springframework.boot.test.autoconfigure.SpringBootDependencyInjectionTestExecutionListener@470f1802, org.springframework.test.context.support.DirtiesContextTestExecutionListener@63021689, org.springframework.boot.test.mock.mockito.ResetMocksTestExecutionListener@703580bf, org.springframework.boot.test.autoconfigure.restdocs.RestDocsTestExecutionListener@3e92efc3, org.springframework.boot.test.autoconfigure.web.client.MockRestServiceServerResetTestExecutionListener@1622f1b, org.springframework.boot.test.autoconfigure.web.servlet.MockMvcPrintOnlyOnFailureTestExecutionListener@72a7c7e0, org.springframework.boot.test.autoconfigure.web.servlet.WebDriverTestExecutionListener@2e4b8173]
13:19:25.893 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved @ProfileValueSourceConfiguration [null] for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.894 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved ProfileValueSource type [class org.springframework.test.annotation.SystemProfileValueSource] for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.920 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved @ProfileValueSourceConfiguration [null] for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.920 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved ProfileValueSource type [class org.springframework.test.annotation.SystemProfileValueSource] for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.923 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved @ProfileValueSourceConfiguration [null] for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.923 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved ProfileValueSource type [class org.springframework.test.annotation.SystemProfileValueSource] for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.924 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved @ProfileValueSourceConfiguration [null] for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.931 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved ProfileValueSource type [class org.springframework.test.annotation.SystemProfileValueSource] for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.939 [main] DEBUG org.springframework.test.context.support.AbstractDirtiesContextTestExecutionListener - Before test class: context [DefaultTestContext@4f209819 testClass = TestSpringRocketMQ, testInstance = [null], testMethod = [null], testException = [null], mergedContextConfiguration = [MergedContextConfiguration@15eb5ee5 testClass = TestSpringRocketMQ, locations = '{}', classes = '{class cn.itcast.rocketmq.spring.MyApplication}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{}', propertySourceProperties = '{org.springframework.boot.test.context.SpringBootTestContextBootstrapper=true}', contextCustomizers = set[org.springframework.boot.test.context.filter.ExcludeFilterContextCustomizer@9660f4e, org.springframework.boot.test.json.DuplicateJsonObjectContextCustomizerFactory$DuplicateJsonObjectContextCustomizer@7d0587f1, org.springframework.boot.test.mock.mockito.MockitoContextCustomizer@0, org.springframework.boot.test.web.client.TestRestTemplateContextCustomizer@167fdd33, org.springframework.boot.test.autoconfigure.properties.PropertyMappingContextCustomizer@0, org.springframework.boot.test.autoconfigure.web.servlet.WebDriverContextCustomizerFactory$Customizer@4232c52b], contextLoader = 'org.springframework.boot.test.context.SpringBootContextLoader', parent = [null]], attributes = map[[empty]]], class annotated with @DirtiesContext [false] with mode [null].
13:19:25.940 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved @ProfileValueSourceConfiguration [null] for test class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.941 [main] DEBUG org.springframework.test.annotation.ProfileValueUtils - Retrieved ProfileValueSource type [class org.springframework.test.annotation.SystemProfileValueSource] for class [cn.itcast.rocketmq.spring.TestSpringRocketMQ]
13:19:25.950 [main] DEBUG org.springframework.test.context.support.DependencyInjectionTestExecutionListener - Performing dependency injection for test context [[DefaultTestContext@4f209819 testClass = TestSpringRocketMQ, testInstance = cn.itcast.rocketmq.spring.TestSpringRocketMQ@291ae, testMethod = [null], testException = [null], mergedContextConfiguration = [MergedContextConfiguration@15eb5ee5 testClass = TestSpringRocketMQ, locations = '{}', classes = '{class cn.itcast.rocketmq.spring.MyApplication}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{}', propertySourceProperties = '{org.springframework.boot.test.context.SpringBootTestContextBootstrapper=true}', contextCustomizers = set[org.springframework.boot.test.context.filter.ExcludeFilterContextCustomizer@9660f4e, org.springframework.boot.test.json.DuplicateJsonObjectContextCustomizerFactory$DuplicateJsonObjectContextCustomizer@7d0587f1, org.springframework.boot.test.mock.mockito.MockitoContextCustomizer@0, org.springframework.boot.test.web.client.TestRestTemplateContextCustomizer@167fdd33, org.springframework.boot.test.autoconfigure.properties.PropertyMappingContextCustomizer@0, org.springframework.boot.test.autoconfigure.web.servlet.WebDriverContextCustomizerFactory$Customizer@4232c52b], contextLoader = 'org.springframework.boot.test.context.SpringBootContextLoader', parent = [null]], attributes = map[[empty]]]].
13:19:26.004 [main] DEBUG org.springframework.test.context.support.TestPropertySourceUtils - Adding inlined properties to environment: {spring.jmx.enabled=false, org.springframework.boot.test.context.SpringBootTestContextBootstrapper=true, server.port=-1}.   ____          _            __ _ _/\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \\\/  ___)| |_)| | | | | || (_| |  ) ) ) )'  |____| .__|_| |_|_| |_\__, | / / / /=========|_|==============|___/=/_/_/_/:: Spring Boot ::        (v2.1.1.RELEASE)2020-10-20 13:19:26.827  INFO 4240 --- [           main] c.i.rocketmq.spring.TestSpringRocketMQ   : Starting TestSpringRocketMQ on DESKTOP-KJBU4QT with PID 4240 (started by Sunny in D:\Users\Sunny\eclipse-workspace\itcast-rocketmq)
2020-10-20 13:19:26.830  INFO 4240 --- [           main] c.i.rocketmq.spring.TestSpringRocketMQ   : No active profile set, falling back to default profiles: default
2020-10-20 13:19:27.993  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration' of type [org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration$$EnhancerBySpringCGLIB$$a92a4cd2] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:28.087  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'rocketmq-org.apache.rocketmq.spring.autoconfigure.RocketMQProperties' of type [org.apache.rocketmq.spring.autoconfigure.RocketMQProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:31.491  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'defaultMQProducer' of type [org.apache.rocketmq.client.producer.DefaultMQProducer] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:31.499  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'org.apache.rocketmq.spring.autoconfigure.JacksonFallbackConfiguration' of type [org.apache.rocketmq.spring.autoconfigure.JacksonFallbackConfiguration$$EnhancerBySpringCGLIB$$daa5e334] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:32.058  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'rocketMQMessageObjectMapper' of type [com.fasterxml.jackson.databind.ObjectMapper] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:38.691  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'rocketMQTemplate' of type [org.apache.rocketmq.spring.core.RocketMQTemplate] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:38.700  INFO 4240 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'transactionHandlerRegistry' of type [org.apache.rocketmq.spring.config.TransactionHandlerRegistry] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2020-10-20 13:19:39.231  INFO 4240 --- [           main] c.i.rocketmq.spring.TestSpringRocketMQ   : Started TestSpringRocketMQ in 13.222 seconds (JVM running for 15.831)
2020-10-20 13:19:42.299  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10611] result: true
2020-10-20 13:19:42.306  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10809] result: true
2020-10-20 13:19:42.306  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10711] result: true
2020-10-20 13:19:42.307  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:9876] result: true
2020-10-20 13:19:42.308  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10911] result: true
2020-10-20 13:19:42.309  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10811] result: true
2020-10-20 13:19:42.374  INFO 4240 --- [       Thread-5] o.s.b.f.support.DisposableBeanAdapter    : Invocation of destroy method failed on bean with name 'rocketMQTemplate': java.lang.IllegalStateException: Shutdown in progress
2020-10-20 13:19:42.374  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10611] result: true
2020-10-20 13:19:42.374  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10811] result: true
2020-10-20 13:19:42.374  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10911] result: true
2020-10-20 13:19:42.374  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:9876] result: true
2020-10-20 13:19:42.374  INFO 4240 --- [lientSelector_1] RocketmqRemoting                         : closeChannel: close the connection to remote address[127.0.0.1:10711] result: true
2020-10-20 13:19:42.375  INFO 4240 --- [       Thread-5] o.s.b.f.support.DisposableBeanAdapter    : Destroy method 'shutdown' on bean with name 'defaultMQProducer' threw an exception: java.lang.IllegalStateException: Shutdown in progress

注意关键提示：
INFO 4240 — [ Thread-5] o.s.b.f.support.DisposableBeanAdapter : Destroy method ‘shutdown’ on bean with name ‘defaultMQProducer’ threw an exception: java.lang.IllegalStateException: Shutdown in progress
测试类中很常见，出现这个异常不要惊慌- -

原因：就是单纯的测试结束了

解决：自己在控制台上翻，可看见打印的测试结果，无打印的也完成了测试，强迫症患者可以在测试方法后加个while(true){}
在这里插入图片描述

查看全文
如若内容造成侵权/违法违规/事实不符，请联系编程学习网邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！

阿里云服务器计算网络增强型实例sn1ne配置使用场景如何？
sn1ne的特点如下： I/O优化实例仅支持SSD云盘和高效云盘处理器与内存配比为1:2 超高网络PPS收发包能力处理器：2.5 GHz主频的Intel Xeon E5-2682 v4（Broadwell）或Platinum 8163（Skylake），计算…...
2024/5/8 19:34:23
2020隐私窃贼病毒分析报告
1.概述近日我们在恒安嘉新态势感知平台上监测到一款仿冒韩国音乐应用的病毒样本。经过安全研究人员分析，发现该应用在用户不知情的情况下，窃取用户设备短信、联系人、设备信息等敏感数据，之后便隐藏图标保持后台长时间运行。图1-1 态势感知…...
2024/5/8 15:15:35
handsontable 日期汉化
在你的handsontable js中找到 i18n: {previousMonth: "Previous Month",nextMonth: "Next Month",months: ["January", "February", "March", "April", "May", "June", "July", &…...
2024/5/9 5:58:10
Base64加密原理和应用场景
目录Base64编码使用场景Base64编码原理Base64编码 base64 最早就是用来邮件传输协议中的，原因是邮件传输协议只支持 ascii 字符传递，因此如果要传输二进制文件，如：图片、视频是无法实现的。因此 base64 就可以用来将二进制文件内…...
2024/4/21 13:46:49
A10pro掉算力解决方案升级官方固件
由于Ethash算法的持续扩容，以太坊DAG文件已突破4G边缘，导致A10Pro拒绝率升高从而引起算力波动。对此，第一时间升级了新的固件，将有效改善A10Pro因扩容带来的适配问题。本次升级是扩容后的必要升级， 更新版本下载链接可…...
2024/5/8 22:32:59
Vue初识、el、data
2020年10月20日真是痛苦的一天第一个VUE程序步骤导入开发版本的Vue.js创建Vue实例对象，设置el属性和data属性使用简洁的模板语法把数据渲染到页面上 <head><meta charset"UTF-8"><meta name"viewport" content"widt…...
2024/4/10 18:55:45
LeetCode#35 搜索插入位置
给定一个排序数组和一个目标值，在数组中找到目标值，并返回其索引。如果目标值不存在于数组中，返回它将会被按顺序插入的位置。你可以假设数组中无重复元素。示例 1: 输入: [1,3,5,6], 5 输出: 2 示例 2: 输入: [1,3,5,6], 2 输出: 1 示…...
2024/5/9 3:33:36
关于错误 Resource temporarily unavailable
strace -p xxx -f -F 跟踪进程查看swoole报错 WARNING swReactorEpoll_wait(:260): EPOLLIN handle failed. fd35, Error: Resource temporarily unavailable[11] 首先考虑linux内核优化...
2024/5/8 17:48:19
laravel6、Yii2、ThinkPHP6、单文件php ab压测
各请求数量数据对比ab -c 100 -n 1000laravelYiiThinkPHP单文件PHPab -c 200 -n 2000LaravelYiiThinkPHP单文件PHPab -c400 -n 4000LaravelYiiThinkPHP单文件PHPab -c600 -n 6000LaravelYiiThinkPHP单文件PHPab -c800 -n 8000laravelYiiThinkP单文件PHPab -c1000 -n 10000Larav…...
2024/5/8 18:52:22
android camera
https://www.jianshu.com/p/bac0e72351e4...
2024/5/8 21:58:52
1067 试密码 (20分 C++实现一个简单题 )
1067 试密码 (20分 C实现一个简单题） 思路代码思路按照题目描述的来操作，一开始我还是遍历字符串，一个一个比较，后来发现原来只要直接写（s ! password）就可以了。。代码要注意的是密码本身没有空格…...
2024/5/9 8:35:20
Redis Cluster入门
Redis Cluster 集群我们要使用集群 redis 并发量 10万 / 每秒 ，但是有些业务需要 100万的 QPS数据量，我们普通机器 16～256g，而我们的业务需要500g 解决方案分布式 ：加机器，方便以后需求扩容 Redis C…...
2024/5/8 15:13:02
Android 屏幕旋转全解析
屏幕旋转一般的解决方案关于屏幕旋转这里，之前一直没太注意，因为根据设备会有指定的屏幕旋转策略如： 1.开发手机应用时一直使用强制竖屏布局 2.开发平板设备一直使用横屏布局 3.开发系统应用，一般给两套即横竖各一套其实这三…...
2024/5/8 11:46:41
对spring中注解的一些疑问
1.Service注解不知道大家有没有过和我一样的疑问，在写代码时写着写着不知道Service是注入到接口上还是实现类？带着这个疑问，搜了几篇帖子，总结一下，首先肯定的是service注解是注入在实现类上的，究其原因S…...
2024/5/8 12:56:52
nw.js 启用窗口最大化
在使用nw.js对html和js进行exe封包时，发现最大化的按钮都是禁用掉的，在package.json里也没有相应的配置项。需要自己手动处理，在页面启动的初始方法里声明如下即可启用窗口最大化。 var MaxWinrequire(nw.gui).Window.get(); MaxWin.setMa…...
2024/4/9 18:12:06
ios 手机时间转换返回值为NAN的问题
在做项目的过程中，遇到时间转换的代码： date: 2020-10-17 time: 12:30 var d new Date(${date} ${time}) const year d.getFullYear() const month d.getMonth() 1 const day d.getDate() const hour d.getHours() > 10 ? d.getHours() : 0…...
2024/4/10 16:28:37
Maven入门第一式
一、Maven基本概念跨平台项目管理工具，主要服务基于Java平台的项目构建依赖管理 1.1 项目构建过程： 【清理】—>【编译】—>【测试】—>【打包】—>【部署】 1.2 依赖管理使用Maven来管理项目中的jar包，自动下载项目…...
2024/4/9 14:10:55
12.python流程控制之if判断
我们仔细回忆一下，所有的事情流程都可以分为三个模式，把事情一件一件的完成，然后遇到了选择，选择做哪件事，然后有些事情需要重复的做几次在计算机中也是一样，程序的控制语句主要分三种：顺序、…...
2024/4/9 5:02:09
学习笔记（25):零基础掌握 Python 入门到实战-方法多态，拒绝隔离
立即学习:https://edu.csdn.net/course/play/26676/339582?utm_sourceblogtoedu 封装是对象的特性之一 Python 中国通过私有化的方式实现封装 （函数名称私有化）...
2024/4/30 9:25:46
【Python 1-3】Visual Studio Code(VSCode) 配置 Python开发环境
使用 VSCode 作为开发Python的IDE工具 IDE(Integrated Development Environment, 集成开发环境)，目前支持Python的IDE有很多。有PyCharm、Eclipse、Atom、Anaconda、Sublime Text等等。我个人更喜欢使用 Visual Studio Code 也就是 VSCode。如果大家有自己喜欢的ID…...
2024/4/10 18:33:10

SpringBoot 2.X 整合 RocketMQ遇到的问题2

相关文章

最新文章