Rumah pangkalan data Redis redis通信协议(protocol)

redis通信协议(protocol)

May 22, 2020 am 09:06 AM
redis

redis通信协议(protocol)

redis的ping pong

登录redis cli客户端后, 输入ping, 服务器会返回pong, 来表示连接状况是完好的, 也表示了服务器大体上是正常运转的.

1.jpg

其中的第一行是我用docker 启动的客户端, 大家如果不是docker的话, 自己正常启动redis -cli就行..

ping之后就会收到pong

使用Java socket 来实现 Redis 的ping pong

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.210", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        InputStream is = socket.getInputStream();
 
        // 向redis服务器写
        os.write("PING\r\n".getBytes());
 
        //从redis服务器读,到bytes中
        byte[] bytes = new byte[1024];
        int len = is.read(bytes);
 
        // to string 输出一下
        System.out.println(new String(bytes,0,len));
    }
Salin selepas log masuk

返回的结果如下:

2.jpg

为什么会有一个 '+'符号 呢? redis -cli里是没有这个加号的呀?

这个和通信协议有关, 一会儿再介绍具体的含义. 不过redis -cli只是把这个'+'符号吞掉处理了, 没显示出来罢了。

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.210", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        InputStream is = socket.getInputStream();
 
        // 向redis服务器写
        os.write("PING\r\n".getBytes());
 
        //从redis服务器读,到bytes中
        byte[] bytes = new byte[1024];
        if(is.read()=='+'){
            // to string 输出一下
            int len = is.read(bytes);
            System.out.println(new String(bytes,0,len));
        }
        // else if $
        // else if *
        // else
    }
Salin selepas log masuk

这样就跟redis -cli里的一样啦.就只是pong了

3.jpg

实现SET 和 GET

set:

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.210", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        InputStream is = socket.getInputStream();
 
        // 向redis服务器写
        os.write("set hello world123\r\n".getBytes());
 
        //从redis服务器读,到bytes中
        byte[] bytes = new byte[1024];
        int len = is.read(bytes);
 
        // to string 输出一下
        System.out.println(new String(bytes,0,len));
    }
Salin selepas log masuk

get:

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.310", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        InputStream is = socket.getInputStream();
 
        // 向redis服务器写
        os.write("get hello\r\n".getBytes());
 
        //从redis服务器读,到bytes中
        byte[] bytes = new byte[1024];
        int len = is.read(bytes);
 
        // to string 输出一下
        System.out.println(new String(bytes,0,len));
    }
Salin selepas log masuk

4.jpg

解释上面例子中的+和$符号

加号'+' 是来表示状态回复的, 在redis服务端向客户端返回状态信息时, 就会先发送一个`+`符号来开头.

接下来是相应的状态信息, 例如'OK'什么的.

最后, 要以'\r\n' 来结尾... 咱们看一下代码就明白了

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.210", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        InputStream is = socket.getInputStream();
 
        // 向redis服务器写
        os.write("set hello world123\r\n".getBytes());
 
        //从redis服务器读,到bytes中
        byte[] bytes = new byte[1024];
        if (is.read() == '+') {
            System.out.println("这是一个状态回复哦! 怎么知道的呢? `+` 号就表示 '状态回复' 了");
            int len = is.read(bytes);
            System.out.println("回复的状态是: " + new String(bytes, 0, len));
        }
 
        // 大家想不想看看bytes里面到底有几个字符吗?
        System.out.println(Arrays.toString(bytes));
        // 输出的是 [79, 75, 13, 10, 0, 0, 0, 0, 0,....]
        // 其中 79 75 是 `OK`
        // 其中 13 10 是 `\r\n`
        // 后面的一串0 是 表示没有后续内容, 已经读完.
    }
Salin selepas log masuk

$ 表示批量读取, 一般格式是: $<数字>, 数字来表示正文的内容的字节数

5.jpg

抓包后是这样的, 客户端向服务端发送了"get hello", 服务端向客户端发送了蓝色的这两行.

