现在的位置: 首页 > 综合 > 正文

Spring基于JMS实现远程访问

2013年11月10日 ⁄ 综合 ⁄ 共 6426字 ⁄ 字号 评论关闭

使用JMS作为底层通信协议,Spring提供了很好的支持。我们可以基于JMS将服务暴露给外部,这一切对于外部完全透明。这里我们基于开源消息中间件ActiveMQ作为中间代理,通过在服务端将服务以消息的形式发布到代理服务器上,然后客户端通过代理服务器实现对服务的远程调用。

ActiveMQ的BrokerService可以非常容易地实现服务端与客户端进行通信的中间代理,Spring配置broker.xml内容如下所示:

通过Spring的IOC容器来管理BrokerService。实现一个基于ActiveMQ的消息代理服务,如下所示:

启动后,代理监听61616,等待服务端发布服务,以及远程客户端调用服务。

看一下,服务端如何进行实现。

定义服务接口和服务实现。服务接口,代码如下所示:

实现上述接口,示例代码如下所示:

然后,服务端的配置server.xml,内容如下所示:

通过Spring的org.springframework.jms.listener.SimpleMessageListenerContainer实现服务的发布,可以配置的属性有:

connectionFactory         连接工厂

destination                    消息目的地,基于ActiveMQ则是一个消息队列

concurrentConsumers   并发消息消费者数量

messageListener           消息监听器

taskExecutor                 线程池

通过上面配置可以看到,连接工厂指定了代理监听服务的端口,我们通过服务端发布服务,作为消息生产者将服务以消息的形式发布,然后客户端作为服务的消费者,通过代理来实现对远程发布服务的调用。

服务端启动的实现,如下所示:

再看一下,客户端如何进行远程访问。

对应的客户端的配置client.xml,内容如下所示:

主要是基于Spring提供的org.springframework.jms.remoting.JmsInvokerProxyFactoryBean来实现,通过消息中间件代理,调用远程发布的服务。

需要注意的是,客户端是通过消息队列(org.apache.activemq.command.ActiveMQQueue)的名称(如上述为shirdrnQ)来获取消息(远程服务),如果无法识别消息队列是无法实现服务的远程访问的。

客户端实现远程访问,示例代码如下所示:

 

抱歉!评论已关闭.