redis.clients.jedis.commands

接口 MultiKeyBinaryRedisPipeline

所有已知实现类:

MultiKeyPipelineBase, Pipeline, Transaction

public interface MultiKeyBinaryRedisPipeline

Multikey related commands (these are split out because they are non-shardable)

方法概要

限定符和类型	方法和说明
Response<java.lang.Long>	bitop(BitOP op, byte[] destKey, byte[]... srcKeys)
Response<byte[]>	blmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to, double timeout)
Response<java.util.List<byte[]>>	blpop(byte[]... args)
Response<java.util.List<byte[]>>	blpop(double timeout, byte[]... args)
Response<java.util.List<byte[]>>	brpop(byte[]... args)
Response<java.util.List<byte[]>>	brpop(double timeout, byte[]... args)
Response<byte[]>	brpoplpush(byte[] source, byte[] destination, int timeout)
Response<java.util.List<byte[]>>	bzpopmax(double timeout, byte[]... keys)
Response<java.util.List<byte[]>>	bzpopmin(double timeout, byte[]... keys)
Response<java.lang.Boolean>	copy(byte[] srcKey, byte[] dstKey, boolean replace)
Response<java.lang.Boolean>	copy(byte[] srcKey, byte[] dstKey, int db, boolean replace)
Response<java.lang.Long>	del(byte[]... keys)
Response<java.lang.Long>	exists(byte[]... keys)
Response<java.lang.Long>	georadiusByMemberStore(byte[] key, byte[] member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
Response<java.lang.Long>	georadiusStore(byte[] key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
Response<java.util.Set<byte[]>>	keys(byte[] pattern)
Response<byte[]>	lmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to)
Response<java.util.List<byte[]>>	mget(byte[]... keys)
Response<java.lang.String>	migrate(java.lang.String host, int port, int destinationDB, int timeout, MigrateParams params, byte[]... keys)
Response<java.lang.String>	mset(byte[]... keysvalues)
Response<java.lang.Long>	msetnx(byte[]... keysvalues)
Response<java.lang.Long>	pfcount(byte[]... keys)
Response<java.lang.String>	pfmerge(byte[] destkey, byte[]... sourcekeys)
Response<java.lang.Long>	publish(byte[] channel, byte[] message)
Response<byte[]>	randomKeyBinary()
Response<java.lang.String>	rename(byte[] oldkey, byte[] newkey)
Response<java.lang.Long>	renamenx(byte[] oldkey, byte[] newkey)
Response<byte[]>	rpoplpush(byte[] srckey, byte[] dstkey)
Response<java.util.Set<byte[]>>	sdiff(byte[]... keys)
Response<java.lang.Long>	sdiffstore(byte[] dstkey, byte[]... keys)
Response<java.util.Set<byte[]>>	sinter(byte[]... keys)
Response<java.lang.Long>	sinterstore(byte[] dstkey, byte[]... keys)
Response<java.lang.Long>	smove(byte[] srckey, byte[] dstkey, byte[] member)
Response<java.lang.Long>	sort(byte[] key, byte[] dstkey)
Response<java.lang.Long>	sort(byte[] key, SortingParams sortingParameters, byte[] dstkey)
Response<java.util.Set<byte[]>>	sunion(byte[]... keys)
Response<java.lang.Long>	sunionstore(byte[] dstkey, byte[]... keys)
Response<java.lang.Long>	touch(byte[]... keys)
Response<java.lang.Long>	unlink(byte[]... keys)
Response<java.lang.String>	unwatch()
Response<java.lang.String>	watch(byte[]... keys)
Response<java.util.List<byte[]>>	xread(int count, long block, java.util.Map<byte[],byte[]> streams) 已过时。 Use xread(redis.clients.jedis.params.XReadParams, java.util.Map.Entry...).
Response<java.util.List<byte[]>>	xread(XReadParams xReadParams, java.util.Map.Entry<byte[],byte[]>... streams)
Response<java.util.List<byte[]>>	xreadGroup(byte[] groupname, byte[] consumer, int count, long block, boolean noAck, java.util.Map<byte[],byte[]> streams) 已过时。 Use #xreadGroup(byte..., byte..., redis.clients.jedis.params.XReadGroupParams, java.util.Map.Entry...).
Response<java.util.List<byte[]>>	xreadGroup(byte[] groupname, byte[] consumer, XReadGroupParams xReadGroupParams, java.util.Map.Entry<byte[],byte[]>... streams)
Response<java.util.Set<byte[]>>	zdiff(byte[]... keys)
Response<java.lang.Long>	zdiffStore(byte[] dstkey, byte[]... keys)
Response<java.util.Set<Tuple>>	zdiffWithScores(byte[]... keys)
Response<java.util.Set<byte[]>>	zinter(ZParams params, byte[]... keys)
Response<java.lang.Long>	zinterstore(byte[] dstkey, byte[]... sets)
Response<java.lang.Long>	zinterstore(byte[] dstkey, ZParams params, byte[]... sets)
Response<java.util.Set<Tuple>>	zinterWithScores(ZParams params, byte[]... keys)
Response<java.util.Set<byte[]>>	zunion(ZParams params, byte[]... keys)
Response<java.lang.Long>	zunionstore(byte[] dstkey, byte[]... sets)
Response<java.lang.Long>	zunionstore(byte[] dstkey, ZParams params, byte[]... sets)
Response<java.util.Set<Tuple>>	zunionWithScores(ZParams params, byte[]... keys)

方法详细资料

copy

Response<java.lang.Boolean> copy(byte[] srcKey,
                                 byte[] dstKey,
                                 int db,
                                 boolean replace)

copy

Response<java.lang.Boolean> copy(byte[] srcKey,
                                 byte[] dstKey,
                                 boolean replace)

del

Response<java.lang.Long> del(byte[]... keys)

unlink

Response<java.lang.Long> unlink(byte[]... keys)

exists

Response<java.lang.Long> exists(byte[]... keys)

lmove

Response<byte[]> lmove(byte[] srcKey,
                       byte[] dstKey,
                       ListDirection from,
                       ListDirection to)

blmove

Response<byte[]> blmove(byte[] srcKey,
                        byte[] dstKey,
                        ListDirection from,
                        ListDirection to,
                        double timeout)

blpop

Response<java.util.List<byte[]>> blpop(byte[]... args)

blpop

Response<java.util.List<byte[]>> blpop(double timeout,
                                       byte[]... args)

brpop

Response<java.util.List<byte[]>> brpop(byte[]... args)

brpop

Response<java.util.List<byte[]>> brpop(double timeout,
                                       byte[]... args)

bzpopmax

Response<java.util.List<byte[]>> bzpopmax(double timeout,
                                          byte[]... keys)

bzpopmin

Response<java.util.List<byte[]>> bzpopmin(double timeout,
                                          byte[]... keys)

keys

Response<java.util.Set<byte[]>> keys(byte[] pattern)

mget

Response<java.util.List<byte[]>> mget(byte[]... keys)

mset

Response<java.lang.String> mset(byte[]... keysvalues)

msetnx

Response<java.lang.Long> msetnx(byte[]... keysvalues)

rename

Response<java.lang.String> rename(byte[] oldkey,
                                  byte[] newkey)

renamenx

Response<java.lang.Long> renamenx(byte[] oldkey,
                                  byte[] newkey)

rpoplpush

Response<byte[]> rpoplpush(byte[] srckey,
                           byte[] dstkey)

sdiff

Response<java.util.Set<byte[]>> sdiff(byte[]... keys)

sdiffstore

Response<java.lang.Long> sdiffstore(byte[] dstkey,
                                    byte[]... keys)

sinter

Response<java.util.Set<byte[]>> sinter(byte[]... keys)

sinterstore

Response<java.lang.Long> sinterstore(byte[] dstkey,
                                     byte[]... keys)

smove

Response<java.lang.Long> smove(byte[] srckey,
                               byte[] dstkey,
                               byte[] member)

sort

Response<java.lang.Long> sort(byte[] key,
                              SortingParams sortingParameters,
                              byte[] dstkey)

sort

Response<java.lang.Long> sort(byte[] key,
                              byte[] dstkey)

sunion

Response<java.util.Set<byte[]>> sunion(byte[]... keys)

sunionstore

Response<java.lang.Long> sunionstore(byte[] dstkey,
                                     byte[]... keys)

watch

Response<java.lang.String> watch(byte[]... keys)

unwatch

Response<java.lang.String> unwatch()

zdiff

Response<java.util.Set<byte[]>> zdiff(byte[]... keys)

zdiffWithScores

Response<java.util.Set<Tuple>> zdiffWithScores(byte[]... keys)

zdiffStore

Response<java.lang.Long> zdiffStore(byte[] dstkey,
                                    byte[]... keys)

zinter

Response<java.util.Set<byte[]>> zinter(ZParams params,
                                       byte[]... keys)

zinterWithScores

Response<java.util.Set<Tuple>> zinterWithScores(ZParams params,
                                                byte[]... keys)

zinterstore

Response<java.lang.Long> zinterstore(byte[] dstkey,
                                     byte[]... sets)

zinterstore

Response<java.lang.Long> zinterstore(byte[] dstkey,
                                     ZParams params,
                                     byte[]... sets)

zunion

Response<java.util.Set<byte[]>> zunion(ZParams params,
                                       byte[]... keys)

zunionWithScores

Response<java.util.Set<Tuple>> zunionWithScores(ZParams params,
                                                byte[]... keys)

zunionstore

Response<java.lang.Long> zunionstore(byte[] dstkey,
                                     byte[]... sets)

zunionstore

Response<java.lang.Long> zunionstore(byte[] dstkey,
                                     ZParams params,
                                     byte[]... sets)

brpoplpush

Response<byte[]> brpoplpush(byte[] source,
                            byte[] destination,
                            int timeout)

publish

Response<java.lang.Long> publish(byte[] channel,
                                 byte[] message)

randomKeyBinary

Response<byte[]> randomKeyBinary()

bitop

Response<java.lang.Long> bitop(BitOP op,
                               byte[] destKey,
                               byte[]... srcKeys)

pfmerge

Response<java.lang.String> pfmerge(byte[] destkey,
                                   byte[]... sourcekeys)

pfcount

Response<java.lang.Long> pfcount(byte[]... keys)

touch

Response<java.lang.Long> touch(byte[]... keys)

migrate

Response<java.lang.String> migrate(java.lang.String host,
                                   int port,
                                   int destinationDB,
                                   int timeout,
                                   MigrateParams params,
                                   byte[]... keys)

georadiusStore

Response<java.lang.Long> georadiusStore(byte[] key,
                                        double longitude,
                                        double latitude,
                                        double radius,
                                        GeoUnit unit,
                                        GeoRadiusParam param,
                                        GeoRadiusStoreParam storeParam)

georadiusByMemberStore

Response<java.lang.Long> georadiusByMemberStore(byte[] key,
                                                byte[] member,
                                                double radius,
                                                GeoUnit unit,
                                                GeoRadiusParam param,
                                                GeoRadiusStoreParam storeParam)

xread

@Deprecated
Response<java.util.List<byte[]>> xread(int count,
                                                    long block,
                                                    java.util.Map<byte[],byte[]> streams)

已过时。 Use xread(redis.clients.jedis.params.XReadParams, java.util.Map.Entry...).

xread

Response<java.util.List<byte[]>> xread(XReadParams xReadParams,
                                       java.util.Map.Entry<byte[],byte[]>... streams)

xreadGroup

@Deprecated
Response<java.util.List<byte[]>> xreadGroup(byte[] groupname,
                                                         byte[] consumer,
                                                         int count,
                                                         long block,
                                                         boolean noAck,
                                                         java.util.Map<byte[],byte[]> streams)

已过时。 Use #xreadGroup(byte..., byte..., redis.clients.jedis.params.XReadGroupParams, java.util.Map.Entry...).

xreadGroup

Response<java.util.List<byte[]>> xreadGroup(byte[] groupname,
                                            byte[] consumer,
                                            XReadGroupParams xReadGroupParams,
                                            java.util.Map.Entry<byte[],byte[]>... streams)