首页 > 代码库 > ActiveMQ使用

ActiveMQ使用

2024-07-05 22:56:41   223人阅读

1.下载ActiveMQ

去官方网站下载：http://activemq.apache.org/

2.创建Eclipse项目并运行

创建project：ActiveMQ-5.5，并导入apache-activemq-5.5.1\lib目录下需要用到的jar文件，项目结构如下图所示：

先启动activeMQ.BAT；

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
package com.mzj.jmsActiveMQTest2;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;
 
import org.apache.activemq.ActiveMQConnectionFactory;
/**
 * 消息——生产者
 */
public class Producer {
 
    public static void main(String[] args) throws JMSException {
 
        String jmsProviderAddress = "tcp://localhost:61616";// 地址
 
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                jmsProviderAddress);// 连接器
 
        Connection connection = connectionFactory.createConnection();// 创建连接
 
        Session session = connection.createSession(false,
                Session.AUTO_ACKNOWLEDGE);// 打开会话
 
        Destination dest = session.createQueue("demoQueue");// 消息目的地
 
        MessageProducer producer = session.createProducer(dest);// 消息发送者
 
        Message message = session.createTextMessage("hello world");// 消息
 
        producer.send(message);// 发送
 
        producer.close();// 关闭
        session.close();
        connection.close();
 
    }
 
}

　　

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
package com.mzj.jmsActiveMQTest2;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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 Consumer {
    public static void main(String[] args) throws JMSException {
 
        String jmsProviderAddress = "tcp://localhost:61616";// 地址
 
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                jmsProviderAddress);// 连接器
 
        Connection connection = connectionFactory.createConnection();// 创建连接
 
        Session session = connection.createSession(false,
                Session.AUTO_ACKNOWLEDGE);// 打开会话
 
        String destinationName = "demoQueue";
 
        Destination dest = session.createQueue(destinationName);// 消息目的地
 
        MessageConsumer consumer = session.createConsumer(dest);
 
        connection.start();
 
        Message message = consumer.receive();
 
        TextMessage textMessage = (TextMessage) message;
 
        String text = textMessage.getText();
 
        System.out.println("从ActiveMQ取回一条消息: " + text);
 
        consumer.close();
        session.close();
        connection.close();
 
    }
 
}

　　


联系
我们