Basic test rocketmq broker and name server init

Listens to slave connections to create {@link HAConnection}.

Used for set access channel, if need migrate the rocketmq service to cloud, it is We recommend set the value with "CLOUD". otherwise set with "LOCAL",

An allocate strategy proxy for based on machine room nearside priority. An actual allocate strategy can be specified. If any consumer is alive in a m

Create MappedFile in advance

平均算法 默认 Average Hashing queue algorithm

平均轮询算法 Cycle average Hashing queue algorithm

根据配置为每一个 Consumer 配置固定消费队列

根据 Broker 部署机房名，每个消费者负责不同 Broker 上的队列 Computer room Hashing queue algorithm, such as Alipay logic room

一致性 Hash Consistent Hashing queue algorithm

Strategy Algorithm for message allocating between consumers

先根据filesize排序 然后根据文件名排序，因为文件名的最后一部分都是偏移量 优先分配 filesize 大的 filename 小的

Write messages callback interface

When write a message to the commit log, returns results

When write a message to the commit log, returns code

An expression which performs an operation on two expression values. <p> This class was taken from ActiveMQ org.apache.activemq.filter.BinaryExpression

Wrapper of bytes array, in order to operate single bit easily.

Simple implement of bloom filter.

Data generated by bloom filter, include: <li>1. Bit positions allocated to requester;</li> <li>2. Total bit num when allocating;</li>

BooleanConstantExpression

A BooleanExpression is an expression that always produces a Boolean result. <p> This class was taken from ActiveMQ org.apache.activemq.filter.BooleanE

Broker端快速失败机制实现 https://mp.weixin.qq.com/s?__biz=MzIzNzgyMjYxOQ==&mid=2247484718&idx=1&sn=de898f6efec78890e699eb02d8d1ee74&scene=19#wechat_redirect c