文档章节

zbus消息唯一性约束增强

少帮主
 少帮主
发布于 2016/01/01 09:32
字数 157
阅读 532
收藏 4

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
4.2K
29
zbus 0.9.3 发布 MQ、RPC、微服务总线

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

少帮主
2017/09/26
1K
4
ZBUS高可用HA介绍

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

少帮主
2015/12/21
4.9K
6
MQ、RPC、服务总线--zbus

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

少帮主
2014/01/22
67.4K
56
玛雅牛/jfinal-zbus

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

玛雅牛
2015/08/06
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

【七】组合Action

本章描述了常用定义Action的方法。 自定义action builders 我们在action一章已经看过如何声明一个action——有request parameter、无request parameter、有body parser等等。你可以在 asynch...

Landas
35分钟前
0
0
Spring Boot实战之基础回顾

本文作者: 吴伟祥 本文链接: https://wuweixiang.cn/2018/08/21/Spring-Boot实战之基础回顾/ 版权声明: 本博客所有文章除特别声明外均为原创,采用CC BY-NC-SA 4.0 许可协议。转载请在文章开...

吴伟祥
36分钟前
0
0
OAuth认证开发

提示: 以下测试是基于项目安装成功,初始化数据库(initial_db.ddl, oauth.ddl, initial_data.ddl)后的测试, 也可在页面上点击"client_details"菜单里进行测试 方式1:基于浏览器 (grant_type=...

舒文joven
44分钟前
1
0
第二章-对象及变量的并发访问-第二篇

锁对象的改变 请阅读如下代码 public class MainClass { private String lock = "123"; public void printStringB() { try { synchronized (lock) { ......

简心
48分钟前
0
0
日志中记录代理IP以及真实客户端、apache只记录指定URI的日志

apache 日志中记录代理IP以及真实客户端 默认情况下log日志格式为: LogFormat "%h %l %u %t "%r" %>s %b "%{Referer}i" "%{User-Agent}i"" combined 其中%h 是记录访问者的IP,如果在web的前...

李超小牛子
57分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部