# 使用JMS进行消息传递 本指南将引导您完成使用JMS代理发布和订阅消息的过程。 ## 你会建立什么 您将构建一个使用Spring的应用程序 `JmsTemplate` 发布一条消息并使用 `@JmsListener` 托管bean的带批注的方法。 ## 你需要什么 * 约15分钟 * 最喜欢的文本编辑器或IDE * [JDK 1.8](http://www.oracle.com/technetwork/java/javase/downloads/index.html) 或更高版本 * [Gradle 4+](http://www.gradle.org/downloads) 或 [Maven 3.2+](https://maven.apache.org/download.cgi) * 您还可以将代码直接导入到IDE中： * [弹簧工具套件（STS）](https://spring.io/guides/gs/sts) * [IntelliJ IDEA](https://spring.io/guides/gs/intellij-idea/) ## 如何完成本指南 像大多数Spring 一样 [入门指南](https://spring.io/guides) ，您可以从头开始并完成每个步骤，也可以绕过您已经熟悉的基本设置步骤。 无论哪种方式，您最终都可以使用代码。 要 **从头开始** ，请继续 [使用Gradle构建](https://spring.io/guides/gs/messaging-jms/#scratch) 。 要 **跳过基础知识** ，请执行以下操作： * [下载](https://github.com/spring-guides/gs-messaging-jms/archive/master.zip) 并解压缩本指南的源存储库，或使用 对其进行克隆 [Git](https://spring.io/understanding/Git) ： `git clone [https://github.com/spring-guides/gs-messaging-jms.git](https://github.com/spring-guides/gs-messaging-jms.git)` * 光盘进入 `gs-messaging-jms/initial` * 跳至 [创建消息接收器](https://spring.io/guides/gs/messaging-jms/#initial) 。 **完成后** ，您可以根据中的代码检查结果 `gs-messaging-jms/complete`. ## 用Gradle构建 ## 用Maven编译 ## 使用您的IDE进行构建 ## 创建一个消息接收者 Spring提供了将消息发布到任何 [POJO的方法](https://spring.io/understanding/POJO) 。 在本指南中，您将研究如何通过JMS消息代理发送消息。 首先，让我们创建一个非常简单的POJO，其中体现了电子邮件的详细信息。 请注意，我们没有发送电子邮件。 我们只是将有关某个内容的详细信息从一个地方发送到另一个地方，以发送消息。 `src/main/java/hello/Email.java` ~~~ Unresolved directive in <stdin> - include::complete/src/main/java/hello/Email.java[] ~~~ 这个POJO非常简单，包含两个字段 **to** 和 **body** ，以及假定的getter和setter集。 在这里，您可以定义一个消息接收者： `src/main/java/hello/Receiver.java` ~~~ Unresolved directive in <stdin> - include::complete/src/main/java/hello/Receiver.java[] ~~~ `Receiver`也称为 **消息驱动POJO** 。 如您在上面的代码中看到的，不需要实现任何特定的接口，也不需要使该方法具有任何特定的名称。 此外，该方法可以具有 [非常灵活的签名](https://docs.spring.io/spring/docs/current/spring-framework-reference/htmlsingle/#jms-annotated-method-signature) 。 特别注意，此类在JMS API上没有导入。 这 `JmsListener` 批注定义了名称 `Destination` 该方法应侦听的内容以及对 `JmsListenerContainerFactory`用于创建基础消息侦听器容器。 严格来讲，除非您需要自定义容器的构建方式，否则不需要最后一个属性，因为Spring Boot会在必要时注册默认工厂。 该 [参考文档](https://docs.spring.io/spring/docs/current/spring-framework-reference/integration.html#jms-annotated-method-signature) 涵盖得更详细。 ## 使用Spring发送和接收JMS消息 接下来，连接发送方和接收方。 `src/main/java/hello/Application.java` ~~~ Unresolved directive in <stdin> - include::complete/src/main/java/hello/Application.java[] ~~~ `@SpringBootApplication` 是一个方便注释，它添加了以下所有内容： * `@Configuration`：将类标记为应用程序上下文的Bean定义的源。 * `@EnableAutoConfiguration`：告诉Spring Boot根据类路径设置，其他bean和各种属性设置开始添加bean。 例如，如果 `spring-webmvc` 在类路径上，此注释将应用程序标记为Web应用程序并激活关键行为，例如设置 `DispatcherServlet`. * `@ComponentScan`：告诉Spring在服务器中寻找其他组件，配置和服务 `hello` 包，让它找到控制器。 这 `main()` 方法使用Spring Boot的 `SpringApplication.run()`启动应用程序的方法。 您是否注意到没有一行XML？ 没有 `web.xml`文件。 该Web应用程序是100％纯Java，因此您无需处理任何管道或基础结构。 `@EnableJms` 触发发现带有注释的方法 `@JmsListener`，在后台创建消息侦听器容器。 为了清楚起见，我们还定义了 `myFactory` 在中引用的bean `JmsListener`接收者的注释。 因为我们使用 `DefaultJmsListenerContainerFactoryConfigurer` 由Spring Boot提供的基础架构 `JmsMessageListenerContainer` 将与引导默认情况下创建的引导程序相同。 默认值 `MessageConverter` 只能转换基本类型（例如 `String`, `Map`, `Serializable`）和我们的 `Email` 不是 `Serializable`故意。 我们要使用Jackson并将内容以文本格式序列化为json（即 `TextMessage`）。 Spring Boot将检测到是否存在 `MessageConverter` 并将其关联到两个默认值 `JmsTemplate` 和任何 `JmsListenerContainerFactory` 由...制作 `DefaultJmsListenerContainerFactoryConfigurer`. `JmsTemplate`使将消息发送到JMS目标变得非常简单。 在里面 `main` 跑步者方法，启动后，您可以使用 `jmsTemplate` 发送一个 `Email`POJO。 因为我们的习俗 `MessageConverter` 已自动与其关联，则将在 `TextMessage` 只要。 您未看到定义的两个bean是 `JmsTemplate` 和 `ConnectionFactory`。 这些是由Spring Boot自动创建的。 在这种情况下，ActiveMQ代理将以嵌入式方式运行。 默认情况下，Spring Boot创建一个 `JmsTemplate`配置为 来 [传输到队列](https://docs.spring.io/spring/docs/current/spring-framework-reference/integration.html#jms-destinations) 通过将 **pubSubDomain** 设置为false 。 这 `JmsMessageListenerContainer`也配置相同。 要覆盖，请设置 `spring.jms.isPubSubDomain=true` 通过Boot的属性设置（在内部 `application.properties`或按环境变量）。 然后确保接收容器具有相同的设置。 春天的 JmsTemplate 可以直接通过其接收消息 receive方法，但只能同步工作，这意味着它将阻塞。 因此，我们建议您使用监听器容器，例如 DefaultMessageListenerContainer 使用基于缓存的连接工厂，因此您可以异步使用消息，并以最大的连接效率使用消息。 ### 建立可执行的JAR 您可以使用Gradle或Maven从命令行运行该应用程序。 您还可以构建一个包含所有必需的依赖项，类和资源的可执行JAR文件，然后运行该文件。 生成可执行jar使得在整个开发生命周期中，跨不同环境等等的情况下，都可以轻松地将服务作为应用程序进行发布，版本控制和部署。 如果您使用Gradle，则可以通过使用以下命令运行该应用程序 `./gradlew bootRun`。 或者，您可以通过使用以下命令构建JAR文件： `./gradlew build` 然后运行JAR文件，如下所示： ~~~ java -jar build/libs/gs-messaging-jms-0.1.0.jar ~~~ 如果您使用Maven，则可以通过使用以下命令运行该应用程序 `./mvnw spring-boot:run`。 或者，您可以使用以下命令构建JAR文件： `./mvnw clean package` 然后运行JAR文件，如下所示： ~~~ java -jar target/gs-messaging-jms-0.1.0.jar ~~~ 此处描述的步骤将创建可运行的JAR。 您还可以 构建经典的WAR文件 。 当它运行时，埋在所有日志中，您应该看到以下消息： ~~~ Sending an email message. Received <Email{to=info@example.com, body=Hello}> ~~~ ## 概括 恭喜你！ 您刚刚开发了基于JMS的消息的发布者和使用者。