You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/07/05 14:30:16 UTC
[rocketmq-site] branch new-official-website updated (e0161343 -> cb98481f)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
from e0161343 Merge pull request #149 from SamanthaWangdl/master
add 8ba729a4 Add order message, transaction msg, batch msg, delay msg document for new-new-official-website
add 5efac576 Add order message, transaction msg, batch msg, delay msg document for new-new-official-website
new dcf531ed Merge remote-tracking branch 'origin/new-official-website' into new-official-website
new cb98481f Merge to new code
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../06message2.md" | 62 ++++++++++
.../07message3.md" | 45 ++++++-
.../08message4.md" | 26 ++++
.../09message5.md" | 134 ++++++++++++++++++++-
docs/picture/batch.png | Bin 0 -> 22083 bytes
...2\213\345\212\241\346\266\210\346\201\2571.png" | Bin 0 -> 138706 bytes
...2\213\345\212\241\346\266\210\346\201\2572.png" | Bin 0 -> 126379 bytes
...66\210\346\201\257\345\217\221\351\200\201.png" | Bin 0 -> 121795 bytes
8 files changed, 265 insertions(+), 2 deletions(-)
create mode 100644 docs/picture/batch.png
create mode 100644 "docs/picture/\344\272\213\345\212\241\346\266\210\346\201\2571.png"
create mode 100644 "docs/picture/\344\272\213\345\212\241\346\266\210\346\201\2572.png"
create mode 100644 "docs/picture/\351\241\272\345\272\217\346\266\210\346\201\257\345\217\221\351\200\201.png"
[rocketmq-site] 02/02: Merge to new code
Posted by ji...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
commit cb98481fa5709cc6459728468681d14e8244fa02
Author: RongtongJin <ji...@mails.ucas.ac.cn>
AuthorDate: Tue Jul 5 22:29:59 2022 +0800
Merge to new code
---
"docs/02-\347\224\237\344\272\247\350\200\205/06message2.md" | 2 +-
"docs/02-\347\224\237\344\272\247\350\200\205/08message4.md" | 2 +-
"docs/02-\347\224\237\344\272\247\350\200\205/09message5.md" | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git "a/docs/02-\347\224\237\344\272\247\350\200\205/06message2.md" "b/docs/02-\347\224\237\344\272\247\350\200\205/06message2.md"
index 41daf549..aaee4f26 100644
--- "a/docs/02-\347\224\237\344\272\247\350\200\205/06message2.md"
+++ "b/docs/02-\347\224\237\344\272\247\350\200\205/06message2.md"
@@ -1,7 +1,7 @@
# 顺序消息发送
顺序消息是一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。在Apache RocketMQ中支持分区顺序消息，如下图所示，我们可以按照某一个标准对消息进行分区（比如图中的ShardingKey），同一个ShardingKey的消息会被分配到同一个队列中，并按照顺序被消费。顺序消息的应用场景也非常广泛，比如在创建订单的例子中，需要保证同一个订单的生成、付款和发货，这三个操作被顺序执行。如果是普通消息，订单A的消息可能会被轮询发送到不同的队列中，不同队列的消息将无法保持顺序，而顺序消息发送时将ShardingKey相同（同一订单号）的消息序路由到一个逻辑队列中。
-
+
顺序消息的代码如下所示：
diff --git "a/docs/02-\347\224\237\344\272\247\350\200\205/08message4.md" "b/docs/02-\347\224\237\344\272\247\350\200\205/08message4.md"
index b722a212..65ac207a 100644
--- "a/docs/02-\347\224\237\344\272\247\350\200\205/08message4.md"
+++ "b/docs/02-\347\224\237\344\272\247\350\200\205/08message4.md"
@@ -2,7 +2,7 @@
在对吞吐率有一定要求的情况下，Apache RocketMQ可以将一些消息聚成一批以后进行发送，可以增加吞吐率，并减少API和网络调用次数。
-
+
```java
public class SimpleBatchProducer {
diff --git "a/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md" "b/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
index e2046547..37c855a0 100644
--- "a/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
+++ "b/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
@@ -2,13 +2,13 @@
在一些对数据最终一致性有强需求的场景，可以用Apache RocketMQ 事务消息来解决，从而保证上下游数据的一致性。
-
+
事务消息发送分为两个阶段，第一阶段会发送一个半事务消息，半事务消息是指暂不能投递的消息，生产者已经成功地将消息发送到了Broker，但是Broker未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，如果发送成功则执行本地事务，并根据本地事务执行成功与否，向Broker确认半事务消息状态（commit或者rollback），半事务消息只有commit状态才会真正向下游投递。如果由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，Broker端会通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态（Commit或是Rollback）。这样最终保证了本地事务执行成功，下游就能收到消息，本地事务执行失败，下游就收不到消息。总而保证了上下游数据的一致性。
整个事务消息的详细交互流程如下图所示：
-
+
事务消息发送步骤如下：
[rocketmq-site] 01/02: Merge remote-tracking branch 'origin/new-official-website' into new-official-website
Posted by ji...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
commit dcf531ed030ae4263666fcc3c0adaeef1cb1d061
Merge: 5efac576 e0161343
Author: RongtongJin <ji...@mails.ucas.ac.cn>
AuthorDate: Tue Jul 5 22:27:19 2022 +0800
Merge remote-tracking branch 'origin/new-official-website' into new-official-website
.../default/site-docs-01-whychoose-md-68d.json | 2 +-
...4\273\213\347\273\215-01-whychoose-md-144.json" | 14 +-
...\273\213\347\273\215-02-quickstart-md-909.json" | 18 +-
...\344\273\213\347\273\215-03-whatis-md-aea.json" | 24 +
...5\274\200\345\247\213-01-whychoose-md-280.json" | 14 +-
...5\274\200\345\247\213-01-whychoose-md-4b7.json" | 22 +
...\274\200\345\247\213-02-quickstart-md-6af.json" | 24 +
...\274\200\345\247\213-02-quickstart-md-842.json" | 18 +-
...\345\274\200\345\247\213-03-whatis-md-883.json" | 24 +
...\345\274\200\345\247\213-03-whatis-md-fde.json" | 24 +
.../default/site-docs-02-quickstart-md-dee.json | 2 +-
...4\272\247\350\200\205-04-concept-1-md-a4f.json" | 24 +
...4\272\247\350\200\205-05-message-1-md-45f.json" | 24 +
...4\272\247\350\200\205-06-message-2-md-68b.json" | 24 +
...4\272\247\350\200\205-07-message-3-md-901.json" | 24 +
...4\272\247\350\200\205-08-message-4-md-76b.json" | 24 +
...4\272\247\350\200\205-09-message-5-md-1b3.json" | 24 +
.../default/site-docs-03-whatis-md-581.json | 4 +-
...0\264\271\350\200\205-11-concept-2-md-7f4.json" | 24 +
...10\350\264\271\350\200\205-12-push-md-864.json" | 24 +
...10\350\264\271\350\200\205-13-pull-md-cdb.json" | 24 +
...210\350\264\271\350\200\205-14-pop-md-e6c.json" | 24 +
.../default/site-docs-04-concept-1-md-25d.json | 4 +-
...\350\277\220\347\273\264-15-deploy-md-40e.json" | 24 +
...0\277\220\347\273\264-16-admintool-md-ef5.json" | 24 +
...0\277\220\347\273\264-17-dashboard-md-210.json" | 24 +
...50\277\220\347\273\264-18-exporter-md-d56.json" | 24 +
.../default/site-docs-05-message-1-md-233.json | 4 +-
...3\345\256\236\350\267\265-19-jvmos-md-195.json" | 24 +
...263\345\256\236\350\267\265-20-log-md-8f0.json" | 24 +
...5\256\236\350\267\265-21-subscribe-md-f78.json" | 24 +
...263\345\256\236\350\267\265-22-faq-md-231.json" | 24 +
.../default/site-docs-06-message-2-md-124.json | 4 +-
...0\351\205\215\347\275\256-23-local-md-610.json" | 24 +
...\351\205\215\347\275\256-24-server-md-98e.json" | 24 +
.../default/site-docs-07-message-3-md-9ff.json | 4 +-
...d-1d7.json => site-docs-07-streams-md-b91.json} | 17 +-
...345\205\266\344\273\226-25-streams-md-bfa.json" | 24 +
...45\205\266\344\273\226-26-connnect-md-b01.json" | 24 +
...05\266\344\273\226-27-event-bridge-md-3f9.json" | 24 +
...7-\345\205\266\344\273\226-28-mqtt-md-50b.json" | 24 +
.../default/site-docs-08-message-4-md-dd7.json | 4 +-
...7\345\215\227-29-how-to-contribute-md-d9b.json" | 24 +
...207\345\215\227-30-code-guidelines-md-fe1.json" | 24 +
...14\207\345\215\227-31-pull-request-md-c9b.json" | 24 +
...\207\345\215\227-32-release-manual-md-660.json" | 20 +
.../default/site-docs-09-message-5-md-0e2.json | 6 +-
.../default/site-docs-10-message-6-2-md-f6c.json | 11 +-
.../default/site-docs-10-message-6-md-fda.json | 4 +-
.../default/site-docs-11-concept-2-md-bcd.json | 6 +-
.../default/site-docs-12-push-md-388.json | 4 +-
.../default/site-docs-13-pull-md-1a1.json | 4 +-
.../default/site-docs-14-pop-md-982.json | 4 +-
.../default/site-docs-15-deploy-md-4cf.json | 4 +-
.../default/site-docs-16-admintool-md-407.json | 4 +-
.../default/site-docs-17-dashboard-md-bf8.json | 4 +-
.../default/site-docs-18-exporter-md-4ea.json | 4 +-
.../default/site-docs-19-jvmos-md-418.json | 4 +-
.../default/site-docs-20-log-md-462.json | 4 +-
.../default/site-docs-21-subscribe-md-853.json | 4 +-
.../default/site-docs-22-faq-md-ec4.json | 4 +-
.../default/site-docs-23-local-md-2a7.json | 4 +-
.../default/site-docs-24-server-md-396.json | 4 +-
.../default/site-docs-25-streams-md-1d7.json | 4 +-
.../default/site-docs-26-connnect-md-2a4.json | 4 +-
.../default/site-docs-27-event-bridge-md-84b.json | 4 +-
.../default/site-docs-28-mqtt-md-7aa.json | 4 +-
.../site-docs-29-how-to-contribute-md-75b.json | 4 +-
.../site-docs-30-code-guidelines-md-316.json | 4 +-
.../default/site-docs-31-pull-request-md-2b6.json | 4 +-
.../site-docs-32-release-manual-md-b3b.json | 4 +-
.../default/version-current-metadata-prop-751.json | 145 +--
.../default/docusaurus-debug-all-content-673.json | 967 ++++++++++-----------
.docusaurus/globalData.json | 195 ++---
.docusaurus/registry.js | 131 +--
.docusaurus/routes.js | 232 ++---
.docusaurus/routesChunkNames.json | 300 ++++---
.docusaurus/site-metadata.json | 4 +-
build/assets/css/styles.2c8e1aaa 2.css | 1 +
build/assets/js/2431.754ab92f 2.js | 1 +
build/assets/js/2b67c9e1.3a818452 3.js | 1 +
build/assets/js/351ae245.703aa9f9 2.js | 2 +
build/assets/js/351ae245.703aa9f9.js.LICENSE 2.txt | 1 +
build/assets/js/388c76ea.02af5200 3.js | 1 +
build/assets/js/396fec6a.b92c9314 2.js | 1 +
build/assets/js/400.699c1ca1 2.js | 1 +
build/assets/js/40724967.ca24deda 2.js | 1 +
build/assets/js/418dd8b3.b660da48 3.js | 1 +
build/assets/js/462dd286.255bb828 3.js | 1 +
build/assets/js/4cf832c6.ad2cbb9c 3.js | 1 +
build/assets/js/4ea4b6d7.0f3c63da 3.js | 1 +
build/assets/js/55960ee5.8bc286b0 3.js | 1 +
build/assets/js/581bab9f.dd67bdef 2.js | 1 +
build/assets/js/6159.ca6cef06 2.js | 2 +
build/assets/js/6159.ca6cef06.js.LICENSE 2.txt | 14 +
build/assets/js/6213.2316b8f2 2.js | 1 +
build/assets/js/6213.2316b8f2 3.js | 1 +
build/assets/js/6254.03708626 2.js | 1 +
build/assets/js/6546.4e7592d5 2.js | 1 +
build/assets/js/6875c492.4f72f847 3.js | 1 +
build/assets/js/68d93b53.11012f97 3.js | 1 +
build/assets/js/6945.33e80eed 2.js | 1 +
build/assets/js/6c374c29.625c9016 2.js | 1 +
build/assets/js/773e1e21.aecacf7b 2.js | 1 +
build/assets/js/7aa20364.f0db18a4 3.js | 1 +
build/assets/js/814f3328.e6cf3d47 3.js | 1 +
build/assets/js/84ba4c96.86cf6975 3.js | 1 +
build/assets/js/8530c33b.087d2643 3.js | 1 +
build/assets/js/8eb17b65.28f357dd 3.js | 1 +
build/assets/js/9185.79a82055 2.js | 2 +
build/assets/js/9185.79a82055.js.LICENSE 2.txt | 8 +
build/assets/js/935f2afb.98b9055f 2.js | 1 +
build/assets/js/9554.b97e8010 2.js | 1 +
build/assets/js/982b3559.d8e40665 3.js | 1 +
build/assets/js/9e4087bc.f866cf00 2.js | 1 +
build/assets/js/9ff47762.6af8068a 3.js | 1 +
build/assets/js/a1d6fe1e.6a656a17 2.js | 1 +
build/assets/js/a6aa9e1f.43d938a9 3.js | 1 +
build/assets/js/a7023ddc.4eadba8e 3.js | 1 +
build/assets/js/b2b675dd.0e165a9c 3.js | 1 +
build/assets/js/b2f554cd.3ec56951 3.js | 1 +
build/assets/js/b3bad197.5568ccb7 3.js | 1 +
build/assets/js/bcdbba37.14803c4c 2.js | 1 +
build/assets/js/bf8be382.b6af9361 2.js | 1 +
build/assets/js/bf8be382.b6af9361 3.js | 1 +
build/assets/js/c2a763ff.58766f80 2.js | 1 +
build/assets/js/c2a763ff.58766f80 3.js | 1 +
build/assets/js/c4f5d8e4.700a3258 2.js | 1 +
build/assets/js/ccc49370.e12e2ce0 2.js | 1 +
build/assets/js/ccc49370.e12e2ce0 3.js | 1 +
build/assets/js/dd70c91d.58011b13 2.js | 1 +
build/assets/js/dd70c91d.58011b13 3.js | 1 +
build/assets/js/dee14a6c.12967670 2.js | 1 +
build/assets/js/ec4f2c0f.d71d33c5 2.js | 1 +
build/assets/js/f15304d0.30a4146f 2.js | 1 +
build/assets/js/f15304d0.30a4146f 3.js | 1 +
build/assets/js/f321f471.13b5ee66 2.js | 1 +
build/assets/js/f321f471.13b5ee66 3.js | 1 +
build/assets/js/f6caaeeb.22e3e32d 2.js | 1 +
build/assets/js/fd93cfee.aa5fa867 2.js | 1 +
build/assets/js/fda4d0be.228f6a24 2.js | 1 +
build/assets/js/main.839a3eb4 2.js | 2 +
build/assets/js/main.839a3eb4.js.LICENSE 2.txt | 44 +
build/blog/index 3.html | 19 +
.../index 2.html" | 18 +
build/components/LogoCarousel/index 2.html | 19 +
build/docs/04concept1/index 2.html | 18 +
build/docs/05message1/index 2.html | 19 +
build/docs/06message2/index 2.html | 18 +
build/docs/07message3/index 2.html | 18 +
build/docs/09message5/index 2.html | 19 +
build/docs/10message6/index 2.html | 18 +
build/docs/11concept2/index 2.html | 18 +
build/docs/12push/index 2.html | 18 +
build/docs/14pop/index 2.html | 19 +
build/docs/15deploy/index 2.html | 18 +
build/docs/15deploy/index 3.html | 19 +
build/docs/16admintool/index 2.html | 18 +
build/docs/20log/index 2.html | 18 +
build/docs/21subscribe/index 2.html | 18 +
build/docs/22FAQ/index 2.html | 18 +
build/docs/23local/index 2.html | 18 +
build/docs/23local/index 3.html | 19 +
build/docs/27EventBridge/index 2.html | 18 +
build/docs/28MQTT/index 2.html | 18 +
build/docs/30code-guidelines/index 2.html | 19 +
build/docs/31pull-request/index 2.html | 18 +
build/docs/32release-manual/index 2.html | 18 +
build/docs/index 2.html | 19 +
build/docs/tags/index 2.html | 19 +
build/download/index 2.html | 20 +
build/img/favicon-32x32 2.png | Bin 0 -> 1402 bytes
.../01-\344\273\213\347\273\215/01whychoose.md" | 0
.../01-\344\273\213\347\273\215/02quickstart.md" | 0
.../01-\344\273\213\347\273\215/03whatis.md" | 6 +-
.../04concept1.md" | 6 +-
.../05message1.md" | 6 +-
.../06message2.md" | 0
.../07message3.md" | 0
.../08message4.md" | 0
.../09message5.md" | 0
.../11concept2.md" | 0
.../12push.md" | 0
.../13pull.md" | 0
.../14pop.md" | 0
.../15deploy.md" | 0
.../16admintool.md" | 0
.../17Dashboard.md" | 0
.../18Exporter.md" | 0
.../19JVMOS.md" | 0
.../20log.md" | 0
.../21subscribe.md" | 0
.../22FAQ.md" | 0
.../23local.md" | 0
.../24server.md" | 0
.../07-\345\205\266\344\273\226/25streams.md" | 0
.../07-\345\205\266\344\273\226/26Connnect.md" | 0
.../07-\345\205\266\344\273\226/27EventBridge.md" | 0
.../07-\345\205\266\344\273\226/28MQTT.md" | 0
.../29how-to-contribute.md" | 0
.../30code-guidelines.md" | 0
.../31pull-request.md" | 0
.../32release-manual.md" | 0
docs/10message6 2.md | 2 -
docs/10message6.md | 2 -
sidebars.js | 183 ++--
206 files changed, 2641 insertions(+), 1192 deletions(-)