public static void main(String[] args) throws Exception {
        // socket
        Socket socket = new Socket("140.143.135.210", 6379);
 
        // oi流
        OutputStream os = socket.getOutputStream();
        // 为了解析&#39;\r\n&#39;方便, 我就用改为字符流了
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
 
        // 向redis服务器写
        os.write("get hello\r\n".getBytes());
 
        // 缓冲数组
        char[] chars = new char[1024];
 
        //从redis服务器读,到bytes中
        if (br.read() == &#39;$&#39;) {
            System.out.println("这是一个批量回复哦! 怎么知道的呢? `$` 号就表示 &#39;批量回复&#39; 了");
            System.out.println("$ 后面会跟一个数字, 来表示正文内容的大小");
            // readLine直接能判断&#39;\r&#39; &#39;\n&#39;
            int len = Integer.parseInt(br.readLine());
            System.out.println("$后面跟着的数字是: " + len + ", 表示正文是" + len + "个字节, 接下来只要读取" + len + "个字节就好了");
 
            // 接下来只读取len个字符就ok了  (其实单位应该是字节, 但是我中途为了readLine省事, 改用了字符流, 个数是不变的)
            br.read(chars, 0, len);
            System.out.println("get到的结果是: " + new String(chars, 0, len) + ", 数一数真的是" + len + "个字符");
        }
    }
Salin selepas log masuk

Redis通信协议就只是这样?

no!!!刚才客户端向服务端发送的 "get hello" , 这种只是"内联命令", 而不是Redis真正的通信协议.

问: 什么意思呢? 答: 就是说你可以像之前那样给服务端发, 服务器端接受到后, 会遍历一遍你发送的内容, 最后根据空格来分析你所发的内容的含义.

问: 这样有什么不好的吗? 答: 如果这样的话, 你就把解析的工作交给了服务器来做, 会加大服务器的工作量.

问: 那怎么样才是符合规范的呢? 符合协议的话真的会提高服务器的效率? 答: 首先看一下符合协议的客户端和服务端之间的交互把.如下例子:

例: set java python ,抓到包之后是这样的:

6.JPG

红色是客户端发送的内容, 蓝色是服务器端返回的内容.

咱们一起解析一下:

*3表示 , 客户端即将发送3段内容

哪三段呢? 第一段: '$3 SET' 第二段: '$4 java' 第三段: '$6 python'

更严格地说: 第一段: '$3\r\nSET\r\n' 第二段:'$4\r\njava\r\n' 第三段:'$6\r\npython\r\n'

$符号的意思在上一小节就已经提到过了, 表示下文的内容的长度, 方便服务器进行读取.

例如: $6就已经把python的长度给汇报出来了, 服务器只需要截取区间[index, index+6]就好了, 不需要去找空格在什么地方(找空格的时间复杂度是O(n), 而$6这种写法是O(1) )

Jedis

其实Jedis做的工作大体就是把SET key value 这样的格式转化为下面这种格式, 然后发到Redis服务端:

*3\r\n
$3\r\n
SET\r\n
$3\r\n
key\r\n
$5\r\n
value\r\n
Salin selepas log masuk

更多redis知识请关注redis入门教程栏目。

Atas ialah kandungan terperinci redis通信协议(protocol). Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

AI Hentai Generator

AI Hentai Generator

Menjana ai hentai secara percuma.

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Cara Membina Mod Kluster Redis Cara Membina Mod Kluster Redis Apr 10, 2025 pm 10:15 PM

Mod Redis cluster menyebarkan contoh Redis ke pelbagai pelayan melalui sharding, meningkatkan skalabilitas dan ketersediaan. Langkah -langkah pembinaan adalah seperti berikut: Buat contoh Redis ganjil dengan pelabuhan yang berbeza; Buat 3 contoh sentinel, memantau contoh redis dan failover; Konfigurasi fail konfigurasi sentinel, tambahkan pemantauan maklumat contoh dan tetapan failover; Konfigurasi fail konfigurasi contoh Redis, aktifkan mod kluster dan tentukan laluan fail maklumat kluster; Buat fail nodes.conf, yang mengandungi maklumat setiap contoh Redis; Mulakan kluster, laksanakan perintah Buat untuk membuat kluster dan tentukan bilangan replika; Log masuk ke kluster untuk melaksanakan perintah maklumat kluster untuk mengesahkan status kluster; buat

Cara membersihkan data redis Cara membersihkan data redis Apr 10, 2025 pm 10:06 PM

