利用RESP协议，手搓一个简易Redis客户端

*3
$3
SET
$4
name
$6
小明

package org.open.java;

import java.io.*;
import java.net.Socket;
import java.net.SocketAddress;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.stream.Stream;

public class MyRedis {
    static Socket socket;
    static PrintWriter writer;
    static BufferedReader reader;
    public static void main(String[] args) {
        try {
            // 创建连接
            socket = new Socket("127.0.0.1", 6379);

            // 获取输出流
            OutputStream outputStream = socket.getOutputStream();
            writer = new PrintWriter(new OutputStreamWriter(outputStream, StandardCharsets.UTF_8));

            // 获取输入流
            InputStream inputStream = socket.getInputStream();
            reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));

            sendRedisCode("auth 123123");
            sendRedisCode("set name Tom");
            sendRedisCode("get name");
            sendRedisCode("mget name age addr");
        } catch (IOException e) {
            System.out.println(e);
        }
        finally{
            try {
                // 4.关闭联接
                socket.close();
            } catch (IOException e) {
                System.out.println(e);
            }
        }
    }

    private static void handleRedisResponse() throws IOException {
        String s = reader.readLine();
        System.out.println(s);
        if(s.startsWith("$")){
            long l = Long.parseLong(s.replace("$", ""));
            if(l > 0) {
                System.out.println(reader.readLine());
            }
        }
        else if(s.startsWith("*"))
        {
            long l = Long.parseLong(s.replace("*", ""));
            for (long i = 0; i < l; i++) {
                handleRedisResponse();
            }
        }
    }

    private static void sendRedisCode(String redisCode) throws IOException {
        String[] args = redisCode.split(" ");

        writer.println("*" + args.length);

        for (String arg : args) {
            writer.println("$" + arg.getBytes(StandardCharsets.UTF_8).length);
            writer.println(arg);
        }

        writer.flush();

        System.out.println(redisCode);

        // 3.接收并解析响应
        handleRedisResponse();
        System.out.println("");
    }
}

using System.Net.Sockets;
using System.Text;

// 创建Socket
var socket = new Socket(SocketType.Stream, ProtocolType.Tcp);

// 建立连接 
socket.Connect("127.0.0.1", 6379);

sendCode("auth 123123");
sendCode("set name Tom");
sendCode("get name");
sendCode("mget name age addr");

// 关闭Socket
socket.Close();

string sendCode(string code)
{
    // 推送命令
    socket.Send(Encoding.UTF8.GetBytes(getCode(code)));

    // 接收返馈（循环接收，避免数据不全）
    var buffer = new byte[8192];
    var sb = new StringBuilder();
    int received;
    do
    {
        received = socket.Receive(buffer);
        sb.Append(Encoding.UTF8.GetString(buffer, 0, received));
    } while (socket.Available > 0);

    // 解析结果
    var msg = sb.ToString();
    Console.WriteLine(code);
    Console.WriteLine(msg);
    return msg;
}

string getCode(string code)
{
    if (string.IsNullOrWhiteSpace(code)) {
        return "";
    }
    var cs = code.Split(' ');
    StringBuilder sb = new StringBuilder();
    sb.AppendLine("*" + cs.Length);
    foreach (var c in cs)
    { 
        sb.AppendLine($"${Encoding.UTF8.GetBytes(c).Length}");
        sb.AppendLine($"{c}");
    }
    //Console.WriteLine(sb.ToString());
    return sb.ToString();
}

import socket
import select

# 创建Socket并建立连接
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(("127.0.0.1", 6379))

def get_code(code: str) -> bytes:
    """将Redis命令转换为RESP协议格式"""
    if not code or not code.strip():
        return b""
    parts = code.split(" ")
    lines = [f"*{len(parts)}"]
    for c in parts:
        byte_len = len(c.encode("utf-8"))
        lines.append(f"${byte_len}")
        lines.append(c)
    resp = "\r\n".join(lines) + "\r\n"
    print(resp, end="")
    return resp.encode("utf-8")

def send_code(code: str) -> str:
    """发送Redis命令并接收响应"""
    # 推送命令
    sock.send(get_code(code))

    # 接收返馈（循环接收，避免数据不全）
    chunks = []
    while True:
        readable, _, _ = select.select([sock], [], [], 0.5)
        if not readable:
            break
        data = sock.recv(8192)
        if not data:
            break
        chunks.append(data)

    # 解析结果
    msg = b"".join(chunks).decode("utf-8")
    print(msg)
    print()
    return msg

# 登录Redis
send_code("auth 123123")

send_code("get name")

# 关闭Socket
sock.close()