基于JMS消息中间件的分布式系统初探究

在一个大型网站中,如果要把整个业务拆分成N个子业务,每个业务单独部署到一台服务器上,那么需要解决的问题有:

自身的部署。是部署到JavaEE容器中随容器启动,还是做为一个standalone程序单独启动?子系统如何暴露服务接口(如何与其它系统进行通讯)。服务请求者直接通过Socket直连,还是通过Web Service, RMI等技术?

这里我们尝试通过standalone方式部署,通过JMS中间件实现通讯。如图所示:

在客户端(运行Web服务)和服务端,我们使用Spring, Spring JMS框架简化消息收发过程,JMS Provider使用ActiveMQ。

在服务端,需要手动创建Spring的ApplicationContext:

@Componentpublic class Bootstrap {private static ApplicationContext ctx;(String[] args) {initSpring(“spring-config.xml”);}(String configPath) {ctx = new ClassPathXmlApplicationContext(configPath);}}

然后编写一个组件作为JMS消息处理器:

@Componentpublic class SayHelloHandler {public String onSaveMember(String username) {return “OK”;}}

我们希望Spring能在从taolijie.member.request.queue消息队列收到一条消息时调用上述方法,则需在spring-config.xml中做如下配置:

==”onSaveMember” /></jms:listener-container>

同时,我们还要配置ConnectionFactory和JmsTemplate:

====>

做好上面的工作后,当Spring收到ActiveMQ来自taolijie.member.request.queue队列的一条消息时就会调用onSaveMember方法,将消息中的payload转换成String类型传入到方法中。如果该方法有返回值,Spring JMS会自动将返回值封装成Message对象并设置JMSReplayTo消息头,ActiveMQ则会按照该消息头将返回的消息投递给发送端。

在客户端的配置与上面相同,只是需要使用Spring JMS提供的JmsTemplate编写发送一个发送消息组件:

{@Autowiredprivate JmsTemplate jmsTemplate;(String name) {System.out.println(“sending persistence request”);Message msg = jmsTemplate.sendAndReceive(“taolijie.member.request.queue”,(Session session) -> {return session.createObjectMessage(new String(“hello”));});TextMessage txt = (TextMessage) msg;try {System.out.println(“done. ” + txt.getText());} catch (JMSException e) {// … …}}}

当我们调用JmsTemplate的sendAndReceive()方法时,Spring会帮我们创建一个临时的队列用于接收返回消息,并时同该方法阻塞,,等待返回消息。如果不想发送同步消息,可以改为调用send(),该方法会立即返回。

以上只是一个模型,我们可以在服务端消息处理方法(如onSaveMember())中添加我们需要的业务逻辑方法,处理完成后返回信息给客户端。所有服务端应用都可以单独部署在一台服务器中,这样就简单实现了一个分布式系统。

发光并非太阳的专利,你也可以发光

基于JMS消息中间件的分布式系统初探究

相关文章:

你感兴趣的文章:

标签云: