文档章节

zbus消息唯一性约束增强

少帮主
 少帮主
发布于 2016/01/01 09:32
字数 157
阅读 528
收藏 4
点赞 0
评论 1

zbus-6.3.0 (master)增加新特性,支持对队列消息的唯一性约束,生产者可以在消息头部打标识(键名key),唯一标识决定消息是否入队列。使用示例


BrokerConfig config = new BrokerConfig();
config.setServerAddress("127.0.0.1:15555");
final Broker broker = new SingleBroker(config);
 
Producer producer = new Producer(broker, "MyMQ");
producer.createMQ(); // 如果已经确定存在,不需要创建
 
for(int i=0; i<10; i++){ 
    Message msg = new Message(); 
    msg.setHead("key", "hong"); //设置消息唯一性约束
    msg.setBody("hello world"+i);
    msg = producer.sendSync(msg);  
}
		
broker.close();


发送了10次,但是由于设定了key唯一性,最终zbus服务器入队列只有1条

© 著作权归作者所有

共有 人打赏支持
少帮主

少帮主

粉丝 315
博文 6
码字总数 3921
作品 2
深圳
其他
加载中

评论(1)

自风
自风
我试试多线程来send上去看看。
zbus 0.9.0 新版发布,MQ、RPC、微服务总线

经过相当长一段时间的重构优化,zbus新版0.9.0发布。 依然保持小巧极速易用,核心~400K Jar包,发行 ~3M,极少依赖,重点增强: 消息队列(MQ) 单播、广播、组播、订阅消息模式统一 支持磁盘...

少帮主 ⋅ 2017/09/18 ⋅ 29

zbus 0.9.3 发布 MQ、RPC、微服务总线

小巧而极速的MQ, RPC实现, 支持HTTP/TCP代理,开放易扩展,多语言支撑微服务,系统总线架构 小版本更新列表: HTTP MessageCodec去除了默认的Content-Type设置 RpcCodec正确返回JSON+Charse...

少帮主 ⋅ 2017/09/26 ⋅ 4

使用微软MSMQ可能遇到的坑

最近重新捣鼓回 ZBUS5.0 与 微软MSMQ对接,碰到了些坑,希望能对新手有所帮助。 微软的MSMQ坑比较多,Win7下可能出现下面的bug http://support.microsoft.com/kb/2554746 验证方法: netsta...

少帮主 ⋅ 2014/08/21 ⋅ 5

ZBUS高可用HA介绍

请参考最新文档 http://zbus.io/guide/ha?menu=ha http://git.oschina.net/rushmore/zbus 1. ZBUS 高可用设计 Zbus高可用采用ZbusServer + TrackServer结合完成,相对于单机版本的zbus,客户...

少帮主 ⋅ 2015/12/21 ⋅ 6

玛雅牛/jfinal-zbus

jfinal-zbus插件 项目依赖:jfina 2.2 ,zbus, fastjson , reflections,详见pom.xml文件 更新说明: 1)发送接受全部泛型化,更容易写出类型安全,高质量的代码。 2)支持直接发送JFinal中...

玛雅牛 ⋅ 2015/08/06 ⋅ 0

MQ、RPC、服务总线--zbus

小巧而极速的MQ, RPC实现, 支持HTTP/TCP代理,开放易扩展,多语言支撑微服务,系统总线架构 zbus核心是一个独立实现的小巧极速的消息队列(MQ),支持持久化与内存队列, 支持单播、广播、组...

少帮主 ⋅ 2014/01/22 ⋅ 56

zbus-5.1.0 正式版发布,轻量级 Java 消息总线

zbus 5.1.0正式版本发布,zbus 是一个轻量级服务总线/消息队列,目前 OSChina 正在使用该消息总线。 该版本主要更新包括: 1)zbus主项目拆分出zbus-remoting通讯子项目 2)fastjson与commo...

少帮主 ⋅ 2015/03/31 ⋅ 29

ZBUS项目结构概貌

项目已经更新,请参考 zbus.io http://git.oschina.net/rushmore/zbus ZBUS项目代码概览 broker -- 链接代理,解决连接池管理,链接高可用 kit --工具类,包括log日志、对象池等 mq --消息队...

少帮主 ⋅ 2015/09/17 ⋅ 2

