[大数据]springcloud超简单绑定RabbitMq

本文章默认读者已经接触过RabbitMq，关于RabbitMq的相关概念和安装的问题不再赘述。

服务端：一共需要准备三个类，服务类、配置类、常量类
配置类：

@Configuration
public class MQConfig {
    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }
}

服务类：

@Service
public class RabbitService {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    /**
     * 发送消息
     *
     * @param exchange   交换机
     * @param routingKey 路由键
     * @param message    消息
     */
    public boolean sedMessage(String exchange, String routingKey, Object message) {
        rabbitTemplate.convertAndSend(exchange, routingKey, message);
        return true;
    }
}

常量类：

public class MqConst {
    public static final String EXCHANGE_DIRECT_ORDER = "exchange.direct.order";//交换机
    public static final String ROUTING_ORDER = "order";//路由名
    public static final String QUEUE_ORDER  = "queue.order";//队列名
}

发送端： 就直接引入RabbitTemplate然后调用服务端中服务类的方法即可

OrderMqVo orderMqVo = new OrderMqVo();
            orderMqVo.setScheduleId(orderInfo.getScheduleId());
            //短信提示
            MsmVo msmVo = new MsmVo();
            msmVo.setPhone(orderInfo.getPatientPhone());
            orderMqVo.setMsmVo(msmVo);
//上面这几行是要发送的数据            
           rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_ORDER, MqConst.ROUTING_ORDER, orderMqVo);//里面的参数是常量类里写的

消费端： 注册一个监听器

@Component
public class SmsReceiver {
    @Autowired
    private MsmService msmService;

    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = MqConst.QUEUE_MSM_ITEM, durable = "true"),
            exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_MSM),
            key = {MqConst.ROUTING_MSM_ITEM}
    ))
    public void send(MsmVo msmVo, Message message, Channel channel) {
        msmService.send(msmVo);
    }
}