bbossgroups jms组件框架
bbossgroups jms组件框架
bboss aop框架的jms组件提供针对jms规范的一组简单的操作接口，可一通过 JMSTemplate组件来实现JMS消息的接收和发送功能。
系统中提供了两个JMS Template实现：
org.frameworkset.mq.JMSTemplate—提供所有的jms接收和发送接口，不带主题订阅功能接口
org.frameworkset.mq.JMSReceiveTemplate-提供所有的jms接收和发送接口，带主题订阅功能接口
下面是举一些简单的例子，说明这连个模板类的使用方法。
系统中可以方便地通过扩展连接工程管理抽象类
org.frameworkset.mq.JMSConnectionFactory来实现不同的jms服务提供商的jms服务器的支持。开发人员只需要实现JMSConnectionFactory的抽象方法：
/**
* 构建特定提供商的连接工厂
*
* @return
*/
public abstract ConnectionFactory buildConnectionFactory() throws Exception;
bboss aop框架中的jms组件提供了对apache activemq server的实现：
org.frameworkset.mq. AMQConnectionFactory
本章都是以apache activemq server为例来说明jms组件的基本接口。
由于篇幅问题，省略相关配置的介绍，感兴趣的朋友可以到以下地址下载详细的文档介绍：
http://sourceforge.net/projects/bboss/files/bbossgroups-1.0/bbossgroups%20document.zip/download
其中aop框架技术白皮书中有bboss jms组件的详细介绍，这里只列出一些测试用例。
测试用例
1.2.1 从连接池工厂中获取jms connection
下面的代码从连接池工厂中获取jms connection对象，先后获取两次验证连接池是否生效。
JMSConnectionFactory factory = (JMSConnectionFactory)BaseSPIManager.getBeanObject("test.amq.PooledConnectionFactory");
try
{
Connection connection = factory.getConnection();
connection.start();
connection.close();
connection = factory.getConnection();
connection.start();
connection.close();
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
1.2.2 从连接工厂中获取jms connection
从连接工厂中获取jms connection,每次都会创建新的jms connection
JMSConnectionFactory factory = (JMSConnectionFactory)BaseSPIManager.getBeanObject("test.amq.ConnectionFactory");
try
{
Connection connection = factory.getConnection();
connection.start();
connection.close();
connection = factory.getConnection();
connection.start();
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
1.2.3 向队列atest中发送消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "ahello");
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.4 向队列atest发送持久化的消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "phello",true);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.5 向队列atest中发送持久化消息，指定优先级和过期时间
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "allhello",true,4,10000);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.6 从队列atest中同步接收消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
Message msg = template.receive("atest");
System.out.println("testReceiveMessage:"+ msg);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.7 从队列atest中异步接收消息
利用test.jms.receive.template模板从队列atest中异步接收消息。
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.jms.receive.template");
try
{
template.setMessageListener("atest",new MessageListener() {
public void onMessage(Message arg0)
{
System.out.println("msg comming:"+arg0);
}
});
}
catch (Exception e)
{
template.stop();
}
finally
{
}
1.2.8 向主题getsubtest发送消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("topic://getsubtest", "getsubtest");
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.9 从主题订阅消息
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.topic.receive.jmstemplate");
try
{
template.getTopicSubscriber("getsubtest", "subscribename").setMessageListener(new MessageListener() {
public void onMessage(Message arg0)
{
System.out.println("topic msg comming:"+arg0);
}
});
}
catch (Exception e)
{
template.stop();
}
finally
{
}
1.2.10 从主题退订消息
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.topic.receive.jmstemplate");
try
{
template.unsubscribe("subscribename");
}
catch (Exception e)
{
template.stop();
}
finally
{
}
注意事项：使用主题发布和订阅消息时，不要使用连接池连接工厂。