File tree Expand file tree Collapse file tree 2 files changed +53
-0
lines changed
Expand file tree Collapse file tree 2 files changed +53
-0
lines changed Original file line number Diff line number Diff line change @@ -90,6 +90,18 @@ for ($i = 0; $i < 10; $i++) {
9090 ]);
9191}
9292
93+ // Send Batch message
94+ $messages = [];
95+ for ($i = 0;$i < 10;$i++) {
96+ $messages[] = json_encode([
97+ 'id' => $i,
98+ 'now' => date('Y-m-d H:i:s')
99+ ]);
100+ }
101+
102+ $messageID = $producer->send($messages);
103+ echo "batch message id ${messageID}\n";
104+
93105// close
94106$producer->close();
95107
@@ -187,6 +199,20 @@ while (true) {
187199$consumer->close();
188200```
189201
202+ > 批量接收消息
203+
204+ - 只有当生产者批量发送消息时,才能接收到批量消息。
205+
206+ ``` php
207+ $messages = $consumer->batchReceive();
208+ foreach ($messages as $message) {
209+ // ...
210+
211+ // Ack
212+ $consumer->ack($message);
213+ }
214+ ```
215+
190216> 订阅多个主题
191217
192218``` php
Original file line number Diff line number Diff line change @@ -91,6 +91,19 @@ for ($i = 0; $i < 10; $i++) {
9191 ]);
9292}
9393
94+ // Send Batch message
95+ // The underlying protocol will automatically package these messages into a message and send it to pulsar
96+ $messages = [];
97+ for ($i = 0;$i < 10;$i++) {
98+ $messages[] = json_encode([
99+ 'id' => $i,
100+ 'now' => date('Y-m-d H:i:s')
101+ ]);
102+ }
103+
104+ $messageID = $producer->send($messages);
105+ echo "batch message id ${messageID}\n";
106+
94107// close
95108$producer->close();
96109```
@@ -189,6 +202,20 @@ while (true) {
189202$consumer->close();
190203```
191204
205+ > Receive Batch Message
206+
207+ - Only when the producer sends the message in bulk can the batch message be received.
208+
209+ ``` php
210+ $messages = $consumer->batchReceive();
211+ foreach ($messages as $message) {
212+ // ...
213+
214+ // Ack
215+ $consumer->ack($message);
216+ }
217+ ```
218+
192219> Subscribe to multiple topics
193220
194221``` php
You can’t perform that action at this time.
0 commit comments