标签：队列 spring jmsTemplate brokerService 连接器 new activemq public

一.applicationContext配置对象

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <context:component-scan base-package="com.aib.mapper"/>


    <!--  配置spring的连接工厂  -->
    <bean id="jmsFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <property name="targetConnectionFactory">
            <!--  配置activemq原生工厂  -->
            <bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="brokerURL" value="tcp://localhost:61616"></property>
            </bean >
        </property>
    </bean >

    <!--  配置topic  -->
    <bean id="activeMQQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <constructor-arg index="0" value="spring-queue"></constructor-arg>
    </bean >
    <!--  配置queue  -->
    <bean id="activeMQTopic" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg index="0" value="spring-topic"></constructor-arg>
    </bean >
    <!--  配置JMSTemplate  -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="jmsFactory"></property>
        <property name="defaultDestination" ref="activeMQQueue"></property>
        <property name="messageConverter" ref="messageConverter"></property>
    </bean >

    <!--  配置消息的转换器  -->
    <bean id="messageConverter" class="org.springframework.jms.support.converter.SimpleMessageConverter">

    </bean>
</beans>

　　JMSTemplate是操作mq的一个对象，即充当生产者也是消费者，都有两者API的功能

　　测试JMSTemplate：

public class spring_producer {

    @Test
    public void testJmsTemplate(){

        ApplicationContext ioc = new ClassPathXmlApplicationContext("applicationContext.xml");

        JmsTemplate jmsTemplate = (JmsTemplate) ioc.getBean("jmsTemplate");

        jmsTemplate.send(new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {

                TextMessage message = session.createTextMessage("我很牛逼");

                return message;
            }
        });
        System.out.println("发出消息了");
    }

    public static void main(String[] args) throws Exception{

        //使用broker充当mq实例
        BrokerService brokerService = new BrokerService();

        //使用jms协议
        brokerService.setUseJmx(true);
        //获得连接器
        brokerService.addConnector("tcp://localhost:61616");
        //开启连接器
        brokerService.start();
    }
}

标签：队列,spring,jmsTemplate,brokerService,连接器,new,activemq,public
来源： https://www.cnblogs.com/ibcdwx/p/14058516.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。