release 0.1.0

Author: guangxuCheng

docs/tubemq_clients_cn.md

@@ -20,7 +20,7 @@ TubeMQ的Master地址信息对象，该对象的特点是支持配置多个Maste
 
 #### **c) TubeClientConfig：**
 
-MessageSessionFactory（消息会话工厂）初始化类，用来携带创建网络连接信息、客户端控制参数信息的对象类，包括RPC时长设置、Socket属性设置、连接质量检测参数设置、TLS参数设置、认证授权信息设置等信息，该类，连同接下来介绍的ConsumerConfig类，与TubeMQ-3.8.0版本之前版本的类变更最大的类，主要原因是在此之前TubeMQ的接口定义超6年多没有变更，接口使用上存在接口语义定义有歧义、接口属性设置单位不清晰、程序无法识别多种情况的内容选择等问题，考虑到代码开源自查问题方便性，以及新手学习成本问题，我们这次作了接口的重定义。对于重定义的前后差别，见配置接口定义说明部分介绍。
+MessageSessionFactory（消息会话工厂）初始化类，用来携带创建网络连接信息、客户端控制参数信息的对象类，包括RPC时长设置、Socket属性设置、连接质量检测参数设置、TLS参数设置、认证授权信息设置等信息，该类，连同接下来介绍的ConsumerConfig类，与TubeMQ-0.1.0版本之前版本的类变更最大的类，主要原因是在此之前TubeMQ的接口定义超6年多没有变更，接口使用上存在接口语义定义有歧义、接口属性设置单位不清晰、程序无法识别多种情况的内容选择等问题，考虑到代码开源自查问题方便性，以及新手学习成本问题，我们这次作了接口的重定义。对于重定义的前后差别，见配置接口定义说明部分介绍。
 
 
 

docs/tubemq_config_introduction.md

@@ -2,7 +2,7 @@
 
 The TubeMQ server includes two modules for the Master and the Broker. The Master also includes a Web front-end module for external page access (this part is stored in the resources). Considering the actual deployment, two modules are often deployed in the same machine, TubeMQ. The contents of the three parts of the two modules are packaged and delivered to the operation and maintenance; the client does not include the lib package of the server part and is delivered to the user separately.
 
-Master and Broker use the ini configuration file format, and the relevant configuration files are placed in the master.ini and broker.ini files in the tubemq-server-3.8.0/conf/ directory.
+Master and Broker use the ini configuration file format, and the relevant configuration files are placed in the master.ini and broker.ini files in the tubemq-server-0.1.0/conf/ directory.
 
 Their configuration is defined by a set of configuration units. The Master configuration consists of four mandatory units: [master], [zookeeper], [bdbStore], and optional [tlsSetting]. The Broker configuration is mandatory. Broker], [zookeeper] and optional [tlsSetting] consist of a total of 3 configuration units; in actual use, you can also combine the contents of the two configuration files into one ini file.
 

docs/tubemq_perf_test_vs_Kafka_cn.md

@@ -29,7 +29,7 @@ TubeMQ是腾讯大数据自研的分布式消息中间件。其系统架构思
 
 **角色**|**TubeMQ**|**Kafka**
 :---:|---|---
-**软件版本**|tubemq-3.8.0|Kafka\_2.11-0.10.2.0
+**软件版本**|tubemq-0.1.0|Kafka\_2.11-0.10.2.0
 **zookeeper部署**|与Broker不在同一台机器上，单机|与Broker配置不在同一台机器，单机
 **Broker部署**|单机|单机
 **Master部署**|与Broker不在同一台机器上，单机|不涉及
@@ -50,7 +50,7 @@ TubeMQ是腾讯大数据自研的分布式消息中间件。其系统架构思
 |:---:|---|---|
 | **日志存储**          | Raid10处理后的SATA盘或SSD盘 | Raid10处理后的SATA盘或SSD盘 |
 | **启动参数**          | BROKER_JVM_ARGS="-Dcom.sun.management.jmxremote -server -Xmx24g -Xmn8g -XX:SurvivorRatio=6 -XX:+UseMembar -XX:+UseConcMarkSweepGC -XX:+CMSParallelRemarkEnabled -XX:+CMSScavengeBeforeRemark -XX:ParallelCMSThreads=4 -XX:+UseCMSCompactAtFullCollection -verbose:gc -Xloggc:$BASE_DIR/logs/gc.log.`date +%Y-%m-%d-%H-%M-%S` -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+CMSClassUnloadingEnabled -XX:CMSInitiatingOccupancyFraction=75 -XX:CMSFullGCsBeforeCompaction=1 -Dsun.net.inetaddr.ttl=3 -Dsun.net.inetaddr.negative.ttl=1 -Dtubemq.fast_boot=false -Dtubemq.home=$tubemq_home -cp $CLASSPATH"|KAFKA_HEAP_OPTS="-Xms24g -Xmx24g -XX:PermSize=48m -XX:MaxPermSize=48m -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35
