PolarDB:Orca 接続ガイド

依存関係の設定を追加します (Maven)：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.3.0</version>
</dependency>

コード例：Jedis はパスワードパラメーターを 1 つしか受け付けないため、互換性のために username:password フォーマットを使用します。

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisExample {
    public static void main(String[] args) {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        
        // Orca 接続情報
        String host = "pz-****************.rwlb.rds.aliyuncs.com"; // ご利用の Orca エンドポイントに置き換えてください
        int port = 6379;
        String username = "orca_user"; // ご利用の Orca ユーザー名に置き換えてください
        String password = "orca_password"; // ご利用の Orca パスワードに置き換えてください

        // Jedis の認証では、ユーザー名とパスワードを連結する必要があります
        String authPassword = username + ":" + password;

        JedisPool pool = new JedisPool(poolConfig, host, port, 3000, authPassword);
        
        try (Jedis jedis = pool.getResource()) {
            jedis.set("name", "jedis");
            System.out.println(jedis.get("name"));
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            pool.destroy();
        }
    }
}

依存関係の設定を追加します (Maven)：

<dependency>
    <groupId>io.lettuce</groupId>
    <artifactId>lettuce-core</artifactId>
    <version>6.3.0.RELEASE</version>
</dependency>
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-transport-native-epoll</artifactId>
    <version>4.1.100.Final</version>
    <classifier>linux-x86_64</classifier>
</dependency>

コード例：Lettuce はユーザー名とパスワードを個別に設定することをサポートしています。このメソッドを推奨します。

import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisCommands;

public class LettuceExample {
    public static void main(String[] args) {
        // Orca 接続情報
        String host = "pz-****************.rwlb.rds.aliyuncs.com"; // ご利用の Orca エンドポイントに置き換えてください
        int port = 6379;
        String username = "orca_user"; // ご利用の Orca ユーザー名に置き換えてください
        String password = "orca_password"; // ご利用の Orca パスワードに置き換えてください

        // Lettuce はユーザー名とパスワードの個別設定をサポートしています
        RedisURI uri = RedisURI.Builder
                .redis(host, port)
                .withAuthentication(username, password)
                .build();
        RedisClient redisClient = RedisClient.create(uri);

        StatefulRedisConnection<String, String> connection = redisClient.connect();

        RedisCommands<String, String> syncCommands = connection.sync();

        syncCommands.set("name", "Lettuce");
        String value = syncCommands.get("name");
        // 出力：Lettuce
        System.out.println("Get value: " + value); 

        connection.close();
        redisClient.shutdown();
    }
}

依存関係の設定を追加します (Maven)：

<!-- バージョン管理を統一するための Spring Boot 親プロジェクト -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.7.18</version> <!-- 最近の安定バージョンを推奨します -->
    <relativePath/>
</parent>

<!-- その他の設定項目... -->

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-simple</artifactId>
        <version>1.7.36</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <!-- パッケージングと実行のための Spring Boot Maven プラグイン -->
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

コード例：以下のいずれかの方法を選択して設定を行い、Orca に接続します。

依存関係をインストールします。

pip install redis

コード例：redis-py バージョン 4.2 以降は、個別の username パラメーターをサポートしています。古いバージョンを使用する場合は、password パラメーターに username:password フォーマットを使用してください。

import redis

# Orca 接続情報
host = 'pz-****************.rwlb.rds.aliyuncs.com'  # ご利用の Orca エンドポイントに置き換えてください
port = 6379
username = 'orca_user'  # ご利用の Orca ユーザー名に置き換えてください
password = 'orca_password'  # ご利用の Orca パスワードに置き換えてください

# 推奨される方法 (redis-py >= 4.2)
r = redis.Redis(host=host, port=port, username=username, password=password)

# 古いバージョンとの互換性のための方法
# auth_password = f'{username}:{password}'
# r = redis.Redis(host=host, port=port, password=auth_password)

r.set('name', 'redis-py')
print(r.get('name').decode('utf-8'))
r.close()

依存関係をインストールします。

go get github.com/go-redis/redis/v8

コード例：go-redis は個別の Username フィールドをサポートしています。このメソッドを推奨します。古いクライアントバージョンを使用する場合は、Password フィールドの値として username:password を使用してください。

package main

import (
    "context"
    "fmt"
    "github.com/go-redis/redis/v8"
)

var ctx = context.Background()

func main() {
    client := redis.NewClient(&redis.Options{
        Addr:     "pz-****************.rwlb.rds.aliyuncs.com:6379", // ご利用の Orca アドレスとポートに置き換えてください
        Username: "orca_user",     // ご利用の Orca ユーザー名に置き換えてください
        Password: "orca_password", // ご利用の Orca パスワードに置き換えてください
        DB:       0,
    })

    err := client.Set(ctx, "name", "go-redis", 0).Err()
    if err != nil {
        panic(err)
    }

    val, err := client.Get(ctx, "name").Result()
    if err != nil {
        panic(err)
    }
    fmt.Println("Get value:", val)
}

依存関係をインストールします。

npm install redis

コード例：node-redis は、接続 URL に認証情報を含めることをサポートしています。

import { createClient } from 'redis';

