redis 模拟redis server接收信息

package com.ahd.redis;

import redis.clients.jedis.Jedis;

public class JedisTest {
    public static void main(String[] args) {
        Jedis jedis=new Jedis("127.0.0.1");

        jedis.set("name","ahdg");

        jedis.close();
    }
}

 

package com.ahd.redis;

  

  import java.io.IOException;

  import java.io.InputStream;

  import java.net.ServerSocket;

  import java.net.Socket;

  

  /***

 * 模拟redis服务器

 */

  public class RedisServer {

    public static void main(String[] args) throws IOException {

        //1. 创建服务器对象

        ServerSocket serverSocket=new ServerSocket(6379);

        //2. accept方法

        Socket accept = serverSocket.accept();

        //3. 获取输入流

        InputStream inputStream = accept.getInputStream();

        //4. 将请求的信息转成字符串并打印

        byte[] content=new byte[2048];

        inputStream.read(content);

  
        System.out.println(new String(content));

    }

}