使用go net实现简单的redis通信协议

 图解redis通信协议

请求协议：

请求协议一般格式：

*<参数数量> CR LF
$<参数 1 的字节数量> CR LF
<参数 1 的数据> CR LF
...
$<参数 N 的字节数量> CR LF
<参数 N 的数据> CR LF

例如，一个登录命令：

*2    									2-> 参数数量
$4    								4-> 字节数量
AUTH
$13
password@2018

返回结果：

+OK

实际上，发送的命令为“*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]))
}

运行结果

+OK

+OK

*9
$4
set2
$1
s
$4
set3
$7
string3
$4
int1
$4
test
$7
string2
$7
string1
$7
string4

到此这篇关于使用go net实现简单的redis通信协议的文章就介绍到这了,更多相关go redis通信协议内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Go语言开发redis封装及简单使用详解

    目录 go redis 集合操作--sadd 安装redigo 带密码的redis操作 批量添加 无密码redis操作 redis封装包 参考 go redis 集合操作--sadd redis的go语言包,我们使用官方推荐的redigo,https://github.com/garyburd/redigo 安装redigo $ go get github.com/garyburd/redigo 带密码的redis操作 package main import ( "log" "

  • Go实现Redis连接池方法

    目录 一.什么是连接池,连接池有什么用 二.代码展示 一.什么是连接池,连接池有什么用 先看看别人是怎么介绍连接池的吧: 连接池基本的思想是在系统初始化的时候,将数据库连接作为对象存储在内存中,当用户需要访问数据库时,并非建立一个新的连接,而是从连接池中取出一个已建立的空闲连接对象.使用完毕后,用户也并非将连接关闭,而是将连接放回连接池中,以供下一个请求访问使用.而连接的建立.断开都由连接池自身来管理.同时,还可以通过设置连接池的参数来控制连接池中的初始连接数.连接的上下限数以及每个连接的最大使

  • Golang连接Redis数据库的方法

    Golang连接Redis数据库 golang连接数据库,这里博主推荐使用go-redis这个库,理由很简单(连接数据库的操作类似在数据库里面输入命令) go-redis的安装方式 go get -v https://github.com/go-redis/redis -v小v,是输出过程.一般情况下不带-v什么反馈都看不到. 连接redis的方式 package ... import ( "github.com/go-redis/redis" ) func main() { clie

  • Go语言开发中redis的使用详解

    前段时间因为忙一些其它的事情,分享的有些少,最近学习一下redis在Go语言开发中的应用. 一.理论知识 Redis是一个开源的.使用C语言编写的.支持网络交互的.可基于内存也可持久化的Key-Value数据库. Redis 优势 性能极高 – Redis能读的速度是110000次/s,写的速度是81000次/s . 丰富的数据类型 – Redis支持二进制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 数据类型操作. 原子 – Redis的所有操

  • go redis实现滑动窗口限流的方式(redis版)

    之前给大家介绍过单机当前进程的滑动窗口限流 , 这一个是使用go redis list结构实现的滑动窗口限流 , 原理都一样 , 但是支持分布式 原理可以参考之前的文章介绍 func LimitFreqs(queueName string, count uint, timeWindow int64) bool { currTime := time.Now().Unix() length := uint(ListLen(queueName)) if length < count { ListPus

  • golang-redis之sorted set类型操作详解

    golang-redis之sorted set类型操作详解

    1:安装redigo go get github.com/garyburd/redigo/redis 2:引用redigo import ( "github.com/garyburd/redigo/redis" ) 3:连接Redis c, err := redis.Dial("tcp", "192.168.2.225:6379") if err != nil { fmt.Println("connect to redis err&qu

  • golang实现redis的延时消息队列功能示例

    前言 在学习过程中发现redis的zset还可以用来实现轻量级的延时消息队列功能,虽然可靠性还有待提高,但是对于一些对数据可靠性要求不那么高的功能要求完全可以实现.本次主要采用了redis中zset中的zadd, zrangebyscore 和 zdel来实现一个小demo. 提前准备 安装redis, redis-go 因为用的是macOS, 直接 $ brew install redis $ go get github.com/garyburd/redigo/redis 又因为比较懒,生成任

  • 使用go net实现简单的redis通信协议

    使用go net实现简单的redis通信协议

     图解redis通信协议 请求协议: 请求协议一般格式: *<参数数量> CR LF $<参数 1 的字节数量> CR LF <参数 1 的数据> CR LF ... $<参数 N 的字节数量> CR LF <参数 N 的数据> CR LF 例如,一个登录命令: *2 2-> 参数数量 $4 4-> 字节数量 AUTH $13 password@2018 返回结果: +OK 实际上,发送的命令为"*2\r\n$4\r\nAU

  • .NET Core实现简单的Redis Client框架

    目录 0,关于RedisRESP 1,定义数据类型 2,定义异步消息状态机 3,定义命令发送模板 4,定义RedisClient 5,实现简单的RESP解析 6,实现命令发送客户端 7,如何使用 8,更多客户端 9,更多测试 10,性能测试 0,关于 Redis RESP RESP 全称 REdis Serialization Protocol ,即 Redis 序列化协议,用于协定客户端使用 socket 连接 Redis 时,数据的传输规则. 官方协议说明:https://redis.io/

  • 简单了解redis常见客户端及Sharding机制原理

    1.redis的几种常见客户端: Jedis:是Redis的Java实现客户端,提供了比较全面的Redis命令的支持; Redisson:实现了分布式和可扩展的Java数据结构. Lettuce:高级Redis客户端,用于线程安全同步,异步和响应使用,支持集群,Sentinel,管道和编码器. 1)优点: Jedis:比较全面的提供了Redis的操作特性 Redisson:促使使用者对Redis的关注分离,提供很多分布式相关操作服务,例如,分布式锁,分布式集合,可通过Redis支持延迟队列 Le

  • redis缓存的简单操作（get、put）

    本文介绍简单的redis缓存操作,包括引入jedisjar包.配置redis.RedisDao需要的一些工具.向redis中放数据(put).从redis中取数据(get).访问redis时的逻辑 一.引入jedis jar包 <!-- java访问redis的jar包jedis --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId&g

  • Redis 命令的详解及简单实例

    Redis 命令的详解及简单实例 Redis 命令用于在 redis 服务上执行操作. 要在 redis 服务上执行命令需要一个 redis 客户端.Redis 客户端在我们之前下载的的 redis 的安装包中. 语法 Redis 客户端的基本语法为: $ redis-cli 实例 以下实例讲解了如何启动 redis 客户端: 启动 redis 客户端,打开终端并输入命令 redis-cli.该命令会连接本地的 redis 服务. $redis-cli redis 127.0.0.1:6379>

  • Redis RESP 协议实现实例详解

    Redis RESP 协议实现实例详解

    目录 引言 回顾RESP协议 如何拆解RESP协议 功能实现 总结 引言 我们之前已经学习了RESP协议的内容,且已经完成了一个最简单的Redis读写分离中间件,我们来看拆解下该demo, 看看Redis RESP协议实现起来到底有多简单. 回顾RESP协议 RESP是基于TCP来实现的Redis通信协议,该协议是以/r/n(行)进行分割的,协议支持5种类型,具体信息如下: 类型 前缀 备注 简单字符串 + 简单字符串以+开头 错误数据 - 错误数据以-开头 整数 : 整数以:开头 复杂字符串

  • redis中事务机制及乐观锁的实现

    Redis事务机制 在MySQL等其他数据库中,事务表示的是一组动作,这组动作要么全部执行,要么全部不执行. Redis目前对事物的支持相对简单.Redis只能保证一个client发起的事务中的命令可以连续的执行,而中间不会插入其他的client命令.当一个client在一个链接中发出multi命令时,这个链接会进入一个事务上下文,该连接后续的命令不会立即执行,而是先放到一个队列中,当执行exec命令时,redis会顺序的执行队列中的所有命令. Multi 开启事务: 127.0.0.1:637

  • Redis构建分布式锁

    Redis构建分布式锁

    1.前言 为什么要构建锁呢?因为构建合适的锁可以在高并发下能够保持数据的一致性,即客户端在执行连贯的命令时上锁的数据不会被别的客户端的更改而发生错误.同时还能够保证命令执行的成功率. 看到这里你不禁要问redis中不是有事务操作么?事务操作不能够实现上面的功能么? 的确,redis中的事务可以watch可以监控数据,从而能够保证连贯执行的时数据的一致性,但是我们必须清楚的认识到,在多个客户端同时处理相同的数据的时候,很容易导致事务的执行失败,甚至会导致数据的出错. 在关系型数据库中,用户首先向数

  • Redis总结笔记（一）：安装和常用命令

    Redis总结笔记（一）：安装和常用命令

    一.redis简单介绍 redis是NoSql家族的一员,键值对的内存型数据库.但是它支持把数据保存到本地.这点比memcached好. 缺点: 没有本地数据缓冲, 目前还没有完整的数据聚集化支持 优点: 配置简单, 使用方便, 高性能,支持不同的数据类型(hashes, lists, sets, sorted sets) ASP.NET WebUI for viewing content of the cache 二.安装 windows版本非官方版本.但是是"微软的团队维护的"这个

  • 详解centos下搭建redis集群

    详解centos下搭建redis集群

    必备的工具: redis-3.0.0.tar redis-3.0.0.gem (ruby和redis接口) 分析: 首先,集群数需要基数,这里搭建一个简单的redis集群(6个redis实例进行集群). 在一台服务器上操作,因此仅需要6个不同的端口号即可.分别是:7001.7002.7003.7004.7005.7006. 步骤: 1.上传redis-3.0.0.tar到服务器(自己指定自己的软件目录),解压redis-3.0.0.tar. 2.安装c语言环境(安装centos之后,自带c语言环

随机推荐