MQ发送消息和监听消息

private static List routingKey=“********”;//routingKey的名字，与业务关联

1.发送

rabbitTemplate.convertAndSend(routingKey,“发送的内容，可以是业务代码定义好的实体类”);

2.监听和消费

@RabbitListener(queues = "#{T(com.*****本类的地址).getQueues()}")
    public void processLimitCredit(CreditSendMessage message) {
        try {
                  System.out.println("消费："+gson.toJson(message));
        }catch (Exception e){
            log.error("积分消费异常",e);
        }
    }

    public static String[] getQueues() {
    //返回要监听的队列的RoutingKey的名字，对应发送时定义的routingKey的名字， 可以是筛选后的集合，可以读取配置文件
        return  routingKey ;
    }