<?php
$mysql = new SwooleCoroutineMySQL();
$mysql->connect([
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'root',
    'password' => 'xxxxx',
    'database' => 'db_name',
]);
 
// 异步协程执行 MySQL 查询语句
SwooleCoroutineun(function () use ($mysql) {
    $result = $mysql->query('SELECT * FROM `table_name` WHERE `id`=?', 123);
    var_dump($result);
});

<?php
// 连接 Redis 数据库
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
 
// 将要存储的数据转换成 JSON 格式并推送到 Redis 队列中
$data = ['name' => '张三', 'gender' => '男', 'age' => 18];
$json_data = json_encode($data);
$redis->lpush('data_queue', $json_data);

<?php
use ElasticsearchClientBuilder;
 
// Elasticsearch 配置
$params = [
    'hosts' => [
        'http://127.0.0.1:9200',
    ]
];
 
// 创建 Elasticsearch 客户端
$client = ClientBuilder::create()->setHosts($params['hosts'])->build();
 
// 搜索名称为“张三”的文档数据
$params = [
    'index' => 'my_index',
    'type' => 'person',
    'body' => [
        'query' => [
            'match' => [
                'name' => '张三',
            ]
        ]
    ]
];
 
$response = $client->search($params);