Cara Mengosongkan Data Redis: Gunakan perintah Flushall untuk membersihkan semua nilai utama. Gunakan perintah flushdb untuk membersihkan nilai utama pangkalan data yang dipilih sekarang. Gunakan Pilih untuk menukar pangkalan data, dan kemudian gunakan FlushDB untuk membersihkan pelbagai pangkalan data. Gunakan perintah DEL untuk memadam kunci tertentu. Gunakan alat REDIS-CLI untuk membersihkan data.

Cara menggunakan perintah redis Cara menggunakan perintah redis Apr 10, 2025 pm 08:45 PM

Menggunakan Arahan Redis memerlukan langkah -langkah berikut: Buka klien Redis. Masukkan arahan (nilai kunci kata kerja). Menyediakan parameter yang diperlukan (berbeza dari arahan ke arahan). Tekan Enter untuk melaksanakan arahan. Redis mengembalikan tindak balas yang menunjukkan hasil operasi (biasanya OK atau -r).

Cara menggunakan kunci redis Cara menggunakan kunci redis Apr 10, 2025 pm 08:39 PM

Menggunakan REDIS untuk mengunci operasi memerlukan mendapatkan kunci melalui arahan SETNX, dan kemudian menggunakan perintah luput untuk menetapkan masa tamat tempoh. Langkah-langkah khusus adalah: (1) Gunakan arahan SETNX untuk cuba menetapkan pasangan nilai utama; (2) Gunakan perintah luput untuk menetapkan masa tamat tempoh untuk kunci; (3) Gunakan perintah DEL untuk memadam kunci apabila kunci tidak lagi diperlukan.

Cara Membaca Gilir Redis Cara Membaca Gilir Redis Apr 10, 2025 pm 10:12 PM

Untuk membaca giliran dari Redis, anda perlu mendapatkan nama giliran, membaca unsur -unsur menggunakan arahan LPOP, dan memproses barisan kosong. Langkah-langkah khusus adalah seperti berikut: Dapatkan nama giliran: Namakannya dengan awalan "giliran:" seperti "giliran: my-queue". Gunakan arahan LPOP: Keluarkan elemen dari kepala barisan dan kembalikan nilainya, seperti LPOP Queue: My-Queue. Memproses Baris kosong: Jika barisan kosong, LPOP mengembalikan nihil, dan anda boleh menyemak sama ada barisan wujud sebelum membaca elemen.

Cara melaksanakan redis yang mendasari Cara melaksanakan redis yang mendasari Apr 10, 2025 pm 07:21 PM

Redis menggunakan jadual hash untuk menyimpan data dan menyokong struktur data seperti rentetan, senarai, jadual hash, koleksi dan koleksi yang diperintahkan. Redis berterusan data melalui snapshots (RDB) dan menambah mekanisme tulis sahaja (AOF). Redis menggunakan replikasi master-hamba untuk meningkatkan ketersediaan data. Redis menggunakan gelung acara tunggal untuk mengendalikan sambungan dan arahan untuk memastikan atom dan konsistensi data. Redis menetapkan masa tamat tempoh untuk kunci dan menggunakan mekanisme memadam malas untuk memadamkan kunci tamat tempoh.

Cara membaca kod sumber redis Cara membaca kod sumber redis Apr 10, 2025 pm 08:27 PM

Cara terbaik untuk memahami kod sumber REDIS adalah dengan langkah demi langkah: Dapatkan akrab dengan asas -asas Redis. Pilih modul atau fungsi tertentu sebagai titik permulaan. Mulakan dengan titik masuk modul atau fungsi dan lihat baris kod mengikut baris. Lihat kod melalui rantaian panggilan fungsi. Berhati -hati dengan struktur data asas yang digunakan oleh REDIS. Kenal pasti algoritma yang digunakan oleh Redis.

Cara Membuat Mesej Middleware Untuk Redis Cara Membuat Mesej Middleware Untuk Redis Apr 10, 2025 pm 07:51 PM

Redis, sebagai middleware mesej, menyokong model penggunaan pengeluaran, dapat meneruskan mesej dan memastikan penghantaran yang boleh dipercayai. Menggunakan Redis sebagai middleware mesej membolehkan pematuhan latensi rendah, boleh dipercayai dan berskala.

See all articles