java实现消息队列的两种方式(小结)

package com.jms.service.impl;

import com.jms.service.producerservice;

import org.springframework.jms.core.jmstemplate;

import org.springframework.stereotype.service;

import javax.annotation.resource;

import javax.jms.destination;

/**

  * 发送消息

  */

@service

public class producerserviceimpl implements producerservice {

  @resource

  private jmstemplate jmstemplate;

  public void sendmessage(destination destination, string msg) {

   system.out.println( "向队列" +destination+ "发送消息" );

   jmstemplate.convertandsend(destination,msg);

  }

  public void sendmessage(string msg) {

   system.out.println( "向队列" +jmstemplate.getdefaultdestination().tostring()+ "发送消息" );

   jmstemplate.convertandsend(msg);

  }

}

package com.jms.service.impl;

import com.jms.service.customerservice;

import org.springframework.jms.core.jmstemplate;

import org.springframework.stereotype.service;

import javax.annotation.resource;

import javax.jms.destination;

import javax.jms.jmsexception;

import javax.jms.textmessage;

@service

public class customerserviceimpl implements customerservice {

  @resource

  private jmstemplate jmstemplate;

  /**

   * 接收消息

   * @param destination

   */

  public void receive(destination destination) {

   textmessage textmessage = (textmessage) jmstemplate.receive(destination);

   try {

    system.out.println( "从队列》" +destination.tostring()+ "成功获取消息》" +textmessage.gettext());

   } catch (jmsexception e) {

    e.printstacktrace();

   }

  }

}

<?xml version= "1.0" encoding= "utf-8" ?>

<beans xmlns= "http://HdhCmsTestspringframework.org/schema/beans"

   xmlns:xsi= "http://HdhCmsTestw3.org/2001/xmlschema-instance"

   xmlns:context= "http://HdhCmsTestspringframework.org/schema/context"

   xmlns:mvc= "http://HdhCmsTestspringframework.org/schema/mvc"

   xsi:schemalocation="http: //HdhCmsTestspringframework.org/schema/beans

   http: //HdhCmsTestspringframework.org/schema/beans/spring-beans.xsd

   http: //HdhCmsTestspringframework.org/schema/context

   http: //HdhCmsTestspringframework.org/schema/context/spring-context.xsd

   http: //HdhCmsTestspringframework.org/schema/mvc

   http: //HdhCmsTestspringframework.org/schema/mvc/spring-mvc.xsd

   ">

  <!-- 启动包扫描功能，以便注册带有 @controller 、 @service 、 @repository 、 @component 等注解的类成为spring的bean -->

  <context:component-scan base- package = "com.jms.service" > </context:component-scan>

  <!-- 配置根视图 -->

  <!--<mvc:view-controller path= "/" view-name= "index" />-->

  <!--启用注解-->

  <mvc:annotation-driven />

  <!-- 视图层配置 -->

  <!--<bean class = "org.springframework.web.servlet.view.internalresourceviewresolver" >-->

   <!--<property name= "prefix" value= "/web-inf/view/" />-->

   <!--<property name= "suffix" value= ".jsp" />-->

  <!--</bean>-->

  <!-- 配置jms连接工厂 -->

  <bean id= "connectionfactory" class = "org.apache.activemq.activemqconnectionfactory" >

   <property name= "brokerurl" value= "tcp://localhost:61616" />

  </bean>

  <!-- 定义消息队列（queue） -->

  <bean id= "queuedestination" class = "org.apache.activemq测试数据mand.activemqqueue" >

   <!-- 设置消息队列的名字 -->

   <constructor-arg>

    <value>queue1</value>

   </constructor-arg>

  </bean>

  <!-- 配置jms模板（queue），spring提供的jms工具类，它发送、接收消息。 -->

  <bean id= "jmstemplate" class = "org.springframework.jms.core.jmstemplate" >

   <property name= "connectionfactory" ref= "connectionfactory" />

   <property name= "defaultdestination" ref= "queuedestination" />

   <property name= "receivetimeout" value= "10000" />

  </bean>

</beans>

package com.jsm.test;

import com.jms.service.customerservice;

import com.jms.service.producerservice;

import org.junit.test;

import org.springframework.context.support.classpathxmlapplicationcontext;

import javax.jms.destination;

/**

  * 消息队列测试类

  */

public class jmstest {

  @test

  public void producertest(){

   classpathxmlapplicationcontext springcontext = new classpathxmlapplicationcontext( new string[]{ "classpath:spring-core.xml" });

   producerservice producerservice = (producerservice)springcontext.getbean( "producerserviceimpl" );

   customerservice customerservice = (customerservice)springcontext.getbean( "customerserviceimpl" );

   destination destination = (destination)springcontext.getbean( "queuedestination" );

   producerservice.sendmessage( "测试消息队列" );

   customerservice.receive(destination);

  }

}