コミュニティ 学ぶ ツールライブラリ レジャー
検索
日本語
ホームページ > データベース > Redis > 本文

Go Redis クライアントで使用されるメソッドは何ですか?

WBOY
リリース： 2023-06-03 09:01:38
転載
1041 人が閲覧しました

    はじめに

    go-redis と redigo の最下層は、ユニバーサル Do メソッドを呼び出すことによって実装されますが、

    redigo:

    • 入力はユニバーサル型であるため、各コマンドのパラメータと戻り値を覚えておく必要があり、非常に使いにくいです。 ##パラメータの型はユニバーサルです この型により、コンパイル段階でパラメータの型を確認することは不可能です

    • 各コマンドは、使用方法、パラメータの数などを記録するのに時間がかかります。

    • go-redis:

    各 redis コマンドの機能を絞り込みます。覚えておく必要があるのはコマンドだけです。特定の用途のインターフェイスについてアプリケーションを直接チェックします。使用コストが低くなります。

    • #第 2 に、基になる Redis のタイプに応じてデータ型を統一し、コンパイル時のパラメータ タイプ

    • そして、その応答は Result インターフェイスを使用して均一に返されるため、戻りパラメータ タイプの正確性が保証され、より使いやすくなります。

    • パフォーマンスの比較

      BenchmarkRedis/redigo_client_Benchmark-12     31406	     36919 ns/op
BenchmarkRedis/go-redis_client_Benchmark-12   29977	     38152 ns/op
BenchmarkRedis/redigo_client_Benchmark-12     27928	     39923 ns/op
BenchmarkRedis/go-redis_client_Benchmark-12   27127	     46451 ns/op
      ログイン後にコピー
      • 上の図からわかるように、go-redis の各操作は redigo よりも約 10% 遅いですが、redigo はアプリケーションの表示/接続の終了を行う必要があることがわかります。 , そのため、両者の全体的なパフォーマンスの差は大きくありません
    #Redigo ライブラリ

    redigo は Redis データベースの Go クライアントです。Redis の操作は基本的にコマンドと同じです。Redigo コマンドは基本的に実装されています。 

    Do(ctx context.Context, cmd string, args ...interface{}) (interface{}, error)
    ログイン後にコピー

    Do

    関数を呼び出すと、ユニバーサル パラメータを使用してすべての機能を実現できますが、非常に使いにくいです。パラメータの型はユニバーサル型なので、パラメータの型は第二に、各コマンドは使用方法やパラメータの数などを記録するのに時間がかかり、使用コストが高くなります。

    デモ

    基本的な接続をデモします。プールの確立、ping、文字列操作、ハッシュ操作、リスト操作、期限切れなどの操作 

    package main
