jms介绍

一：jms介绍

1.jms（java message service java消息服务），是J2EE规范的一部分，跟jdbc差不

多，sun只提供了接口，由各个厂商（provider）来进行具体的实现，然后使用者使用他们

的jar包进行开发使用即可。

2.另外在jms的API中，jms传递消息有两种方式，一种是点对点的Queue，还有一个是发布

订阅的Topic方式。区别在于：

3.对于Queue模式，一个发布者发布消息，下面的接收者按队列顺序接收，比如发布了10个

消息，有两个接收者A,B，那就是A,B总共会收到10条消息，不重复。

4.对于Topic模式，一个发布者发布消息，有两个接收者A,B来订阅，那么发布了10条消息，

A,B各收到10条消息。


二：ActiveMQ介绍

1.activeMQ是apache下的一个开源jms产品。


三：开始实现代码

1.使用activeMQ来完成jms的发送，必须要下载activeMQ，然后再本机安装，并且启动

activeMQ的服务才行。在官网下载完成之后，运行bin目录下面的activemq.bat，将

activeMQ成功启动。
      
2.启动成功之后可以运行：http:// localhost:8161/admin/index.jsp 查看一下。

3.spring-jms.xml配置

<?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"
 xmlns:jms="http://www.springframework.org/schema/jms"
 xsi:schemaLocation="http://www.springframework.org/schema/beans
            http:// www.springframework.org/schema/beans/spring-beans-2.5.xsd
            http:// www.springframework.org/schema/context
            http:// www.springframework.org/schema/context/spring-context-2.5.xsd
            http:// www.springframework.org/schema/jms
					// http://www.springframework.org/schema/jms/spring-jms-2.5.xsd">
 <bean id="jndiTemplate"
  class="org.springframework.jndi.JndiTemplate">
  <property name="environment">
   <props>
    <prop key="java.naming.factory.initial">
     org.apache.activemq.jndi.ActiveMQInitialContextFactory
    </prop>
    <prop key="brokerURL">tcp:// localhost:61616</prop>
    <prop key="queue.myqueue">myqueue</prop>
    <prop key="connectionFactoryNames">
     ConnectionFactory
    </prop>
   </props>
  </property>
 </bean>

 <bean id="connectionFactory"
  class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiName" value="ConnectionFactory" />
  <property name="jndiTemplate" ref="jndiTemplate" />
 </bean>

 <bean id="jmsTemplate"
  class="org.springframework.jms.core.JmsTemplate">
  <property name="connectionFactory" ref="connectionFactory" />
  <property name="defaultDestinationName" value="myqueue" />
  <property name="pubSubDomain" value="false" />
 </bean>

 <bean id="producer" class="com.mypack.SpringJmsProducer">
  <property name="jmsTemplate" ref="jmsTemplate" />
 </bean>

 <bean id="consumer" class="com.mypack.SpringJmsConsumer">
  <property name="jmsTemplate" ref="jmsTemplate" />
 </bean>


</beans>

package com.mypack;

import org.springframework.jms.core.JmsTemplate;

public class SpringJmsConsumer {

 private JmsTemplate jmsTemplate;

 public JmsTemplate getJmsTemplate() {

  return jmsTemplate;

 }

 public void setJmsTemplate(JmsTemplate jmsTemplate) {

  this.jmsTemplate = jmsTemplate;

 }

 public String receive() {

  return (String) jmsTemplate.receiveAndConvert();

 }

}

package com.mypack;

import org.springframework.jms.core.JmsTemplate;

public class SpringJmsProducer {

    private JmsTemplate jmsTemplate;

    public void send(String message) {

        jmsTemplate.convertAndSend(message);

    }

    public JmsTemplate getJmsTemplate() {

        return jmsTemplate;

    }

    public void setJmsTemplate(JmsTemplate jmsTemplate) {

        this.jmsTemplate = jmsTemplate;

    }

}

 package com.mypack;

import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class SpringJmsConsumerMain {

 public static void main(String[] args) {

  BeanFactory factory = new ClassPathXmlApplicationContext(
    "spring-jms.xml");

  SpringJmsConsumer consumer = null;

  consumer = (SpringJmsConsumer) factory.getBean("consumer");

  System.out.println("message = " + consumer.receive());

 }

}

 package com.mypack;

import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class SpringJmsProducerMain {

 public static void main(String[] args) {

  BeanFactory factory = new ClassPathXmlApplicationContext(
    "spring-jms.xml");

  SpringJmsProducer producer = null;

  producer = (SpringJmsProducer) factory.getBean("producer");

  producer.send("hello world,jms");

 }

}