small change.

Author: tangxuehua

src/EQueue/Broker/BrokerSetting.cs

@@ -61,7 +61,7 @@ public class BrokerSetting
         /// </summary>
         public ChunkManagerConfig QueueChunkConfig { get; set; }
 
-        public BrokerSetting(string chunkFileStoreRootPath = @"c:\equeue-store", int messageChunkDataSize = 256 * 1024 * 1024, int chunkCacheMaxPercent = 75, int chunkCacheMinPercent = 40, bool syncFlush = false, bool enableCache = true)
+        public BrokerSetting(string chunkFileStoreRootPath = @"c:\equeue-store", int messageChunkDataSize = 256 * 1024 * 1024, int chunkCacheMaxPercent = 75, int chunkCacheMinPercent = 40, int maxLogRecordSize = 4 * 1024 * 1024, int chunkWriteBuffer = 128 * 1024, int chunkReadBuffer = 128 * 1024, bool syncFlush = false, bool enableCache = true)
         {
             ProducerAddress = new IPEndPoint(SocketUtils.GetLocalIPV4(), 5000);
             ConsumerAddress = new IPEndPoint(SocketUtils.GetLocalIPV4(), 5001);
@@ -87,9 +87,9 @@ public BrokerSetting(string chunkFileStoreRootPath = @"c:\equeue-store", int mes
                 enableCache,
                 syncFlush,
                 Environment.ProcessorCount * 2,
-                4 * 1024 * 1024,
-                128 * 1024,
-                128 * 1024,
+                maxLogRecordSize,
+                chunkWriteBuffer,
+                chunkReadBuffer,
                 chunkCacheMaxPercent,
                 chunkCacheMinPercent,
                 1,
@@ -107,8 +107,8 @@ public BrokerSetting(string chunkFileStoreRootPath = @"c:\equeue-store", int mes
                 syncFlush,
                 Environment.ProcessorCount * 2,
                 8,
-                128 * 1024,
-                128 * 1024,
+                chunkWriteBuffer,
+                chunkReadBuffer,
                 chunkCacheMaxPercent,
                 chunkCacheMinPercent,
                 1,

src/EQueue/Clients/Producers/Producer.cs

@@ -160,7 +160,7 @@ private int GetAvailableQueueId(Message message, string routingKey)
         }
         private IList<int> GetTopicQueueIds(string topic)
         {
-            var queueIds = _topicQueueIdsDict.GetOrAdd(topic, new List<int>());
+            var queueIds = _topicQueueIdsDict.GetOrAdd(topic, k => new List<int>());
             if (queueIds.IsEmpty())
             {
                 try

src/Samples/QuickStart/QuickStart.BrokerServer/Program.cs

@@ -18,6 +18,7 @@ static void Main(string[] args)
                 ConfigurationManager.AppSettings["fileStoreRootPath"],
                 chunkCacheMaxPercent: 95,
                 messageChunkDataSize: int.Parse(ConfigurationManager.AppSettings["chunkSize"]) * 1024 * 1024,
+                chunkWriteBuffer: int.Parse(ConfigurationManager.AppSettings["chunkWriteBuffer"]) * 1024,
                 enableCache: bool.Parse(ConfigurationManager.AppSettings["enableCache"]))).Start();
             Console.ReadLine();
         }

src/Samples/QuickStart/QuickStart.BrokerServer/app.config

@@ -5,7 +5,8 @@
   </startup>
   <appSettings>
     <add key="fileStoreRootPath" value="d:\equeue-store"/>
-    <add key="chunkSize" value="256"/>
+    <add key="chunkSize" value="256"/><!--MB-->
+    <add key="chunkWriteBuffer" value="256"/><!--KB-->
     <add key="enableCache" value="true"/>
   </appSettings>
 </configuration>