使用go net實(shí)現(xiàn)簡單的redis通信協(xié)議
更新時(shí)間：2021年12月03日 11:48:18 作者：luslin1711
本文主要介紹了go net實(shí)現(xiàn)簡單的redis通信協(xié)議，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
?圖解redis通信協(xié)議
請(qǐng)求協(xié)議：
請(qǐng)求協(xié)議一般格式：
*<參數(shù)數(shù)量> CR LF $<參數(shù) 1 的字節(jié)數(shù)量> CR LF <參數(shù) 1 的數(shù)據(jù)> CR LF ... $<參數(shù) N 的字節(jié)數(shù)量> CR LF <參數(shù) N 的數(shù)據(jù)> CR LF
例如，一個(gè)登錄命令：
*2 2-> 參數(shù)數(shù)量 $4 4-> 字節(jié)數(shù)量 AUTH $13 password@2018
返回結(jié)果：
+OK
實(shí)際上，發(fā)送的命令為“*2\r\n$4\r\nAUTH\r\n$13\r\npassword@2018\r\n”
測試代碼：
package main
import (
"bufio"
"fmt"
"net"
"strconv"
"testing"
"time"
)
type Conn struct {
// Shared
conn net.Conn
// Read
br *bufio.Reader
// Write
bw *bufio.Writer
}
func (c *Conn) Write(cmd string, args ...string) error {
_, err := c.bw.WriteString("*" + strconv.Itoa(1 + len(args)) + "\r\n")
if err != nil {
return err
}
_, err =c.bw.WriteString("$" + strconv.Itoa(len(cmd)) + "\r\n" + cmd + "\r\n")
if err != nil {
return err
}
for _, v := range args {
_, err :=c.bw.WriteString("$" + strconv.Itoa(len(v)) + "\r\n" + v + "\r\n")
if err != nil {
return err
}
}
err = c.bw.Flush()
if err != nil {
return err
}
return nil
}
func TestDail(t *testing.T) {
conn,err := net.Dial("tcp","127.0.0.1:6379")
if err != nil {
panic(err)
}
var c = &Conn{
conn: conn,
br : bufio.NewReader(conn),
bw: bufio.NewWriter(conn),
}
err = c.Write("AUTH","password@2018")
if err != nil {
panic(err)
}
p, err := c.br.ReadSlice('\n')
if err != nil {
panic(err)
}
fmt.Println(string(p))
err = c.Write("SELECT", "5")
if err != nil {
panic(err)
}
p, err = c.br.ReadSlice('\n')
if err != nil {
panic(err)
}
fmt.Println(string(p))
err = c.Write("keys","*")
if err != nil {
panic(err)
}
buffer := make([]byte, 4096)
n, err := c.br.Read(buffer)
if err != nil {
panic(err)
}
fmt.Println(string(buffer[:n]))
}
運(yùn)行結(jié)果
+OK
+OK
*9
$4
set2
$1
s
$4
set3
$7
string3
$4
int1
$4
test
$7
string2
$7
string1
$7
string4
到此這篇關(guān)于使用go net實(shí)現(xiàn)簡單的redis通信協(xié)議的文章就介紹到這了,更多相關(guān)go redis通信協(xié)議內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
本文主要來介紹讀寫鎖的一種Go語言的實(shí)現(xiàn)方式RWMutex，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-03-03
一文帶你掌握Go語言并發(fā)模式中的Context的上下文管理
在?Go?的日常開發(fā)中，Context?上下文對(duì)象無處不在，無論是處理網(wǎng)絡(luò)請(qǐng)求、數(shù)據(jù)庫操作還是調(diào)用?RPC?等場景，那你真的熟悉它的正確用法嗎，隨著本文一探究竟吧2023-05-05
在本篇文章里小編給大家整理的是一篇關(guān)于Go語言基礎(chǔ)知識(shí)點(diǎn)介紹內(nèi)容，有興趣的朋友們可以跟著學(xué)習(xí)參考下。2021-07-07
這篇文章主要是對(duì)零值和空值判斷現(xiàn)狀進(jìn)行簡單的梳理和分享,文中的示例代碼講解詳細(xì),對(duì)我們深入了解go語言有一定的幫助,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-08-08
GO中使用谷歌GEMINI模型任務(wù)代碼實(shí)例
這篇文章主要為大家介紹了GO中使用谷歌GEMINI模型任務(wù)代碼實(shí)例探究,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2024-01-01
Go基礎(chǔ)教程系列之import導(dǎo)入包(遠(yuǎn)程包)和變量初始化詳解
這篇文章主要介紹了Go基礎(chǔ)教程系列之import導(dǎo)包和初始化詳解,需要的朋友可以參考下2022-04-04
golang sync.Pool 指針數(shù)據(jù)覆蓋問題解決
本文主要介紹了使用sync.Pool時(shí)遇到指針數(shù)據(jù)覆蓋的問題,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2025-03-03
了解最新的Go語言面試題型,讓面試不再是難事,下面這篇文章主要給大家介紹了關(guān)于Go語言切片面試?？嫉囊恍﹩栴},文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-02-02
Go?for-range?的?value值地址每次都一樣的原因解析
循環(huán)語句是一種常用的控制結(jié)構(gòu)，在?Go?語言中，除了?for?關(guān)鍵字以外，還有一個(gè)?range?關(guān)鍵字，可以使用?for-range?循環(huán)迭代數(shù)組、切片、字符串、map?和?channel?這些數(shù)據(jù)類型，這篇文章主要介紹了Go?for-range?的?value值地址每次都一樣的原因解析,需要的朋友可以參考下2023-05-05
在現(xiàn)代編程語言中，接口是不可或缺的一個(gè)重要特性，這篇文章將為大家詳細(xì)介紹Go語言中的接口，從而能夠更好得使用Go語言，需要的可以參考一下2023-06-06