ActiveMQ 입문 예

1. Maven 프로젝트 를 새로 만 들 고 다음 과 같은 의존 도 를 추가 합 니 다.

<dependency>
	<groupId>org.apache.activemq</groupId>
	<artifactId>activemq-all</artifactId>
	<version>5.11.1</version>
</dependency>

둘:
server (끼 워 넣 기, activemq 설치 다운로드 필요 없 음)

package com.lala.mq;

import java.util.concurrent.TimeUnit;

import org.apache.activemq.broker.BrokerService;

public class Server 
{
	public static void main(String[] args)throws Exception
	{
		BrokerService broker = new BrokerService();
		broker.addConnector("tcp://127.0.0.1:55551");
		broker.setUseJmx(false);
		broker.start();
		TimeUnit.SECONDS.sleep(9999);
	}
}

생산자

package com.lala.mq;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class MyProducer
{
	public static void main(String[] args) throws Exception
	{
		ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://127.0.0.1:55551");
		
		Connection conn = cf.createConnection();
		
		conn.start();
		
		Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
		
		Queue queue = session.createQueue("cib");
		
		MessageProducer producer = session.createProducer(queue);
		
		TextMessage tm = null;
		
		for(int i=1;i<=5;i++)
		{
			tm = session.createTextMessage("this is test message and msgid = " + i);
			producer.send(tm);
		}
		
		session.close();
		
		conn.close();
	}
}

소비자 (소비자)

package com.lala.mq;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class MyConsumer 
{
	public static void main(String[] args)throws Exception
	{
		ConnectionFactory cf = new ActiveMQConnectionFactory("tcp://127.0.0.1:55551");
		
		Connection conn = cf.createConnection();
		
		conn.start();
		
		Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
		
		Queue queue = session.createQueue("cib");
		
		MessageConsumer consumer = session.createConsumer(queue);
		
		consumer.setMessageListener((message) -> {
			TextMessage tm = (TextMessage)message;
			try {
				System.out.println("    ：" + tm.getText());
			} catch (Exception e) {
				e.printStackTrace();
			}
		});
	}
}

실행
먼저 실행: Server
재 실행: Consumer
마지막 실행: Producer
출력 을 볼 수 있 습 니 다.
마지막.
주의: 이상 의 방법 은 activemq 서 비 스 를 미리 다운로드 할 필요 가 없습니다.

이 내용에 흥미가 있습니까?

현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:

activeMQ의 질문

오늘은 mule로 activeMQ와 통합할 때, mule를 시작할 때 항상 activeMQ의 시작에 머물러 있습니다.원본 코드를 보니 active MQ에 사순환이 생겼습니다. 위의 코드에서dolock은 시종일관fal...

텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.

CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.

ActiveMQ 입문 예

좋은 웹페이지 즐겨찾기