中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

Redis如何批量導入數據

小新
579
2021-02-22 14:36:19
欄目: 大數據

Redis如何批量導入數據

Redis批量導入數據的示例:

1.準備一個redis protocol的文件,通過java程序來輸出的,代碼如下:

<<RedisBatchTest>>

public class RedisBatchTest {

    public static void main(String[] args) {

        String outputFile = "d:\\temp\\redis_input.txt";

        RedisBatchTest test = new RedisBatchTest();

        test.generateFile(outputFile);

    }

    /**

     * 格式化成輸入字符串

     *

     * @param args

     * @return

     */

    private String getString(String key, String value) {

        StringBuilder sb = new StringBuilder();

        sb.append("*3").append("\r\n");

        sb.append("$3").append("\r\n");

        sb.append("SET\r\n");

        sb.append("$").append(key.getBytes().length).append("\r\n");

        sb.append(key).append("\r\n");

        sb.append("$").append(value.getBytes().length).append("\r\n");

        sb.append(value).append("\r\n");

        return sb.toString();

    }

    public void generateFile(String file) {

        

        BufferedWriter w = null;

        String key = null;

        String value = null;

        StringBuilder sb = new StringBuilder();

        try {

            w = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file), "utf-8"));

            for (int i = 1; i <= 380; i++) {

                key = "test_batch_" + i;

                value = "v_" + i + "注冊即送水電費ServiceTest"; // 這是key對應的value

                sb.append(this.getString(key, value));

                if (i % 10 == 0) {

                    w.write(sb.toString());

                    w.flush();

                    sb.delete(0, sb.length());

                    System.out.println("Current write: " + i);

                }

            }

            

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            try {

                w.flush();

                w.close();

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

}

2.執行java代碼后,會在d:\\temp目錄下生成一個文本文件,將這個文件上傳到要執行的機器上。

3.再通過終端控制臺執行以下命令將文件內容批量導入即可。

cat input/redis_input.txt | bin/redis-cli -p 6370 -a yourpasswd –pipe


0
同心县| 监利县| 台东县| 淄博市| 泽州县| 肥东县| 台北市| 游戏| 泸州市| 西充县| 南澳县| 洪泽县| 长宁县| 铁岭县| 弥勒县| 黑水县| 新民市| 且末县| 芜湖市| 滨州市| 弥渡县| 曲麻莱县| 双柏县| 霍林郭勒市| 田东县| 太湖县| 工布江达县| 开远市| 灯塔市| 沁水县| 上犹县| 清丰县| 桐庐县| 克东县| 岗巴县| 石首市| 于都县| 墨玉县| 九江市| 延长县| 石台县|