ActiveMQ笔记(6)：消息延时投递

在开发业务系统时，某些业务场景需要消息定时发送或延时发送（类似：飞信的短信定时发送需求），这时候就需要用到activemq的消息延时投递，详细的文档可参考官网说明，本文只介绍二种常用的用法：

注：本文采用spring的JmsTemplate来发送消息

步骤1、首先要修改activemq.xml配置文件，启用延时投递

 <broker xmlns="http://activemq.apache.org/schema/core" ... schedulerSupport="true" >

     ...

   </broker>

即：在broker节点加上schedulerSupport="true"，然后重启activemq即可

步骤2、定义一个MessagePostProcessor的实现类

import javax.jms.JMSException;

import javax.jms.Message;

import lombok.Data;

import org.apache.activemq.ScheduledMessage;

import org.apache.commons.lang3.StringUtils;

import org.springframework.jms.core.MessagePostProcessor;

/**

 * MQ延时投递处理器（注：ActiveMQ的配置文件中，要配置schedulerSupport="true"，否则不起作用）

 * by: 杨俊明 2016-06-16

 */

@Data

public class ScheduleMessagePostProcessor implements MessagePostProcessor {

    private long delay = 0l;

    private String corn = null;

    public ScheduleMessagePostProcessor(long delay) {

        this.delay = delay;

    }

    public ScheduleMessagePostProcessor(String cron) {

        this.corn = cron;

    }

    public Message postProcessMessage(Message message) throws JMSException {

        if (delay > 0) {

            message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay);

        }

        if (!StringUtils.isEmpty(corn)) {

            message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON, corn);

        }

        return message;

    }

}

步骤3、jmsTemplate发送示例

        Object message1 = "corn消息内容：" + DateUtil.formatDate(new Date());

        //分 时 天 月 星期几

        jmsTemplate.convertAndSend(message1, new ScheduleMessagePostProcessor("40 22 * * *"));

        logger.info("消息1：[" + message1 + "] 延时发送成功！");

        jmsTemplate.convertAndSend(message1, new ScheduleMessagePostProcessor("50 22 * * *"));

        logger.info("消息1：[" + message1 + "] 延时发送成功！");

        Object message2 = "message：" + DateUtil.formatDate(new Date());

        jmsTemplate.convertAndSend(message2, new ScheduleMessagePostProcessor(30 * 1000));//延时30秒

        jmsTemplate.convertAndSend(message2, new ScheduleMessagePostProcessor(3600 * 24 * 1000));//延时24小时

        logger.info("消息2：[" + message2 + "] 延时发送成功！");

上面的代码演示了二种延时的用法：延时N毫秒、按corn表达式延时（注：此corn表达式并非Quartz框架中的corn表达式，而是linux中corntab中的表达式，基本顺序是"分(0-59) 时(0-23) 日(1-31) 月（1-12）星期几(1-7) "）

发送成功后，可以登录activemq的webconsole查看消息的属性：

在scheduled面板中，可以看到延时的消息

注：在开启消息持久化存储的前提下，就算把相应的queue在webconsole面板中删除（即删除队列），只要投递的时间尚未到，该消息也不会删除，仍然能正常延时投递。

此外，在queues面板中，如何查看某条具体的消息，也可以通过属性发现这条消息是延时消息，参考下图：

参考文章：
1、Delay and Schedule Message Delivery

2、喂鸡百科上的Corn表达式解释（中文）

3、喂鸡百科上的Corn表达式解释（英文）

4、kahaDB官方文档

ActiveMQ笔记(6)：消息延时投递的更多相关文章

