Rabbitmq 入门

version: "3.2"

services:
  some-rabbit:
    image: rabbitmq:3-management
    hostname: "my-host"
    environment:
      RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
      RABBITMQ_DEFAULT_USER: "rabbitmq"
      RABBITMQ_DEFAULT_PASS: "rabbitmq"
      RABBITMQ_DEFAULT_VHOST: "/"
    ports:
      - "15672:15672"
      - "5672:5672"

spring:
  rabbitmq:
    username: rabbitmq
    password: rabbitmq

@Bean
public Queue myQueue() {
    return new Queue("myQueue", false);
}

@Test
void producer1() {
    rabbitTemplate.convertAndSend("myQueue", "Hello, world!");
}

@RabbitListener(queues = "myQueue")
public void listen(String in) {
    System.out.println("Message read from myQueue : " + in);
}

@Bean
public Declarables fanoutBindings() {
    Queue fanoutQueue1 = new Queue("fanout.queue1", false);
    Queue fanoutQueue2 = new Queue("fanout.queue2", false);
    FanoutExchange fanoutExchange = new FanoutExchange("fanout.exchange");

    return new Declarables(
            fanoutQueue1,
            fanoutQueue2,
            fanoutExchange,
            BindingBuilder.bind(fanoutQueue1).to(fanoutExchange),
            BindingBuilder.bind(fanoutQueue2).to(fanoutExchange));
}

@Test
void producer2() {
    String message = " payload is broadcast";
    rabbitTemplate.convertAndSend("fanout.exchange", "", "fanout" + message);
}

@RabbitListener(queues = {"fanout.queue1"})
public void receiveMessageFromFanout1(String message) {
    System.out.println("Received fanout 1 message: " + message);
}

@RabbitListener(queues = {"fanout.queue2"})
public void receiveMessageFromFanout2(String message) {
    System.out.println("Received fanout 2 message: " + message);
}

@Bean
public Declarables topicBindings() {
    Queue topicQueue1 = new Queue("topicQueue1Name", false);
    Queue topicQueue2 = new Queue("topicQueue2Name", false);

    TopicExchange topicExchange = new TopicExchange("topicExchangeName");

    return new Declarables(
            topicQueue1,
            topicQueue2,
            topicExchange,
            BindingBuilder
                    .bind(topicQueue1)
                    .to(topicExchange).with("*.important.*"),
            BindingBuilder
                    .bind(topicQueue2)
                    .to(topicExchange).with("#.error"));
}

@Test
void producer2() {
    String message = " payload is broadcast";
    rabbitTemplate.convertAndSend("topicExchangeName", "hello.important.warn",
            "topic important warn" + message);
    rabbitTemplate.convertAndSend("topicExchangeName", "my.important.error",
            "topic important error" + message);
}

@RabbitListener(queues = {"topicQueue1Name"})
public void receiveMessageFromTopic1(String message) {
    System.out.println("Received topic 1 (" + "BINDING_PATTERN_IMPORTANT" + ") message: " + message);
}

@RabbitListener(queues = {"topicQueue2Name"})
public void receiveMessageFromTopic2(String message) {
    System.out.println("Received topic 2 (" + "BINDING_PATTERN_ERROR" + ") message: " + message);
}