1. 概述
我们在之前的文章中看到了如何使用Spring Remoting在异步通道之上提供RPC作为AMQP队列。但是，我们也可以使用JMS获得相同的结果。
在本文中，我们将探讨如何使用Spring Remoting JMS和Apache ActiveMQ作为消息传递中间件来设置远程调用。
2. 启动Apache ActiveMQ代理
Apache ActiveMQ是一个开源消息代理，它使应用程序能够异步交换信息，并且它与Java Message Service API完全兼容。
要运行我们的实验，我们首先需要设置ActiveMQ的运行实例。我们可以选择几种方法：按照官方指南中描述的步骤，将其嵌入到Java应用程序中，或者更简单地使用以下命令启动Docker容器：
docker run -p 61616:61616 -p 8161:8161 rmohr/activemq:5.14.3
这将启动一个ActiveMQ容器，该容器在端口8081上公开一个简单的管理Web GUI，我们可以通过它检查可用队列、连接的客户端和其他管理信息。JMS客户端将需要使用端口61616连接到代理并交换消息。
3. Maven依赖
与之前介绍Spring Remoting的文章一样，我们将设置一个服务器和一个客户端Spring Boot应用程序来展示JMS Remoting的工作原理。
通常我们会仔细选择Spring Boot启动器依赖项，如下所述：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
</exclusion>
</exclusions>
</dependency>
我们明确排除了spring-boot-starter-tomcat，以便在类路径中不包含与Tomcat相关的.jar文件。
反过来，这将阻止Spring Boot的自动配置机制在应用程序启动时启动嵌入式Web服务器，因为我们不需要它。
4. 服务器应用
4.1 公开服务
我们将设置一个服务器应用程序，它公开客户端将能够调用的CabBookingService。
第一步是声明一个bean，它实现了我们想要向客户公开的服务接口。这是将在服务器上执行业务逻辑的bean：
@Bean
CabBookingService bookingService() {
return new CabBookingServiceImpl();
}
然后让我们定义服务器将从中检索调用的队列，并在构造函数中指定其名称：
@Bean
Queue queue() {
return new ActiveMQQueue("remotingQueue");
}
正如我们已经从之前的文章中了解到的那样，Spring Remoting的主要概念之一是服务导出器，它是从某个源(在本例中是ActiveMQ队列)收集调用请求的组件并在服务实现上调用所需的方法。
为了使用JMS，我们定义了一个JmsInvokerServiceExporter：
@Bean
JmsInvokerServiceExporter exporter(CabBookingService implementation) {
JmsInvokerServiceExporter exporter = new JmsInvokerServiceExporter();
exporter.setServiceInterface(CabBookingService.class);
exporter.setService(implementation);
return exporter;
}
最后，我们需要定义一个负责消费消息的监听器。监听器充当ActiveMQ和JmsInvokerServiceExporter之间的桥梁，它监听队列上可用的调用消息，将调用转发给服务导出器并将结果序列化：
@Bean SimpleMessageListenerContainer listener(ConnectionFactory factory, JmsInvokerServiceExporter exporter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(factory);
container.setDestinationName("remotingQueue");
container.setConcurrentConsumers(1);
container.setMessageListener(exporter);
return container;
}
4.2 配置
让我们记住设置application.properties文件以允许Spring Boot配置一些基本对象，例如监听器所需的ConnectionFactory。
各种参数的值主要取决于ActiveMQ的安装方式，以下是我们运行这些示例的同一台机器上运行的Docker容器的合理配置：
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.packages.trusted=org.springframework.remoting.support,java.lang,cn.tuyucheng.taketoday.api
spring.activemq.broker-url参数是对ActiveMQ端口的引用。相反，需要对spring.activemq.packages.trusted参数进行更深入的解释。
从版本5.12.2开始，ActiveMQ默认拒绝任何ObjectMessage类型的消息，用于交换序列化的Java对象，因为在某些情况下它被认为是安全攻击的潜在载体。
无论如何，可以指示ActiveMQ接收指定包中的序列化对象。org.springframework.remoting.support是包含表示远程方法调用及其结果的主要消息的包。
包cn.tuyucheng.taketoday.api包含我们服务的参数和结果。添加java.lang是因为表示出租车预订结果的对象引用了一个String，所以我们也需要对其进行序列化。
5. 客户端应用
5.1 调用远程服务
现在让我们来处理客户端。同样，我们需要定义将写入调用消息的队列。我们需要仔细检查客户端和服务器是否使用相同的名称。
@Bean
Queue queue() {
return new ActiveMQQueue("remotingQueue");
}
然后我们需要设置一个导出器：
@Bean
FactoryBean invoker(ConnectionFactory factory, Queue queue) {
JmsInvokerProxyFactoryBean factoryBean = new JmsInvokerProxyFactoryBean();
factoryBean.setConnectionFactory(factory);
factoryBean.setServiceInterface(CabBookingService.class);
factoryBean.setQueue(queue);
return factoryBean;
}
现在，我们可以像使用本地bean一样使用远程服务：
CabBookingService service = context.getBean(CabBookingService.class);
out.println(service.bookRide("13 Seagate Blvd, Key Largo, FL 33037"));
5.2 运行示例
同样对于客户端应用程序，我们必须在应用程序的.properties文件中正确选择值。在常见的设置中，这些将与服务器端使用的完全匹配。
这应该足以演示通过Apache ActiveMQ进行的远程调用。因此，让我们首先启动ActiveMQ，然后是服务器应用程序，最后是将调用远程服务的客户端应用程序。
6. 总结
在这个快速教程中，我们了解了如何使用Spring Remoting在JMS系统(ActiveMQ)之上提供RPC。
Spring Remoting不断展示如何轻松快速地设置异步调用，而不管底层通道如何。
与往常一样，本教程的完整源代码可在GitHub上获得。
Post Directory
