RabbitMQ-SpringBoot2

1.依赖引用

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

2.配置文件

spring:
  rabbitmq:
    host: 192.168.2.17
    port: 5672
    username: admin
    password: admin

3.配置类

这个类可以没有，但总提示，看着闹心

package com.example.rabbitmq.cluster;import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class ClusterConfig {public static final String queueName = "cluster.queue";public static final String exchangeName = "cluster.exchange";public static final String keyName = "cluster.key";@Bean("clusterQueue")public Queue queue() {Queue queue = QueueBuilder.durable(queueName).build();return queue;}@Bean("clusterDirectExchange")public DirectExchange directExchange() {DirectExchange exchange = ExchangeBuilder.directExchange(exchangeName).build();return exchange;}@Beanpublic Binding binding(@Qualifier("clusterQueue") Queue queue,@Qualifier("clusterDirectExchange") DirectExchange directExchange) {return BindingBuilder.bind(queue).to(directExchange).with(keyName);}}

4.消费者

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Slf4j
@Component
public class ClusterConsumer {@RabbitListener(queues = ClusterConfig.queueName)public void receiveMsg(Message message){String msg = new String(message.getBody());log.info("[ClusterConsumer] 收到消息:{}", msg);}}

5.生产者

package com.example.rabbitmq.cluster;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;@Slf4j
@RequestMapping("clu")
@RestController
public class ClusterController {private RabbitTemplate rabbitTemplate;public ClusterController(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}@GetMapping("v1")public String v1() {rabbitTemplate.convertAndSend(ClusterConfig.exchangeName, ClusterConfig.keyName, "Cluster111");log.info("已经发送 Cluster111");return "已经发送 Cluster111";}}

6.测试