Configure socket buffer size through system property (#2915)

Author: sazzad16

src/main/java/redis/clients/jedis/util/RedisInputStream.java

@@ -22,6 +22,10 @@
  */
 public class RedisInputStream extends FilterInputStream {
 
+  private static final int INPUT_BUFFER_SIZE = Integer.parseInt(
+      System.getProperty("jedis.bufferSize.input",
+          System.getProperty("jedis.bufferSize", "8192")));
+
   protected final byte[] buf;
 
   protected int count, limit;
@@ -35,7 +39,7 @@ public RedisInputStream(InputStream in, int size) {
   }
 
   public RedisInputStream(InputStream in) {
-    this(in, 8192);
+    this(in, INPUT_BUFFER_SIZE);
   }
 
   public byte readByte() throws JedisConnectionException {

src/main/java/redis/clients/jedis/util/RedisOutputStream.java

@@ -10,6 +10,11 @@
  * used outside Jedis
  */
 public final class RedisOutputStream extends FilterOutputStream {
+
+  private static final int OUTPUT_BUFFER_SIZE = Integer.parseInt(
+      System.getProperty("jedis.bufferSize.output",
+          System.getProperty("jedis.bufferSize", "8192")));
+
   protected final byte[] buf;
 
   protected int count;
@@ -36,7 +41,7 @@ public final class RedisOutputStream extends FilterOutputStream {
       't', 'u', 'v', 'w', 'x', 'y', 'z' };
 
   public RedisOutputStream(final OutputStream out) {
-    this(out, 8192);
+    this(out, OUTPUT_BUFFER_SIZE);
   }
 
   public RedisOutputStream(final OutputStream out, final int size) {