用AI赚第一桶💰低成本搭建一套AI赚钱工具,源码可二开。 广告
# 使用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的消息的发布者和使用者。