import net.openhft.chronicle.Chronicle; //导入依赖的package包/类
public Master() throws IOException {
    String indexPath = Utils.prepareIndexDirectory(TEST_INDEX_DIRECTORY_PATH);
    //int tenSeconds = 10 * 1000;
    Chronicle build = ChronicleQueueBuilder.vanilla(indexPath).cycleLength(3600000).build();
    m_chronicle = ChronicleQueueBuilder.source(build).bindAddress(PORT).build();
    m_appender = m_chronicle.createAppender();
    m_server = new Thread(new Runnable() {
        @Override
        public void run() {
            m_chronicle.clear();
            m_logger.info("start server");
            for (long i = 1; i <= 1000000; i++) {
                String msg = "test" + i;
                m_logger.info("server stock:" + msg);
                publish(msg.getBytes());
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    //
                }
            }
            m_appender.close();
        }
    });
}
 

import net.openhft.chronicle.Chronicle; //导入依赖的package包/类
/**
 * c-tor
 *
 * @param chronicle   the Chronicle
 * @param serializer  the DomainEventStream serializer
 */
public ChronicleDomainEventReader(Chronicle chronicle, Serializer serializer) {
    m_serializer = serializer;

    try {
        m_excerpt = chronicle.createTailer();
    } catch (Exception e) {
        m_excerpt = null;
        LOGGER.warn("CreateTailer - Exception",e);
    }
}
 

import net.openhft.chronicle.Chronicle; //导入依赖的package包/类
/**
 * c-tor
 *
 * @param chronicle  the Chronicle
 * @param serializer the DomainEventStream serializer
 */
public ChronicleDomainEventWriter(Chronicle chronicle, Serializer serializer) {
    m_serializer = serializer;

    try {
        m_excerpt = chronicle.createAppender();
    } catch (Exception e) {
        m_excerpt = null;
        LOGGER.warn("CreateAppender - Exception",e);
    }
}
 

import net.openhft.chronicle.Chronicle; //导入依赖的package包/类
public static final CommandLog commandLog(final int serverId, final String name) throws IOException {
    final String path = Files.fileDirectory();
    final String child = Files.fileName(serverId, name);
    final Chronicle chronicle = ChronicleQueueBuilder.vanilla(path, child).build();
    return new ChronicleCommandLog((VanillaChronicle)chronicle, new ExpandableArrayBuffer(INITIAL_BUFFER_SIZE));
}
 

import net.openhft.chronicle.Chronicle; //导入依赖的package包/类
protected void init(final Chronicle chronicle) {
    m_chronicle = chronicle;
    m_writer = new ChronicleDomainEventWriter<>(m_chronicle, m_serializer);
}