Sailong Ren

增加了MIT 开源协议的中文版本。

link zk timeOut,

2

``` Connection timed out for connection string (127.0.0.1:2181) and timeout (5000) / elapsed (5022) org.apache.curator.CuratorConnectionLossException: KeeperErrorCode = ConnectionLoss at org.apache.curator.ConnectionState.checkTimeouts(ConnectionState.java:225) at org.apache.curator.ConnectionState.getZooKeeper(ConnectionState.java:94) at org.apache.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:117) at org.apache.curator.framework.imps.CuratorFrameworkImpl.getZooKeeper(CuratorFrameworkImpl.java:489) at org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuilderImpl.java:237) at org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuilderImpl.java:226)...

请问这种BufferTrigger的使用场景是什么呢

2

因为每台机器都会enqueue() 这也意味着每台机器都会触发Trigger的逻辑， 只能用在MQ的消费逻辑的enqueue() 做别的业务批量处理逻辑吗？

commit -u

如果多机房多活的场景，你这个加锁也是避免不了一致性错误的

Hello, 如标题， 这样做，是为什么呢？ 参考了Spring这类的框架代码？