RabbitMQ使用——基于SpringBoot

spring:
  application:
    name: spring-boot-amqp
  rabbitmq:
    host: 192.168.80.140
    port: 5672
    username: rabbit
    password: 123456

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfiguration {
    @Bean
    public Queue queue() {
        return new Queue("helloRabbit");
    }
}

@Component
public class HelloRabbitConsumer {
    @RabbitListener(queues = "helloRabbit")
    public void process(String message) {
        System.out.println("Consumer: " + message);
    }
}

@Component
public class HelloRabbitProvider {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) {
        rabbitTemplate.convertAndSend("helloRabbit", message);
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class RabbitmqSpringbootApplicationTests {
    @Autowired
    private HelloRabbitProvider helloRabbitProvider;

    @Test
    public void testSender() {
        for (int i = 0; i < 10; i++) {
            helloRabbitProvider.send("hello motor");
        }
    }
}

@Configuration
public class RabbitMQConfiguration {
    @Bean
    public Queue getQueue() {
        return new Queue("simple_queue");
    }

    @Bean
    public FanoutExchange getFanoutExchange(){
        return  new FanoutExchange("fanout_exchange_new");
    }

    @Bean
    public Binding getBinding(Queue getQueue, FanoutExchange getFanoutExchange){
        return BindingBuilder.bind(getQueue).to(getFanoutExchange);
    }

    @Bean
    public TopicExchange getTopicExchange(){
        return new TopicExchange("topic_exchange_new");
    }

    @Bean
    public Binding getBinding2(Queue getQueue,TopicExchange getTopicExchange){
        return BindingBuilder.bind(getQueue).to(getTopicExchange).with("product.*");
    }
}

@Component
public class RabbitProvider {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send(String message) {
        //rabbitTemplate.convertAndSend("helloRabbit", message);
        //rabbitTemplate.convertAndSend("fanout_exchange_new","", message);
        rabbitTemplate.convertAndSend("topic_exchange_new","product.add","topic模式消息");
    }
}