一、SpringBoot整合abbitmq

1.1、消息发送者

工程配置

 
        org.springframework.boot
        spring-boot-starter-parent
        3.2.0
    
    
        
            org.springframework.boot
            spring-boot-starter-amqp
        
        
            org.springframework.boot
            spring-boot-starter-test
        
    

spring:
  rabbitmq:
    host: 192.168.200.110
    port: 5672
    username: guest
    password: 123456
    virtual-host: /

@SpringBootApplication
public class PMQMain {
    public static void main(String[] args) {
        SpringApplication.run(PMQMain.class,args);
    }
}

测试代码：

@SpringBootTest
public class MQTest {
    public static final String EXCHANGE_DIRECT = "exchange.direct.order";
    public static final String ROUTING_KEY = "order";
    @Resource
    private RabbitTemplate rabbitTemplate;
    @Test
    public void test1(){
        rabbitTemplate.convertAndSend(EXCHANGE_DIRECT,ROUTING_KEY,"你好，沸羊羊");
    }
}

1.2、消息的接收者 

工程配置

 
        org.springframework.boot
        spring-boot-starter-parent
        3.2.0
    
    
        
            org.springframework.boot
            spring-boot-starter-amqp
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
            org.projectlombok
            lombok
        
    

spring:
  rabbitmq:
    host: 192.168.200.110
    port: 5672
    username: guest
    password: 123456
    virtual-host: /
logging:
  level:
    com.cjc.mq.listener.MyMessageListener: info

@SpringBootApplication
public class MQMain {
    public static void main(String[] args) {
        SpringApplication.run(MQMain.class,args);
    }
}

测试代码：

@Component
@Slf4j
public class MyMessageListener {
    public static final String EXCHANGE_DIRECT = "exchange.direct.order";
    public static final String ROUTING_KEY = "order";
    public static final String QUEUE_NAME = "queue.order";
    //监听+创建交换机与队列关系
//    @RabbitListener(bindings = @QueueBinding(
//            value = @Queue(value = QUEUE_NAME,durable = "true"),
//            exchange = @Exchange(value = EXCHANGE_DIRECT),
//            key = {ROUTING_KEY}))
    //监听
    @RabbitListener(queues = {QUEUE_NAME})
    public void getMessage(String date, Message message, Channel channel){
        log.info("接收消息为：" + date);
    }
}