client.java

import java.net.*;

import javax.xml.crypto.Data;

import java.io.*;
import java.util.Scanner;

public class client {
    public static void main(String[] args) {
        Socket s = null;
            DataOutputStream out = null;   
            DataInputStream in = null;
              BufferedReader d = null;
        try {
             s = new Socket("localhost", 6379);
            System.out.println("Connected to Redis server...");
            
            out = new DataOutputStream(s.getOutputStream());   
            in = new DataInputStream(s.getInputStream());
          d = new BufferedReader(new InputStreamReader(System.in));   
        }catch (Exception e) {
            e.printStackTrace();    
        }
            String msg = "";    
               while(!msg.equals("exit")){
                try{
                    msg = d.readLine();
                    out.writeUTF(msg);
                    System.out.println("Server response: " + in.readUTF()); 
                }
                catch(IOException i){
                    System.out.println(i);
                    break;
            }
        }
            try{
               s.close(); 
                in.close();
                out.close();
            } catch(IOException i){
                System.out.println(i);
            }
             
    }
}