return false;
BytesWrapper other = (BytesWrapper) obj;
if (!Arrays.equals(bytes, other.bytes))
return false;
return true;
}
}[java] view plaincopyprint package com.cdai.studio.redis;
import java.util.HashMap;
class Persistence {
private HashMap
new HashMap
void put(String key, Object value) {
storage.put(key, value);
}
Object get(String key) {
return storage.get(key);
}
}
package com.cdai.studio.redis;
import java.util.HashMap;
class Persistence {
private HashMap
new HashMap
void put(String key, Object value) {
storage.put(key, value);
}
Object get(String key) {
return storage.get(key);
}
}
3.简单的客户端
[java] view plaincopyprint package com.cdai.studio.redis;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;
public class RedisServer {
private RedisDB redis;
public RedisServer(RedisDB redis) {
this.redis = redis;
}
@SuppressWarnings("unchecked")
public void start() {
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(1234);
while (true) {
Socket socket = serverSocket.accept();
ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
List
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;
public class RedisServer {
private RedisDB redis;
public RedisServer(RedisDB redis) {
this.redis = redis;
}
@SuppressWarnings("unchecked")
public void start() {
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(1234);
while (true) {
Socket socket = serverSocket.accept();
ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
List
Object response = null;
if ("Set".equals(request.get(0))) {
redis.Set((String) request.get(1), request.get(2));
}