ActiveMQ笔记(7)：如何清理无效的延时消息？
ActiveMQ的延时消息是一个让人又爱又恨的功能,具体使用可参考上篇ActiveMQ笔记(6):消息延时投递,在很多需要消息延时投递的业务场景十分有用,但是也有一个缺陷,在一些大访问量的场景,如果瞬 ...
ActiveMQ 笔记（八）高级特性和大厂常考重点
个人博客网:https://wushaopei.github.io/ (你想要这里多有) 1.可用性保证引入消息队列之后该如何保证其高可用性? 持久化.事务.签收. 以及带复制的 Leavel ...
php 利用activeMq+stomp实现消息队列
php 利用activeMq+stomp实现消息队列一.activeMq概述 ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线.ActiveMQ 是一个完全支持JMS1.1和J ...
Linux进程间通信IPC学习笔记之消息队列（SVR4)
Linux进程间通信IPC学习笔记之消息队列(SVR4)
【ActiveMQ】持久化消息队列的三种方式
1.ActiveMQ消息持久化方式,分别是:文件.mysql数据库.oracle数据库 2.修改方式: a.文件持久化: ActiveMQ默认的消息保存方式,一般如果没有修改过其他持久化方式的话可以不 ...
ActiveMq笔记1-消息可靠性理论
原博客:http://shift-alt-ctrl.iteye.com/blog/2020182 https://mp.weixin.qq.com/s/h74d6LtGB5M8VF0oLrXdCA 我 ...
php 事务处理，ActiveMQ的发送消息，与处理消息
可以通过链式发送->处理->发送...的方式处理类似事务型业务逻辑比如发送一个注册消息,消息队列处理完注册以后,紧接着发送一个新手优惠券赠送,赠送完再发一个其它后续逻辑处理的消息等待后 ...
ActiveMQ发布-订阅消息模式（同点对点模式的区别）
点对点与发布订阅最初是由JMS定义的.这两种模式主要区别或解决的问题就是发送到队列的消息能否重复消费(多订阅) 点对点: 消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费 ...
【RabbitMQ】如何进行消息可靠投递【上篇】
说明前几天,突然发生线上报警,钉钉连发了好几条消息,一看是RabbitMQ相关的消息,心头一紧,难道翻车了? [橙色报警] 应用[xxx]在[08-15 16:36:04]发生[错误日志异常],al ...

随机推荐

从零开始，DIY一个jQuery（3）
在前两章,为了方便调试,我们写了一个非常简单的 jQuery.fn.init 方法: jQuery.fn.init = function (selector, context, root) { if ...
Install pyodbc in OpenSUSE
Install pyodbc in OpenSUSE: Install unixODBC-2.3.2 ./configure --prefix=/usr/local/unixODBC --enable ...
Leetcode 234 Palindrome Linked List 链表
判断链表是否是回文. 我直接将链表的一半进行倒置,然后将两半的链表进行比较 /** * Definition for singly-linked list. * struct ListNode { * ...
Android代码规范----按钮单击事件的四种写法
[前言] 按钮少的时候用第三种的匿名内部类会比较快,比如写demo测试的时候或者登陆界面之类. 按钮多的时候一般选择第四种写法. 一.第一种写法:在XML文件中声明onClick属性(很少用) 在XM ...
mybatis中的oracle和mysql分页
这段时间一直在用mybatis+spring+springMVC的框架,总结点东西吧. mybatis的oracle分页写法: <?xml version="1.0" enc ...
Java 多线程简单实例（Thread）
package second; public class A extends Thread { public void run(){ for(int i = 1;i <= 10 ; i++){ ...
“_In_opt_z_”: 未声明的标识符
问题使用VS2010 + WDK 环境进行驱动开发时,编译阶段出现如下等错误提示 “_In_opt_z_”: 未声明的标识符解决办法将..\Microsoft Visual Studio 10. ...
[ An Ac a Day ^_^ ] CodeForces 468A 24 Game 构造
题意是让你用1到n的数构造24 看完题解感觉被样例骗了…… 很明显 n<4肯定不行然后构造出来4 5的组成24的式子把大于4(偶数)或者5(奇数)的数构造成i-(i-1)=1 之后就是无尽的 ...
Gatling简单测试SpringBoot工程
前言 Gatling是一款基于Scala 开发的高性能服务器性能测试工具,它主要用于对服务器进行负载等测试,并分析和测量服务器的各种性能指标.目前仅支持http协议,可以用来测试web应用程序和RES ...
Web前端之iframe详解
iframe基本内涵通常我们使用iframe直接直接在页面嵌套iframe标签指定src就可以了. <iframe src="demo_iframe_sandbox.htm" ...

ActiveMQ笔记(6)：消息延时投递

ActiveMQ笔记(6)：消息延时投递的更多相关文章

随机推荐

热门专题