AMQP操作文档

一、发送消息：（示例：TestReceiver.java）

1. 声明注入

    @Autowired 
     private AmqpTemplate amqpTemplate;

2. 发送消息

   this.amqpTemplate.convertAndSend(AmqpExchange.TEST_EXCHANGE,
                   AmqpExchange.TEST_EXCHANGE + "_ROUTING",
                   putMessage);

   发送消息，第一个参数为枚举，String类型，代表接收的交换器名字。（为静态常量，位于AmqpExchange）
   第二个参数为字符串，指定接收路由，String类型，自行指定一个有意义的字串，全剧唯一 （命名规范：交换机名称后缀_QUEUE，例如：MEMBER_LOGIN_QUEUE） 第三个参数为发送的对象，object类型，接收器处理所需要的参数。无参需要写空字符串

二、处理消息（事例：TestReceiver.java）

@RabbitListener(bindings = @QueueBinding(
            value = @Queue(value = AmqpExchange.TEST_EXCHANGE + "_QUEUE"),
            exchange = @Exchange(value = AmqpExchange.TEST_EXCHANGE, type = ExchangeTypes.FANOUT)
    ))
    public void receiver(String message) {
        cache.put(cacheKey, message);
    }

Queue.value 命名规范：业务

RabbitListener(bindings = @QueueBinding( value = @Queue(value = "queue自定义名称，消费者定义，注意唯一"), exchange = @Exchange(value = "交换机名称，静态常量")))

三、消息路由名称的定义

路由的名字需要定义在以下常量中

• 路径 cn.shoptnt.model.base.AmqpExchange
• 内容

    /**
     * PC首页变化消息
     */
    public static final String PC_INDEX_CHANGE = "PC_INDEX_CHANGE";

    /**
     * 移动端首页变化消息
     */
    public static final String MOBILE_INDEX_CHANGE = "MOBILE_INDEX_CHANGE";

    /**
     * 商品变化消息
     */
    public static final String GOODS_CHANGE = "GOODS_CHANGE";

    /**
     * 商品变化消息附带原因
     */
    public static final String GOODS_CHANGE_REASON = "GOODS_CHANGE_REASON";

    /**
     * 帮助变化消息
     */
    public static final String HELP_CHANGE = "HELP_CHANGE";


    /**
     * 页面生成消息
     */
    public static final String PAGE_CREATE = "PAGE_CREATE";

    /**
     * 索引生成消息
     */
    public static final String INDEX_CREATE = "INDEX_CREATE";

    /**
     * 订单创建消息
     * 没有入库
     */
    public static final String ORDER_CREATE = "ORDER_CREATE";

    /**
     * 入库失败消息
     * 入库失败
     */
    public static final String ORDER_INTODB_ERROR = "ORDER_INTODB_ERROR";

    /**
     * 订单状态变化消息
     * 带入库的
     */
    public static final String ORDER_STATUS_CHANGE = "ORDER_STATUS_CHANGE";

    /**
     * 会员登录消息
     */
    public static final String MEMEBER_LOGIN = "MEMEBER_LOGIN";

    /**
     * 会员注册消息
     */
    public static final String MEMEBER_REGISTER = "MEMEBER_REGISTER";

    /**
     * 店铺变更消息
     */
    public static final String SHOP_CHANGE_REGISTER = "SHOP_CHANGE_REGISTER";

    /**
     * 分类变更消息
     */
    public static final String GOODS_CATEGORY_CHANGE = "GOODS_CATEGORY_CHANGE";

    /**
     * 售后状态改变消息
     */
    public static final String REFUND_STATUS_CHANGE = "REFUND_STATUS_CHANGE";

    /**
     * 发送站内信息
     */
    public static final String MEMBER_MESSAGE = "MEMBER_MESSAGE";

    /**
     * 发送手机短信消息
     */
    public static final String _SEND_MESSAGE = "_SEND_MESSAGE";

    /**
     * 邮件发送消息
     */
    public static final String EMAIL_SEND_MESSAGE = "EMAIL_SEND_MESSAGE";

    /**
     * 商品评论消息
     */
    public static final String GOODS_COMMENT_COMPLETE = "GOODS_COMMENT_COMPLETE";

    /**
     * 网上支付
     */
    public static final String ONLINE_PAY = "ONLINE_PAY";

    /**
     * 完善个人资料
     */
    public static final String MEMBER_INFO_COMPLETE = "MEMBER_INFO_COMPLETE";

四、延时任务

延时任务的作用是可以指定一个任务在具体时间被触发。

比如促销活动开始时主动触发一些动作，如写入缓存等。

定义延时任务需要用到TimeTrigger接口，用法如下：

@Autowired
private TimeTrigger timeTrigger;

public void main(){
       //创建活动即通知mq
        PintuanChangeMsg pintuanChangeMsg = new PintuanChangeMsg();
        pintuanChangeMsg.setPintuanId(id);
        pintuanChangeMsg.setOptionType(1);
    //第一个参数，执行器
    //第二个参数，执行器执行调用的参数
    //第三个参数，执行日期
    //第四个参数，唯一key，可以为空，如果不需要操作更新或者删除延时任务的话

        //新增定时任务
        timeTrigger.add("pintuanTimeTriggerExecute", pintuanChangeMsg,              activeDO.getStartTime(),"TIME_TRIGGER_PINTUAN_"+id);
        //修改定时任务   
        timeTrigger.edit("pintuanTimeTriggerExecute", pintuanChangeMsg, activeDO.getStartTime(),"TIME_TRIGGER_PINTUAN_"+id);
        //删除
        timeTrigger.del("TIME_TRIGGER_PINTUAN_"+id);

}

在上述接口的第一个参数是一个执行器的beanName ,当延迟任务被触发时，这个具体的执行器会被调用，执行器的实现举例如下：

/**
 * 执行器
 *
 * @author Chopper
 * @version v1.0
 * @since v7.0
 * 2019-02-13 下午5:34
 */
@Component
public class PintuanTimeTriggerExecuter implements TimeTriggerExecuter {

    /**
     * 执行任务
     *
     * @param object 任务参数
     */
    @Override
    public void execute(Object object) {
        //这里的object就是在定义延迟任务时传递过来的msg
    }
}