-| **配置文件**          | 在tubemq-3.8.0版本broker.ini配置文件上改动: consumerRegTimeoutMs=35000<br>tcpWriteServiceThread=50<br>tcpReadServiceThread=50<br>primaryPath为SATA盘日志目录|kafka_2.11-0.10.2.0版本server.properties配置文件上改动：<br>log.flush.interval.messages=5000<br>log.flush.interval.ms=10000<br>log.dirs为SATA盘日志目录<br>socket.send.buffer.bytes=1024000<br>socket.receive.buffer.bytes=1024000<br>socket.request.max.bytes=2147483600<br>log.segment.bytes=1073741824<br>num.network.threads=25<br>num.io.threads=48<br>log.retention.hours=5
+| **配置文件**          | 在tubemq-0.1.0版本broker.ini配置文件上改动: consumerRegTimeoutMs=35000<br>tcpWriteServiceThread=50<br>tcpReadServiceThread=50<br>primaryPath为SATA盘日志目录|kafka_2.11-0.10.2.0版本server.properties配置文件上改动：<br>log.flush.interval.messages=5000<br>log.flush.interval.ms=10000<br>log.dirs为SATA盘日志目录<br>socket.send.buffer.bytes=1024000<br>socket.receive.buffer.bytes=1024000<br>socket.request.max.bytes=2147483600<br>log.segment.bytes=1073741824<br>num.network.threads=25<br>num.io.threads=48<br>log.retention.hours=5
 | **其它**             | 除测试用例里特别指定，每个topic创建时设置：<br>memCacheMsgSizeInMB=5<br>memCacheFlushIntvl=20000<br>memCacheMsgCntInK=10 <br>unflushThreshold=5000<br>unflushInterval=10000<br>unFlushDataHold=5000 | 客户端代码里设置：<br>生产端：<br>props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");<br>props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");<br>props.put("linger.ms", "200");<br>props.put("block.on.buffer.full", false);<br>props.put("max.block.ms", "10");<br>props.put("batch.size", 50000);<br>props.put("buffer.memory", 1073741824 );<br>props.put("metadata.fetch.timeout.ms", 30000);<br>props.put("metadata.max.age.ms", 1000000);<br>props.put("request.timeout.ms", 1000000);<br>消费端：<br>props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "30000"); <br>props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");<br>props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");<br>props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true/false);<br>props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "10000");
 
 ## 测试场景及结论

pom.xml

@@ -23,7 +23,7 @@
     <groupId>com.tencent.tubemq</groupId>
     <artifactId>tubemq</artifactId>
     <inceptionYear>2013</inceptionYear>
-    <version>3.8.0</version>
+    <version>0.1.0</version>
     <packaging>pom</packaging>
     <name>tubemq</name>
 
@@ -35,10 +35,10 @@
     </modules>
 
     <properties>
-        <tubemq-core-version>3.8.0</tubemq-core-version>
-        <tubemq-client-version>3.8.0</tubemq-client-version>
-        <tubemq-server-version>3.8.0</tubemq-server-version>
-        <tubemq-example-version>3.8.0</tubemq-example-version>
+        <tubemq-core-version>0.1.0</tubemq-core-version>
+        <tubemq-client-version>0.1.0</tubemq-client-version>
+        <tubemq-server-version>0.1.0</tubemq-server-version>
+        <tubemq-example-version>0.1.0</tubemq-example-version>
         <junit.version>4.11</junit.version>
         <mockito.version>2.0.2-beta</mockito.version>
         <powermock.version>1.6.5</powermock.version>

tubemq-client/pom.xml

@@ -23,7 +23,7 @@
     <parent>
         <artifactId>tubemq</artifactId>
         <groupId>com.tencent.tubemq</groupId>
-        <version>3.8.0</version>
+        <version>0.1.0</version>
     </parent>
     <artifactId>tubemq-client</artifactId>
     <name>tubemq-client</name>

tubemq-client/src/main/java/com/tencent/tubemq/client/common/TubeClientVersion.java

@@ -18,7 +18,7 @@
 package com.tencent.tubemq.client.common;
 
 public class TubeClientVersion {
-    public static final String CONSUMER_VERSION = "3.8.0";
-    public static final String PRODUCER_VERSION = "3.8.0";
+    public static final String CONSUMER_VERSION = "0.1.0";
+    public static final String PRODUCER_VERSION = "0.1.0";
 
 }

tubemq-core/pom.xml

@@ -23,7 +23,7 @@
     <parent>
         <artifactId>tubemq</artifactId>
         <groupId>com.tencent.tubemq</groupId>
-        <version>3.8.0</version>
+        <version>0.1.0</version>
     </parent>
     <artifactId>tubemq-core</artifactId>
     <name>tubemq-core</name>

tubemq-example/pom.xml

@@ -23,7 +23,7 @@
     <parent>
         <artifactId>tubemq</artifactId>
         <groupId>com.tencent.tubemq</groupId>
-        <version>3.8.0</version>
+        <version>0.1.0</version>
     </parent>
     <artifactId>tubemq-example</artifactId>
     <name>tubemq-example</name>

tubemq-server/pom.xml

@@ -23,7 +23,7 @@
     <parent>
         <artifactId>tubemq</artifactId>
         <groupId>com.tencent.tubemq</groupId>
-        <version>3.8.0</version>
+        <version>0.1.0</version>
     </parent>
     <artifactId>tubemq-server</artifactId>
     <name>tubemq-server</name>

tubemq-server/src/main/java/com/tencent/tubemq/server/common/TubeServerVersion.java

@@ -18,5 +18,5 @@
 package com.tencent.tubemq.server.common;
 
 public class TubeServerVersion {
-    public static final String BROKER_VERSION = "3.8.0";
+    public static final String BROKER_VERSION = "0.1.0";
 }