Skip to content

Commit 253ebf9

Browse files
committed
update README
1 parent f995d2e commit 253ebf9

File tree

2 files changed

+54
-1
lines changed

2 files changed

+54
-1
lines changed

README-CN.md

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff 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

README.md

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ for ($i = 0; $i < 10; $i++) {
7979
MessageOptions::PROPERTIES => [
8080
'key' => 'value',
8181
'ms' => microtime(true),
82-
]
82+
],
8383
]);
8484
echo 'messageID ' . $messageID . "\n";
8585
}
@@ -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

0 commit comments

Comments
 (0)