RabbitMq 五种工作模式 springboot 整合

整合：

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

@RestController
@RequestMapping("rabbit")
public class RabbitMqController {



    @Resource
    private RabbitTemplate rabbitTemplate;


    
    @GetMapping("common")
    public void sendMessage(){
        rabbitTemplate.convertAndSend("station_test","{name:123}");
    }

    
    @GetMapping("pub")
    public void pubsendMessage(){
        rabbitTemplate.convertAndSend("amq.fanout","station_test","{name:123}");
    }



    
    @GetMapping("direct")
    public void directsendMessage(){
        rabbitTemplate.convertAndSend("amq.direct","direct_route","{name:123}");
    }


    
    @GetMapping("topic")
    public void topicsendMessage(){
        rabbitTemplate.convertAndSend("amq_topic","error.log","{name:123}");
    }
}

@Component
public class RabbtMqMessageReceiver {


    @RabbitListener(queues = "station_test")
    public void listenSimpleQueueMessage(String msg) throws InterruptedException {
        System.out.println("spring 消费者1接收到消息：【" + msg + "】");
    }


    @RabbitListener(queues = "station_test")
    public void listenSimpleQueueMessage2(String msg) throws InterruptedException {
        System.out.println("spring 消费者2接收到消息：【" + msg + "】");
    }
}

yml

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
#静态资源加载配置