阿里的mq的demo中怎么发送不了定时消息,配置了还是当时就发送

public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("producer/producer.xml");
HttpMQProducerServiceImpl producer = context.getBean(HttpMQProducerServiceImpl.class);

    // 发送定时消息: producer.send("msg", "tag", "key", startDeliverTime);
    Long timeStamp=null;
    try {
        timeStamp =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse("2017-02-16 10:26:00").getTime();
    } catch (ParseException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
        if (producer.sendMessage("nihao","meinu","什么",timeStamp)) {
            System.out.println("send message success");
        } else {
            System.out.println("send message failed");
        }

    //context.close();
}
0

1个回答

https://help.aliyun.com/document_detail/29550.html
检查你的时间戳,要考虑时区。

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
阿里MQ普通+顺序+延时消息 整合Spring
前言由于公司项目需要,研究了下AliWareMQ。阿里mq的普通消息和延时消息还是挺简单的。不过在顺序消息的时候出现了一些瓶颈。后来查阅源码和依据demo整理了一版融合Spring的版本。实例mq配置文件(Spring)主要是顺序消息的配置,以及多实例的配置(需要在控制台配置p/c)<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http:/
activeMQ延时发送
activeMQ启用延时投递 延时投递属性: Property name type description AMQ_SCHEDULED_DELAY long 延迟投递的时间 AMQ_SCHEDULED_PERIOD long 重复投递时间间隔 AMQ_SCHEDULED_REPEAT
RocketMQ——Producer篇:发送定时消息
目前只支持固定精度级别的定时消息,服务器按照1-N定义了如下级别: “1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h”;若要发送定时消息,在应用层初始化Message消息对象之后,调用Message.setDelayTimeLevel(int level)方法来设置延迟级别,按照序列取相应的延迟级别,例如level=2,则延迟为5
ActiveMQ 延迟和定时消息投递
延迟和定时消息投递(Delay and Schedule Message Delivery)有时候我们不希望消息马上被broker投递出去,而是想要消息60秒以后发给消费者,或者我们想让消息没隔一定时间投递一次,一共投递指定的次数。。。类似这种需求,ActiveMQ提供了一种broker端消息定时调度机制。我们只需要把几个描述消息定时调度方式的参数作为属性添加到消息,broker端的调度器就会按照...
MQ发送事务消息
MQ事务消息交互流程如下: 发送事务消息包含以下两个步骤: 发送半消息及执行本地事务 package com.alibaba.webx.TryHsf.app1;import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.PropertyKeyConst;im
ActiveMQ 延迟消息与定时消息传递
使用场景:     订单超时未处理     消息定时发送业务     延迟消息业务场景 ActiveMQ 延迟 &amp;amp; 定时消息发送(Delay and Schedule Message Delivery)使用: 客户端使用延迟消息必须遵守如下配置属性: 属性名称 类型 描述 AMQ_SCHEDULED_DELAY long 消息延迟时间单位:毫秒 ...
MQ收发顺序消息
发送和订阅顺序消息,请使用 Java SDK 1.2.7 及以上版本。 顺序消息是 MQ 提供的一种按照顺序进行发布消费的消息类型,适用由于需要严格按照先进先出的原则进行消息发布和消费的场景。详情请参考顺序消息文档。 全局顺序消息和分区顺序消息的收发方式基本一样,具体请参考以下示例代码。 发送消息示例代码: package com.aliyun.openservices.ons
RocketMq(3)-发送带有事务的消息
RocketMq支持事务性的消息 RocketMq支持传输带有事务的消息,可以用来保持数据的最终一致性。下面我来简单的实现一个带有事务的消息 生产者端的代码 需要写事务检查的Listener,自定义一个类,实现TransactionCheckListener(rocketMq3.0.8版本以前) public LocalTransactionState checkLocalTransac...
RocketMQ-定时发送
定时消息这个特性在很多业务中都会用到,比如在电商交易中用户下单之后超过半个小时还没有支付,这时就需要把该订单关闭。在这种场景下,我们可以在创建订单的时候就发送一条延迟消息,该消息在30分钟以后投递给消费者,消费者在收到消息后判断对应订单是否已完成支付,如果没有支付就关闭订单。 目前RocketMQ只支持固定精度级别的定时消息,服务器按照1-N定义了如下级别: “1...
RabbitMQ+Spring Quartz 实现消息的定时发送和接收
因公司需要使用RabbitMQ作为中间件实现消息的发送和接收。同时加入Spring Quartz 实现消息的定时发送。所以做了个Dome.只是做个演示。 主要有4个项目。 两个消费者一个生产者,一个调度者。生产者生产者比较简单,只是把要发送的消息保存到数据库。在界面上显示所有的消息。点击全部发送并没有发送消息只是修改消息的状态为NOT_SEND. 界面截图 调度者调度者定时重数据库查询
WebSphereMQ发送消息和读取消息
1.webspheremq发送消息 package com.wsmq; import com.ibm.mq.MQC; import com.ibm.mq.MQEnvironment; import com.ibm.mq.MQException; import com.ibm.mq.MQMessage; import com.ibm.mq.MQPutMessageOptions; import
RocketMq-延迟消息及 代码实现
支持延迟消息 RocketMQ 支持定时消息,但是不支持任意时间精度,仅支持特定的 level,例如定时 5s, 10s, 1m 等。其中,level=0 级表示不延时,level=1 表示 1 级延时,level=2 表示 2 级延时,以此类推。 配置 打开安装目录的./conf/broker.conf  文件,并添加如下延迟级别的时长设置: messageDelayLevel = 1...
Java——定时请求后端接口数据发送RabbitMQ消息队列到指定MQ服务器
RabbitMQ入门参考博客:http://m.blog.csdn.net/article/details?id=50487028(内含介绍、环境配置及基本实现说明) RabbitMQ官方文档参考,发送Topic exchange队列:http://www.rabbitmq.com/tutorials/tutorial-five-java.html(内含各种语言的各种实现方法) 项目部
[ActiveMQ]发送消息与接收消息测试Demo
ubuntu下: 安装并启动ActiveMQ 1.官网http://activemq.apache.org/下载最新版本的ActiveMQ,并解压;2.进入对应目录,sudo ./activemq start3,启动成功后,登录http://localhose:8161/admin/,登陆账号和密码都为admin,创建一个queue名为jyQueue; 启动成功;发送端:package MQj
消息中间件 RocketMQ源码解析:定时消息与消息重试
2019独角兽企业重金招聘Python工程师标准&gt;&gt;&gt; ...
RocketMQ 多个实例消息聚集在一个实例的坑
RT。上周有个问题一直未解决,先说需求: 有A和B两个实例的RocketMQ,并不是集群关系。A的实例是服务器本地的RocketMQ,B的实例是阿里云上所购买的实例。在JAVA代码中,要做到往A发消息的时候也要往B推送消息。 光看需求,其实so easy。因为自己对RocketMQ不是很了解,就“天真”的认为只是调用两个实例化对象的send方法而已。实际上这里蕴藏着一个深坑。 用过Ro...
RocketMQ源码 — 九、 RocketMQ延时消息
RocketMQ源码 — 九、 RocketMQ延时消息 上一节消息重试里面提到了重试的消息可以被延时消费,其实除此之外,用户发送的消息也可以指定延时时间(更准确的说是延时等级),然后在指定延时时间之后投递消息,然后被consumer消费。阿里云的ons还支持定时消息,而且延时消息是直接指定延时时间,其实阿里云的延时消息也是定时消息的另一种表述方式,都是通过设置消息被投递的时间来实现的,但是Ap...
ActiveMQ 三种发送消息方式(同步,异步,单向)
MQ 发送普通消息有三种实现方式:[color=red][b]可靠同步发送、可靠异步发送、单向(Oneway)发送。[/b][/color]本文介绍了每种实现的原理、使用场景以及三种实现的异同,同时提供了代码示例以供参考。 [size=medium][b]可靠同步发送[/b][/size] 原理:同步发送是指消息发送方发出数据后,会在收到接收方发回响应之后才发下一个数据包的通讯方式。 ...
springboot与activemq结合以及mq延迟demo
springboot与activemq结合以及mq延迟demospringboot与activemq结合以及mq延迟demo
ActiveMQ 定时调度的使用查看任务消息
   当我们发送消息之后,如果想查看当前有多少消息尚未发送可以自己写一些代码实现,可以写一些定时获取任务或者发送消息的实现,必须使用SchedulerBroker,JobScheduler,测试实现如下: package easyway.app.activemq.demo.schedules; import java.io.File; import java.util.List; im...
