RabbitAdmin 和 RabbitTemplate

RabbitAdmin 该类封装了对 RabbitMQ 的管理操作

@Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory createConnectionFactory) {
        return new RabbitAdmin(createConnectionFactory);
    }

DirectProducer

@Component
@Slf4j
public class DirectProducer{

@Autowired
    private RabbitAdmin rabbitAdmin;

    public void message() {
        Queue adminQueue = new Queue("adminQueue", true);
        FanoutExchange fanoutExchange = new FanoutExchange("adminExchange", true, false);
        rabbitAdmin.declareExchange(fanoutExchange);
        rabbitAdmin.declareQueue(adminQueue);
        rabbitAdmin.declareBinding(BindingBuilder.bind(adminQueue).to(fanoutExchange));
        String message = "rabbitmqAdmin";
        RabbitTemplate rabbitTemplate = rabbitAdmin.getRabbitTemplate();
        rabbitTemplate.convertAndSend("adminExchange", "", message, cur -> {
            //设置消息持久化
            cur.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
            return cur;
        });
        Message receive = rabbitTemplate.receive("adminQueue");
        log.info(">>>>>>>>接收到消息为：{}", receive.getBody());
    }
}

RabbitTemplate

最后

以上就是时尚灰狼为你收集整理的RabbitAdmin 和 RabbitTemplate的全部内容，希望文章能够帮你解决RabbitAdmin 和 RabbitTemplate所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。