Springboot + ActiveMq 简单实现
1 引入依赖包
pom.xml 添加以下内容
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
1
2
3
4
2 增加配置
在application.properties文件中添加以下内容
spring.activemq.broker-url=tcp://10.8.206.178:61616
spring.activemq.user=admin
spring.activemq.password=admin
#无超时时间
spring.activemq.pool.enabled=false
#(为true时是topic模式，为false是queue模式)
jms.pub-sub-domain=false
1
2
3
4
5
6
7
当然还有许多参数可以添加 ，本人并没有全部测试
# 在考虑结束之前等待的时间
#spring.activemq.close-timeout=15s
# 默认代理URL是否应该在内存中。如果指定了显式代理，则忽略此值。
spring.activemq.in-memory=true
# 是否在回滚回滚消息之前停止消息传递。这意味着当启用此命令时，消息顺序不会被保留。
spring.activemq.non-blocking-redelivery=false
# 密码
spring.activemq.password=123456
# 等待消息发送响应的时间。设置为0等待永远。
spring.activemq.send-timeout=0
spring.activemq.user=haha
# 是否信任所有包
#spring.activemq.packages.trust-all=
# 要信任的特定包的逗号分隔列表（当不信任所有包时）
#spring.activemq.packages.trusted=
# 当连接请求和池满时是否阻塞。设置false会抛“JMSException异常”。
#spring.activemq.pool.block-if-full=true
# 如果池仍然满，则在抛出异常前阻塞时间。
#spring.activemq.pool.block-if-full-timeout=-1ms
# 是否在启动时创建连接。可以在启动时用于加热池。
#spring.activemq.pool.create-connection-on-startup=true
# 是否用Pooledconnectionfactory代替普通的ConnectionFactory。
#spring.activemq.pool.enabled=false
# 连接过期超时。
#spring.activemq.pool.expiry-timeout=0ms
# 连接空闲超时
#spring.activemq.pool.idle-timeout=30s
# 连接池最大连接数
#spring.activemq.pool.max-connections=1
# 每个连接的有效会话的最大数目。
#spring.activemq.pool.maximum-active-session-per-connection=500
# 当有"JMSException"时尝试重新连接
#spring.activemq.pool.reconnect-on-exception=true
# 在空闲连接清除线程之间运行的时间。当为负数时，没有空闲连接驱逐线程运行。
#spring.activemq.pool.time-between-expiration-check=-1ms
# 是否只使用一个MessageProducer
#spring.activemq.pool.use-anonymous-producers=true
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
3 搭建生产者
controller类
import javax.jms.Destination;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class controller {
@Autowired
MqService mqservice;
@RequestMapping(value = "/sendMsg",method = RequestMethod.GET)
@ResponseBody
public String sendMsg(){
Destination destination =new ActiveMQQueue("test.queue");;
mqservice.sendMessage("Mq你好", destination);
return "Mq消息发送成功";
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
Service类
import javax.jms.Destination;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;
@Service
public class MqService {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
void sendMessage(String msg,Destination destination){
this.jmsMessagingTemplate.convertAndSend(destination, msg);
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
测试：已经生产了一个消息在队列中
搭建消费者
建立监听消费，即有消息在队列中会自动消费
service类
import javax.jms.Destination;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;
@Service
public class MqServer {
private JmsMessagingTemplate jms;
@JmsListener(destination = "test.queue")
public void receiveQueue(String text) {
System.err.println("收到消息"+text);
// return text;
}
}
测试
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
登陆控制台查看
使用主动消费策略，即客户自己主动消费队列中的消息
我们把代码写在contrller类中
import javax.jms.Destination;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
public class controller {
@Autowired
MqServer mqserver;
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@RequestMapping(value = "/getMsg",method = RequestMethod.GET)
@ResponseBody
public String getMsg(){
Message string=this.jmsMessagingTemplate.receive("test.queue1");
return "Mq消息接受成功 "+string.getPayload() ;
}
}
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
测试
发送http://localhost:8989/getMsg
登陆控制台
注意事项：
注意我们在消费队列和生产队列中选择的策略（点对点/订阅）
思考的问题：
1 队列的长度是怎么设置的，超出队列长度后消息会丢失吗？
2 采用订阅者模式消息是如何消费的？
3 跟rabbitMq的区别和优势？