redis 7 support

leonchen83 · Feb 4, 2022 · 7f93fba · 7f93fba
1 parent 21cfc8c
commit 7f93fba
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/cmd/ReplyParser.java b/src/main/java/com/moilioncircle/redis/replicator/cmd/ReplyParser.java
@@ -75,7 +75,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
             switch (c) {
                 case DOLLAR:
                     // RESP Bulk Strings
-                    ByteBuilder builder = ByteBuilder.allocate(128);
+                    ByteBuilder builder = ByteBuilder.allocate(32);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);
@@ -104,7 +104,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
                     throw new AssertionError("Callback is null");
                 case COLON:
                     // RESP Integers
-                    builder = ByteBuilder.allocate(128);
+                    builder = ByteBuilder.allocate(32);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);
@@ -119,7 +119,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
                     return Long.parseLong(builder.toString());
                 case STAR:
                     // RESP Arrays
-                    builder = ByteBuilder.allocate(128);
+                    builder = ByteBuilder.allocate(32);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);
@@ -140,7 +140,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
                     return ary;
                 case PLUS:
                     // RESP Simple Strings
-                    builder = ByteBuilder.allocate(128);
+                    builder = ByteBuilder.allocate(64);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);
@@ -153,7 +153,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
                     }
                 case MINUS:
                     // RESP Errors
-                    builder = ByteBuilder.allocate(128);
+                    builder = ByteBuilder.allocate(64);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);
@@ -166,7 +166,7 @@ public Object parse(BulkReplyHandler handler) throws IOException {
                     }
                 case HASHTAG:
                     // #TS:${timestamp}\r\n
-                    builder = ByteBuilder.allocate(128);
+                    builder = ByteBuilder.allocate(32);
                     while (true) {
                         while ((c = in.read()) != '\r') {
                             builder.put((byte) c);