modify readme

xingwenge · Jul 30, 2019 · 96f30d5 · 96f30d5
1 parent 6b987e8
commit 96f30d5
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -79,15 +79,15 @@ $ composer update
 try {
     $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SOCKET_CLUE);
     # $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SWOOLE);
-    # $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SOCKET);
+
     $client->connect("127.0.0.1", 11111);
     $client->checkValid();
     $client->subscribe("1001", "example", ".*\\..*");
+    # $client->subscribe("1001", "example", "db_name.tb_name"); # 设置过滤
 
     while (true) {
         $message = $client->get(100);
-        $entries = $message->getEntries();
-        if ($entries) {
+        if ($entries = $message->getEntries()) {
             foreach ($entries as $entry) {
                 Fmt::println($entry);
             }

diff --git a/src/sample/client.php b/src/sample/client.php
@@ -13,15 +13,15 @@
 try {
     $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SOCKET_CLUE);
     # $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SWOOLE);
-    # $client = CanalConnectorFactory::createClient(CanalClient::TYPE_SOCKET);
+
     $client->connect("127.0.0.1", 11111);
     $client->checkValid();
     $client->subscribe("1001", "example", ".*\\..*");
+    # $client->subscribe("1001", "example", "db_name.tb_name"); # 设置过滤
 
     while (true) {
         $message = $client->get(100);
-        $entries = $message->getEntries();
-        if ($entries) {
+        if ($entries = $message->getEntries()) {
             foreach ($entries as $entry) {
                 Fmt::println($entry);
             }