zbus 0.11.0 发布,MQ、RPC、微服务总线

zbus 0.11.0 已发布。zbus 是小巧而极速的 MQ, RPC 实现, 支持 HTTP/TCP 代理,开放易扩展,多语言支撑微服务,系统总线架构。 0.11.0 更新列表 大更新 - MQ消费者端增加ACK确认,以及可配置的...

少帮主 ⋅ 2017/11/16 ⋅ 19

JFinal极简zbus插件--jfinal-zbus

JFinal极简zbus插件, 该插件具有以下特点: 1)简化设计,去掉了异步发送,仅支持同步发送。 2)信息发送/接收支持泛型,类型安全。 3)可直接发送/接收JFinal中特有的Model对象和Record对...

玛雅牛 ⋅ 2015/08/06 ⋅ 6

没有更多内容

加载失败,请刷新页面

加载更多

下一页

iExec Blockchain Marketplace for Cloud

iExec Releases the First-Ever Blockchain Marketplace for Trading Cloud Computing Berlin, Germany, May 29, 2018. iExec has released its blockchain-based decentralized cloud marke......

openthings ⋅ 31分钟前 ⋅ 0

OSChina 周二乱弹 —— 加班的代码不要枉费了我的童子功

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @小小编辑:推荐歌曲《29》- 未完成乐队 《29》- 未完成乐队 手机党少年们想听歌,请使劲儿戳(这里) @FalconChen :#看球提醒# 02:00 巴西v...

小小编辑 ⋅ 50分钟前 ⋅ 15

Docker Swarm的前世今生

概述 在我的《Docker Swarm集群初探》一文中,我们实际体验了Docker Swarm容器集群技术的魅力,与《Kubernetes实践录》一文中提到的Kubernetes集群技术相比,Docker Swarm没有Kubernetes显得...

CodeSheep ⋅ 今天 ⋅ 0

骰子游戏代码开源地址

因为阿里云现在服务器已经停用了,所以上面的配置已经失效。 服务端开源地址:https://gitee.com/goalya/chat4.git 客户端开源地址:https://gitee.com/goalya/client4.git 具体运行界面请参考...

算法之名 ⋅ 今天 ⋅ 0

设计模式--装饰者模式

装饰者模式 定义 动态地给一个对象添加一些额外的职责。就增加功能来说,装饰模式相比生成子类更为灵活。 通用类图 意图 动态地给一个对象添加一些额外的职责。就增加功能来说,装饰模式相比...

gaob2001 ⋅ 今天 ⋅ 0

JavaScript零基础入门——(八)JavaScript的数组

JavaScript零基础入门——(八)JavaScript的数组 欢迎大家回到我们的JavaScript零基础入门,上一节课我们讲了有关JavaScript正则表达式的相关知识点,便于大家更好的对字符串进行处理。这一...

JandenMa ⋅ 今天 ⋅ 0

sbt网络问题解决方案

转自:http://dblab.xmu.edu.cn/blog/maven-network-problem/ cd ~/.sbt/launchers/0.13.9unzip -q ./sbt-launch.jar 修改 vi sbt/sbt.boot.properties 增加一个oschina库地址: [reposit......

狐狸老侠 ⋅ 今天 ⋅ 0

大数据,必须掌握的10项顶级安全技术

我们看到越来越多的数据泄漏事故、勒索软件和其他类型的网络攻击,这使得安全成为一个热门话题。 去年,企业IT面临的威胁仍然处于非常高的水平,每天都会看到媒体报道大量数据泄漏事故和攻击...

p柯西 ⋅ 今天 ⋅ 0

Linux下安装配置Hadoop2.7.6

前提 安装jdk 下载 wget http://mirrors.hust.edu.cn/apache/hadoop/common/hadoop-2.7.6/hadoop-2.7.6.tar.gz 解压 配置 vim /etc/profile # 配置java环境变量 export JAVA_HOME=/opt/jdk1......

晨猫 ⋅ 今天 ⋅ 0

crontab工具介绍

crontab crontab 是一个用于设置周期性被执行的任务工具。 周期性执行的任务列表称为Cron Table crontab(选项)(参数) -e:编辑该用户的计时器设置; -l:列出该用户的计时器设置; -r:删除该...

Linux学习笔记 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部