JMS 公共

点对点域

发布/订阅域

ConnectionFactory

QueueConnectionFactory

TopicConnectionFactory

Connection

QueueConnection

TopicConnection

Destination

Queue

Topic

Session

QueueSession

TopicSession

MessageProducer

QueueSender

TopicPublisher

MessageConsumer

QueueReceiver

TopicSubscriber

package com.mq;

import java.util.Date;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MapMessage;

import javax.jms.MessageProducer;

import javax.jms.Session;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Producer {

public static void main(String[] args) {

String user = ActiveMQConnection. DEFAULT_USER;

String password = ActiveMQConnection. DEFAULT_PASSWORD;

String url = ActiveMQConnection. DEFAULT_BROKER_URL;

String subject = "TOOL.DEFAULT" ;

ConnectionFactory contectionFactory = new ActiveMQConnectionFactory(user,password,url);

try {

Connection connection = contectionFactory.createConnection();

connection.start();

Session session = connection.createSession(Boolean. TRUE, Session. AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue(subject);

MessageProducer producer = session.createProducer(destination);

for( int i = 0;i<=20;i++){

MapMessage message = session.createMapMessage();

message.setLong( "count", new Date().getTime());

Thread. sleep(1000);

producer.send(message);

System. out.println( "--发送消息："+ new Date());

}

session.commit();

session.close();

connection.close();

} catch (JMSException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

package com.mq;

import java.util.Date;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MapMessage;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.MessageListener;

import javax.jms.Session;

import org.apache.activemq.ActiveMQConnection;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Consumer {

public static void main(String[] args) {

String user = ActiveMQConnection. DEFAULT_USER;

String password = ActiveMQConnection. DEFAULT_PASSWORD;

String url = ActiveMQConnection. DEFAULT_BROKER_URL;

String subject = "TOOL.DEFAULT" ;

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,password,url);

Connection connection;

try {

connection = connectionFactory.createConnection();

connection.start();

final Session session = connection.createSession(Boolean. TRUE, Session. AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue(subject);

MessageConsumer message = session.createConsumer(destination);

message.setMessageListener( new MessageListener(){

public void onMessage(Message msg) {

MapMessage message = (MapMessage)msg;

try {

System. out.println( "--收到消息："+ new Date(message.getLong("count" )));

session.commit();

} catch (JMSException e) {

e.printStackTrace();

}

}

});

Thread. sleep(30000);

session.close();

connection.close();

} catch (JMSException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

<? xml version ="1.0" encoding ="GBK" ?>

<beans xmlns ="http://www.springframework.org/schema/beans"

xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance"

xmlns:aop ="http://www.springframework.org/schema/aop"

xmlns:tx ="http://www.springframework.org/schema/tx"

xmlns:context ="http://www.springframework.org/schema/context"

xsi:schemaLocation ="

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-3.0.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.0.xsd

http://www.springframework.org/schema/aop

http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"

default-autowire ="byName" >

</ beans>

<? xml version ="1.0" encoding ="GBK" ?>

<web-app version ="2.5" xmlns ="http://java.sun.com/xml/ns/javaee"

xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation ="http://java.sun.com/xml/ns/javaee

http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" >

<context-param >

<param-name >contextConfigLocation </param-name >

<param-value >classpath*:applicationContext*.xml </param-value >

</ context-param>

<servlet >

<servlet-name >spring </servlet-name >

<servlet-class >

org.springframework.web.servlet.DispatcherServlet

</ servlet-class>

<load-on-startup >1</ load-on-startup>

</ servlet>

<servlet-mapping >

<servlet-name >spring </servlet-name >

<url-pattern >/</ url-pattern>

</ servlet-mapping>

<welcome-file-list >

<welcome-file >index.jsp </welcome-file >

</ welcome-file-list>

</ web-app>

<!-- 配置Jms模板 -->

<bean id ="jmsTemplate"

class ="org.springframework.jms.core.JmsTemplate" >

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

<property name ="defaultDestination" ref ="destination" />

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

</ bean>

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

<bean id ="connectionFactory"

class ="org.apache.activemq.ActiveMQConnectionFactory" >

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

</ bean>

<!-- 发送消息的目的地（队列） -->

<bean id ="destination"

class ="org.apache.activemq.command.ActiveMQQueue" >

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

<constructor-arg index ="0" value ="myQueue" />

</ bean>

package com.mq.service;

public interface ProducerService {

public void send();

}

package com.mq.service;

import java.util.Date;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MapMessage;

import javax.jms.Message;

import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;

public class ProducerServiceImpl implements ProducerService {

JmsTemplate jmsTemplate ;

Destination destination ;

public void send() {

MessageCreator messageCreator = new MessageCreator(){

public Message createMessage(Session session) throws JMSException {

MapMessage message = session.createMapMessage();

message.setLong( "count", new Date().getTime());

System. out.println( "--发送消息："+ new Date());

return message;

}

};

jmsTemplate .send( this.destination ,messageCreator);

}

public void setJmsTemplate(JmsTemplate jmsTemplate) {

this.jmsTemplate = jmsTemplate;

}

public void setDestination(Destination destination) {

this.destination = destination;

}

}

package com.mq.service;

public interface ConsumerService {

public void receive();

}

package com.mq.service;

import java.util.Date;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MapMessage;

import org.springframework.jms.core.JmsTemplate;

public class ConsumerServiceImpl implements ConsumerService {

JmsTemplate jmsTemplate ;

Destination destination ;

public void receive() {

MapMessage message = (MapMessage)jmsTemplate .receive();

try {

System. out.println( "--收到消息："+ new Date(message.getLong("count" )));

} catch (JMSException e) {

e.printStackTrace();

}

}

public void setJmsTemplate(JmsTemplate jmsTemplate) {

this.jmsTemplate = jmsTemplate;

}

public void setDestination(Destination destination) {

this.destination = destination;

}

}

<bean id ="producerService"

class ="com.mq.service.ProducerServiceImpl" >

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

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

</ bean>

<bean id ="consumerService"

class ="com.mq.service.ConsumerServiceImpl" >

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

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

</ bean>

<? xml version ="1.0" encoding ="GBK" ?>

<beans xmlns ="http://www.springframework.org/schema/beans"

xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance"

xmlns:aop ="http://www.springframework.org/schema/aop"

xmlns:tx ="http://www.springframework.org/schema/tx"

xmlns:context ="http://www.springframework.org/schema/context"

xsi:schemaLocation ="

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-3.0.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.0.xsd

http://www.springframework.org/schema/aop

http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"

default-autowire ="byName" >

<bean id ="producerService"

class ="com.mq.service.ProducerServiceImpl" >

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

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

</ bean>

<bean id ="consumerService"

class ="com.mq.service.ConsumerServiceImpl" >

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

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

</ bean>

<!-- 配置Jms模板 -->

<bean id ="jmsTemplate"

class ="org.springframework.jms.core.JmsTemplate" >

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

<property name ="defaultDestination" ref ="destination" />

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

</ bean>

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

<bean id ="connectionFactory"

class ="org.apache.activemq.ActiveMQConnectionFactory" >

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

</ bean>

<!-- 发送消息的目的地（队列） -->

<bean id ="destination"

class ="org.apache.activemq.command.ActiveMQQueue" >

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

<constructor-arg index ="0" value ="myQueue" />

</ bean>

</ beans>

package com.mq.service;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ProducerTest {

private static ApplicationContext appContext = new ClassPathXmlApplicationContext(

"applicationContext.xml" );

private static void send() {

ProducerService producerService = (ProducerService) appContext

.getBean( "producerService");

producerService.send();

}

/**

* @param args

*/

public static void main(String[] args) {

send();

}

}

package com.mq.service;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ConsumerTest {

private static ApplicationContext appContext = new ClassPathXmlApplicationContext(

"applicationContext.xml" );

private static void receive() {

ConsumerService consumerService = (ConsumerService) appContext

.getBean( "consumerService");

consumerService.receive();

}

/**

* @param args

*/

public static void main(String[] args) {

receive();

}

}