0%

ActiveMQ 5基本使用


安装启动

安装直接去官网下载然后解压即可

windows正常就是通过bin目录下的.\activemq start命令即可启动(5.10以前不用加start)

Linux则是./activemq start

然后可以通过localhost:8161/admin访问web控制台,默认用户名密码都是admin。

发送测试

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
52
53
54
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

public static final String USERNAME = ActiveMQConnectionFactory.DEFAULT_USER;

public static final String PASSWORD = ActiveMQConnectionFactory.DEFAULT_PASSWORD;

public static final String URL = "tcp://127.0.0.1:61616";

public static void main(String[] args) throws Exception {

// 第一步:建立ConnectionFactory工厂对象,需要填入用户名,密码,以及连接的地址。默认tcp://127.0.0.1:61616
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);

// 第二部:通过ConnectionFactory工厂对象我们创建一个Connection连接
// 并且调用Connection的start启动连接, Connection默认是关闭的。
Connection connection = connectionFactory.createConnection();
connection.start();

// 第三部:通过Connection对象创建Session会话(上下文环境对象),用于接受消息
// 参数配置1为是否启用事物,参数配置2为签收模式,一般设置为自动签收。
Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

// 第四部: 通过Session创建Destination,指的是一个客户端用来指定生产消息目标和消息来源的对象
// 在ptp模式中,Destination被称做为Queue(队列),在Pub/Sub模式下,Destination被称作Topic(主题)
Destination destination = session.createQueue("helloworld-queue");

// 第五步:我们需要通过Session对象创建消息的发送和接受对象,(生产者和消费者)MessageProducer/MessageConsumer
MessageProducer producer = session.createProducer(destination);

// 第六步:我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性(DeliveryMode)
producer.setDeliveryMode(DeliveryMode.PERSISTENT);

// 第七部:最后我们使用jms规范的TextMessage形式创建数据(通过Session对象),
// 并用MessageProducer的send方法发送数据,同理客户端使用receive方法进行接受数据。
TextMessage message = session.createTextMessage("producer hello word!");
producer.send(message);

// 最后不要忘了关闭资源。
if (connection != null) {
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
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

public static final String USERNAME = ActiveMQConnectionFactory.DEFAULT_USER;

public static final String PASSWORD = ActiveMQConnectionFactory.DEFAULT_PASSWORD;

public static final String URL = "tcp://127.0.0.1:61616";

public static void main(String[] args) throws Exception {

// 第一步:建立ConnectionFactory工厂对象,需要填入用户名,密码,以及连接的地址。默认tcp://127.0.0.1:61616
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);

// 第二部:通过ConnectionFactory工厂对象我们创建一个Connection连接
// 并且调用Connection的start启动连接, Connection默认是关闭的。
Connection connection = connectionFactory.createConnection();
connection.start();

// 第三部:通过Connection对象创建Session会话(上下文环境对象),用于接受消息
// 参数配置1为是否启用事物,参数配置2为签收模式,一般设置为自动签收。
Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

// 第四部: 通过Session创建Destination,指的是一个客户端用来指定生产消息目标和消息来源的对象
// 在ptp模式中,Destination被称做为Queue(队列),在Pub/Sub模式下,Destination被称作Topic(主题)
// 到此处为止,和生产端的代码一样
Destination destination = session.createQueue("helloworld-queue");

// 第五步:创建MessageConsumer对象
MessageConsumer consumer = session.createConsumer(destination);

// 第六步:接受message
TextMessage message = (TextMessage) consumer.receive();
System.out.println(message.getText());

// 最后不要忘了关闭资源。
if (connection != null) {
connection.close();
}
}

}

接受结果

producer hello word!

最后

至此,就是ActiveMQ的基本使用,至于其他特性可以参考官方文档