這篇文章給大家分享的是有關(guān)Redis協(xié)議的示例分析的內(nèi)容。小編覺(jué)得挺實(shí)用的，因此分享給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧。

成都創(chuàng)新互聯(lián)"三網(wǎng)合一"的企業(yè)建站思路。企業(yè)可建設(shè)擁有電腦版、微信版、手機(jī)版的企業(yè)網(wǎng)站。實(shí)現(xiàn)跨屏營(yíng)銷(xiāo)，產(chǎn)品發(fā)布一步更新，電腦網(wǎng)絡(luò)+移動(dòng)網(wǎng)絡(luò)一網(wǎng)打盡，滿(mǎn)足企業(yè)的營(yíng)銷(xiāo)需求！成都創(chuàng)新互聯(lián)具備承接各種類(lèi)型的成都做網(wǎng)站、網(wǎng)站設(shè)計(jì)項(xiàng)目的能力。經(jīng)過(guò)10年的努力的開(kāi)拓，為不同行業(yè)的企事業(yè)單位提供了優(yōu)質(zhì)的服務(wù)，并獲得了客戶(hù)的一致好評(píng)。前言

我們用過(guò)很多redis的客戶(hù)端，有沒(méi)有相過(guò)自己擼一個(gè)redis客戶(hù)端？ 其實(shí)很簡(jiǎn)單，基于socket，監(jiān)聽(tīng)6379端口，解析數(shù)據(jù)就可以了。

redis協(xié)議

解析數(shù)據(jù)的過(guò)程主要依賴(lài)于redis的協(xié)議了。 我們寫(xiě)個(gè)簡(jiǎn)單例子看下redis的協(xié)議：

public class RedisTest {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        jedis.set("eat", "I want to eat");
    }
}

監(jiān)聽(tīng)socket：

public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(6379);
        Socket socket = server.accept();
        byte[] chars = new byte[64];
        socket.getInputStream().read(chars);
        System.out.println(new String(chars));
    }

看下數(shù)據(jù)：

*3
$3
SET
$3
eat
$13
I want to eat

參照官方協(xié)議文檔https://redis.io/topics/protocol，解析下數(shù)據(jù)。

（1）簡(jiǎn)單字符串 Simple Strings, 以 "+"加號(hào) 開(kāi)頭 （2）錯(cuò)誤 Errors, 以"-"減號(hào) 開(kāi)頭 （3）整數(shù)型 Integer， 以 ":" 冒號(hào)開(kāi)頭 （4）大字符串類(lèi)型 Bulk Strings, 以 "$"美元符號(hào)開(kāi)頭，長(zhǎng)度限制512M （5）組類(lèi)型 Arrays，以 "*"星號(hào)開(kāi)頭 并且，協(xié)議的每部分都是以 "\r\n" (CRLF) 結(jié)尾的。

所以上面的數(shù)據(jù)的含義是：

*3   數(shù)組包含3個(gè)元素，分別是SET、eat、I want to eat
$3   是一個(gè)字符串，且字符串長(zhǎng)度為3
SET  字符串的內(nèi)容
$3   是一個(gè)字符串，且字符串長(zhǎng)度為3
eat  字符串的內(nèi)容
$13  是一個(gè)字符串，且字符串長(zhǎng)度為13
I want to eat 字符串的內(nèi)容

執(zhí)行g(shù)et 'eat'的數(shù)據(jù)如下：

*2
$3
GET
$3
eat

擼一個(gè)客戶(hù)端

掌握了redis協(xié)議，socket之后，我們就可以嘗試擼一個(gè)客戶(hù)端了。

socket：

public RedisClient(String host, int port){
        try {
            this.socket = new Socket(host,port);
            this.outputStream = this.socket.getOutputStream();
            this.inputStream = this.socket.getInputStream();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

set協(xié)議：

public String set(final String key, String value) {
        StringBuilder sb = new StringBuilder();
        //雖然輸出的時(shí)候，會(huì)被轉(zhuǎn)義，然而我們傳送的時(shí)候還是要帶上\r\n
        sb.append("*3").append("\r\n");
        sb.append("$3").append("\r\n");
        sb.append("SET").append("\r\n");
        sb.append("$").append(key.length()).append("\r\n");
        sb.append(key).append("\r\n");
        sb.append("$").append(value.length()).append("\r\n");
        sb.append(value).append("\r\n");
        byte[] bytes= new byte[1024];
        try {
            outputStream.write(sb.toString().getBytes());
            inputStream.read(bytes);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return new String(bytes);
    }

測(cè)試：

RedisClient redisClient = new RedisClient("127.0.0.1", 6379);
        String result = redisClient.set("eat", "please eat");
        System.out.println(result);

執(zhí)行結(jié)果：

+OK

感謝各位的閱讀！關(guān)于Redis協(xié)議的示例分析就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！

分享題目：Redis協(xié)議的示例分析-創(chuàng)新互聯(lián)
標(biāo)題URL：http://weahome.cn/article/djheje.html