SimpleMessage:一个简单的磁盘消息存储引擎

简单消息 一个简单的磁盘消息存储引擎 用途 程序中的持久化存储解决方案 使用 放消息 public void testProducer() throws Exception { MessageStoreConfig cc = new MessageStoreConfig(); MessageStore ms = MessageStore.getInstance(cc.getStorePathRootDir()); for (int i = 0; i < 100; i++) { ByteBuffer bb = ByteBuffer.allocate(16); bb.clear(); bb.put(("hello" + i).getBytes()); bb.flip(); ms.putMessage("topic1", bb); } ms.shutdown