消息队列普通消息的发送
本 Demo 主要目的在于帮助初次接触 Aliware MQ 的工程师,一步一步搭建 MQ 测试工程。Demo 程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例。 安装 IDE 您可以使用 IDEA 或者 Eclipse。本文以 IDEA 为例。 请在 https://www.jetbrains.com/idea/ 下
spring配置RabbitMQ的发送和接收demo
springMVC配置RabbitMQ的发送和接收demo首先,整个demo包含6个文件: spring-rabbitmq.xml:配置rabbitmq的queue,exchange,已经发送和接受的bean; MQProducer.java:发送消息到指定队列的接口; MQProducerImpl.java:发送消息到指定队列的实现类; QueueListenter.java:监听queu
RocketMQ三种消息发送方式-同步、异步、单向
可靠同步发送 主要运用在比较重要一点消息传递/通知等业务: public class SyncProducer { public static void main(String[] args) throws Exception { DefaultMQProducer producer = new DefaultMQProducer(&quot;test&quot;...
ActiveMQ中的消息重发时间间隔和重发次数吗?
首先,我们得大概了解下,在哪些情况下,ActiveMQ服务器会将消息重发给消费者,这里为简单起见,假定采用的消息发送模式为队列(即消息发送者和消息接收者)。       1.如果消息接收者在处理完一条消息的处理过程后没有对MOM进行应答,则该消息将由MOM重发.       2.如果我们队某个队列设置了预读参数(consumer.prefetchSize),如果消息接收者在处理第一条消
ActiveMq 的高级特性
ActiveMQ 高级特性 异步发送 消息生产者使用持久(persistent)传递模式发送消息的时候,Producer.send() 方法会被阻塞,直到 broker 发送一个确认消息给生产者,这个确认消息暗示生产者 broker 已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称为同步发送。但有一个例外,当发送方法在一个事物上下文中时,被阻塞的是 commi...
JAVA发送接收MQ代码示例
上几篇关于MQ的博客里,并没有介绍的透彻,今天我把用到的类整理到里一起,集成了监视、查找、发送、接收、保存报文的功能。首先,新建TemoteTest类申明: private static MQQueueManager qMgr; // 队列管理器名称 private static MQQueue qQueue; // 消息通道 private static String Q_M
activeMQ消息队列(xml方式)
一、项目搭建(spring+activeMQ环境)导包:&amp;lt;!-- 消息队列 MQ --&amp;gt; &amp;lt;dependency&amp;gt; &amp;lt;groupId&amp;gt;org.apache.activemq&amp;lt;/groupId&amp;gt; &amp;lt;artifactId&amp;gt;activemq-spring&amp;lt;/artifactId&amp;gt; &amp;lt;version&amp;gt;
AMQ消费时间次数机制
JMS是一个用于提供消息服务的技术规范,它制定了在整个消息服务提供过程中的所有数据结构和交互流程。而MQ则是消息队列服务,是面向消息中间件(MOM)的最终实现,是真正的消息服务提供者。MQ的实现可以基于JMS,也可以基于其他规范或标准,其中ActiveMQ就是基于JMS规范实现的消息队列。 一: 在指定机器M(ip加端口)安装AMQ:解压下载包并运行解压目录下的activemq.bat即可 ...
关于RokectMQ消息队列的运用
自己封装的RocketUtil public class RocketMQUtils { public static Producer getProducer(String producerId){ Properties properties = new Properties(); //您在控制台创建的Producer ID proper
activemq 队列消息定时清理
activemq 队列消息定时清理
关于阿里消息队列RocketMQ(安装、使用和坑),你需要知道的事情
为什么选择RocketMQ Apache RocketMQ作为阿里开源的一款高性能、高吞吐量的分布式消息中间件。因为阿里有海量的数据量,无数业务场景的应用,是RocketMQ抢尽风头风头,成为不可多得中间件项目,加上已经正式加入Apach俱乐部,作为顶级的开源项目! 一、关于RocketMQ 关于这个RocketMQ这个中间件,你有一些需要了解的地方。 阅读阿里中间件团队关于RocketM...
ActiveMQ 发送消息和接收消息 Demo
package com.mq; public class ConstanParam { public static String USER = "admin"; public static String PASSWORD = "123456"; public static String URL = "failover://tcp://10.10.10.10:61
ActiveMQ消息的延时和定时投递
ActiveMQ对消息延时和定时投递做了很好的支持,其内部启动Scheduled来对该功能支持,也提供了一个封装的消息类型:org.apache.activemq.ScheduledMessage,只需要把几个描述消息定时调度方式的参数作为属性添加到消息,broker端的调度器就会按照我们想要的行为去处理消息。
分享一篇关于使用阿里云消息队列中遇到的坑
相信很多小伙伴都在开发中使用过消息队列,尤其是高并发的情况,一般可以在缓存中操作数据,然后通过消息异步处理业务逻辑,操作数据库等。 本人所在的公司使用了阿里云的消息队列和RabbitMQ,据说使用阿里云消息队列的一部分原因是RabbitMQ实现延迟消息比较复杂,要依赖死信...接下来进入主题,说说我是怎么使用消息和遇到的坑吧~ 一般来讲,...
Alibaba阿里 RocketMQ入门实例(四种消息类型)
发送顺序消息 public class ProducerClient { public static void main(String[] args) { Properties properties = new Properties(); // 您在控制台创建的 Group ID properties.put(PropertyKeyCon...
RocketMQ-延时消息Demo及实现原理分析
文章目录延时消息Producer Demo源码分析延时消息持久化内部变量含义初始化load方法start方法延时消息调度总结 假设有这么一个需求,用户下单后如果30分钟未支付,则该订单需要被关闭。你会怎么做? 最简单的做法,可以服务端启动个定时器,隔个几秒扫描数据库中待支付的订单,如果(当前时间-订单创建时间)&gt;30分钟,则关闭订单。 这种方案优点是实现简单,缺点呢? 定时扫描意味着隔个几...
WebSphere MQ发送接收消息_二
WebSphere MQ发送接收消息_二 MQQueueConnectionFactory
阿里云API定时发送短信(小记)
定时任务的代码: import com.google.gson.Gson; import com.jianke.bid.common.SMSUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import...
RabbitMQ+Spring Quartz 实现消息的定时发送和接收和定时任务的管理
RabbitMQ+Spring Quartz 实现消息的定时发送和接收, 进行定时任务的动态创建和管理。
调用MQ发送xml文件并接收回复的message
调用MQ向指定的队列中传输xml文件,同时发送成功后到指定的队列中去读取回复的xml格式的消息