You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2017/06/06 13:21:11 UTC
[4/4] incubator-rocketmq-site git commit: Build
Build
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/commit/94c21bba
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/tree/94c21bba
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/diff/94c21bba
Branch: refs/heads/asf-site
Commit: 94c21bba60c4d85b76d83cce5592cb5c2c66d53a
Parents: a496c5a
Author: dongeforever <do...@apache.org>
Authored: Tue Jun 6 21:20:55 2017 +0800
Committer: dongeforever <do...@apache.org>
Committed: Tue Jun 6 21:20:55 2017 +0800
----------------------------------------------------------------------
content/about/contact/index.html | 4 +-
content/about/rewards/index.html | 4 +-
content/about/team/index.html | 4 +-
content/archive-layout-with-content/index.html | 2 +-
content/collection-archive/index.html | 9 +-
content/docs/batch-example/index.html | 37 ++--
content/docs/best-practice-broker/index.html | 10 +-
content/docs/best-practice-consumer/index.html | 8 +-
content/docs/best-practice-namesvr/index.html | 8 +-
content/docs/best-practice-producer/index.html | 8 +-
content/docs/broadcast-example/index.html | 78 ++++----
content/docs/cli-admin-tool/index.html | 10 +-
content/docs/cluster-deployment/index.html | 8 +-
content/docs/code-guidelines/index.html | 8 +-
content/docs/core-concept/index.html | 8 +-
content/docs/documentation/index.html | 8 +-
content/docs/faq/index.html | 28 +--
content/docs/filter-by-sql92-example/index.html | 63 +++---
content/docs/motivation/index.html | 26 +--
content/docs/order-example/index.html | 113 +++++------
content/docs/pull-request/index.html | 8 +-
content/docs/quick-start/index.html | 13 +-
content/docs/release-manual.html | 8 +-
content/docs/rmq-arc/index.html | 24 +--
content/docs/rmq-deployment/index.html | 18 +-
content/docs/roadmap/index.html | 8 +-
content/docs/schedule-example/index.html | 15 +-
content/docs/simple-example/index.html | 192 ++++++-------------
content/dowloading/releases/index.html | 8 +-
content/feed.xml | 2 +-
content/index.html | 28 +--
31 files changed, 342 insertions(+), 426 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/about/contact/index.html
----------------------------------------------------------------------
diff --git a/content/about/contact/index.html b/content/about/contact/index.html
index 84ea58b..00117ad 100644
--- a/content/about/contact/index.html
+++ b/content/about/contact/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -212,7 +212,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="CONTACT">
<meta itemprop="description" content="Contact.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 29, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/about/rewards/index.html
----------------------------------------------------------------------
diff --git a/content/about/rewards/index.html b/content/about/rewards/index.html
index 6471919..3f3a08e 100644
--- a/content/about/rewards/index.html
+++ b/content/about/rewards/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -212,7 +212,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="REWARDS">
<meta itemprop="description" content="Rewards.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="January 25, 2017">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/about/team/index.html
----------------------------------------------------------------------
diff --git a/content/about/team/index.html b/content/about/team/index.html
index f1a3c11..c6f545e 100644
--- a/content/about/team/index.html
+++ b/content/about/team/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -212,7 +212,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="TEAM">
<meta itemprop="description" content="Project team.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 29, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/archive-layout-with-content/index.html
----------------------------------------------------------------------
diff --git a/content/archive-layout-with-content/index.html b/content/archive-layout-with-content/index.html
index 397751c..e85d70b 100644
--- a/content/archive-layout-with-content/index.html
+++ b/content/archive-layout-with-content/index.html
@@ -869,7 +869,7 @@
<h2 class="archive__item-title" itemprop="headline">
- <a href="/docs/filter-by-sql92-example/" rel="permalink">Filter By SQL92 Example </a>
+ <a href="/docs/filter-by-sql92-example/" rel="permalink">Filter Example </a>
</h2>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/collection-archive/index.html
----------------------------------------------------------------------
diff --git a/content/collection-archive/index.html b/content/collection-archive/index.html
index caf2549..967294a 100644
--- a/content/collection-archive/index.html
+++ b/content/collection-archive/index.html
@@ -403,7 +403,7 @@
</h2>
- <p class="archive__item-excerpt" itemprop="description">In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for ...</p>
+ <p class="archive__item-excerpt" itemprop="description">At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async commun...</p>
</article>
</div>
@@ -553,7 +553,10 @@
</h2>
- <p class="archive__item-excerpt" itemprop="description">The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the document...</p>
+ <p class="archive__item-excerpt" itemprop="description">The following questions are frequently asked with regard to the RocketMQ project in general.
+
+General
+1. Why did we create rocketmq project instead of select...</p>
</article>
</div>
@@ -780,7 +783,7 @@
<h2 class="archive__item-title" itemprop="headline">
- <a href="/docs/filter-by-sql92-example/" rel="permalink">Filter By SQL92 Example
+ <a href="/docs/filter-by-sql92-example/" rel="permalink">Filter Example
</a>
</h2>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/batch-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/batch-example/index.html b/content/docs/batch-example/index.html
index 38b57e0..ee5a91c 100644
--- a/content/docs/batch-example/index.html
+++ b/content/docs/batch-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Batch Example">
<meta itemprop="description" content="How to use batch in Rocketmq">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="April 25, 2017">
<div class="page__inner-wrap">
@@ -446,7 +446,7 @@
<nav class="toc">
<header><h4 class="nav__title"><i class="fa fa-file-text"></i> On This Page</h4></header>
<ul class="toc__menu" id="markdown-toc">
- <li><a href="#when-to-use-batch" id="markdown-toc-when-to-use-batch">When to use batch</a></li>
+ <li><a href="#why-batch" id="markdown-toc-why-batch">Why batch?</a></li>
<li><a href="#usage-constraints" id="markdown-toc-usage-constraints">Usage constraints</a></li>
<li><a href="#how-to-use-batch" id="markdown-toc-how-to-use-batch">How to use batch</a></li>
<li><a href="#split-into-lists" id="markdown-toc-split-into-lists">Split into lists</a></li>
@@ -455,25 +455,16 @@
</nav>
</aside>
-<h4 id="when-to-use-batch">When to use batch</h4>
-<p>Batch is not for packaging but improving performance of small messages. So the messages of the same batch should act the same role, no more effort should be taken to split the batch.
-No split has another important advantage, messages of the same batch should be sent atomically, that is all successfully or all unsuccessfully, of which the importance is self-evident.
-So performance and atomicity are the original intentions, which will reflect on the usage constraints.
-That is to say, if you want to improve performance for small messages or to send messages atomically, batch is a nice solution for you.</p>
-<h4 id="usage-constraints">Usage constraints</h4>
-<p>Performance and atomicity are worth the following constraints:
-messages of the same batch should have:</p>
+<h3 id="why-batch">Why batch?</h3>
+<p>Sending messages in batch improves performance of delivering small messages.</p>
-<ol>
- <li>same topic: If they belong to different topics(internally the queues), then may be sent to different brokers, which will against atomicity.</li>
- <li>same waitStoreMsgOK: also differences will against atomicity.</li>
- <li>no delay level: If we care about the delay level, we need to decode the internal properties of every message, which will cause much performance loss.</li>
-</ol>
+<h3 id="usage-constraints">Usage constraints</h3>
+<p>Messages of the same batch should have: same topic, same waitStoreMsgOK and no schedule support.</p>
-<p>And the most important, the total size, that is the sum of size of each message in one batch, should be no more than 1M.</p>
+<p>Besides, the total size of the messages in one batch should be no more than 1MiB.</p>
-<h4 id="how-to-use-batch">How to use batch</h4>
-<p>If you just send several small messages in a time and do not need to worry about the size limit, it is easy to use batch:</p>
+<h3 id="how-to-use-batch">How to use batch</h3>
+<p>If you just send messages of no more than 1MiB at a time, it is easy to use batch:</p>
<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">String</span> <span class="n">topic</span> <span class="o">=</span> <span class="s">"BatchTest"</span><span class="o">;</span>
<span class="n">List</span><span class="o"><</span><span class="n">Message</span><span class="o">></span> <span class="n">messages</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o"><>();</span>
@@ -489,8 +480,8 @@ messages of the same batch should have:</p>
</code></pre>
</div>
-<h4 id="split-into-lists">Split into lists</h4>
-<p>The complexity only grow when you send large batch and you may not sure if it exceeds the size limit (1M).</p>
+<h3 id="split-into-lists">Split into lists</h3>
+<p>The complexity only grow when you send large batch and you may not sure if it exceeds the size limit (1MiB).</p>
<p>At this time, you’d better split the lists:</p>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/best-practice-broker/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-broker/index.html b/content/docs/best-practice-broker/index.html
index a07c9f8..5a8cf90 100644
--- a/content/docs/best-practice-broker/index.html
+++ b/content/docs/best-practice-broker/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Broker">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 25, 2016">
<div class="page__inner-wrap">
@@ -501,7 +501,7 @@ If you just want to make it easy, you may only need a ASYNC_MASTER without SLAVE
<nav class="pagination">
- <a href="/docs/filter-by-sql92-example/" class="pagination--pager" title="Filter By SQL92 Example
+ <a href="/docs/filter-by-sql92-example/" class="pagination--pager" title="Filter Example
">Previous</a>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/best-practice-consumer/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-consumer/index.html b/content/docs/best-practice-consumer/index.html
index 5b88af1..86232c1 100644
--- a/content/docs/best-practice-consumer/index.html
+++ b/content/docs/best-practice-consumer/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Consumer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 25, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/best-practice-namesvr/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-namesvr/index.html b/content/docs/best-practice-namesvr/index.html
index 6221ca7..7105eab 100644
--- a/content/docs/best-practice-namesvr/index.html
+++ b/content/docs/best-practice-namesvr/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For NameServer">
<meta itemprop="description" content="In Apache RocketMQ, name servers are designed to coordinate each component of the distributed systemand fulfill much of this responsibility through managing topic route information.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 25, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/best-practice-producer/index.html
----------------------------------------------------------------------
diff --git a/content/docs/best-practice-producer/index.html b/content/docs/best-practice-producer/index.html
index a936d35..ee0888a 100644
--- a/content/docs/best-practice-producer/index.html
+++ b/content/docs/best-practice-producer/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Best Practice For Producer">
<meta itemprop="description" content="Some useful tips for users.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 25, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/broadcast-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/broadcast-example/index.html b/content/docs/broadcast-example/index.html
index 0056f78..8343868 100644
--- a/content/docs/broadcast-example/index.html
+++ b/content/docs/broadcast-example/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Broadcasting">
<meta itemprop="description" content="How to send broadcast messages in Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="April 25, 2017">
<div class="page__inner-wrap">
@@ -446,31 +446,25 @@
<nav class="toc">
<header><h4 class="nav__title"><i class="fa fa-file-text"></i> On This Page</h4></header>
<ul class="toc__menu" id="markdown-toc">
- <li><a href="#what-is-broadcasting" id="markdown-toc-what-is-broadcasting">What is Broadcasting</a></li>
- <li><a href="#how-to-use" id="markdown-toc-how-to-use">How to use</a> <ul>
- <li><a href="#firstproduce-message-as-before" id="markdown-toc-firstproduce-message-as-before">First,Produce message as before</a></li>
- <li><a href="#secondconsume-message-in-broadcast-mode" id="markdown-toc-secondconsume-message-in-broadcast-mode">Second,Consume message in Broadcast mode</a></li>
- </ul>
- </li>
+ <li><a href="#what-is-broadcasting" id="markdown-toc-what-is-broadcasting">What is broadcasting</a></li>
+ <li><a href="#producer-example" id="markdown-toc-producer-example">Producer example</a></li>
+ <li><a href="#consumer-example" id="markdown-toc-consumer-example">Consumer example</a></li>
</ul>
</nav>
</aside>
-<h4 id="what-is-broadcasting">What is Broadcasting</h4>
-<p>Broadcasting is when sending a meeage to a topic,all subscribers of the topic will receive the message even if they are in the same consumer group.If you want all subscribers in a group receive all the messages in a topic,broadcasting is a good choice.</p>
-
-<h4 id="how-to-use">How to use</h4>
+<h3 id="what-is-broadcasting">What is broadcasting</h3>
+<p>Broadcasting is sending a message to all subscribers of a topic. If you want all subscribers receive messages about a topic, broadcasting is a good choice.</p>
-<h5 id="firstproduce-message-as-before">First,Produce message as before</h5>
+<h3 id="producer-example">Producer example</h3>
-<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQProducer</span><span class="o">(</span><span class="s">"ProducerGroupName"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">BroadcastProducer</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="n">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQProducer</span><span class="o">(</span><span class="s">"ProducerGroupName"</span><span class="o">);</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
-<span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
-
-<span class="k">for</span> <span class="o">(</span><span class="kt">int</span> <span class="n">i</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span> <span class="n">i</span> <span class="o"><</span> <span class="mi">10000000</span><span class="o">;</span> <span class="n">i</span><span class="o">++){</span>
- <span class="k">try</span> <span class="o">{</span>
- <span class="o">{</span>
+ <span class="k">for</span> <span class="o">(</span><span class="kt">int</span> <span class="n">i</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span> <span class="n">i</span> <span class="o"><</span> <span class="mi">100</span><span class="o">;</span> <span class="n">i</span><span class="o">++){</span>
<span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
<span class="s">"TagA"</span><span class="o">,</span>
<span class="s">"OrderID188"</span><span class="o">,</span>
@@ -478,42 +472,42 @@
<span class="n">SendResult</span> <span class="n">sendResult</span> <span class="o">=</span> <span class="n">producer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
<span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="s">"%s%n"</span><span class="o">,</span> <span class="n">sendResult</span><span class="o">);</span>
<span class="o">}</span>
-
- <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">Exception</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">e</span><span class="o">.</span><span class="na">printStackTrace</span><span class="o">();</span>
+ <span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
<span class="o">}</span>
<span class="o">}</span>
-<span class="n">producer</span><span class="o">.</span><span class="na">shutdown</span><span class="o">();</span>
</code></pre>
</div>
-<h5 id="secondconsume-message-in-broadcast-mode">Second,Consume message in Broadcast mode</h5>
+<h3 id="consumer-example">Consumer example</h3>
-<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name_1"</span><span class="o">);</span>
+<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="kd">public</span> <span class="kd">class</span> <span class="nc">BroadcastConsumer</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <span class="n">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"example_group_name"</span><span class="o">);</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="n">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">setConsumeFromWhere</span><span class="o">(</span><span class="n">ConsumeFromWhere</span><span class="o">.</span><span class="na">CONSUME_FROM_FIRST_OFFSET</span><span class="o">);</span>
-<span class="c1">//set to broadcast mode</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">setMessageModel</span><span class="o">(</span><span class="n">MessageModel</span><span class="o">.</span><span class="na">BROADCASTING</span><span class="o">);</span>
+ <span class="c1">//set to broadcast mode</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">setMessageModel</span><span class="o">(</span><span class="n">MessageModel</span><span class="o">.</span><span class="na">BROADCASTING</span><span class="o">);</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="s">"TagA || TagC || TagD"</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="s">"TagA || TagC || TagD"</span><span class="o">);</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="n">MessageListenerConcurrently</span><span class="o">()</span> <span class="o">{</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="n">MessageListenerConcurrently</span><span class="o">()</span> <span class="o">{</span>
- <span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="n">List</span><span class="o"><</span><span class="n">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span>
- <span class="n">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="n">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o">+</span> <span class="s">"%n"</span><span class="o">);</span>
- <span class="k">return</span> <span class="n">ConsumeConcurrentlyStatus</span><span class="o">.</span><span class="na">CONSUME_SUCCESS</span><span class="o">;</span>
- <span class="o">}</span>
-<span class="o">});</span>
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="n">ConsumeConcurrentlyStatus</span> <span class="nf">consumeMessage</span><span class="o">(</span><span class="n">List</span><span class="o"><</span><span class="n">MessageExt</span><span class="o">></span> <span class="n">msgs</span><span class="o">,</span>
+ <span class="n">ConsumeConcurrentlyContext</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="n">Thread</span><span class="o">.</span><span class="na">currentThread</span><span class="o">().</span><span class="na">getName</span><span class="o">()</span> <span class="o">+</span> <span class="s">" Receive New Messages: "</span> <span class="o">+</span> <span class="n">msgs</span> <span class="o">+</span> <span class="s">"%n"</span><span class="o">);</span>
+ <span class="k">return</span> <span class="n">ConsumeConcurrentlyStatus</span><span class="o">.</span><span class="na">CONSUME_SUCCESS</span><span class="o">;</span>
+ <span class="o">}</span>
+ <span class="o">});</span>
-<span class="n">consumer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
-<span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="s">"Broadcast Consumer Started.%n"</span><span class="o">);</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">printf</span><span class="o">(</span><span class="s">"Broadcast Consumer Started.%n"</span><span class="o">);</span>
+ <span class="o">}</span>
+<span class="o">}</span>
</code></pre>
</div>
-<p>Enjoy it.</p>
</section>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/cli-admin-tool/index.html
----------------------------------------------------------------------
diff --git a/content/docs/cli-admin-tool/index.html b/content/docs/cli-admin-tool/index.html
index e7492d7..a04390f 100644
--- a/content/docs/cli-admin-tool/index.html
+++ b/content/docs/cli-admin-tool/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="CLI Admin Tool">
<meta itemprop="description" content="RocketMQ provides a CLI admin tool belt to query, manage and diagnose various issues.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 17, 2016">
<div class="page__inner-wrap">
@@ -465,7 +465,7 @@
<p>The admin tool is shipped along with RocketMQ. Either you download a pre-built binary version or build from source by yourself, you already have it.</p>
-<p>In case you have source code, the <a href="https://github.com/apache/incubator-rocketmq/tree/master/tools">rocketmq-tools module</a> contains its source code.</p>
+<p>In case you don’t have source code, the <a href="https://github.com/apache/incubator-rocketmq/tree/master/tools">rocketmq-tools module</a> contains its source code.</p>
<h1 id="how-to-use">How to use</h1>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/cluster-deployment/index.html
----------------------------------------------------------------------
diff --git a/content/docs/cluster-deployment/index.html b/content/docs/cluster-deployment/index.html
index e8b6053..8ec4cdd 100644
--- a/content/docs/cluster-deployment/index.html
+++ b/content/docs/cluster-deployment/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Cluster Configuration and Deployment">
<meta itemprop="description" content="Prerequisite">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 17, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/code-guidelines/index.html
----------------------------------------------------------------------
diff --git a/content/docs/code-guidelines/index.html b/content/docs/code-guidelines/index.html
index 423459a..42558bc 100644
--- a/content/docs/code-guidelines/index.html
+++ b/content/docs/code-guidelines/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Coding Guidelines">
<meta itemprop="description" content="Apache RocketMQ Coding Guidelines">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 30, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/core-concept/index.html
----------------------------------------------------------------------
diff --git a/content/docs/core-concept/index.html b/content/docs/core-concept/index.html
index ce24804..0ec46d7 100644
--- a/content/docs/core-concept/index.html
+++ b/content/docs/core-concept/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Core Concept">
<meta itemprop="description" content="">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 17, 2016">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/documentation/index.html
----------------------------------------------------------------------
diff --git a/content/docs/documentation/index.html b/content/docs/documentation/index.html
index b83b207..13cc0d6 100644
--- a/content/docs/documentation/index.html
+++ b/content/docs/documentation/index.html
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -429,7 +429,7 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Documentation">
<meta itemprop="description" content="Apache RocketMQ Documentation">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="March 02, 2017">
<div class="page__inner-wrap">
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/faq/index.html
----------------------------------------------------------------------
diff --git a/content/docs/faq/index.html b/content/docs/faq/index.html
index d759e83..2db6b4a 100644
--- a/content/docs/faq/index.html
+++ b/content/docs/faq/index.html
@@ -18,7 +18,7 @@
-<meta name="description" content="The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the documentation or ask the community.General1. Why create rocketmq project instead of selecting other products?In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability. So we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss.">
+<meta name="description" content="The following questions are frequently asked with regard to the RocketMQ project in general.General1. Why did we create rocketmq project instead of selecting other products?Please refer to Why RocketMQ">
@@ -30,13 +30,13 @@
- <meta property="og:description" content="The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the documentation or ask the community.General1. Why create rocketmq project instead of selecting other products?In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability. So we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss.">
+ <meta property="og:description" content="The following questions are frequently asked with regard to the RocketMQ project in general.General1. Why did we create rocketmq project instead of selecting other products?Please refer to Why RocketMQ">
<meta name="twitter:site" content="@ApacheRocketMQ">
<meta name="twitter:title" content="Frequently Asked Questions">
- <meta name="twitter:description" content="The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the documentation or ask the community.General1. Why create rocketmq project instead of selecting other products?In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability. So we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss.">
+ <meta name="twitter:description" content="The following questions are frequently asked with regard to the RocketMQ project in general.General1. Why did we create rocketmq project instead of selecting other products?Please refer to Why RocketMQ">
<meta name="twitter:url" content="">
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -428,8 +428,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Frequently Asked Questions">
- <meta itemprop="description" content="The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the documentation or ask the community.General1. Why create rocketmq project instead of selecting other products?In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability. So we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="description" content="The following questions are frequently asked with regard to the RocketMQ project in general.General1. Why did we create rocketmq project instead of selecting other products?Please refer to Why RocketMQ">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 28, 2016">
<div class="page__inner-wrap">
@@ -442,21 +442,21 @@
<section class="page__content" itemprop="text">
- <p>The following questions are frequently asked with regard to the RocketMQ project in general. If you have further questions, make sure to consult the documentation or ask the community.</p>
+ <p>The following questions are frequently asked with regard to the RocketMQ project in general.</p>
<h2 id="general">General</h2>
-<h3 id="1-why-create-rocketmq-project-instead-of-selecting-other-products">1. Why create rocketmq project instead of selecting other products?</h3>
-<p>In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability. So we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss.</p>
+<h3 id="1-why-did-we-create-rocketmq-project-instead-of-selecting-other-products">1. Why did we create rocketmq project instead of selecting other products?</h3>
+<p>Please refer to <a href="/docs/motivation/">Why RocketMQ</a></p>
<h3 id="2-do-i-have-to-install-other-softewares-such-as-zookeeper-to-use-rocketmq">2. Do I have to install other softewares, such as zookeeper, to use RocketMQ?</h3>
-<p>No. RocketMQ can run without any other softeware, you can run broker server and name server indepentently. Aslo, the topic can be created by using command, such as sh mqadmin updatetopic etc. After creating successfully, you enjoy yourself with RocketMQ.</p>
+<p>No. RocketMQ can run independently.</p>
<h2 id="usage">Usage</h2>
<h3 id="1-where-does-the-newly-created-consumer-id-start-consuming-messages">1. Where does the newly created Consumer ID start consuming messages?</h3>
<ol>
- <li>If the topic sends a message within three days, then the consumer start consume message from the first message saved in the server.</li>
- <li>If the topic sends a message in three days ago, the consumer start consume message from the latest message in the server, in other words, starting to consume the message queue tail.</li>
+ <li>If the topic sends a message within three days, then the consumer start consuming messages from the first message saved in the server.</li>
+ <li>If the topic sends a message three days ago, the consumer start consuming messages from the latest message in the server, in other words, starting from the tail of message queue.</li>
<li>If such consumer is the second reboot, then start to consumer message from the last consumption location.</li>
</ol>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/filter-by-sql92-example/index.html
----------------------------------------------------------------------
diff --git a/content/docs/filter-by-sql92-example/index.html b/content/docs/filter-by-sql92-example/index.html
index e0c7c4b..7e98fdb 100644
--- a/content/docs/filter-by-sql92-example/index.html
+++ b/content/docs/filter-by-sql92-example/index.html
@@ -13,7 +13,7 @@
-<title>Filter By SQL92 Example - Apache RocketMQ</title>
+<title>Filter Example - Apache RocketMQ</title>
@@ -25,7 +25,7 @@
<meta property="og:locale" content="en">
<meta property="og:site_name" content="Apache RocketMQ">
-<meta property="og:title" content="Filter By SQL92 Example">
+<meta property="og:title" content="Filter Example">
@@ -35,7 +35,7 @@
<meta name="twitter:site" content="@ApacheRocketMQ">
- <meta name="twitter:title" content="Filter By SQL92 Example">
+ <meta name="twitter:title" content="Filter Example">
<meta name="twitter:description" content="How to filter messages by SQL92 in Apache RocketMQ.">
<meta name="twitter:url" content="">
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -427,22 +427,22 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
- <meta itemprop="headline" content="Filter By SQL92 Example">
+ <meta itemprop="headline" content="Filter Example">
<meta itemprop="description" content="How to filter messages by SQL92 in Apache RocketMQ.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="April 27, 2017">
<div class="page__inner-wrap">
<header>
- <h1 class="page__title" itemprop="headline">Filter By SQL92 Example
+ <h1 class="page__title" itemprop="headline">Filter Example
</h1>
</header>
<section class="page__content" itemprop="text">
- <p>In most cases, tag is simple and useful to select message as you want. For example:</p>
+ <p>In most cases, tag is a simple and useful design to select message you want. For example:</p>
<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"CID_EXAMPLE"</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TOPIC"</span><span class="o">,</span> <span class="s">"TAGA || TAGB || TAGC"</span><span class="o">);</span>
@@ -455,18 +455,19 @@
<ul class="toc__menu" id="markdown-toc">
<li><a href="#principle" id="markdown-toc-principle">Principle</a></li>
<li><a href="#grammars" id="markdown-toc-grammars">Grammars</a></li>
- <li><a href="#interface" id="markdown-toc-interface">Interface</a></li>
- <li><a href="#examples" id="markdown-toc-examples">Examples</a></li>
+ <li><a href="#usage-constraints" id="markdown-toc-usage-constraints">Usage constraints</a></li>
+ <li><a href="#producer-example" id="markdown-toc-producer-example">Producer example</a></li>
+ <li><a href="#consumer-example" id="markdown-toc-consumer-example">Consumer example</a></li>
</ul>
</nav>
</aside>
-<p>Consumer will recieve messages that contains TAGA or TAGB or TAGC. But the limitation is that one message only could has one tag, this may be not suitable for more sophisticated scenarios.At this time, you could use sql expression to select messages.</p>
+<p>The consumer will recieve messages that contains TAGA or TAGB or TAGC. But the limitation is that one message only can have one tag, and this may not work for sophisticated scenarios. In this case, you can use SQL expression to filter out messages.</p>
<h3 id="principle">Principle</h3>
-<p>SQL feature could do some calculation through the properties you put in messages when sending. Under the grammars defined by RocketMQ, you can implement some interesting logic as you want. Here is an example:</p>
+<p>SQL feature could do some calculation through the properties you put in when sending messages. Under the grammars defined by RocketMQ, you can implement some interesting logic. Here is an example:</p>
<pre>
------------
@@ -487,41 +488,36 @@
<h3 id="grammars">Grammars</h3>
-<p>RocketMQ only defines some basic grammars to support this feature. Not enough ? You could also extend it easily.</p>
+<p>RocketMQ only defines some basic grammars to support this feature. You could also extend it easily.</p>
<ol>
<li>Numeric comparison, like <code class="highlighter-rouge">></code>, <code class="highlighter-rouge">>=</code>, <code class="highlighter-rouge"><</code>, <code class="highlighter-rouge"><=</code>, <code class="highlighter-rouge">BETWEEN</code>, <code class="highlighter-rouge">=</code>;</li>
<li>Character comparison, like <code class="highlighter-rouge">=</code>, <code class="highlighter-rouge"><></code>, <code class="highlighter-rouge">IN</code>;</li>
<li><code class="highlighter-rouge">IS NULL</code> or <code class="highlighter-rouge">IS NOT NULL</code>;</li>
- <li>Logical <code class="highlighter-rouge">AND</code>, logical <code class="highlighter-rouge">OR</code>, logical <code class="highlighter-rouge">NOT</code>;</li>
+ <li>Logical <code class="highlighter-rouge">AND</code>, <code class="highlighter-rouge">OR</code>, <code class="highlighter-rouge">NOT</code>;</li>
</ol>
-<p>Constant type are:</p>
+<p>Constant types are:</p>
<ol>
<li>Numeric, like 123, 3.1415;</li>
- <li>Character, like ‘abc’, must be maked with single quotes;</li>
+ <li>Character, like ‘abc’, must be made with single quotes;</li>
<li><code class="highlighter-rouge">NULL</code>, special constant;</li>
<li>Boolean, <code class="highlighter-rouge">TRUE</code> or <code class="highlighter-rouge">FALSE</code>;</li>
</ol>
-<h3 id="interface">Interface</h3>
+<h3 id="usage-constraints">Usage constraints</h3>
-<p>Only push consumer could select messages by SQL92.The interface is:</p>
+<p>Only push consumer could select messages by SQL92. The interface is:</p>
<p><code class="highlighter-rouge">public void subscribe(final String topic, final MessageSelector messageSelector)</code></p>
-<h3 id="examples">Examples</h3>
+<h3 id="producer-example">Producer example</h3>
<p>You can put properties in message through method <code class="highlighter-rouge">putUserProperty</code> when sending.</p>
<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">DefaultMQProducer</span> <span class="n">producer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQProducer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name"</span><span class="o">);</span>
-<span class="k">try</span> <span class="o">{</span>
- <span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
-<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">MQClientException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">e</span><span class="o">.</span><span class="na">printStackTrace</span><span class="o">();</span>
- <span class="k">return</span><span class="o">;</span>
-<span class="o">}</span>
+<span class="n">producer</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
<span class="n">Message</span> <span class="n">msg</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Message</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span>
<span class="n">tag</span><span class="o">,</span>
@@ -536,17 +532,14 @@
</code></pre>
</div>
+<h3 id="consumer-example">Consumer example</h3>
+
<p>Use <code class="highlighter-rouge">MessageSelector.bySql</code> to select messages through SQL92 when consuming.</p>
<div class="language-java highlighter-rouge"><pre class="highlight"><code><span class="n">DefaultMQPushConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DefaultMQPushConsumer</span><span class="o">(</span><span class="s">"please_rename_unique_group_name_4"</span><span class="o">);</span>
-<span class="k">try</span> <span class="o">{</span>
- <span class="c1">// only subsribe messages have property a, also a >=0 and a <= 3</span>
- <span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="n">MessageSelector</span><span class="o">.</span><span class="na">bySql</span><span class="o">(</span><span class="s">"a between 0 and 3"</span><span class="o">);</span>
-<span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">MQClientException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">e</span><span class="o">.</span><span class="na">printStackTrace</span><span class="o">();</span>
- <span class="k">return</span><span class="o">;</span>
-<span class="o">}</span>
+<span class="c1">// only subsribe messages have property a, also a >=0 and a <= 3</span>
+<span class="n">consumer</span><span class="o">.</span><span class="na">subscribe</span><span class="o">(</span><span class="s">"TopicTest"</span><span class="o">,</span> <span class="n">MessageSelector</span><span class="o">.</span><span class="na">bySql</span><span class="o">(</span><span class="s">"a between 0 and 3"</span><span class="o">);</span>
<span class="n">consumer</span><span class="o">.</span><span class="na">registerMessageListener</span><span class="o">(</span><span class="k">new</span> <span class="n">MessageListenerConcurrently</span><span class="o">()</span> <span class="o">{</span>
<span class="nd">@Override</span>
@@ -577,7 +570,7 @@
<h4 class="page__share-title">Share on</h4>
- <a href="https://twitter.com/intent/tweet?via=ApacheRocketMQ&text=Filter By SQL92 Example /docs/filter-by-sql92-example/" class="btn btn--twitter" title="Share on Twitter"><i class="fa fa-fw fa-twitter" aria-hidden="true"></i><span> Twitter</span></a>
+ <a href="https://twitter.com/intent/tweet?via=ApacheRocketMQ&text=Filter Example /docs/filter-by-sql92-example/" class="btn btn--twitter" title="Share on Twitter"><i class="fa fa-fw fa-twitter" aria-hidden="true"></i><span> Twitter</span></a>
<a href="https://www.facebook.com/sharer/sharer.php?u=/docs/filter-by-sql92-example/" class="btn btn--facebook" title="Share on Facebook"><i class="fa fa-fw fa-facebook" aria-hidden="true"></i><span> Facebook</span></a>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq-site/blob/94c21bba/content/docs/motivation/index.html
----------------------------------------------------------------------
diff --git a/content/docs/motivation/index.html b/content/docs/motivation/index.html
index f916c6c..3f020b9 100644
--- a/content/docs/motivation/index.html
+++ b/content/docs/motivation/index.html
@@ -18,7 +18,7 @@
-<meta name="description" content="In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for async communication, search, social network activity stream, data pipeline, even in our trade order process. As our trade business throughput rises more and more inconceivably, pressure originating from our messaging cluster also become more and more obvious.">
+<meta name="description" content="At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.">
@@ -30,13 +30,13 @@
- <meta property="og:description" content="In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for async communication, search, social network activity stream, data pipeline, even in our trade order process. As our trade business throughput rises more and more inconceivably, pressure originating from our messaging cluster also become more and more obvious.">
+ <meta property="og:description" content="At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.">
<meta name="twitter:site" content="@ApacheRocketMQ">
<meta name="twitter:title" content="Motivation">
- <meta name="twitter:description" content="In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for async communication, search, social network activity stream, data pipeline, even in our trade order process. As our trade business throughput rises more and more inconceivably, pressure originating from our messaging cluster also become more and more obvious.">
+ <meta name="twitter:description" content="At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.">
<meta name="twitter:url" content="">
@@ -57,7 +57,7 @@
<meta property="og:type" content="article">
- <meta property="article:published_time" content="2017-06-02T15:31:28+08:00">
+ <meta property="article:published_time" content="2017-06-06T21:20:18+08:00">
@@ -183,7 +183,7 @@
- <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
+ <li><a href="/docs/motivation/" class="active">Why RocketMQ</a></li>
@@ -191,7 +191,7 @@
- <li><a href="/docs/motivation/" class="active">Why RocketMQ</a></li>
+ <li><a href="/docs/quick-start/" class="">Quick Start</a></li>
@@ -428,8 +428,8 @@
<article class="page" itemscope itemtype="http://schema.org/CreativeWork">
<meta itemprop="headline" content="Motivation">
- <meta itemprop="description" content="In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for async communication, search, social network activity stream, data pipeline, even in our trade order process. As our trade business throughput rises more and more inconceivably, pressure originating from our messaging cluster also become more and more obvious.">
- <meta itemprop="datePublished" content="June 02, 2017">
+ <meta itemprop="description" content="At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.">
+ <meta itemprop="datePublished" content="June 06, 2017">
<meta itemprop="dateModified" content="December 17, 2016">
<div class="page__inner-wrap">
@@ -442,7 +442,7 @@
<section class="page__content" itemprop="text">
- <p>In the early stages, we constructed our distributed messaging middleware on the basis of ActiveMQ 5.x(less than 5.3). Our international business uses it for async communication, search, social network activity stream, data pipeline, even in our trade order process. As our trade business throughput rises more and more inconceivably, pressure originating from our messaging cluster also become more and more obvious.</p>
+ <p>At early stages, we constructed our distributed messaging middleware based on ActiveMQ 5.x(prior to 5.3). Our multinational business uses it for async communication, search, social network activity stream, data pipeline, even in its trade processes. As our trade business throughput rises, pressure originating from our messaging cluster also become urgent.</p>
<aside class="sidebar__right">
<nav class="toc">
@@ -457,12 +457,12 @@
<h1 id="why-rocketmq-">Why RocketMQ ?</h1>
-<p>Based on our observations and research, with more and more queues and virtual topics in use, ActiveMQ IO module becomes a bottleneck. In some cases, slower consumers can slow down the producers. We tried our best efforts to handle this problems through throttling, circuit breaker or degradation, but it cannot scale out gracefully. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements such as low latency and high reliability, see <a href="/rocketmq/how-to-support-more-queues-in-rocketmq/">here</a> for details.</p>
+<p>Based on our research, with increased queues and virtual topics in use, ActiveMQ IO module reaches a bottleneck. We tried our best to solve this problem through throttling, circuit breaker or degradation, but it didn’t work well. So we begin to focus on the popular messaging solution Kafka at that time. Unfortunately, Kafka can not meet our requirements especially low latency and high reliability, see <a href="/rocketmq/how-to-support-more-queues-in-rocketmq/">here</a> for details.</p>
-<p>In this context, we decided to innovate a new messaging middleware to handle a broad set of use cases, ranging from traditional publish/subscribe scenario to demandingly high volume realtime transaction system that tolerates no message loss. We also created a cornerstone product based on RocketMQ, a Platform as a Service (PaaS) product named the
-<a href="https://intl.aliyun.com/">Alibaba Cloud Platform</a>. Today, more than 100 companies are using the RocketMQ open source version in their business solutions. We believe RocketMQ can benefit more people, so we would like to share it around the world.</p>
+<p>In this context, we decided to invent a new messaging engine to handle a broader set of use cases, ranging from traditional pub/sub scenarios to high volume realtime zero-loss tolerance transaction system. We believe this solution can be beneficial, so we would like to open source it to the community. Today, more than 100 companies are using the open source version of RocketMQ in their business. We also published a commercial distribution based on RocketMQ, a Platform as a Service (PaaS) product called the
+<a href="https://intl.aliyun.com/">Alibaba Cloud Platform</a>.</p>
-<p>The following are some different design between RocketMQ, ActiveMQ and Kafka（They are the apache’s most popular messaging solutions according to <a href="https://github.com/akullpp/awesome-java">awesome-java</a>):</p>
+<p>The following table demonstrates the comparison between RocketMQ, ActiveMQ and Kafka (Apache’s most popular messaging solutions according to <a href="https://github.com/akullpp/awesome-java">awesome-java</a>):</p>
<h1 id="rocketmq-vs-activemq-vs-kafka">RocketMQ vs. ActiveMQ vs. Kafka</h1>