1.RabbitMQ
1.1添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
1.2配置文件
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.password=
spring.rabbitmq.username=
1.3代码实现
1.3.1启用注解@EnableRabbit
1.3.2配置
@Configuration
public class AmqpConfiguration {
@Bean
public Queue queue() {
return new Queue("luoping.queue");
}
}
@Component
public class LuopingAmqpComponent {
@Autowired
private AmqpTemplate amqpTemplate;
public void send(String msg) {
this.amqpTemplate.convertAndSend("luoping.queue", msg);
}
@RabbitListener(queues = "luoping.queue")
public void receiveQueue(String text) {
System.out.println("接受到：" + text);
}
}
2.ActiveMQ
2.1添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
2.2配置文件
spring.activemq.in-memory=true
#spring.activemq.broker-url=
#spring.activemq.password=
#spring.activemq.user=
#spring.activemq.packages.trust-all=false
#spring.activemq.packages.trusted=
#spring.activemq.pool.configuration.*=
#spring.activemq.pool.enabled=false
#spring.activemq.pool.expiry-timeout=0
#spring.activemq.pool.idle-timeout=30000
#spring.activemq.pool.max-connections=1
2.3代码实现
启动注解 ： @EnableJms 添加在main方法里面
配置队列
@Configuration
public class JmsConfiguration {
@Bean
publicQueuequeue() {
return new ActiveMQQueue("luoping.queue");
}
}
--------------------
@Component
public class LuopingJmsComponent {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired
private Queue queue;
public void send(String msg) {
this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
}
@JmsListener(destination = "luoping.queue")
public void receiveQueue(String text) {
System.out.println("接受到：" + text);
}
}
