SpringBoot整合RabbitMQ开发实战详解

 org.springframework.boot
 spring-boot-starter-amqp

 cn.hutool
 hutool-all
 4.0.2

@Configuration
public class RabbitMQConfig {

 public final static String QUEUE_NAME = "spring-boot-queue";
 public final static String EXCHANGE_NAME = "spring-boot-exchange";
 public final static String ROUTING_KEY = "spring-boot-key";

 // 创建队列
 @Bean
 public Queue queue() {
 return new Queue(QUEUE_NAME);
 }

 // 创建一个 topic 类型的交换器
 @Bean
 public TopicExchange exchange() {
 return new TopicExchange(EXCHANGE_NAME);
 }

 // 使用路由键（routingKey）把队列（Queue）绑定到交换器（Exchange）
 @Bean
 public Binding binding(Queue queue, TopicExchange exchange) {
 return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY);
 }

 @Bean
 public ConnectionFactory connectionFactory() {
 CachingConnectionFactory cOnnectionFactory= new CachingConnectionFactory("127.0.0.1", 5672);
 connectionFactory.setUsername("guest");
 connectionFactory.setPassword("guest");
 return connectionFactory;
 }

 @Bean
 public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
 return new RabbitTemplate(connectionFactory);
 }

}

@RestController
public class ProducerController {

 @Autowired
 private RabbitTemplate rabbitTemplate;

 @GetMapping("/sendMessage")
 public Object sendMessage() {
 new Thread(() -> {
  for (int i = 0; i <100; i++) {
  String value = new DateTime().toString("yyyy-MM-dd HH:mm:ss");
  Console.log("send message {}", value);
  rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, value);
  }
 }).start();
 return "ok";
 }

}

@Component
public class Consumer {

 @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
 public void consumeMessage(String message) {
 Console.log("consume message {}", message);
 }
}