码迷,mamicode.com
首页 > 其他好文 > 详细

JMS - 基于JMS的RPC

时间:2014-11-03 20:39:42      阅读:258      评论:0      收藏:0      [点我收藏+]

标签:des   style   blog   http   io   color   ar   os   使用   

现在试试通过JMS,在应用程序之间发送消息。
先看看spring提供的RPC方案(其实还有其他方案,只是没见过谁用)。
需要使用到这两个类:
·org.springframework.jms.remoting.JmsInvokerServiceExporter将bean导出为基于消息的服务
·org.springframework.jms.remoting.JmsInvokerProxyFactoryBean让客户端调用服务

 

比较一下JmsInvokerServiceExporter和RmiServiceExporter:

bubuko.com,布布扣

 

package pac.testcase.jms;
public interface JmsRmiService {
    String doServe(String requestedNum);
}

 

package pac.testcase.jms;
import org.springframework.stereotype.Service;
@Service
public class JmsRmiServiceImpl implements JmsRmiService {
                                                                                                                                                     
    public String doServe(String content) {
        System.out.println(content.concat(" has been requested!!"));
        return "your message::".concat(content).concat(":::length:")+content.length();
    }
}

 

将这个pojo声明为服务,在spring配置文件中配置:

<bean id="serverService" class="org.springframework.jms.remoting.JmsInvokerServiceExporter"
    p:serviceInterface="pac.testcase.jms.JmsRmiService"
    p:service-ref="JmsRmiServiceImpl">
</bean>

 

需将他设置为jms监听器,配置方法和一般的jmsMessageListener的配置相同:

<amq:connectionFactory id="jmsFactory" />
<jms:listener-container
    destination-type="queue"
    connection-factory="jmsFactory"
    concurrency="3"
    container-type="simple">
    <jms:listener  destination="sparta" ref="serverService"  />
</jms:listener-container>

 

container-type有simple和default,根据不同的type也可以使用task-Executor,这里先简单记录一下。

先启动jms broker再启动:

new ClassPathXmlApplicationContext("classpath:applicationContext-*.xml").getBean(JmsRmiService.class);

 

client这边我需要一个调用代理帮我去调用接口,也就是JmsInvokerProxyFactoryBean;
配置如下:

<amq:connectionFactory id="connectionFactory" />
<bean id="clientService" class="org.springframework.jms.remoting.JmsInvokerProxyFactoryBean"
    p:serviceInterface="pac.test.jms.SenderRmiService"
    p:connectionFactory-ref="connectionFactory"
    p:queueName="sparta"/>

配置中的serviceInterface是client端中根据要调用的方法创建的一个接口。

 

main方法试着调用看看:

public static void main(String[] args) {
    ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
    SenderRmiService service = (SenderRmiService)context.getBean("clientService");
    System.out.println(service.doServe("这才是斯巴达!!"));
}

 

server端输出:
bubuko.com,布布扣
client端输出:
bubuko.com,布布扣

JMS - 基于JMS的RPC

标签:des   style   blog   http   io   color   ar   os   使用   

原文地址:http://www.cnblogs.com/alvez/p/4071937.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!