首页 > 编程笔记 > java/安卓 > springboot 整合RabbitMQ

springboot 整合RabbitMQ

时间:2019-09-18

本文章向大家介绍springboot 整合RabbitMQ，主要包括springboot 整合RabbitMQ使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。

pom.xml

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

application.yml

spring:
 rabbitmq:
  host: localhost
  port: 5672
  username: admin
  password: 123456

RabbitConfig

@Configuration
public class RabbitConfig {

    @Bean
    public Queue helloQueue() {
        return new Queue("hello");
    }

    @Bean
    public Queue neoQueue() {
        return new Queue("neo");
    }

    @Bean
    public Queue objectQueue() {
        return new Queue("object");
    }
    
}

Sender

@Component
public class HelloSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String context = "hello " + new Date();
        System.out.println("Sender : " + context);
        this.rabbitTemplate.convertAndSend("hello", context);
    }

}

Receiver

@Component
@RabbitListener(queues = "hello")
public class HelloReceiver {

    @RabbitHandler
    public void process(String hello) {
        System.out.println("Receiver  : " + hello);
    }

}

原文地址：https://www.cnblogs.com/yhood/p/11541064.html

随机文章