import (
   "fmt"
   "github.com/gomodule/redigo/redis"
)
func main() {
   // 新建一个连接池
   var pool *redis.Pool
   pool = &redis.Pool{
      MaxIdle:     10,  //最初的连接数量
      MaxActive:   0,   //连接池最大连接数量,（0表示自动定义），按需分配
      IdleTimeout: 300, //连接关闭时间 300秒 （300秒不使用自动关闭）
      Dial: func() (redis.Conn, error) { //要连接的redis数据库
         return redis.Dial("tcp", "localhost:6379")
      },
   }
   conn := pool.Get() //从连接池，取一个链接
   defer conn.Close()
   // 0. ping正常返回pong， 异常res is nil, err not nil
   res, err := conn.Do("ping")
   fmt.Printf("ping res=%v\n", res)
   if err != nil {
      fmt.Printf("ping err=%v\n", err.Error())
   }
   // string操作
   // set
   res, err = conn.Do("set", "name", "测试001")
   fmt.Printf("set res=%v\n", res)
   if err != nil {
      fmt.Printf("set err=%v\n", err.Error())
   }
   // get
   res, err = redis.String(conn.Do("get", "name"))
   fmt.Printf("get res=%v\n", res)
   if err != nil {
      fmt.Printf("get err=%v\n", err.Error())
   }
   // MSet   MGet
   res, err = conn.Do("MSet", "name", "测试001", "age", 18)
   fmt.Printf("MSet res=%v\n", res)
   if err != nil {
      fmt.Printf("MSet err=%v\n", err.Error())
   }
   r, err := redis.Strings(conn.Do("MGet", "name", "age"))
   fmt.Printf("MGet res=%v\n", r)
   if err != nil {
      fmt.Printf("MGet err=%v\n", err.Error())
   }
   // expire
   res, err = conn.Do("expire", "name", 5)
   fmt.Printf("expire res=%v\n", r)
   if err != nil {
      fmt.Printf("expire err=%v\n", err.Error())
   }
   // list操作
   // lpush lpop
   res, err = conn.Do("lpush", "hobby", "篮球", "足球", "乒乓球")
   fmt.Printf("lpush res=%v\n", r)
   if err != nil {
      fmt.Printf("lpush err=%v\n", err.Error())
   }
   // lpop
   rs, er := conn.Do("lpop", "hobby")
   fmt.Printf("lpop res=%v\n", rs)
   if er != nil {
      fmt.Printf("lpop err=%v\n", er.Error())
   }
   // hash 操作
   // hset
   res, err = conn.Do("HSet", "userinfo", "name", "lqz")
   fmt.Printf("HSet res=%v\n", r)
   if err != nil {
      fmt.Printf("HSet err=%v\n", err.Error())
   }
   // hget
   r4, er4 := conn.Do("HGet", "userinfo", "name")
   fmt.Printf("HGet res=%v\n", r4)
   if er4 != nil {
      fmt.Printf("HGet err=%v\n", er4.Error())
   }
}
    ログイン後にコピー

    go-redis コンポーネントの紹介と使用

    go-redis はサーバーに対応する 3 つのクライアント モードを提供します、クラスター、センチネル、スタンドアロン モード。これら 3 つのモードは接続プールで共通であり、柔軟なフック メカニズムも提供します。基礎となる実際の It は、呼び出されるユニバーサル Do メソッドでもあります。

    しかし、go-redis は各 redis コマンドの機能を洗練させています。コマンドを覚えて、具体的な使い方を直接確認するだけで済みます。インターフェイスを申請するだけで、使用コストが低くなります。第 2 に、統合されています。 Redis の基礎となるタイプに応じたデータ型。これはコンパイル中にパラメータのタイプをチェックするのに役立ち、その応答は Result インターフェイスを使用して均一に返されるため、返されるパラメータのタイプが正確で、よりユーザーフレンドリーであることが保証されます。

    デモ

    Go Redis クライアントで使用されるメソッドは何ですか? 基本的な接続プールの確立、ping、文字列操作、ハッシュ操作、リスト操作、期限切れおよびその他の操作を示します

    func main() {
   var rdb = redis2.NewClient(
      &redis2.Options{
         Addr:     "localhost:6379",
         Password: "", DB: 1,
         MinIdleConns: 1,
         PoolSize:     1000,
      })
   ctx := context.Background()
   res, err = rdb.Ping(ctx).Result()
   fmt.Printf("ping res=%v\n", res)
   if err != nil {
      fmt.Printf("ping err=%v\n", err.Error())
   }
   // string操作
   // set
   res, err = rdb.Set(ctx, "name", "测试001", 0).Result()
   fmt.Printf("set res=%v\n", res)
   if err != nil {
      fmt.Printf("set err=%v\n", err.Error())
   }
   // get
   res, err = rdb.Get(ctx, "name").Result()
   fmt.Printf("get res=%v\n", res)
   if err != nil {
      fmt.Printf("get err=%v\n", err.Error())
   }
   // MSet   MGet
   res, err = rdb.MSet(ctx, "name", "测试001", "age", "18").Result()
   fmt.Printf("MSet res=%v\n", res)
   if err != nil {
      fmt.Printf("MSet err=%v\n", err.Error())
   }
   var ret []interface{}
   ret, err = rdb.MGet(ctx, "name", "age").Result()
   fmt.Printf("MGet res=%v\n", ret)
   if err != nil {
      fmt.Printf("MGet err=%v\n", err.Error())
   }
   // expire
   res, err = rdb.Expire(ctx, "name", time.Second).Result()
   fmt.Printf("expire res=%v\n", res)
   if err != nil {
      fmt.Printf("expire err=%v\n", err.Error())
   }
   // list操作
   // lpush lpop
   res, err = rdb.LPush(ctx, "hobby", "篮球", "足球", "乒乓球").Result()
   fmt.Printf("lpush res=%v\n", res)
   if err != nil {
      fmt.Printf("lpush err=%v\n", err.Error())
   }
   // lpop
   rs, err = rdb.LPop(ctx, "hobby").Result()
   fmt.Printf("lpop res=%v\n", rs)
   if er != nil {
      fmt.Printf("lpop err=%v\n", er.Error())
   }
   // hash 操作
   // hset
   res, err = rdb.HSet(ctx, "userinfo", "name", "lqz").Result()
   fmt.Printf("HSet res=%v\n", r)
   if err != nil {
      fmt.Printf("HSet err=%v\n", err.Error())
   }
   // hget
   r4, er4 = rdb.HGet(ctx, "userinfo", "name").Result()
   fmt.Printf("HGet res=%v\n", r4)
   if er4 != nil {
      fmt.Printf("HGet err=%v\n", er4.Error())
   }
}
    ログイン後にコピー

    パフォーマンス テスト

    package main
