How to implement golang redis

In today's big data era, the amount of data is growing exponentially. In order to process these massive data quickly and better, traditional databases can no longer meet the needs. NoSQL databases came into being, among which Redis is widely used.

Redis is a memory-based database that can provide high-performance and low-latency data reading and writing, and supports multiple data structures, clusters, transactions and many other features. Using Redis in Go language can give full play to the advantages of Redis and make it smooth and natural to use. Next, let's explore how to use Redis in Go language.

1. Install Redis

Before using Redis, we need to install Redis first. Under the Linux operating system, you can use the following command to install:

sudo apt-get update sudo apt-get install redis-server

After the installation is complete, you can use theredis-clicommand to open the Redis client.

2. Install the Redis driver

In the Go language, we need to use a third-party driver to access Redis. Commonly used Redis drivers include the following:

• redigo
• go-redis
• radix

Among them, redigo is the more popular Redis driver. You can use the following command to install:

go get github.com/gomodule/redigo/redis

3. Connect to Redis

In the Go language, it is very simple to connect to Redis. You can use the following code to implement the connection:

package main import ( "github.com/gomodule/redigo/redis" "log" ) func main() { c, err := redis.Dial("tcp", "localhost:6379") if err != nil { log.Fatal(err) } defer c.Close() }

In the above code, we use the redis.Dial function to establish a connection with Redis. The parametertcpspecifies the use of TCP connection, and the parameterlocalhost:6379specifies the connection address and port number.

4. Operating Redis

After the connection is successful, we can use redigo to operate Redis. The following are some common operation examples:

1. Setting and getting values

_, err := c.Do("SET", "key", "value") if err != nil { log.Fatal(err) } value, err := redis.String(c.Do("GET", "key")) if err != nil { log.Fatal(err) } fmt.Println(value)

In the above code, we use theSETcommand to set a key-value key-value pair. Then use theGETcommand to obtain the value corresponding to the key, and the output result is value.

2. Delete key-value pairs

_, err := c.Do("DEL", "key") if err != nil { log.Fatal(err) }

In the above code, we use theDELcommand to delete the value corresponding to a key.

3. Check whether the key exists

exist, err := redis.Bool(c.Do("EXISTS", "key")) if err != nil { log.Fatal(err) } fmt.Println(exist)

In the above code, we use theEXISTScommand to check whether the key exists. If it exists, outputtrue, otherwise outputfalse.

4. Set the expiration time of the key

_, err := c.Do("EXPIRE", "key", "10") if err != nil { log.Fatal(err) }

In the above code, we use theEXPIREcommand to set the expiration time of 10 seconds for the key.

5. Publish and subscribe

psc := redis.PubSubConn{Conn: c} if err := psc.Subscribe("channel"); err != nil { log.Fatal(err) } go func() { for { switch v := psc.Receive().(type) { case redis.Message: fmt.Printf("%s: message: %s\n", v.Channel, v.Data) case redis.Subscription: fmt.Printf("%s: %s %d\n", v.Channel, v.Kind, v.Count) case error: log.Printf("error: %v\n", v) return } } }() if _, err := c.Do("PUBLISH", "channel", "hello"); err != nil { log.Fatal(err) }

In the above code, we use theSubscribecommand to subscribe to a channel named channel, and use thePUBLISHcommand to publish received a message. Then, we use theReceivefunction to receive the subscribed message.

5. Summary

This article introduces the basic knowledge of using Redis in Go language, including installing Redis, installing Redis driver, connecting to Redis, operating Redis, etc. Through studying this article, I believe that readers have mastered this knowledge and can flexibly apply it in actual development.

The above is the detailed content of How to implement golang redis. For more information, please follow other related articles on the PHP Chinese website!