基于SpringBoot+SpringCloud+Mybatis+Docker分布式敏捷开发系统架构，提供整套公共微.zip

package redis.clients.jedis; import static redis.clients.jedis.Protocol.toByteArray; import java.io.Closeable; import java.net.URI; import java.util.AbstractMap; import java.util.AbstractSet; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.Iterator; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.Set; import redis.clients.jedis.BinaryClient.LIST_POSITION; import redis.clients.jedis.commands.*; import redis.clients.jedis.exceptions.InvalidURIException; import redis.clients.jedis.exceptions.JedisDataException; import redis.clients.jedis.exceptions.JedisException; import redis.clients.jedis.params.geo.GeoRadiusParam; import redis.clients.jedis.params.set.SetParams; import redis.clients.jedis.params.sortedset.ZAddParams; import redis.clients.jedis.params.sortedset.ZIncrByParams; import redis.clients.util.JedisByteHashMap; import redis.clients.util.JedisURIHelper; import redis.clients.util.SafeEncoder; public class BinaryJedis implements BasicCommands, BinaryJedisCommands, MultiKeyBinaryCommands, AdvancedBinaryJedisCommands, BinaryScriptingCommands, Closeable { protected Client client = null; protected Transaction transaction = null; protected Pipeline pipeline = null; public BinaryJedis() { client = new Client(); } public BinaryJedis(final String host) { URI uri = URI.create(host); if (uri.getScheme() != null && uri.getScheme().equals("redis")) { initializeClientFromURI(uri); } else { client = new Client(host); } } public BinaryJedis(final String host, final int port) { client = new Client(host, port); } public BinaryJedis(final String host, final int port, final int timeout) { client = new Client(host, port); client.setConnectionTimeout(timeout); client.setSoTimeout(timeout); } public BinaryJedis(final String host, final int port, final int connectionTimeout, final int soTimeout) { client = new Client(host, port); client.setConnectionTimeout(connectionTimeout); client.setSoTimeout(soTimeout); } public BinaryJedis(final JedisShardInfo shardInfo) { client = new Client(shardInfo.getHost(), shardInfo.getPort()); client.setConnectionTimeout(shardInfo.getConnectionTimeout()); client.setSoTimeout(shardInfo.getSoTimeout()); client.setPassword(shardInfo.getPassword()); client.setDb(shardInfo.getDb()); } public BinaryJedis(URI uri) { initializeClientFromURI(uri); } public BinaryJedis(final URI uri, final int timeout) { initializeClientFromURI(uri); client.setConnectionTimeout(timeout); client.setSoTimeout(timeout); } public BinaryJedis(final URI uri, final int connectionTimeout, final int soTimeout) { initializeClientFromURI(uri); client.setConnectionTimeout(connectionTimeout); client.setSoTimeout(soTimeout); } private void initializeClientFromURI(URI uri) { if (!JedisURIHelper.isValid(uri)) { throw new InvalidURIException(String.format( "Cannot open Redis connection due invalid URI. %s", uri.toString())); } client = new Client(uri.getHost(), uri.getPort()); String password = JedisURIHelper.getPassword(uri); if (password != null) { client.auth(password); client.getStatusCodeReply(); } int dbIndex = JedisURIHelper.getDBIndex(uri); if (dbIndex > 0) { client.select(dbIndex); client.getStatusCodeReply(); client.setDb(dbIndex); } } @Override public String ping() { checkIsInMultiOrPipeline(); client.ping(); return client.getStatusCodeReply(); } /** * Set the string value as value of the key. The string can't be longer than 1073741824 bytes (1 * GB). * <p> * Time complexity: O(1) * @param key * @param value * @return Status code reply */ @Override public String set(final byte[] key, final byte[] value) { checkIsInMultiOrPipeline(); client.set(key, value); return client.getStatusCodeReply(); } /** * Set the string value as value of the key. The string can't be longer than 1073741824 bytes (1 * GB). * @param key * @param value * @param params * @return Status code reply */ @Override public String set(final byte[] key, final byte[] value, final SetParams params) { checkIsInMultiOrPipeline(); client.set(key, value, params); return client.getStatusCodeReply(); } /** * Get the value of the specified key. If the key does not exist the special value 'nil' is * returned. If the value stored at key is not a string an error is returned because GET can only * handle string values. * <p> * Time complexity: O(1) * @param key * @return Bulk reply */ @Override public byte[] get(final byte[] key) { checkIsInMultiOrPipeline(); client.get(key); return client.getBinaryBulkReply(); } /** * Ask the server to silently close the connection. */ @Override public String quit() { checkIsInMultiOrPipeline(); client.quit(); String quitReturn = client.getStatusCodeReply(); client.disconnect(); return quitReturn; } /** * Test if the specified keys exist. The command returns the number of keys existed Time * complexity: O(N) * @param keys * @return Integer reply, specifically: an integer greater than 0 if one or more keys existed 0 if * none of the specified keys existed */ @Override public Long exists(final byte[]... keys) { checkIsInMultiOrPipeline(); client.exists(keys); return client.getIntegerReply(); } /** * Test if the specified key exists. The command returns "1" if the key exists, otherwise "0" is * returned. Note that even keys set with an empty string as value will return "1". Time * complexity: O(1) * @param key * @return Boolean reply, true if the key exists, otherwise false */ @Override public Boolean exists(final byte[] key) { checkIsInMultiOrPipeline(); client.exists(key); return client.getIntegerReply() == 1; } /** * Remove the specified keys. If a given key does not exist no operation is performed for this * key. The command returns the number of keys removed. Time complexity: O(1) * @param keys * @return Integer reply, specifically: an integer greater than 0 if one or more keys were removed * 0 if none of the specified key existed */ @Override public Long del(final byte[]... keys) { checkIsInMultiOrPipeline(); client.del(keys); return client.getIntegerReply(); } @Override public Long del(final byte[] key) { checkIsInMultiOrPipeline(); client.del(key); return client.getIntegerReply(); } /** * Return the type of the value stored at key in form of a string. The type can be one of "none", * "string", "list", "set". "none" is returned if the key does not exist. Time complexity: O(1) * @param key * @return Status code reply, specifically: "none" if the key does not exist "string" if the key * contains a String value "list" if the key contains a List value "set" if the key * contains a Set value "zset" if the key contains a Sorted Set value "hash" if the key * contains a Hash value */ @Override public String type(final byte[] key) { checkIsInMultiOrPipeline(); client.type(key); return client.getStatusCodeReply(); } /** * Delete all the keys of the currently selected DB. This command never fails. * @return Status code reply */ @Override public String flushDB() { checkIsInMultiOrPipeline(); client.flushDB(); return client.getStatusCodeReply(); } /** * Returns all the keys matching the glob-style pattern as space separated strings. For example if * you have in the database the keys "foo" and "foobar" the command "KEYS foo*" will return * "foo foobar". * <p> * Note that while the time comple