// Orca 接続情報
const host = 'pz-****************.rwlb.rds.aliyuncs.com'; // ご利用の Orca エンドポイントに置き換えてください
const port = 6379;
const username = 'orca_user'; // ご利用の Orca ユーザー名に置き換えてください
const password = 'orca_password'; // ご利用の Orca パスワードに置き換えてください

const client = createClient({
    url: `redis://${username}:${encodeURIComponent(password)}@${host}:${port}/0`
});

client.on('error', (err) => console.error('Redis Client Error:', err));

async function runExample() {
    try {
        await client.connect();
        await client.set('name', 'node-redis');
        const value = await client.get('name');
        console.log('get name:', value);
    } finally {
        await client.disconnect();
    }
}

runExample();

依存関係をインストールします：通常、パッケージマネージャーを使用してインストールできます。例えば、CentOS の場合：

sudo yum install php-redis

コード例：PhpRedis 拡張機能の auth メソッドは、ユーザー名とパスワードを含む配列を渡すことをサポートしています。

<?php
$redis = new Redis();

// Orca 接続情報
$host = 'pz-****************.rwlb.rds.aliyuncs.com'; // ご利用の Orca エンドポイントに置き換えてください
$port = 6379;
$user = 'orca_user';     // ご利用の Orca ユーザー名に置き換えてください
$password = 'orca_password'; // ご利用の Orca パスワードに置き換えてください

if ($redis->connect($host, $port) === false) {
    die($redis->getLastError());
}

// ユーザー名とパスワードを含む配列を使用して認証
if ($redis->auth([$user, $password]) === false) {
    die($redis->getLastError());
}

$redis->set("name", "php-redis");
echo $redis->get("name");

$redis->close();
?>

依存関係のインストール：ソースコードからコンパイルしてインストールします。

git clone https://github.com/redis/hiredis.git
cd hiredis
make && sudo make install

コード例：redisCommand を使用して AUTH コマンドを実行します。連結された username:password フォーマットを使用できます。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <hiredis.h>

int main() {
    // Orca 接続パラメーター
    const char *hostname = "********.rwlb.rds.aliyuncs.com"; // ご利用の Orca エンドポイントに置き換えてください
    int port = 6379;
    // 使いやすさのためにユーザー名とパスワードを別々に定義
    const char *username = "orca_user"; // ご利用の Orca ユーザー名に置き換えてください
    const char *password = "orca_password"; // ご利用の Orca パスワードに置き換えてください

    redisContext *c;
    redisReply *reply;

    // 1. Redis に接続 (タイムアウト付きの接続を推奨)
    struct timeval timeout = { 2, 0 }; // 2 秒のタイムアウト
    c = redisConnectWithTimeout(hostname, port, timeout);
    if (c == NULL || c->err) {
        if (c) {
            printf("Connection error: %s\n", c->errstr);
            redisFree(c);
        } else {
            printf("Can't allocate redis context\n");
        }
        exit(1);
    }

    // 2. 認証
    // "AUTH <username> <password>" フォーマットを使用
    reply = redisCommand(c, "AUTH %s %s", username, password);
    if (reply == NULL) {
        // reply が NULL の場合、I/O エラーが発生。c->errstr を確認
        printf("AUTH command failed: %s\n", c->errstr);
        redisFree(c);
        exit(1);
    }
    // 応答自体がエラータイプかどうかを確認
    if (reply->type == REDIS_REPLY_ERROR) {
        printf("Authentication failed: %s\n", reply->str);
        freeReplyObject(reply);
        redisFree(c);
        exit(1);
    }
    printf("Authenticated successfully\n");
    freeReplyObject(reply); // 認証成功後、応答を解放することを忘れないでください

    // 3. SET コマンドを実行
    reply = redisCommand(c, "SET mykey %s", "Hello, hiredis!");
    if (reply == NULL) {
        printf("SET command failed: %s\n", c->errstr);
        redisFree(c);
        exit(1);
    }

    // 成功した SET コマンドに対して、hiredis は STATUS タイプの応答を返します
    if (reply->type == REDIS_REPLY_STATUS && strcmp(reply->str, "OK") == 0) {
        printf("SET mykey succeeded\n");
    } else {
        printf("SET failed with reply: %s\n", reply->str);
    }
    freeReplyObject(reply);

    // 4. GET コマンドを実行
    reply = redisCommand(c, "GET mykey");
    if (reply == NULL) {
        printf("GET command failed: %s\n", c->errstr);
        redisFree(c);
        exit(1);
    }

    if (reply->type == REDIS_REPLY_STRING) {
        printf("GET mykey = %s\n", reply->str);
    } else if (reply->type == REDIS_REPLY_NIL) {
        printf("Key 'mykey' does not exist\n");
    } else {
        printf("GET returned unexpected type: %d, error: %s\n", reply->type, reply->str);
    }
    freeReplyObject(reply);

    // 5. 接続を閉じる
    redisFree(c);
    printf("Disconnected from Redis\n");

    return 0;
}

コンパイルと実行

# コンパイル。-I と -L の後のパスを実際のインストール場所に合わせて調整してください
gcc -o orca orca.c -I/usr/local/include/hiredis -L/usr/local/lib -lhiredis

# 実行
./orca