import (
   "context"
   redis2 "github.com/go-redis/redis/v8"
   "github.com/gomodule/redigo/redis"
   "testing"
   "time"
)
func BenchmarkRedis(b *testing.B) {
   // 新建一个连接池
   var pool *redis.Pool
   pool = &redis.Pool{
      MaxIdle:     10,   //最初的连接数量
      MaxActive:   1000, //连接池最大连接数量,（0表示自动定义），按需分配
      IdleTimeout: 300,  //连接关闭时间 300秒 （300秒不使用自动关闭）
      Dial: func() (redis.Conn, error) { //要连接的redis数据库
         return redis.Dial("tcp", "localhost:6379")
      },
   }
   var rdb = redis2.NewClient(
      &redis2.Options{
         Addr:         "localhost:6379",
         Password:     "",
         MinIdleConns: 10,
         PoolSize:     1000,
      })
   b.Run("redigo client Benchmark", func(b *testing.B) {
		for j := 0; j < b.N; j++ {
			conn := pool.Get() //从连接池，取一个链接
			conn.Do("set", time.Now().String(), 10000, time.Second)
			conn.Do("get", time.Now().String())
			conn.Close()
		}
	})
	ctx := context.Background()
	b.Run("go-redis client Benchmark", func(b *testing.B) {
		for j := 0; j < b.N; j++ {
			rdb.Set(ctx,  time.Now().String(), 1000, time.Second)
			rdb.Get(ctx,  time.Now().String())
		}
	})
}
    ログイン後にコピー

    結果出力

    goos: darwin

    goarch: amd64

    cpu: Intel(R) Core(TM) i7-9750H CPU @ 2.60GHz

    BenchmarkRedis

    BenchmarkRedis/redigo_client_Benchmark
    BenchmarkRedis/redigo_client_Benchmark-12 26386 39110 ns/op

    BenchmarkRedis/go-redis_client_Benchmark
    BenchmarkRedis/go-redis_client_Benchmark -12 28186 37794 ns/op

    以上がGo Redis クライアントで使用されるメソッドは何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

    関連ラベル：
    redis go
    ソース：yisu.com
    前の記事：RedisTemplateのopsForValueの使い方 次の記事：Redis データシャーディングを実装する方法
    このウェブサイトの声明
    この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
    著者別の最新記事
    最新の問題
    React を使用して Go サーバーから Cookie データを取得できません React の後、バックエンドを開始し、バックエンド サーバーに githubOAUTH とセッションを追加してデータを保存しました。これらはすべてバックエンドで正常に動作し、セッ...
    から 2024-04-06 13:09:26
    0
    1
    384
    React アプリケーションを Go バックエンドにプロキシできるようにしながら、明示的に localhost をサーバーとして使用するにはどうすればよいですか? Go で書かれたバックエンドがあります。すべてが正常に動作し、POSTMAN からの呼び出しが配信されていますが、次のエラーが発生して、突然 React アプリからこのサーバーを呼...
    から 2024-04-03 08:20:24
    0
    1
    361
    関連トピック
    詳細>
    人気のおすすめ
    人気のチュートリアル
    詳細>
    関連するチュートリアル
    人気のおすすめ
    最新のコース
    最新のダウンロード
    詳細>
    ウェブエフェクト
    公式サイト
    サイト素材
    フロントエンドテンプレート