package redis.clients.jedis; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketException; import java.util.ArrayList; import java.util.List; import redis.clients.jedis.Protocol.Command; import redis.clients.jedis.exceptions.JedisConnectionException; import redis.clients.jedis.exceptions.JedisException; import redis.clients.util.RedisInputStream; import redis.clients.util.RedisOutputStream; import redis.clients.util.SafeEncoder; public class Connection { private String host; private int port = Protocol.DEFAULT_PORT; private Socket socket; private Protocol protocol = new Protocol(); private RedisOutputStream outputStream; private RedisInputStream inputStream; private int pipelinedCommands = 0; private int timeout = Protocol.DEFAULT_TIMEOUT; public int getTimeout() { return timeout; } public void setTimeout(final int timeout) { this.timeout = timeout; } public void setTimeoutInfinite() { try { socket.setKeepAlive(true); socket.setSoTimeout(0); } catch (SocketException ex) { throw new JedisException(ex); } } public void rollbackTimeout() { try { socket.setSoTimeout(timeout); socket.setKeepAlive(false); } catch (SocketException ex) { throw new JedisException(ex); } } public Connection(final String host) { super(); this.host = host; } protected Connection sendCommand(final Command cmd, final String... args) { final byte[][] bargs = new byte[args.length][]; for (int i = 0; i < args.length; i++) { bargs[i] = SafeEncoder.encode(args[i]); } return sendCommand(cmd, bargs); } protected Connection sendCommand(final Command cmd, final byte[]... args) { connect(); protocol.sendCommand(outputStream, cmd, args); pipelinedCommands++; return this; } protected Connection sendCommand(final Command cmd) { connect(); protocol.sendCommand(outputStream, cmd, new byte[0][]); pipelinedCommands++; return this; } public Connection(final String host, final int port) { super(); this.host = host; this.port = port; } public String getHost() { return host; } public void setHost(final String host) { this.host = host; } public int getPort() { return port; } public void setPort(final int port) { this.port = port; } public Connection() { } public void connect() { if (!isConnected()) { try { socket = new Socket(); socket.connect(new InetSocketAddress(host, port), timeout); socket.setSoTimeout(timeout); outputStream = new RedisOutputStream(socket.getOutputStream()); inputStream = new RedisInputStream(socket.getInputStream()); } catch (IOException ex) { throw new JedisConnectionException(ex); } } } public void disconnect() { if (isConnected()) { try { inputStream.close(); outputStream.close(); if (!socket.isClosed()) { socket.close(); } } catch (IOException ex) { throw new JedisConnectionException(ex); } } } public boolean isConnected() { return socket != null && socket.isBound() && !socket.isClosed() && socket.isConnected() && !socket.isInputShutdown() && !socket.isOutputShutdown(); } protected String getStatusCodeReply() { pipelinedCommands--; final byte[] resp = (byte[]) protocol.read(inputStream); if (null == resp) { return null; } else { return SafeEncoder.encode(resp); } } public String getBulkReply() { final byte[] result = getBinaryBulkReply(); if (null != result) { return SafeEncoder.encode(result); } else { return null; } } public byte[] getBinaryBulkReply() { pipelinedCommands--; return (byte[]) protocol.read(inputStream); } public Long getIntegerReply() { pipelinedCommands--; return (Long) protocol.read(inputStream); } public List getMultiBulkReply() { final List bresult = getBinaryMultiBulkReply(); if (null == bresult) { return null; } final ArrayList result = new ArrayList(bresult.size()); for (final byte[] barray : bresult) { if (barray == null) { result.add(null); } else { result.add(SafeEncoder.encode(barray)); } } return result; } @SuppressWarnings("unchecked") public List getBinaryMultiBulkReply() { pipelinedCommands--; return (List) protocol.read(inputStream); } @SuppressWarnings("unchecked") public List getObjectMultiBulkReply() { pipelinedCommands--; return (List) protocol.read(inputStream); } public List getAll() { List all = new ArrayList(); while (pipelinedCommands > 0) { all.add(protocol.read(inputStream)); pipelinedCommands--; } return all; } public Object getOne() { pipelinedCommands--; return protocol.read(inputStream); } }