我正在尝试使用Spring Boot和Spring Cloud AWS SQS构建最小的Gradle Java项目,但无法从队列中读取它。
这些是我的项目文件:
build.gradle:
apply plugin: "java" apply plugin: "eclipse" apply plugin: "spring-boot" apply plugin: "io.spring.dependency-management" sourceCompatibility = 1.8 targetCompatibility = 1.8 buildscript { repositories { mavenCentral() } dependencies { classpath("org.springframework.boot:spring-boot-gradle-plugin:1.3.5.RELEASE") classpath("io.spring.gradle:dependency-management-plugin:0.5.2.RELEASE") } } dependencyManagement { imports { mavenBom("org.springframework.cloud:spring-cloud-aws:1.1.0.RELEASE") } } repositories { mavenCentral() } dependencies { compile("org.springframework.boot:spring-boot-starter-actuator:1.3.5.RELEASE") compile("org.springframework.cloud:spring-cloud-starter-aws:1.1.0.RELEASE") // if I don't add the line below, the annotation @MessageMapping is not found :( // I would have expected that cloud-starter-aws would have taken care of it compile("org.springframework.cloud:spring-cloud-aws-messaging:1.1.0.RELEASE") // this has been added to fix an exception happening, please read below compile("org.springframework.data:spring-data-commons:1.12.1.RELEASE") }
Application.java:
package com.test; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
QueueListener.java:
package com.test.sqs; import java.util.logging.Logger; import org.springframework.messaging.handler.annotation.MessageMapping; import com.test.sqs.model.TestMessage; public class QueueListener { @MessageMapping("test_queue") private void receiveMessage(TestMessage testMessage) { System.out.println("Test message received: " + testMessage.getMessage()); } }
src / main / resources中的application.yaml:
cloud: aws: credentials: accessKey: ********************** secretKey: ********************** region: static: us-west-2
应用程序在启动时会引发异常(但是您可以在日志调试模式下看到该异常!):
org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.amazonaws.auth.profile.ProfilesConfigFile]: Constructor threw exception; nested exception is java.lang.IllegalArgumentException: AWS credential profiles file not found in the given path: C:\src\collector\default
但我总是在日志中看到它确实从yaml文件中提取了我的凭据:
2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.accessKey' in [systemProperties] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.accessKey' in [systemEnvironment] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.accessKey' in [random] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.accessKey' in [applicationConfigurationProperties] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Found key 'cloud.aws.credentials.accessKey' in [applicationConfigurationProperties] with type [String] and value '***' 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.secretKey' in [systemProperties] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.secretKey' in [systemEnvironment] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.secretKey' in [random] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Searching for key 'cloud.aws.credentials.secretKey' in [applicationConfigurationProperties] 2016-05-19 11:15:14.546 DEBUG 11704 --- [ main] o.s.c.e.PropertySourcesPropertyResolver : Found key 'cloud.aws.credentials.secretKey' in [applicationConfigurationProperties] with type [String] and value '***'
因此,我不确定为什么会在其他地方查看?
它还引发此异常(仅当您处于记录调试模式时,才总是可见):
java.lang.ClassNotFoundException: org.springframework.data.web.config.EnableSpringDataWebSupport
所以我不得不添加build.gradle
compile("org.springframework.data:spring-data-commons:1.12.1.RELEASE")
但是现在例外不再存在了,但是程序不执行任何操作就开始和结束了,并且不再打印日志了!
其他一些事实:
我不确定build.gradle的第34行:
compile("org.springframework.cloud:spring-cloud-starter-aws:1.1.0.RELEASE") // if I don't add the line below, the annotation @MessageMapping is not found :( // I would have expected that cloud-starter-aws would have taken care of it compile("org.springframework.cloud:spring-cloud-aws-messaging:1.1.0.RELEASE") // this has been added to fix an exception happening, please read below compile("org.springframework.data:spring-data-commons:1.12.1.RELEASE")
可能是问题的征兆,我希望所有需要的库都可以由cloud-starter-aws自动加载。
我想念什么?谢谢!
发现了问题,这当然是愚蠢的。
Spring没有加载QueueListener类,因为它没有Service / Component批注,因此:
@Service public class SqsQueueSender { ... }
解决了这个问题。