File tree Expand file tree Collapse file tree 2 files changed +0
-53
lines changed
Expand file tree Collapse file tree 2 files changed +0
-53
lines changed Original file line number Diff line number Diff line change @@ -90,18 +90,6 @@ 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-
10593// close
10694$producer->close();
10795
@@ -199,20 +187,6 @@ while (true) {
199187$consumer->close();
200188```
201189
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-
216190> 订阅多个主题
217191
218192``` php
Original file line number Diff line number Diff line change @@ -91,19 +91,6 @@ 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-
10794// close
10895$producer->close();
10996```
@@ -202,20 +189,6 @@ while (true) {
202189$consumer->close();
203190```
204191
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-
219192> Subscribe to multiple topics
220193
221194``` php
You can’t perform that action at this time.
0 commit comments