zbus消息唯一性约束增强
zbus消息唯一性约束增强
少帮主 发表于2年前
zbus消息唯一性约束增强
  • 发表于 2年前
  • 阅读 490
  • 收藏 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条

共有 人打赏支持
少帮主
粉丝 309
博文 6
码字总数 3921
作品 2
评论 (1)
自风
我试试多线程来send上去看看。
×
少帮主
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: