文档章节

生产者发送时的参数设置

Zero零_度
 Zero零_度
发布于 2016/03/08 15:19
字数 195
阅读 9
收藏 0
点赞 1
评论 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零_度
粉丝 67
博文 1245
码字总数 252866
作品 0
程序员
ActiveMQ使用生产者堵塞的问题

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

伊人梦醉
2016/08/08
818
0
kafka知识体系50-生产者编程实践

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

molyeo
07/12
0
0
架构设计:系统间通信(29)——Kafka及场景应用(中2)

接上文:《架构设计:系统间通信(28)——Kafka及场景应用(中1)》 4-3、复制功能 我们在上文中已经讨论了Kafka使用分区的概念存储消息,一个topic可以有多个分区它们分布在整个Kafka集群的...

yinwenjie
2016/05/06
0
0
RabbitMQ系列二(构建消息队列)

从AMQP协议可以看出,MessageQueue、Exchange和Binding构成了AMQP协议的核心,下面我们就围绕这三个主要组件 从应用使用的角度全面的介绍如何利用Rabbit MQ构建消息队列以及使用过程中的注意...

我类个擦
2015/08/03
0
0
分布式消息队列RabbitMQ之二: exchange、route、queue关系

从AMQP协议可以看出,MessageQueue、Exchange和Binding构成了AMQP协议的核心,下面我们就围绕这三个主要组件 从应用使用的角度全面的介绍如何利用Rabbit MQ构建消息队列以及使用过程中的注意...

wqhlmark64
2017/12/22
0
0
rabbitmq原理介绍(转载)

从AMQP协议可以看出,MessageQueue、Exchange和Binding构成了AMQP协议的核心,下面我们就围绕这三个主要组件 从应用使用的角度全面的介绍如何利用Rabbit MQ构建消息队列以及使用过程中的注意...

yjpfj1203
2016/09/17
71
0
RabbitMQ第二篇--工作队列(任务队列)

1.在上一节中,我们写了一个通过命名队列发送和消费消息的程序,本节中我们将创建一个工作队列。用于在多个工作者之间分配耗时的任务.工作队列又名任务队列,它的主要思想是避免将任务分配给...

老板来瓶82年雪碧
2016/12/14
44
0
了解rxjs

rxjs rxjs(Reactive Extensions for JavaScript)是Javascript的响应式扩展, 响应式的思路是把随时间不断变化的数据、状态、事件等转成可被观察的序列(Observable Sequence),然后订阅序列中对...

bestvist
2017/11/19
0
0
网易蜂巢微服务架构:用RabbitMQ实现轻量级通信

微服务架构与MQ RabbitMQ场景分析与优化 RabbitMQ在网易蜂巢中的应用和案例分享 1微服务架构与MQ 微服务架构是一种架构模式,它将单体应用划分成一组微小的服务,各服务之间使用轻量级的通信...

andrewniu
05/10
0
0
Kafka分区机制介绍与示例

Kafka中可以将Topic从物理上划分成一个或多个分区(Partition),每个分区在物理上对应一个文件夹, 以”topicName_partitionIndex”的命名方式命名,该文件夹下存储这个分区的所有消息(.log...

HZCoder
2016/03/01
11
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

mysql 主从复制中遇到的错误!

。。。。。

万建宁
9分钟前
0
0
DUBBO 详细介绍

摘要: 主要核心部件: Remoting: 网络通信框架,实现了 sync-over-async 和 request-response 消息机制. RPC: 一个远程过程调用的抽象,支持负载均衡、容灾和集群功能 Registry: 服务目录框架...

明理萝
19分钟前
0
1
4 个快速的 Python 编译器 for 2018

简评:Python 和其他的解释型语言一样经常被吐槽性能不行,所以开发人员为了提升性能创建了不少编译器,本文则选取其中的四个做了基准测试。 Python 其实是一种相当快的语言,但它并不像编译...

极光推送
22分钟前
0
0
spring boot注册多个MQ服务器的问题

关于注册到多个MQ源的文章已经有很多了,这里记录一下声明queue的坑; 如果使用注册bean的方式声明queue,会导致声明的queue同时被注册到所有的MQ源上; //如果使用下面的声明方式,que...

placeholder
23分钟前
0
0
Java面试基础篇——第九篇:BIO,NIO,AIO的区别

现在IO模型主要分三类:BIO(同步阻塞IO),NIO(同步非阻塞IO),AIO()。 先来看看BIO。 1. BIO 服务端接受到请求后,要指派或新建一个线程去处理客户端的IO请求,直到收到断开连接的指令。这么做...

developlee的潇洒人生
28分钟前
0
0
@RequestMapping @ResponseBody 和 @RequestBody 用法与区别

1.@RequestMapping 国际惯例先介绍什么是@RequestMapping,@RequestMapping 是一个用来处理请求地址映射的注解,可用于类或方法上。用于类上,表示类中的所有响应请求的方法都是以该地址作为...

特拉仔
31分钟前
1
0
基于 HTML5 结合互联网+ 的 3D 隧道

前言 目前,物资采购和人力成本是隧道业发展的两大瓶颈。比如依靠民间借贷,融资成本很高;采购价格不透明,没有增值税发票;还有项目管控和供应链管理的问题。成本在不断上升,利润在不断下...

xhload3d
32分钟前
0
0
济南小程序热度分析

原文链接:http://www.jnqianle.cn/company/2072.html

tianma3798
33分钟前
1
0
大数据软件

beats 采集 kafka spark hive es grafana zeppelin

ArlenXu
36分钟前
0
0
Mac item2常用快捷键

标签 新建标签:command + t 关闭标签:command + w 切换标签:command + 数字 command + 左右方向键 切换全屏:command + enter 查找:command + f 分屏 水平分屏:command + d 垂直分屏:c...

说回答
39分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部