Re: ServiceThread apache版本的一些疑问？

t的wait操作， > > 这两种实现有什么区别？ > object.wait会导致死锁吗？或者不会从睡眠中醒来？ > > > Thanks > 卢松 > > > Zhanhui Li 于2018年6月11日周一 上午10:04写道： > > > > 主要是缩小了锁的粒度. pls, 原子变量比对象锁效率好一点. > > > > > 在 2018年6月10日，下午3:25，卢松 写道： > > > > > > 各位大佬好。 > > > 有个疑问，a

Re: ServiceThread apache版本的一些疑问？

主要是缩小了锁的粒度. pls, 原子变量比对象锁效率好一点. > 在 2018年6月10日，下午3:25，卢松 写道： > > 各位大佬好。 > 有个疑问，apache版本ServiceThread是这么实现的： > >protected final CountDownLatch2 waitPoint = new CountDownLatch2(1); > > protected void waitForRunning(long interval) { >if (hasNotified.compareAndSet(true, false)) { >

Re: clusterList和statsAll统计数据疑问

1. 这两个统计, 都不是原子型的. 获取的数值时间有微小的差别. 但不应该出现你观察到的这么大的差别. 2. 统计这个地方的代码, 最近Fix了计数上的bug: https://github.com/apache/rocketmq/commit/97322eaf8e939e6835b90198bc411572c29a536a 你可以backport到你的版本. 3. 如果你愿意分享你的stats.log,

Re: transientStorePool的好处

pdf> Zhanhui Li > 在 2018年6月4日，下午8:30，superheizai 写道： > > Hi all, > > there is a broker config item named transientStorePoolEnable, What's the > strength the config item can bring us? > > When it's enabled and for FLUSH_ASYNC master, the directBuf

Re: Hi，您好，我想请教您几个rocketmq的问题，不知道您方便么？

> 龚皓你好, 如果有大量的consume queue, 对系统确实还是有一些影响的. 下面解释下为什么这个影响可控. 1. 每一条消息, 对应的consume queue entry大小只有20字节. 也就是说, 一个queue里面, 发送200多条消息, 才需要一次IO去存储. 2. 由于consume queue完全可以从commit log中构造出来, consume queue的刷盘策略, 可以配置的更松弛一些, 比如每隔T刷盘一次. 这样可以进一步减少随机IO的量. 当然, 这里涉及内存和IO的一个平衡. 3. 实际生产上, 经常会把consume

Re: 关于ROCKETMQ的死信队列

正解, 赞 > 在 2018年6月5日，下午12:29，卢松 写道： > > DLQ的默认读权限是不开的，所以在console上打开DLQ的读权限就可以了 > > 在 2018年6月5日 上午9:10，李承霖 写道： >> >> >> Hi, >> >> 我在代码中声明了一个DefaultMQPushConsumer尝试监听死信队列里的消息，却在代码中获得如下异常 >> >> >> 08:33:30.588 [RebalanceService] ERROR RocketmqClient - >>

Re: rocketmq 写消息的时候，为什么先把消息写到一个bytebuffer里面，然后再刷到磁盘上？

writeBuffer 是预分配的anonymous pages, 并且mlock到物理内存了. 往里面写消息, 不会因为内存不足回收带来延迟. mmap的文件page cache, 在物理内存分配过快, background reclaim速度跟不上的时候, 线程会被block住, 进行direct reclaim, 带来延迟. 可参考: https://events.static.linuxfound.org/sites/events/files/lcjp13_moriya.pdf 祝好 2018-04-07 13:50 GMT+08:00 yuzhou li

Re: [VOTE]RocketMQ-spring 2.0.0 Release and Graduation

+1 On Thu, Dec 6, 2018 at 7:40 PM Kevin Wang wrote: > +1 > > 在 2018年12月6日，下午7:36，liqipeng 写道： > > +1 > > 在 2018年12月6日，下午7:34，heng du 写道： > > Hello RocketMQ Community, > > This is the vote for the 2.0.0 release and the graduation of Apache > RocketMQ-spring. > > Github repo:

Re: 关于RocketMQ消息存储的几点问题

这个Thread讨论了很多话题, 囿于时间, 回复下第一个问题. 帖子认为这两个synchronize都没必要. 很显然是没理解这个地方的设计和并发情况. 简单解释下, 这里实现了经典read-write dual-buffer机制, 以希望达到类似"Group Commit"效果, 调用函数不用等后端IO操作完成. putRequest并没有在putMessage的同步块里面, 因此本身是存在并发调用的; 事实上, 即便放到put message lock里面, 考虑到OS进程调度, 也会存在和flush线程并发访问write ArrayList的情况. 另外,

Re: [VOTE]Open the ISSUE module for Apache RocketMQ Sub Project

+1 > 在 2019年6月4日，下午2:21，chengxiangw...@cmss.chinamobile.com 写道： > > +1 > > > > 程 向往（Cheng Xiangwang） > 中移（苏州）软件技术有限公司 > 云计算产品部 > 电话：18896725053 > 邮箱：chengxiangw...@cmss.chinamobile.com > 地址：苏州市高新区科灵路78号苏高新软件园10幢 > > From: Gosling Von > Date: 2019-06-04 13:57 > To: users > CC:

Re: [Vote] Release gRPC Client for Apache RocketMQ 5.0.0 RC1

+1 I checked the license, notice and checksum, GPG signature. I also validated compilation instructions of the CPP SDK on a clean docker. On Mon, Aug 1, 2022 at 8:39 PM aaron ai wrote: > Hello RocketMQ Community, > > This is the vote for 5.0.0 RC1 of Apache RocketMQ clients. > > Apache

Re: [ANNOUNCE] Release gRPC Client for Apache RocketMQ 5.0.0

Congratulations, we finally reach this milestone! I am suggesting C/C++ users to try this new C++ SDK in that 1. It's designed and implemented from scratch, memory safety is prioritized and guaranteed with address sanitizer, thread safety is ensured by thread sanitizer

Re: RocketMQ client crashed

Which version of RocketMQ was used? As you are using an ARM CPU, ensure that netty transport, tc-native has compatible binary lib included. On Mon, Nov 14, 2022 at 11:09 PM wrote: > Hello everyone > > > > I have a strange problem. The rocketMQ java client sometimes crashes > inexplicably. > >

Re: [VOTE] Release gRPC Rust Client for Apache RocketMQ 5.0.0 RC1

+1 binding I checked license, source tagging, and PGP signature. On Fri, Jul 28, 2023 at 1:37 PM SSpirits wrote: > Hello RocketMQ Community, > > This is the vote for 5.0.0 RC1 of Apache RocketMQ client for Rust. > > Apache RocketMQ clients 5.x series follow the specs of rocketmq-apis< >

Re: [VOTE] Release Apache RocketMQ 5.2.0 RC1

+1 I checked: 1) checksum; 2) license; 3) notice; 4) signature; On Tue, Feb 13, 2024 at 6:34 PM fuyou wrote: > +1 > >= > > fuyou001 > Best Regards > > > > jinrongtong 于2024年2月13日 周二18:18写道： > >> Hello RocketMQ Community, >> >> This is

Re: [VOTE] Release Apache RocketMQ EventBridge 1.1.0

/src/main/._.DS_Store IMO, these release tar/zip packages shall be generated via CI pipeline. This would help us verify these source files matches given git commit conveniently. Zhanhui Li On Sun, Feb 18, 2024 at 9:03 AM 沈林 <2011shen...@gmail.com> wrote: > Hello RocketMQ

Re: [Vote] Release gRPC Go Client for Apache RocketMQ 5.1.0 RC1

+1 Verified hash and tag in the repository; Verified sha512 checksum; On Mon, Jan 22, 2024 at 11:39 AM Zhouxiang Zhan wrote: > +1 > > On Tue, Jan 16, 2024 at 4:30 PM jinrongtong > wrote: > > > +1, I checked[OK] Hash and Tag in GitHub repo is matching the > current > > artifacts[OK] The

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.0.6 RC1

/archive/refs/tags/java-5.0.6.zip How can we ensure the consistency? For example, source package in SVN repository has this file 'rocketmq-client-java-parent-5.0.6/DEPENDENCIES' while there is no such file in the git repository. Zhanhui Li On Mon, Jan 22, 2024 at 9:38 PM aaron ai wrote: > +1 > &