文档章节

生产者发送时的参数设置

Zero零_度
 Zero零_度
发布于 2016/03/08 15:19
字数 195
阅读 9
收藏 0

消息在发送的时候可以指定目的地、是否持久化、消息的优先级、消息的有效时间;
默认情况是不做持久化,永久有效的;
消息的优先级设置不能完全保证消息的先后顺序;

for(int i=0;i<10;i++){
    TextMessage message=session.createTextMessage("ActiveMQ 发送的消息"+i);
    System.out.println("发送消息:"+"ActiveMQ 发送的消息"+i);
    
    /*
     * 目的地
     * 消息
     * 是否持久化
     * 优先级(0-9    0-4:普通、5-9:加急、默认4)
     * 消息在mq存放的有效期,单位毫秒
     */
    messageProducer.send(destination, message, DeliveryMode.NON_PERSISTENT, i, 1000 * 10);
}
消费端在消费数据的时候,顺序并不是从9排到1,也就是设置了优先级,并不能完全保证顺序

© 著作权归作者所有

共有 人打赏支持
Zero零_度
粉丝 68
博文 1246
码字总数 252959
作品 0
程序员
ActiveMQ使用生产者堵塞的问题

1:activeMQ默认的生产者发送的是Persistent message,这种消息的发送每次都需要等待broker给一个确认回复才能进行下一条消息的发送,这种可以在activemq.xml上设置流控,broker检测到目标空...

伊人梦醉
2016/08/08
818
0
消息中间件系列五、rabbit消息的确认机制

前言:这是中间件一个系列的文章之一,有需要的朋友可以看看这个系列的其他文章: 消息中间件系列一、消息中间件的基本了解 消息中间件系列二、Windows下的activeMQ和rabbitMQ的安装 消息中间...

我巴巴
10/11
0
0
史上最透彻的 RabbitMQ 可靠消息传输实战

可能是缓存架构之史上讲的最明白的 RabbitMQ 可靠消息传输实战演练。 一、背景介绍:消息可靠传递的重要性 比如:某个广告主(如:天猫)想在我们的平台(如:今日头条)投放广告,当通过我们...

程序员之家_
09/27
0
0
【RocketMQ】消息的发送

Producer 发送方式 生产者发送消息有三种方式 同步(Sync):发送方线程发送后同步堵塞等待SendResult,若failed则重试下一个broker 异步(Async):发送方线程发送后无需等待返回结果(返回...

SaintTinyBoy
07/29
0
0
kafka知识体系50-生产者编程实践

本文主要实际编程讲解kafka生产者相关内容,版本。 安装 集群安装过程请参考http://www.cnblogs.com/molyeo/p/7151949.html。 安装过程如下: 下载zookeeper安装包(zookeeper-3.4.6),解压到...

molyeo
07/12
0
0

没有更多内容

加载失败,请刷新页面

加载更多

javascript source map 的使用

之前发现VS.NET会为压缩的js文添加一个与文件名同名的.map文件,一直没有搞懂他是用来做什么的,直接删除掉运行时浏览器又会报错,后来google了一直才真正搞懂了这个小小的map文件背后的巨大...

粒子数反转
昨天
0
0
谈谈如何学Linux和它在如今社会的影响

昨天,还在农耕脑力社会,今天已经人工智能技术、大数据、信息技术的科技社会了,高速开展并迅速浸透到当今科技社会的各个方面,Linux日益成为人们信息时代的到来,更加考验我们对信息的处理程...

linux-tao
昨天
0
0
学习设计模式——中介者模式

1. 认识中介者模式 1. 定义:用一个中介对象来封装一系列的对象交互行为,中介者使得各对象不需要显式的互相引用,从而使其松散耦合,独立的改变他们之间的交互。 2. 结构: Mediator:中介者...

江左煤郎
昨天
0
0
深入理解Plasma(1):Plasma 框架

这一系列文章将围绕以太坊的二层扩容框架,介绍其基本运行原理,具体操作细节,安全性讨论以及未来研究方向等。本篇文章作为开篇,主要目的是理解 Plasma 框架。 Plasma 作为以太坊的二层扩容...

HiBlock
昨天
0
0
Java 8 日期 示例

Java 8 推出了全新的日期时间API。Java处理日期、日历和时间的方式一直为社区所诟病,将 java.util.Date设定为可变类型,以及SimpleDateFormat的非线程安全使其应用非常受限。Java也意识到需...

阿刚ABC
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部