ActiveMQ jms 구현의 간단한 실례

전기 작업은 생략하고 표시하지 않는다.
구체적인 코드는 다음과 같습니다.
MessageReceiver

package jms.activemq.myexample;



import javax.jms.Connection;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.Session;

import javax.jms.TextMessage;



import org.apache.activemq.ActiveMQConnectionFactory;



public class MessageReceiver implements Runnable {

	private String url;

	private String user;

	private String password;

	private final String QUEUE;



	public MessageReceiver(String queue, String url, String user, String password) {

		this.url = url;

		this.user = user;

		this.password = password;

		this.QUEUE = queue;

	}



	@Override

	public void run() {

		ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(

				user, password, url);

		Session session = null;

		Destination receiveQueue;

		try {

			Connection connection = connectionFactory.createConnection();



			session = connection

					.createSession(true, Session.SESSION_TRANSACTED);

			receiveQueue = session.createQueue(QUEUE);

			MessageConsumer consumer = session.createConsumer(receiveQueue);



			connection.start();



			while (true) {

				Message message = consumer.receive();



				if (message instanceof TextMessage) {

					TextMessage receiveMessage = (TextMessage) message;

					System.out.println("  Receiver,      : \r
"

							+ receiveMessage.getText());

				} else {

					session.commit();

					break;

				}



			}

			connection.close();

		} catch (JMSException e) {

			e.printStackTrace();

		}

	}



	public String getUrl() {

		return url;

	}



	public void setUrl(String url) {

		this.url = url;

	}



	public String getUser() {

		return user;

	}



	public void setUser(String user) {

		this.user = user;

	}



	public String getPassword() {

		return password;

	}



	public void setPassword(String password) {

		this.password = password;

	}





}

MessageSender

package jms.activemq.myexample;



import java.util.Date;

import javax.jms.Connection;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;







/**

 *      

 * @author xiaochuanyu

 *

 */

public class MessageSender implements Runnable {

	

	private String url;

	private String user;

	private String password;

	private final String QUEUE;



	public MessageSender(String queue, String url, String user, String password) {

		this.url = url;

		this.user = user;

		this.password = password;

		this.QUEUE = queue;

	}



	@Override

	public void run() {

		ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(

				user, password, url);

		Session session = null;

		Destination sendQueue;

		Connection connection = null;



		int messageCount = 0;

		try {

			connection = connectionFactory.createConnection();



			connection.start();



			while (true) {

				session = connection.createSession(true,

						Session.SESSION_TRANSACTED);



				sendQueue = session.createQueue(QUEUE);

				MessageProducer sender = session.createProducer(sendQueue);

				TextMessage outMessage = session.createTextMessage();

				outMessage.setText(new Date() + "      " + messageCount + "   ");



				sender.send(outMessage);



				session.commit();



				sender.close();



				if ((++messageCount) == 10) {

					//         

					break;

				}

				Thread.sleep(1000);

			}

			connection.close();

		} catch (JMSException e) {

			e.printStackTrace();

		} catch (InterruptedException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}



	public String getUrl() {

		return url;

	}



	public void setUrl(String url) {

		this.url = url;

	}



	public String getUser() {

		return user;

	}



	public void setUser(String user) {

		this.user = user;

	}



	public String getPassword() {

		return password;

	}



	public void setPassword(String password) {

		this.password = password;

	}



}

MyActiveMQDemo

package jms.activemq.myexample;



public class MyActiveMQDemo {

	public static void main(String[] args) {

		String url = "tcp://localhost:61616";

		String user = null;

		String password = null;

		String query = "MyQueue";

		

		

		new Thread(new MessageSender(query,url,user,password), "Name-Sender").start();

		new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver").start();

	}

}